这篇文章将为大家详细讲解有关swoole怎么做消息通知，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。
基于swoole、redis做一个消息通知功能
利用swoole开启常驻进程，需要几个按自己的情况来定，swoole进程数最好是和服务器cpu核数相等
利用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怎么做消息通知就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
