redis消息队列简单应用-创新互联

参考 https://blog.yxccan.cn/blog/detail/3


一、什么是消息队列

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

成都网站建设哪家好,找创新互联建站!专注于网页设计、成都网站建设、微信开发、微信小程序、集团成都企业网站建设等服务项目。核心团队均拥有互联网行业多年经验,服务众多知名企业客户;涵盖的客户类型包括:成都白乌鱼等众多领域,积累了大量丰富的经验,同时也获得了客户的一致赞赏!

PS:可以理解为在redis的list列表中存放消息数据,然后按照排队方式先进先出(左进右出;右进左出)

二、可以使用的应用场景

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

三、优点

不仅能够提高系统的负荷,还能够改善因网络阻塞导致的数据缺失
这个可以理解为:异步处理数据,不会一次性给服务器太多压力,并且不直接操作数据库,减少了数据库的压力;并且若在网络阻塞时,若已经添加到消息队列中,那么这些数据会正常执行,不会造成丢失

四、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

五、代码实现思路

以下使用方案二实现思路
例子:发送平台用户邮箱消息通知(可以多场景、如发送验证码、重置密码等等)

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

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

# 第二步 在另一个接口类出队,并且处理消息

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

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

The End.


另外有需要云服务器可以了解下创新互联cdcxhl.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


分享标题:redis消息队列简单应用-创新互联
当前URL:http://pwwzsj.com/article/dgeiic.html