PHP、Unity3D和Workerman的综合应用：如何打造一个全新的虚拟世界

<?php
class Chat
{
    protected $sockets = [];

    public function __construct($address, $port)
    {
        $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
        socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
        socket_bind($socket, $address, $port);
        socket_listen($socket);

        $this->sockets[] = $socket;

        while (true) {
            $changedSockets = $this->sockets;
            socket_select($changedSockets, $write = null, $except = null, null);

            foreach ($changedSockets as $socket) {
                if ($socket === $this->sockets[0]) {
                    $this->accept();
                } else {
                    $this->handleMessage($socket);
                }
            }
        }
    }

    protected function accept()
    {
        $clientSocket = socket_accept($this->sockets[0]);
        $this->sockets[] = $clientSocket;
    }

    protected function handleMessage($socket)
    {
        $buffer = socket_read($socket, 1024, PHP_NORMAL_READ);
        $this->sendMessage($buffer);
    }

    protected function sendMessage($buffer)
    {
        foreach ($this->sockets as $socket) {
            if ($socket !== $this->sockets[0]) {
                socket_write($socket, $buffer, strlen($buffer));
            }
        }
    }
}

$chat = new Chat('localhost', 8000);

using UnityEngine;
using System;
using System.Net.Sockets;
using System.Text;

public class ChatClient : MonoBehaviour
{
    private TcpClient client;
    private NetworkStream stream;
    private byte[] buffer;

    void Start()
    {
        client = new TcpClient("localhost", 8000);
        stream = client.GetStream();
        buffer = new byte[1024];
        stream.BeginRead(buffer, 0, buffer.Length, OnRead, null);
    }

    void OnRead(IAsyncResult result)
    {
        int bytesRead = stream.EndRead(result);
        string message = Encoding.ASCII.GetString(buffer, 0, bytesRead);
        Debug.Log("Received message: " + message);
        stream.BeginRead(buffer, 0, buffer.Length, OnRead, null);
    }

    void OnGUI()
    {
        if (Event.current.type == EventType.KeyDown && Event.current.keyCode == KeyCode.Return)
        {
            string message = "Hello, World!";
            byte[] buffer = Encoding.ASCII.GetBytes(message);
            stream.Write(buffer, 0, buffer.Length);
        }
    }
}

<?php
 require_once 'Workerman/Autoloader.php';

$worker = new Worker('tcp://0.0.0.0:8000');

$worker->onConnect = function($connection){
    echo "New Connection
";
};

$worker->onMessage = function($connection, $message){
    echo "Received message: " . $message . "
";
    $connection->send("Hello, Client!
");
};

Worker::runAll();