php网络编程指南：异步编程和事件循环

use React\EventLoop\Loop;
use React\HttpClient\Client;

// 创建事件循环
$loop = Loop::get();

// 发送 HTTP 请求
$client = new Client($loop);
$client->request('GET', 'http://example.com')->then(function ($response) use ($loop) {
    // 响应处理完毕后关闭循环
    $loop->stop();
}, function ($e) {
    // 出错后关闭循环
    $loop->stop();
});

// 运行事件循环
$loop->run();

use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;

// Chat 消息处理器
class Chat implements MessageComponentInterface
{
    // 所有连接的客户端
    protected $clients;

    public function onOpen(ConnectionInterface $conn)
    {
        $this->clients[] = $conn;
    }

    public function onMessage(ConnectionInterface $from, $msg)
    {
        foreach ($this->clients as $client) {
            $client->send($msg);
        }
    }

    public function onClose(ConnectionInterface $conn)
    {
        // 从客户端集移除连接
    }

    public function onError(ConnectionInterface $conn, \Exception $e)
    {
        // 出错后关闭连接
    }
}

// 创建 HTTP 服务器
$http = new HttpServer(new WsServer(new Chat()));

// 创建并运行 IO 服务器
$io = new IoServer($http, 8080);
$io->run();