Home
  • 计算机网络
  • 操作系统
  • 数据结构与算法
  • 设计模式
  • JavaSE
  • JVM
  • JUC
  • Netty
  • CPP
  • QT
  • UE
  • Go
  • Gin
  • Gorm
  • HTML
  • CSS
  • JavaScript
  • vue2
  • TypeScript
  • vue3
  • react
  • Spring
  • SpringMVC
  • Mybatis
  • SpringBoot
  • SpringSecurity
  • SpringCloud
  • Mysql
  • Redis
  • 消息中间件
  • RPC
  • 分布式锁
  • 分布式事务
  • 个人博客
  • 弹幕视频平台
  • API网关
  • 售票系统
  • 消息推送平台
  • SaaS短链接系统
  • Linux
  • Docker
  • Git
GitHub (opens new window)
Home
  • 计算机网络
  • 操作系统
  • 数据结构与算法
  • 设计模式
  • JavaSE
  • JVM
  • JUC
  • Netty
  • CPP
  • QT
  • UE
  • Go
  • Gin
  • Gorm
  • HTML
  • CSS
  • JavaScript
  • vue2
  • TypeScript
  • vue3
  • react
  • Spring
  • SpringMVC
  • Mybatis
  • SpringBoot
  • SpringSecurity
  • SpringCloud
  • Mysql
  • Redis
  • 消息中间件
  • RPC
  • 分布式锁
  • 分布式事务
  • 个人博客
  • 弹幕视频平台
  • API网关
  • 售票系统
  • 消息推送平台
  • SaaS短链接系统
  • Linux
  • Docker
  • Git
GitHub (opens new window)
  • 基础篇
  • 数据类型篇
  • 持久化篇
  • 网络模型篇
  • 缓存篇
  • 高可用篇
  • 实战篇
  • 拾遗篇
  • Redisson
    • 延时队列
  • Redis
Nreal
2024-03-12
目录

Redisson

# 延时队列

Redisson延迟队列iRDelayedQueue基于Redis中的zset实现,zset中每个元素都可以设置一个分数,代表该元素的权重,Redisson利用这一特性,将需要延迟执行的任务插入到zset中;

每次插入都会发布消息的timeout延时时间,然后客户端开启延时任务,等延时任务时间到了才去zset中通过zrangebyscore取过期消息,加入到就绪消息列表中;

就绪消息列表是个阻塞队列,有消息进入就会被监听到,可以避免对整个zset进行轮询,提高执行效率;

相比较redis优势:

  1. 减少消息丢失可能性:DelayedQueue中的消息会持久化;
  2. 消息不重复消费:每个客户端都从同一个目标队列中获取任务;
拾遗篇

← 拾遗篇

Theme by Vdoing | Copyright © 2021-2024
  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式