Swoole-tcp服务器

心已赠人 2022-11-28 15:14 154阅读 0赞

学习之Swoole4文档  
[tcp][]

//创建Server对象，监听 127.0.0.1:9501 端口
    $server = new Swoole\Server('127.0.0.1', 9501);
    
    //监听连接进入事件
    $server->on('Connect', function ($server, $fd) { 
        echo "Client: Connect.\n";
    });
    
    //监听数据接收事件
    $server->on('Receive', function ($server, $fd, $from_id, $data) { 
        $server->send($fd, "Server: " . $data);
    });
    
    //监听连接关闭事件
    $server->on('Close', function ($server, $fd) { 
        echo "Client: Close.\n";
    });
    
    //启动服务器
    $server->start();

创建一个 TCP 服务器，监听本机 9501 端口。它的逻辑很简单，当客户端 Socket 通过网络发送一个 hello 字符串时，服务器会回复一个 Server: hello 字符串。  
Server 是异步服务器，所以是通过监听事件的方式来编写程序的。当对应的事件发生时底层会主动回调指定的函数。如当有新的 TCP 连接进入时会执行 onConnect 事件回调，当某个连接向服务器发送数据时会回调 onReceive 函数。

服务器可以同时被成千上万个客户端连接，$fd 就是客户端连接的唯一标识符  
调用 $server->send() 方法向客户端连接发送数据，参数就是 $fd 客户端标识符  
调用 $server->close() 方法可以强制关闭某个客户端连接  
客户端可能会主动断开连接，此时会触发 onClose 事件回调

执行程序  
php server.php  
![在这里插入图片描述][20200818152100831.png_pic_center]  
这时就可以使用 telnet/netcat 工具连接服务器。![在这里插入图片描述][20200818152135545.png_pic_center]

[tcp]: https://wiki.swoole.com/#/start/start_tcp_server?id=%E7%A8%8B%E5%BA%8F%E4%BB%A3%E7%A0%81
[20200818152100831.png_pic_center]: /images/20221124/d03da6477e61496ebeb823de625cd875.png
[20200818152135545.png_pic_center]: /images/20221124/36cfe2d93d8e441fa53e229f56fc766e.png