江苏龙网

  1. 主页 > 生活百科 > >

Redis-消息队列的两种实现方式

Redis消息队列

索引：

  1. 基于list的实现方式
  2. 基于publish/subscribe
  3. 实战
消息队列简介消息队列：是消息的顺序集合 。
比如网站的PV统计和查看，传统方式就是每个页面发一个AJAX然后MySQL给PV+1 。用户量非常大的时候，没有办法实时插入PV 。
结合redis消息队列的实现，也是每个用户访问的时候发送ajax到控制器，这个时候redis每次rpush pvlog，相当于直接往数组后面插入一万个行为，接下来用一个脚本运输处理pvlog，set pv查看时候get pv，如果想处理用户请求时间等等，同样可以这样异步处理 。
常见场景和解决的问题：应对流量峰值
异步消费（不定速的插入，生产和匀速的处理，消费）
解耦应用（不同来源的生产和同步去向的消费，基于publish/subscribe实现），即消息队列作为消息池，同时往里面写入的可能有多种数据，根据不同的场景来进行消费 。
redis实现消息队列原理
使用redis实现的最主要优势是简单快捷，性能没有kafka高，但是安装简便，kafka性能高但是比较重，如果消息队列不是很多，比如说一个博客计算pv，那么kafka可能比整个项目还要大 。
实现方式：方法一： 基于list的实现方式 
Redis-消息队列的两种实现方式

文章插图
 
Screen-Shot-2019-04-06-at-7.01.54-PM.png
 
核心代码
没有用消息队列的方式，使用incrBy大概上限在1000万
<?php$redis = new Redis();$redis->connect('127.0.0.1', 6380);$res->select(0);$key = 'pv:index';//看一下是不是没有，如果没有的话就设置成0if(false === $redis->get($key)){$redis->set($key, 0);}// 如果有了就增加1 注意incrBy的上线大概在1000万$redis->incrBy($key,1);`用list来实现
// 用list消息队列实现$key = 'listpv:index';$redis->rPush($key, 1);// 后台的cron来实现// 先连接redis$redis = new Redis();$redis->connect('127.0.0.1', 6380);$res->select(0);$key = 'pv:index';// 用一个死循环while(true){if(false !== $redis->lPop($key)){$redis->incrBy('pv:index');}}// 然后在terminal中无线循环这个脚本基于list来实现消息队列的特点：
【Redis-消息队列的两种实现方式】与水库相似的地方：
水库的容量决定承载能力 — redis的容量决定业务的承载能力
每一滴随只可能经过一个闸门 — 每条消息只能被一个消费者消费
与水库不同的地方：
水库用于蓄水 — 一般要把消息全部消费掉
不要的随扔掉 — 处理失败的消息要做容错
方法二：基于publish/subscribe 
Redis-消息队列的两种实现方式

文章插图
 
Screen-Shot-2019-04-06-at-7.53.22-PM.png
频道固定，生产者和消费者不固定，可能一对多，也可能多对一，也可能多对多 。
命令行的实现方式：
 
首先起两个redis cli，一个作为订阅，一个作为发布
订阅者：SUBSCRIBE channel1 channel2
发布者:
PUBLISH channel1 helloChannel
PUBLISH channel2 helloChannel2
  • 如果这个时候发布到一个没有被订阅的channel，那么这条消息就会丢失 。
  • 如果有多个订阅了同一个channel，但有信息发布到同一个channel的时候，他们都会受到
    代码实现：
发布者：
<?php// 发布者$redis = new Redis();$redis->connect('127.0.0.1', 6380);$res = $redis->publish('c1','hello c1');echo "clients reading c1:{$res}n";$res = $redis->publish('c2','hello c2');echo "clients reading c2:{$res}n";$res = $redis->publish('c3','hello c3');echo "clients reading c3:{$res}n";监听者：
<?php$redis = new Redis();$redis->connect('127.0.0.1', 6380);// 超时控制$redis->setOption(Redis::OPT_READ_TIMEOUT, -1);// 订阅$redis->subscribe(['c1','c2'],function(Redis $instance, $channel, $message){echo "received message form {$channel} : {$message}n";})?```php### 实战部分-生成内容页的质量分：实现三个功能：- 统计首页、列表页、内容页的PV- 统计浏览时间超过5s的内容页- 内容页的PV+1分，浏览时间超过5s+5分，不超过5秒-1分，生成内容页的质量分前端部分：?```JAVAscript<script>// ajax 访问ajax.php，给内容页增加PV$get('ajax.php?action=pv&from=article&aid=<?=$aid?>');// 如果页面打开时间超过5秒，则发出统计setTimeout(function(){$.get('ajax.php?action=get5&aid=<?=$aid?>');},5000);</script>


推荐阅读


上一篇：为什么我使用了索引，查询还是慢？

下一篇：床上可以写字的小桌子一般买多高,一般写字桌子多高