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

要实现一对一聊天功能，使用 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>