当前位置：首页 > PHP教程 > php高级应用 > 列表

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

发布:　来源: PHP粉丝网 　添加日期：2026-03-25 18:47:31　浏览: 评论：0　

这篇文章主要介绍了实现一对一聊天功能的相关代码,本文将使用 Workerman 5.0 作为后端,使用WebSocket在前端进行通信,有需要的小伙伴可以参考一下。

要实现一对一聊天功能，使用 Workerman 5.0 作为后端，前端可以使用 WebSocket 进行通信。以下是实现步骤和代码示例。

1. 安装 Workerman

首先，确保你已经安装了 Workerman，可以通过 Composer 安装：

composer require workerman/workerman

2. 后端代码

创建一个 PHP 文件（例如 chat_server.php），用于处理 WebSocket 连接和消息传递。

  2. require_once __DIR__ . '/vendor/autoload.php'; 
  3.   
  4. use Workerman\Worker; 
  5. use Workerman\Connection\TcpConnection; 
  6.   
  7. // 创建一个 WebSocket 服务器 
  8. $ws_worker = new Worker("websocket://0.0.0.0:2346"); 
  9.   
  10. // 保存用户连接的数组 
  11. $users = []; 
  12.   
  13. // 当有客户端连接时 
  14. $ws_worker->onConnect = function(TcpConnection $connection) use (&$users) { 
  15.     echo "New connection\n"; 
  16. }; 
  17.   
  18. // 当有客户端发送消息时 
  19. $ws_worker->onMessage = function(TcpConnection $connection, $data) use (&$users) { 
  20.     $message = json_decode($data, true); 
  21.   
  22.     if (isset($message['type'])) { 
  23.         switch ($message['type']) { 
  24.             case 'login': 
  25.                 // 用户登录，保存连接 
  26.                 $users[$message['user_id']] = $connection; 
  27.                 $connection->user_id = $message['user_id']; 
  28.                 echo "User {$message['user_id']} logged in\n"; 
  29.                 break; 
  30.   
  31.             case 'chat': 
  32.                 // 一对一聊天 
  33.                 if (isset($users[$message['to_user_id']])) { 
  34.                     $users[$message['to_user_id']]->send(json_encode([ 
  35.                         'type' => 'chat', 
  36.                         'from_user_id' => $connection->user_id, 
  37.                         'message' => $message['message'] 
  38.                     )); 
  39.                 } 
  40.                 break; 
  41.         } 
  42.     } 
  43. }; 
  44.   
  45. // 当客户端断开连接时 
  46. $ws_worker->onClose = function(TcpConnection $connection) use (&$users) { 
  47.     if (isset($connection->user_id)) { 
  48.         unset($users[$connection->user_id]); 
  49.         echo "User {$connection->user_id} disconnected\n"; 
  50.     } 
  51. }; 
  52.   
  53. // 运行 worker 
  54. Worker::runAll(); 

3. 前端代码

在前端，使用 WebSocket 连接到服务器，并实现登录和发送消息的功能。

  1. <!DOCTYPE html> 
  2. <html lang="en"> 
  3. <head> 
  4.     <meta charset="UTF-8"> 
  5.     <title>WebSocket Chat</title> 
  6. </head> 
  7. <body> 
  8.     <div> 
  9.         <input type="text" id="user_id" placeholder="Your User ID"> 
  10.         <button onclick="login()">Login</button> 
  11.     </div> 
  12.     <div> 
  13.         <input type="text" id="to_user_id" placeholder="To User ID"> 
  14.         <input type="text" id="message" placeholder="Message"> 
  15.         <button onclick="sendMessage()">Send</button> 
  16.     </div> 
  17.     <div id="chat"></div> 
  18.   
  19.     <script> 
  20.         let ws; 
  21.         let user_id; 
  22.   
  23.         function login() { 
  24.             user_id = document.getElementById('user_id').value; 
  25.             ws = new WebSocket('ws://127.0.0.1:2346'); 
  26.   
  27.             ws.onopen = function() { 
  28.                 ws.send(JSON.stringify({ 
  29.                     type: 'login', 
  30.                     user_id: user_id 
  31.                 })); 
  32.             }; 
  33.   
  34.             ws.onmessage = function(event) { 
  35.                 const message = JSON.parse(event.data); 
  36.                 if (message.type === 'chat') { 
  37.                     document.getElementById('chat').innerHTML += `<p>From ${message.from_user_id}: ${message.message}</p>`; 
  38.                 } 
  39.             }; 
  40.         } 
  41.   
  42.         function sendMessage() { 
  43.             const to_user_id = document.getElementById('to_user_id').value; 
  44.             const message = document.getElementById('message').value; 
  45.             ws.send(JSON.stringify({ 
  46.                 type: 'chat', 
  47.                 to_user_id: to_user_id, 
  48.                 message: message 
  49.             })); 
  50.         } 
  51.     </script> 
  52. </body> 
  53. </html> 

4. 运行服务器

在终端中运行 PHP 文件启动 WebSocket 服务器：

php chat_server.php start

5. 测试

打开两个浏览器窗口，分别输入不同的用户 ID 并登录。

在一个窗口中输入目标用户 ID 和消息，点击发送。

另一个窗口应该会收到消息并显示在页面上。

总结：

通过以上步骤，你可以实现一个简单的一对一聊天系统。Workerman 作为后端处理 WebSocket 连接和消息传递，前端通过 WebSocket 与服务器通信，实现实时聊天功能。

Tags: PHP调用Workerman5 0 Workerman5 0

分享到：

相关文章

推荐文章

热门文章

最新评论文章