Laravel实现redis发布-订阅
如果说我们需要一个比较简单的这种机制,我们可以采用redis这个轻量级的订阅机制,我们可以参考redis的 Publish/Subscribe 机制,得到比较好的问题解决方案
当然,如果是项目比较复杂,可以考虑使用Kafka， RabbitMQ之类的消息队列组件
首先简单介绍关于redis这个机制相关的几个命令
PSUBSCRIBE pattern [pattern ...]
订阅一个或多个符合给定模式的频道。
PUBSUB subcommand [argument [argument ...]]
查看订阅与发布系统状态。
PUBLISH channel message
将信息发送到指定的频道。
PUNSUBSCRIBE [pattern [pattern ...]]
退订所有给定模式的频道。
SUBSCRIBE channel [channel ...]
订阅给定的一个或多个频道的信息。
UNSUBSCRIBE [channel [channel ...]]
指退订给定的频道。我们是使用Laravel来实现这个
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队列消息
// 启用redis订阅功能 持续监听redis-msg队列是否有消息 如果要消息就会到回调里面被echo
Redis::subscribe(['redis-msg'],function ($message){
echo $message;
});在App\Console\Commands\PublishMsg.php中 handle发送redis队列消息
try{
// 队列名称 消息
Redis::publish('redis-msg','this a test hahhhhhhhhhhhh');
}catch (\Exception $e){
echo "发送失败";
}php artisan Sub:Msg 开启消息订阅
php artisan Pub:Msg 开启消息发布在实际中需要传输数据时,一般会将其序列化为字符串或以json XML等格式进行发送
本文为作者原创，手码不易，允许转载，转载后请以链接形式说明文章出处。
本文参与 腾讯云自媒体分享计划，分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
相关产品与服务
云数据库 Redis
腾讯云数据库 Redis（TencentDB for Redis）是腾讯云打造的兼容 Redis 协议的缓存和存储服务。丰富的数据结构能帮助您完成不同类型的业务场景开发。支持主从热备，提供自动容灾切换、数据备份、故障迁移、实例监控、在线扩容、数据回档等全套的数据库服务。