服务端代码

tcp_server.php

<?php
    //创建Server对象，监听 9501端口
    $server = new Swoole\Server('0.0.0.0', 9501);
    //监听连接进入事件
    $server->on('Connect', function ($server, $fd) {  
        echo "Client: Connect.\n";
    });
    //监听数据接收事件
    $server->on('Receive', function ($server, $fd, $from_id, $data) {
        echo 'request data : ', $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 事件回调

客户端代码

tcp_client.php

<?php
    // 创建一个 TCP 连接
    $client = new Swoole\Client(SWOOLE_SOCK_TCP);
    // 尝试连接到本地的 9501 端口
    if (!$client->connect('127.0.0.1', 9501, -1)) {
        // 连接失败的提示信息
        exit("connect failed. Error: {$client->errCode}\n");
    }
    // 发送到服务端的数据
    $client->send("hello world\n");
    // 打印服务端返回的数据
    echo $client->recv();
    // 关闭连接
    $client->close();
?>

执行代码

## 运行服务端代码(会卡在这个窗口)
[server] php tcp_server.php
## 然后我们查看 9501 端口
[client] netstat -tulpn | grep 9501
tcp        0      0 0.0.0.0:9501            0.0.0.0:*               LISTEN      33922/php 
[client] php tcp_client.php 
Server: hello world                                1                                                    
## 服务端窗口信息
[server] php tcp_server.php
Client: Connect.                                    2
request data : hello world                3
Client: Close.                                        4
## 后边的 1-4 序号, 是我自己手动加上去的,实际没有, 为了使解释一下运行流程
当我们执行了客户端时, 执行了连接操作, 所以打印出来了 2
紧接着, 我们发送了 hello world 数据到服务端, 所以服务端打印出了 3
然后服务端再把数据返回给客户端, 客户端打印出列 1 
客户端执行了关闭操作, 所以打印出了  4

TCP服务器

服务端代码

客户端代码

执行代码