Workerman을 사용하여 PHP 및 Unity3D로 실시간 채팅 애플리케이션을 구축하는 방법

// 引入Workerman的命名空间
use WorkermanWorker;
use WorkermanLibTimer;

// 创建一个Worker对象，端口为1234
$ws_worker = new Worker("websocket://0.0.0.0:1234");

// 设置进程数
$ws_worker->count = 4;

// 客户端连接时的处理函数
$ws_worker->onConnect = function($connection) {
    echo "New connection
";
};

// 客户端断开连接时的处理函数
$ws_worker->onClose = function($connection) {
    echo "Connection closed
";
};

// 收到客户端消息时的处理函数
$ws_worker->onMessage = function($connection, $data) use ($ws_worker) {
    // 向所有客户端广播消息
    foreach($ws_worker->connections as $client_connection) {
        $client_connection->send($data);
    }
};

// 启动Worker
Worker::runAll();

using UnityEngine;
using System.Collections;
using WebSocketSharp;

public class ChatHandler : MonoBehaviour
{
    // WebSocket客户端对象
    WebSocket ws;

    // 服务器地址
    public string serverUrl = "ws://localhost:1234/";

    // 客户端名称
    public string clientName = "UnityClient";

    // 聊天消息
    public string message = "";

    // Start方法，程序启动时会自动调用
    void Start()
    {
        // 创建WebSocket客户端对象
        ws = new WebSocket(serverUrl);

        // 当收到服务器消息时的处理函数
        ws.OnMessage += (sender, e) =>
        {
            Debug.Log("Received: " + e.Data);
        };

        // 连接服务器
        ws.Connect();

        // 发送客户端名称给服务器
        ws.Send(clientName);
    }

    // Update方法，每帧更新时会自动调用
    void Update()
    {
        // 发送消息给服务器
        if (Input.GetKeyDown(KeyCode.Return))
        {
            ws.Send(message);

            // 清空输入框
            message = "";
        }
    }

    // 程序关闭时会自动调用
    void OnApplicationQuit()
    {
        // 断开WebSocket连接
        ws.Close();
    }
}