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

要实现一对一聊天功能使用 Workerman 5.0 作为后端前端可以使用 WebSocket 进行通信。以下是实现步骤和代码示例。1. 安装 Workerman首先确保你已经安装了 Workerman。可以通过 Composer 安装1composer require workerman/workerman2. 后端代码创建一个 PHP 文件例如 chat_server.php用于处理 WebSocket 连接和消息传递。123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354?phprequire_once__DIR__ ./vendor/autoload.php;useWorkerman\Worker;useWorkerman\Connection\TcpConnection;// 创建一个 WebSocket 服务器$ws_workernewWorker(websocket://0.0.0.0:2346);// 保存用户连接的数组$users [];// 当有客户端连接时$ws_worker-onConnect function(TcpConnection$connection)use($users) {echoNew connection\n;};// 当有客户端发送消息时$ws_worker-onMessage function(TcpConnection$connection,$data)use($users) {$message json_decode($data, true);if(isset($message[type])) {switch($message[type]) {caselogin:// 用户登录保存连接$users[$message[user_id]] $connection;$connection-user_id $message[user_id];echoUser {$message[user_id]} logged in\n;break;casechat:// 一对一聊天if(isset($users[$message[to_user_id]])) {$users[$message[to_user_id]]-send(json_encode([typechat,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]);echoUser {$connection-user_id} disconnected\n;}};// 运行 workerWorker::runAll();3. 前端代码在前端使用 WebSocket 连接到服务器并实现登录和发送消息的功能。1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253!DOCTYPE htmlhtmllangenheadmetacharsetUTF-8titleWebSocket Chat/title/headbodydivinputtypetextiduser_idplaceholderYour User IDbuttononclicklogin()Login/button/divdivinputtypetextidto_user_idplaceholderTo User IDinputtypetextidmessageplaceholderMessagebuttononclicksendMessage()Send/button/divdividchat/divscriptlet ws;let user_id;function login() {user_id document.getElementById(user_id).value;ws new WebSocket(ws://127.0.0.1:2346);ws.onopen function() {ws.send(JSON.stringify({type: login,user_id: user_id}));};ws.onmessage function(event) {const message JSON.parse(event.data);if (message.type chat) {document.getElementById(chat).innerHTML pFrom ${message.from_user_id}: ${message.message}/p;}};}function sendMessage() {const to_user_id document.getElementById(to_user_id).value;const message document.getElementById(message).value;ws.send(JSON.stringify({type: chat,to_user_id: to_user_id,message: message}));}/script/body/html4. 运行服务器在终端中运行 PHP 文件启动 WebSocket 服务器1php chat_server.php start5. 测试打开两个浏览器窗口分别输入不同的用户 ID 并登录。在一个窗口中输入目标用户 ID 和消息点击发送。另一个窗口应该会收到消息并显示在页面上。总结通过以上步骤你可以实现一个简单的一对一聊天系统。Workerman 作为后端处理 WebSocket 连接和消息传递前端通过 WebSocket 与服务器通信实现实时聊天功能。