主要是利用 Swoole 的 Redis 协程属性及 Redis list 的阻塞读，当 list 有新消息时， swoole redis 能获取到消息，推送给链接的 fd
swoole.html 用户端代码没有变，还是原来的聊天室页面，具体参见上篇文章
swoole.php
<?php
$server = new swoole_websocket_server("0.0.0.0", 9502);
$server->on('workerStart', function ($server, $workerId) {
$redis = new Swoole\Coroutine\Redis();
$redis->connect('127.0.0.1', 6379);
while (true) {
// brpop 第二个参数 50 表示超时（阻塞等待）时间, blpop 同理，详情建议读文档,对应的 redis 操作是 rpush/lpush key content
if (($message = $redis->brpop('message', 50)) === null) {
continue;
}
// var_dump($message); 结果为数组
foreach ($server->connections as $fd) {
$server->push($fd, 'redis 的 ' . $message[0] . ' 队列发送消息:' . $message[1]);
}
}
});
$server->on('open', function ($server, $request) {
$server->push($request->fd, "hello;\n");
});
$server->on('message', function (swoole_websocket_server $server, $request) {
$server->push($request->fd, "hello");
});
$server->on('close', function ($server, $fd) {
echo "client-{$fd} is closed\n";
$server->close($fd);
});
$server->start();
方式如常：php swoole.php 启动 swoole 进程，然后通过浏览器访问 http://localhost/swoole.html , 新起终端，输入 redis-cli 进入 redis, 然后执行： rpush message xxx, 往 message list 中写入一个数据，swoole 监听着代码，然后就会自动打印数据并推送到 fd，效果如图：
进阶思考：以上的示例为向所有在线的 fd 推消息，如果一个用户登录之后，在 redis 的 hash 中保存用户 id 对应的 fd，而 list 的名称为 user_1_messages, 这样的名称，中间为用户具体 id, 则用户可以消费自己的队列数据，通知在 hash 中查找用户 id 对应的 fd 值，向对应的 fd 推消息。这样就算是一个较完整的简单消息消费系统了，有时间在写具体代码。
tips: 一次性推送多条数据，例如 rpush message content1 content2 content3, brpop 的顺序为 content3 content2 content1,则推送顺序也为 3 2 1
最后恰饭 阿里云全系列产品/短信包特惠购买 中小企业上云最佳选择 阿里云内部优惠券
