Swoole에서 메시지 알림을 수행하는 방법

Swoole 및 Redis 기반 메시지 알림 기능 만들기

Swoole을 사용하여 활성화 영구 필요한 프로세스 수는 상황에 따라 다릅니다. swoole 프로세스 수는 서버 CPU 코어 수 (권장 학습: swoole 비디오 튜토리얼 ) #🎜🎜 ##🎜 🎜#Swoole에서 시작된 상주 프로세스를 사용하여 Redis 큐에 있는 값을 지속적으로 감지합니다. 키 값에 따라 빠르게, 중간, 느리게 등의 가중치 처리를 수행할 수 있습니다. 데이터의 양이 많으면 더 많은 프로세스를 사용할 수 있습니다. 일반적으로 실행을 위해 다른 수의 프로세스를 할당할 수 있습니다.

아래 코드:

swoole 시작 코드

function run()
{
    try {
        $swoole = new \swoole_server(127.0.0.1, 9999);
        $swoole->set([
            'daemonize' => 1, //是否开启守护进程
            'worker_num' => 8, //实际需要去设定
            'log_file' => __APP_LOGS_PATH__ . '/swoole.log'
        ]);
        $swoole->on('WorkerStart', 'onWorkerStart');
        $swoole->on('Receive', 'onReceive');
        $swoole->start();
    } catch (\Exception $e) {
        logs(['err_code' => $e->getCode(), 'err_msg' => $e->getMessage()], 'error');
    }
}

#🎜 🎜#swoole은 Redis Queue의 데이터를 실시간으로 모니터링하고 키 값에 따라 가중치 순위를 지정합니다

code

function onWorkerStart(swoole_server $swoole, $worker_id)
{
    $chQuick = [0, 1, 2, 3];
    $chNormal = [4, 5];
    $chSlow = [6];
    for ($i = 1; $i <= 3000; $i++) {
        $redis = connectRedis();//断线重连redis
        $queueData = $keys = [];
        if (in_array($worker_id, $chQuick)) {
            if ($redis->llen(QUEUE_QUICK))
                $keys[] = QUEUE_QUICK;
            if ($keys)
                $queueData = $redis->brpop(QUEUE_QUICK, 5);
        } elseif (in_array($worker_id, $chNormal)) {
            if ($redis->llen(QUEUE_NORMAL))
                $keys[] = QUEUE_NORMAL;
            if ($redis->llen(QUEUE_QUICK))
                $keys[] = QUEUE_QUICK;
            if ($keys)
                $queueData = $redis->brpop(QUEUE_NORMAL, QUEUE_QUICK, 5);
        } elseif (in_array($worker_id, $chSlow)) {
            if ($redis->llen(QUEUE_SLOW))
                $keys[] = QUEUE_SLOW;
            if ($redis->llen(QUEUE_NORMAL))
                $keys[] = QUEUE_NORMAL;
            if ($redis->llen(QUEUE_QUICK))
                $keys[] = QUEUE_QUICK;
            if ($keys)
                $queueData = $redis->brpop(QUEUE_SLOW, QUEUE_QUICK, QUEUE_NORMAL, 5);
        } else {
            if ($redis->llen(QUEUE_FAIL))
                $keys[] = QUEUE_FAIL;
            if ($redis->llen(QUEUE_SLOW))
                $keys[] = QUEUE_SLOW;
            if ($redis->llen(QUEUE_NORMAL))
                $keys[] = QUEUE_NORMAL;
            if ($redis->llen(QUEUE_QUICK))
                $keys[] = QUEUE_QUICK;
            if ($keys)
                $queueData = $redis->brpop(QUEUE_FAIL, QUEUE_QUICK, QUEUE_NORMAL, QUEUE_SLOW, 5);
        }
        logs(&#39;test&#39;.$keys.&#39;%%&#39;.$queueData);
        if ($queueData) {
            $queueName = $queueData[0];
            $message = $queueData[1];
            if ($worker_id == QUEUE_FAIL_WORKER_ID && $queueName == QUEUE_FAIL) {
                call_user_func_array(&#39;retryPostMessage&#39;, [&$message, &$redis]);
            } else {
                call_user_func_array(&#39;postMessage&#39;, [&$message, &$redis]);
            }
        }
        else
        {
            sleep(5);
        }
    }
sleep(10);
    $redis->close();
    unset($redis);
    method_exists($swoole, &#39;stop&#39;) ? $swoole->stop() : @exit;
}

#🎜 🎜##🎜🎜 #내부의 for 루프는 sleep 기능과 함께 사용됩니다. 3번의 실패는 실패로 기록될 수 있으며 수동으로 처리할 수 있습니다. 위는 Swoole 및 Redis 대기열을 기반으로 하는 간단한 메시지 알림 푸시 기능입니다. 특정 구성은 구성에 작성하거나 데이터베이스에 저장할 수 있습니다.

편리한 점은 블록별로 모듈, 필요에 따라 비즈니스 모듈을 분리하고, 서로 다른 키 값과 서로 다른 연산을 사용하여 자신만의 메시지를 처리할 수 있다는 점입니다. redis에서 데이터를 처리하는 것이 매우 효율적일 수 있습니다

유일한 단점은 프로세스가 차지하는 메모리가 상대적으로 높다는 점입니다

위 내용은 Swoole에서 메시지 알림을 수행하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!