Laravel实现redis发布 订阅消息
如果说我们需要一个比较简单的这种机制,我们可以采用redis这个轻量级的订阅机制,我们可以参考redis的 Publish/Subscribe 机制,得到比较好的问题解决方案 当然,如果是项目比较复杂,可以考虑使用Kafka， RabbitMQ之类的消息队列组件
首先简单介绍关于redis这个机制相关的几个命令
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
PSUBSCRIBE pattern [pattern ...]
订阅一个或多个符合给定模式的频道。
PUBSUB subcommand [argument [argument ...]]
查看订阅与发布系统状态。
PUBLISH channel message
将信息发送到指定的频道。
PUNSUBSCRIBE [pattern [pattern ...]]
退订所有给定模式的频道。
SUBSCRIBE channel [channel ...]
订阅给定的一个或多个频道的信息。
UNSUBSCRIBE [channel [channel ...]]
指退订给定的频道。
我们是使用Laravel来实现这个
1
2
3
4
5
6
composer require predis/predis 安装redis组件
使用Laravel创建发送消息文件及接收消息文件
php artisan make:command PublishMsg --command=Pub:Msg
php artisan make:command SubscribeMsg --command=Sub:Msg
在App\Console\Commands\SubscribeMsg.php中 handle订阅redis队列消息
1
2
3
4
5
// 启用redis订阅功能 持续监听redis-msg队列是否有消息 如果要消息就会到回调里面被echo
Redis::subscribe(['redis-msg'],function ($message){
echo $message;
});
在App\Console\Commands\PublishMsg.php中 handle发送redis队列消息
1
2
3
4
5
6
try{
// 队列名称 消息
Redis::publish('redis-msg','this a test hahhhhhhhhhhhh');
}catch (\Exception $e){
echo "发送失败";
}
1
2
php artisan Sub:Msg 开启消息订阅
php artisan Pub:Msg 开启消息发布
在实际中需要传输数据时,一般会将其序列化为字符串或以json XML等格式进行发送
