基於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佇列裡的數據，根據鍵值進行權重排比
程式碼
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('test'.$keys.'%%'.$queueData);
if ($queueData) {
$queueName = $queueData[0];
$message = $queueData[1];
if ($worker_id == QUEUE_FAIL_WORKER_ID && $queueName == QUEUE_FAIL) {
call_user_func_array('retryPostMessage', [&$message, &$redis]);
} else {
call_user_func_array('postMessage', [&$message, &$redis]);
}
}
else
{
sleep(5);
}
}
sleep(10);
$redis->close();
unset($redis);
method_exists($swoole, 'stop') ? $swoole->stop() : @exit;
}裡面的for迴圈是為了配合sleep函數來使用，三次失敗的可以記入失敗，可以手動去處理。以上就是簡單的基於swoole和redis佇列來完成一個訊息通知推播功能，具體的設定可以寫在設定也可以存在資料庫。
方便的是可以按區塊、按自己的需求、業務模組、進行模組化分離用不同的鍵值不同的操作來對自己的訊息處理，可以很有效率的處理redis裡面的資料
唯一的不足就是進程佔用的記憶體比較高
以上是swoole如何做訊息通知的詳細內容。更多資訊請關注PHP中文網其他相關文章！
