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

更新时间：2025年03月21日 15:20:14 作者：Ai 编码

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

1. 安装 Workerman

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

composer require workerman/workerman

2. 后端代码

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

<?php
require_once __DIR__ . '/vendor/autoload.php';

use Workerman\Worker;
use Workerman\Connection\TcpConnection;

// 创建一个 WebSocket 服务器
$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':
                // 用户登录，保存连接
                $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
Worker::runAll();

3. 前端代码

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

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>WebSocket Chat</title>
</head>
<body>
    <div>
        <input type="text" id="user_id" placeholder="Your User ID">
        <button onclick="login()">Login</button>
    </div>
    <div>
        <input type="text" id="to_user_id" placeholder="To User ID">
        <input type="text" id="message" placeholder="Message">
        <button onclick="sendMessage()">Send</button>
    </div>
    <div id="chat"></div>

    <script>
        let 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 += `<p>From ${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>
</html>

4. 运行服务器

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

php chat_server.php start

5. 测试

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

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

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

总结

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

到此这篇关于PHP调用Workerman5.0实现一对一聊天的文章就介绍到这了,更多相关PHP Workerman聊天内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

PHP 创建标签云函数代码
PHP创建标签云函数代码，使用此函数创建标签云。
2010-05-05
php 无限分类的树类代码
php tree 无限分类代码，需要的朋友可以参考下。
2009-12-12
PHP伪静态写法附代码
PHP伪静态写法伪静态又名：URL重写主要是为了SEO而生的。（SEO是什么？这个不用问我吧。呵呵～搞网络的不懂SEO那就～～～～）
2008-06-06
基于PHP实现JWT登录鉴权的示例代码
JWT(JSON Web Token)是为了在网络应用环境间传递声明而执行的一种基于JSON的开放标准。本文将为大家介绍PHP如何实现JWT登录鉴权，需要的可以参考一下
2022-04-04
PHP开发负载均衡指南
过去当运行一个大的web应用时候意味着运行一个大型的web服务器。因为你的应用吸引了大量的用户，你将不得不在你的服务器里增加更多的内存和处理器。
2010-07-07
Paypal实现循环扣款（订阅）功能
本文主要介绍了Paypal实现循环扣款（订阅）的思路与方法；并对如何使用Paypal的支付接口下总结,具有很好的参考价值,下面跟着小编一起来看下吧
2017-03-03
PHP中echo和print的区别
这篇文章主要介绍了PHP中echo和print的区别,针对二者使用中常见的用法区别进行了较为深入的总结与分析,需要的朋友可以参考下
2014-08-08
php遍历树的常用方法汇总
这篇文章主要介绍了php遍历树的常用方法,实例分析了php常用的三种遍历树的技巧,需要的朋友可以参考下
2015-06-06
PHP实现视频文件上传完整实例
这篇文章主要介绍了PHP实现视频文件上传的技巧,包含了PHP配置信息的设计及大文件的处理,需要的朋友可以参考下
2014-08-08
MySql 按时间段查询数据方法(实例说明)
oready网站的制作已经接近尾声。今天打算完成统计模块功能，所以查找了下mysql按时间段查询数据的语句，记录一下。
2008-11-11