redis消息队列简单应用

参考 blog.yxccan.cn/blog/detail…

第一次写掘金博客，小伙伴萌，多多支持哟~(^__^) 嘻嘻

---

1、什么是消息队列

是一个消息的链表，是一个异步处理的数据处理引擎。

PS：能够理解为在redis的list列表中存放消息数据，而后按照排队方式先进先出（左进右出；右进左出）

2、可使用的应用场景

主要应用一些延迟或异步操做的场景 好比：发送邮件、发送短信、视频转码、图片转码、日志存储、导入数据等 在发送邮件或者短信，咱们不但愿程序一直停留，等待发送成功才相应，而是异步进行处理，即：将待发送的邮件数据添加到消息队列中，而后按照排队前后进行异步发送邮件。

3、优势

不只可以提升系统的负荷，还可以改善因网络阻塞致使的数据缺失 这个能够理解为：异步处理数据，不会一次性给服务器太多压力，而且不直接操做数据库，减小了数据库的压力；而且若在网络阻塞时，若已经添加到消息队列中，那么这些数据会正常执行，不会形成丢失

4、redis实现队列方案

总体思路： 前面提到消息队列，就至关于到银行窗口排队，先到的叫号入队（加入到redis消息队列），而后排到了则根据相应的叫号出队。

redis的一些特色： redis设计用来作缓存的，可是因为它自身的某种特性使得它能够用来作消息队列，它有几个阻塞式的API可使用，正是这些阻塞式的API让其有能力作消息队列；另外，作消息队列的其余特性例如FIFO（先入先出）也很容易实现，只须要一个list对象从头取数据，从尾部塞数据便可；redis能作消息队列还得益于其list对象blpop brpop接口以及Pub/Sub（发布/订阅）的某些接口，它们都是阻塞版的，因此能够用来作消息队列。

方案一：

使用redis的lpush/rpop (rpush/lpop) 命令 简单实现左进右出 或 右进左出 的list列表。 而后须要开启一个线程任务或者定时任务或者轮询方式，不停的调用rpop方法查看List中是否有待处理消息。 缺点：每调用一次都会发起一次链接，这会形成没必要要的浪费。 1）、若是生产者速度大于消费者消费速度，消息队列长度会一直增大，时间久了会占用大量内存空间。 2）、若是睡眠时间过长，这样不能处理一些时效性的消息，睡眠时间太短，也会在链接上形成比较大的开销。

方案二：（推荐）

将方案一中的lpop、rpop命令改成使用blpop（左出）、brpop（右出） 这个指令只有在有元素时才返回，没有则会阻塞直到超时返回null 阻塞实现：不用轮询，当队列key有数据时候，就会响应，这里读取消息不会一直循环去读取，而是一直阻塞，等到有消息过来才读取。 该指令还提供了优先级以及超时参数 实现队列优先级命令：brpop queue1 queue2 ... 这样子便可以实现当队列1有数据时，优先处理，好比银行vip窗口等 实现超时退出：redis的brpop默认不带超时参数（或者说是默认为0（s）），会一直在进程中 实现命令：brpop queue1 timeout

5、代码实现思路

如下使用方案二实现思路 例子：发送平台用户邮箱消息通知（能够多场景、如发送验证码、重置密码等等）

# 第一步 请求发送的平台用户信息进队

//...... 获取用户信息代码省略
$userInfo = ['id'=>1, 'name'=>'张三', 'email'=>'393364227@qq.com'];
$redis->lpush('sendEmailQueue', serialize($userInfo)); //serialize 序列化数组信息，转为字符串
//..... 同步处理，相应页面 发送成功等信息


# 第二步 在另外一个接口类出队，而且处理消息

$userInfo = unserialize(brpop('sendEmailQueue'));
//sendEmail 开始发送邮件操做

# 第三步 将第二步的实现接口添加到进程任务，而且开启进程保护
//可使用linux下的Supervisor来作进程保护
//启动队列进程，便可实现消息队列去发送邮件了

复制代码

The End.