使用redis作为队列的一些实践方式
使用redis作为队列的一些实践方式
wankaiming 发表于8个月前
使用redis作为队列的一些实践方式
  • 发表于 8个月前
  • 阅读 27
  • 收藏 1
  • 点赞 0
  • 评论 0

腾讯云 技术升级10大核心产品年终让利>>>   

一般为了并发数量更加高,响应速度更加快,会考虑将比较耗时的动作异步化处理。

1.可以使用异步注解,用异步线程来完成。

Spring框架的话,直接用个异步注解就好@Async。

2.可以使用redis的订阅和发布、redis列表的左进右出来实现消息队列。订阅和发布是为了即时通知到订阅线程处理数据,列表主要是防止宕机消息丢失。当然redis持久化要配置好,推荐(并且也是默认)的措施为每秒fsync一次, 这种fsync策略可以兼顾速度和安全性。

具体实现步骤如下:

2.1.当要执行耗时动作时,先将message写入redis列表(lpush),然后发布一个消息到redis指定频道(publish channel message),message可以是消息对象的json字符串,以便订阅端好解析出来。

2.2.随着项目启动时,建立一个线程,专门订阅redis一个指定频道(subscribe channel)。当收到消息时,就从redis列表取出数据(rpop),然后解析出消息对象,接着进行耗时动作的逻辑处理。

这个取列表数据的动作应该要用do..while的形式,是为了防止宕机,redis的列表数据还没处理完,下次消息过来的时候,就会把之前遗留的一直处理完毕。

//message是订阅过来的消息内容,queueValue是列表里面取出来的消息内容
do{
	queueValue = redisClientTemplate.rpop(key);
	doSomeThing(queueValue);
}while(null!=queueValue && !message.equals(queueValue));

如果消息数量级别很大,服务器资源也够的情况下,也可以尝试采用功能更加全面的ActiveMQ,它跟Spring整合起来也比较简单。

共有 人打赏支持
wankaiming
粉丝 72
博文 224
码字总数 59096
×
wankaiming
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: