swoole 学习之 tcp、udp服务端和客户端代码总结

男娘i 2022-12-19 13:28 303阅读 0赞

### swoole 学习之 tcp、udp服务端和客户端示例代码整理 ###

*  tcp服务
 *   *  tcp服务端
     *  tcp客户端
     *  tcp客户端键盘输入
 *  udp服务
 *   *  udp服务端
     *  udp客户端
     *  查看进程数

# tcp服务 #

## tcp服务端 ##

<?php
    //创建Server对象，监听 127.0.0.1:9501端口
    $serv = new Swoole\Server("127.0.0.1", 9501);
    
    
    //配置
    $serv->set([
        'worker_num' => 8,//worker进程数 cpu 1-4倍
        'max_request' => 10000,//客户端最大连接数
    ]);
    
    
    //监听连接进入事件
    //$reactor_id 线程id
    //$fd 客户端id
    $serv->on('Connect', function ($serv, $fd, $reactor_id) { 
        echo "Client:{ $fd} -{ $reactor_id}Connect.\n";
    });
    
    //监听数据接收事件
    //$from_id 线程id
    $serv->on('Receive', function ($serv, $fd, $from_id, $data) { 
        echo '收到客户端的内容：' . $data . PHP_EOL;
        $serv->send($fd, "Server 返回: { $from_id} -data：" . $data);
    });
    
    //监听连接关闭事件
    $serv->on('Close', function ($serv, $fd) { 
        echo "Client: Close.\n";
    });
    
    //启动服务器
    $serv->start();
    ?>

启动tcp服务的命令：

php tcpService.php

查看是否启动成功

netstat -taupln | grep '9501'

检查端口号是否存在  
![在这里插入图片描述][20201108122955165.png_pic_center]

## tcp客户端 ##

<?php
    //实例化 swoole tcp服务
    //第一种写法
    $client = new swoole_client(SWOOLE_SOCK_TCP);
    //第二种写法
    //$client = new Swoole\Client(SWOOLE_SOCK_TCP);
    if (!$client->connect('127.0.0.1', 9501, -1)) { 
        exit("连接swoole tcp服务失败: { $client->errCode}\n");
    }
    //连接成功，发送
    $client->send("hello 奇葩\n");
    //得到服务端返回的信息
    echo $client->recv();
    //断开与tcp服务端的链接
    $client->close();

执行客户端命令：

php tcp_client.php

![在这里插入图片描述][20201108123128588.png_pic_center]  
同时查看服务端：  
看到可以接收到来自客户端发送的数据内容并打印出来  
![在这里插入图片描述][20201108123206256.png_pic_center]

## tcp客户端键盘输入 ##

<?php
    //实例化 swoole tcp服务
    //第一种写法
    $client = new swoole_client(SWOOLE_SOCK_TCP);
    //第二种写法
    //$client = new Swoole\Client(SWOOLE_SOCK_TCP);
    if (!$client->connect('127.0.0.1', 9501, -1)) { 
        exit("连接swoole tcp服务失败: { $client->errCode}\n");
    }
    //连接成功，手动输入内容
    fwrite(STDOUT,'请输入要发送的消息：');
    //fgets得到键盘输入的内容，trim去除两侧空格
    $msg=trim(fgets(STDIN));
    //将内容发送给服务端
    $client->send($msg);
    //接收来自服务端的数据
    $server_msg=$client->recv();
    echo '得到来自服务端的数据：'.$server_msg;

客户端执行：

php tcp_client_stdout.php

得到如下内容  
![在这里插入图片描述][20201108123332341.png_pic_center]  
服务端，得到来自客户端的内容  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center]

# udp服务 #

## udp服务端 ##

<?php
    //创建Server对象，监听 127.0.0.1:9502端口
    $serv = new Swoole\Server("127.0.0.1", 9502,SWOOLE_PROCESS,SWOOLE_SOCK_UDP);
    
    //监听数据接收事件
    $serv->on('Packet',function($serv,$data,$clientInfo){ 
        echo "clientInfo<pre>";
        print_r($clientInfo);
    
        //$clientInfo 是客户端的信息，是一个数组，有客户端的ip和端口内容
    
        echo "data<pre>";
        print_r($data);
        //sendto 表示向客户端发送数据
        $serv->sendto($clientInfo['address'],$clientInfo['port'],'Server:'.$data);
    });
    
    //启动服务器
    $serv->start();
    
    ?>

UDP服务器与TCP服务器不同，它没有链接的概念，启动server后，客户端无需connect，直接向server监听的9502端口号发送数据包，对应的事件为onPacket

启动udp服务命令：

php udpService.php

## udp客户端 ##

<?php
    //实例化 swoole tcp服务
    //第一种写法
    $client = new swoole_client(SWOOLE_SOCK_UDP);
    //第二种写法
    //$client = new Swoole\Client(SWOOLE_SOCK_TCP);
    if (!$client->connect('127.0.0.1', 9502, -1)) { 
        exit("连接swoole UDP服务失败: { $client->errCode}\n");
    }
    //连接成功，发送
    $client->send("hello www.qipa250.com\n");
    //得到服务端返回的信息
    echo $client->recv();
    //断开与tcp服务端的链接
    $client->close();

执行客户端命令：

php udp_client.php

![在这里插入图片描述][20201108123733118.png_pic_center]

同时查看服务端打印的内容  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center 1]

## 查看进程数 ##

ps aft | grep tcpService.php

发现有个8个进程  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center 2]  
对应的是

//配置
    $serv->set([
        'worker_num' => 8,//worker进程数 cpu 1-4倍
        'max_request' => 10000,//客户端最大连接数
    ]);

[20201108122955165.png_pic_center]: /images/20221120/2291b458432a4ad9a839240c4d6e33b2.png
[20201108123128588.png_pic_center]: /images/20221120/55d3b1627fad4537808e5bc7fb3d2cd9.png
[20201108123206256.png_pic_center]: https://img-blog.csdnimg.cn/20201108123206256.png#pic_center
[20201108123332341.png_pic_center]: https://img-blog.csdnimg.cn/20201108123332341.png#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center]: https://img-blog.csdnimg.cn/20201108123420624.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n,size_16,color_FFFFFF,t_70#pic_center
[20201108123733118.png_pic_center]: https://img-blog.csdnimg.cn/20201108123733118.png#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center 1]: https://img-blog.csdnimg.cn/20201108123742611.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center 2]: https://img-blog.csdnimg.cn/20201108124906318.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n,size_16,color_FFFFFF,t_70#pic_center