PHP 백엔드 API 개발에서 WebSocket 및 AMQP 메시지 대기열을 처리하는 방법

require 'vendor/autoload.php';

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

class WebSocketServer implements MessageComponentInterface
{
    protected $clients;

    public function __construct()
    {
        $this->clients = new SplObjectStorage;
    }

    public function onOpen(ConnectionInterface $conn)
    {
        $this->clients->attach($conn);
        echo "New client connected {$conn->resourceId}
";
    }

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

    public function onClose(ConnectionInterface $conn)
    {
        $this->clients->detach($conn);
        echo "Client {$conn->resourceId} disconnected
";
    }

    public function onError(ConnectionInterface $conn, Exception $e)
    {
        echo "WebSocket Error: {$e->getMessage()}
";
        $conn->close();
    }
}

$loop = ReactEventLoopFactory::create();
$webSocketServer = new RatchetServerIoServer(
    new RatchetHttpHttpServer(
        new RatchetWebSocketWsServer(
            new WebSocketServer()
        )
    ),
    $loop
);

echo "WebSocket server started
";
$webSocketServer->run();

require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

$channel->queue_declare('hello', false, false, false, false);

$callback = function ($msg) {
    echo 'Received: ', $msg->body, PHP_EOL;
};

$channel->basic_consume('hello', '', false, true, false, false, $callback);

echo "Waiting for messages. To exit press CTRL+C
";
while (count($channel->callbacks)) {
    $channel->wait();
}