Swoole 및 Workerman의 메시지 대기열 및 분산 시스템 통합 및 확장성

Swoole과 Workerman은 모두 PHP 네트워크 통신 엔진으로 메시지 대기열과 분산 시스템의 강력한 통합 및 확장 기능을 제공합니다. 이 기사에서는 특정 코드 예제를 통해 이와 관련된 응용 프로그램을 보여줍니다.

먼저 스울과 워커맨의 특징을 살펴보겠습니다. Swoole은 프로덕션 환경을 위한 PHP 비동기 네트워크 통신 엔진으로 TCP/UDP/Unix Socket/HTTP/WebSocket 및 기타 프로토콜을 지원하며 타이머, 비동기 작업, 하위 프로세스 관리 등의 기능을 제공합니다. Workerman은 다중 프로세스 모델을 채택하고 대규모 동시 연결을 처리할 수 있는 고성능 PHP 소켓 프레임워크입니다.

메시지 큐 측면에서 Swoole은 수신된 메시지를 메시지 큐에 저장할 수 있는 swoole_server의 onMessage 콜백 기능을 제공합니다. Redis를 메시지 대기열로 사용하고 swoole_redis 확장을 통해 Swoole과 통합할 수 있습니다.

<?php
$serv = new swoole_server("127.0.0.1", 9501, SWOOLE_BASE, SWOOLE_SOCK_TCP);

$serv->set([
    'worker_num' => 4,    // 设置工作进程数
]);

$serv->on('WorkerStart', function ($serv, $worker_id) {
    // 连接Redis
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);

    // 消息队列名称
    $queue_name = 'message_queue';
    
    // 消费消息队列
    swoole_timer_tick(1000, function () use ($redis, $queue_name) {
        while ($message = $redis->lPop($queue_name)) {
            // 处理消息
            echo "Received message: " . $message . "
";
        }
    });
});

$serv->on('Receive', function ($serv, $fd, $from_id, $data) {
    // 将接收到的消息存入Redis消息队列
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);
    $redis->rPush('message_queue', $data);
});

$serv->start();
?>

위 코드에서는 Swoole 서버를 생성하고 작업자 프로세스 수를 4로 설정했습니다. WorkerStart 콜백 함수에서는 메시지 처리 함수를 콜백 함수로 사용하여 Redis를 연결하고 타이머를 통해 메시지 대기열을 폴링했습니다. 메시지가 도착하면 onReceive 콜백 함수가 호출되어 수신된 메시지를 Redis 메시지 대기열에 저장합니다.

다음으로 Workerman의 메시지 대기열과 분산 시스템 통합 및 확장성 기능을 살펴보겠습니다. Workerman은 EventManager 구성 요소를 통해 이벤트 기반 개발을 제공합니다.

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

use WorkermanWorker;
use WorkermanRedisQueueClient;
use WorkermanEventLoopSelect;

$worker = new Worker('tcp://127.0.0.1:9501');
$worker->count = 4;

$worker->onWorkerStart = function ($worker) {
    $redis = new PredisClient();
    $queue = new Client($redis);
    
    $queue->onMessage = function ($message) {
        // 处理消息
        echo "Received message: " . $message . "
";
    };
    
    $queue->run();
};

$worker->onMessage = function ($connection, $data) {
    global $worker;
    $worker->queue->sendMessage($data);
};

Worker::$eventLoopClass = Select::class;
Worker::runAll();

위 코드에서는 Workerman 서버를 생성하고 4개의 작업자 프로세스를 설정했습니다. onWorkerStart 콜백 함수에서 Redis에 연결하고 Redis 대기열 클라이언트를 생성했습니다. 큐 클라이언트의 onMessage 콜백 함수를 설정하여 메시지를 처리합니다. 메시지가 수신되면 onMessage 콜백 함수가 호출되어 메시지를 Redis 메시지 대기열로 보냅니다.

위의 코드 예제를 통해 Swoole과 Workerman이 메시지 대기열(예: Redis)과 통합되어 분산 시스템에서 메시지 전달을 구현할 수 있음을 알 수 있습니다. 실제 개발에서는 특정 요구 사항에 따라 적절한 도구를 선택할 수 있습니다. Swoole과 Workerman은 모두 우수한 확장 기능을 제공하며 필요에 따라 사용자 정의할 수 있습니다.

위 내용은 Swoole 및 Workerman의 메시지 대기열 및 분산 시스템 통합 및 확장성의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!