PHP调用Workerman5.0实现一对一聊天

说到用 Workerman 5.0 做一对一聊天，这事儿其实挺清晰的。后端负责处理 WebSocket 连接和消息转发，前端通过 WebSocket 与服务器通信，整个流程走下来，一个实时聊天的雏形就有了。下面直接上步骤和代码，边看边跑，效果更直观。

1. 安装 Workerman

第一步，得先把 Workerman 装好。如果你还没装，用 Composer 来搞定，命令很简单：

composer require workerman/workerman

装完以后，环境就准备好了，后面的事情就顺了。

2. 后端代码

接下来，创建一个 PHP 文件，比方说叫 chat_server.php。这个文件就是整个聊天系统的核心——负责接待客户端的连接、接收消息、转发给目标用户。关键逻辑就在这儿：

服务器，监听 2346 端口
$ws_worker = new Worker("websocket://0.0.0.0:2346");

// 用一个数组来保存在线用户的连接
$users = [];

// 有客户端连上来的时候
$ws_worker->onConnect = function(TcpConnection $connection) use (&$users) {
    echo "New connection\n";
};

// 收到客户端消息的时候
$ws_worker->onMessage = function(TcpConnection $connection, $data) use (&$users) {
    $message = json_decode($data, true);
    if (isset($message['type'])) {
        switch ($message['type']) {
            case 'login':
                // 用户登录，把连接存起来，并记录下用户 ID
                $users[$message['user_id']] = $connection;
                $connection->user_id = $message['user_id'];
                echo "User {$message['user_id']} logged in\n";
                break;
            case 'chat':
                // 一对一聊天：找到目标用户，把消息转发过去
                if (isset($users[$message['to_user_id']])) {
                    $users[$message['to_user_id']]->send(json_encode([
                        'type' => 'chat',
                        'from_user_id' => $connection->user_id,
                        'message' => $message['message']
                    ]));
                }
                break;
        }
    }
};

// 客户端断开连接的时候，把它从在线列表里清除
$ws_worker->onClose = function(TcpConnection $connection) use (&$users) {
    if (isset($connection->user_id)) {
        unset($users[$connection->user_id]);
        echo "User {$connection->user_id} disconnected\n";
    }
};

// 启动服务器
Worker::runAll();

这段代码里，核心就是 $users 数组——它相当于一个“在线通讯录”，每个用户登录后，连接就被登记进去。当 A 要给 B 发消息时，后端直接从通讯录里找到 B 的连接，把消息推过去。整个过程没有数据库，没有复杂路由，干净利落。

3. 前端代码

后端搞定了，前端也得跟上。一个简单的 HTML 页面，配上 Ja vaScript，就能让用户登录、发消息、收消息。代码长这样：

    
    


    

        
        Login
    
    

        
        
        Send
    
    

    

这里的逻辑很直白：用户输入自己的 ID 后点击登录，就建立 WebSocket 连接，并告诉服务器“我来了”。之后，只要输入对方的 ID 和消息内容，点击发送，消息就会通过后端转发到对方那里。收到消息后，页面会实时显示出来。

4. 运行服务器

后端代码写好了，接下来在终端里敲一行命令，就能把服务器跑起来：

php chat_server.php start

如果一切顺利，终端会显示服务器正在监听 2346 端口。这时，就可以开始测试了。

5. 测试

验证效果很简单：打开两个浏览器窗口，分别输入不同的用户 ID 并登录。比如窗口 A 用 ID 1001，窗口 B 用 ID 1002。然后，在窗口 A 里输入目标 ID 1002 和一段消息，点击发送。窗口 B 这边，应该会立刻收到消息并显示出来。反过来试也一样，双向通信正常，就说明系统跑通了。

总结

通过这几步，一个简单但可运行的一对一聊天系统就搭起来了。Workerman 的长处在于，它天然支持 WebSocket 协议，部署起来非常轻便，不需要额外依赖 Apache 或 Nginx 做反向袋里。后端代码里，连接管理和消息转发是核心，前端则负责用户交互和实时展示。如果你需要更复杂的场景，比如群聊、消息持久化、用户状态管理，其实都可以在这个基础上扩展——框架本身提供了足够的灵活性。先从这个起点跑通，后面的事情就好办了。