开发者社区

开发者社区微服务文章正文

扩展RocketMQ 使其支持任意时间精度的消息延迟（2）

2022-04-22 306

版权

版权声明：

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 扩展RocketMQ 使其支持任意时间精度的消息延迟（2）

延迟发送逻辑

根据延迟时间和当前时间差值计算延迟等级

Integer level = DelayLevelCalculate.calculateDefault(l);

标记该消息为延迟消息希望该消息被消费的时候若发现是延迟消息即还未到消费的时间则不消费再次的触发生产者生产一次该消息

fillMessage(msg, level, startSendTime);

文章标签：

云消息队列 MQ

消息中间件

RocketMQ

关键词：

云消息队列 MQ延迟

消息队列RocketMQ版延迟

消息队列RocketMQ版消息

消息队列RocketMQ版时间

扩展消息队列RocketMQ版精度延迟

相关实践学习

RocketMQ一站式入门使用

从源码编译、部署broker、部署namesrv，使用java客户端首发消息等一站式入门RocketMQ。

消息队列 MNS 入门课程

1、消息队列MNS简介本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列：消息队列MNS实操讲本节课介绍消息队列的MNS的实际操作演示 5、动手实验：基于MNS，0基础轻松构建 Web Client 本节课带您一起基于MNS，0基础轻松构建 Web Client

平凡人笔记

目录

相关文章

一个风轻云淡

|

6月前

|

消息中间件存储 Java

RabbitMQ之延迟队列解读

RabbitMQ之延迟队列解读

一个风轻云淡

79 0 0

一只牛博

|

2月前

|

消息中间件监控 Java

Spring Boot中的RabbitMQ死信队列魔法：从异常到延迟，一网打尽【RabbitMQ实战一】

Spring Boot中的RabbitMQ死信队列魔法：从异常到延迟，一网打尽【RabbitMQ实战一】

一只牛博

56 0 0

BUG弄潮儿

|

3月前

|

消息中间件

RabbitMQ 实现消息队列延迟

RabbitMQ 实现消息队列延迟

BUG弄潮儿

119 0 0

小z1

|

1月前

|

消息中间件前端开发算法

【十七】RabbitMQ基础篇（延迟队列和死信队列实战）

【十七】RabbitMQ基础篇（延迟队列和死信队列实战）

小z1

37 1 1

一只牛博

|

2月前

|

消息中间件 Docker 容器

docker构建rabbitmq并配置延迟队列插件

docker构建rabbitmq并配置延迟队列插件

一只牛博

31 0 0

哥的时代

|

3月前

|

消息中间件存储 Java

RabbitMQ之延迟队列（手把手教你学习延迟队列）

【1月更文挑战第12天】延时队列,队列内部是有序的，最重要的特性就体现在它的延时属性上，延时队列中的元素是希望在指定时间到了以后或之前取出和处理，简单来说，延时队列就是用来存放需要在指定时间被处理的元素的队列的。

哥的时代

307 1 2

愿天堂没有BUG（公众号同名）

|

8月前

|

消息中间件 Java

RabbitMQ实现延迟消息居然如此简单，整个插件就完事了

RabbitMQ实现延迟消息的方式有两种，一种是使用死信队列实现，另一种是使用延迟插件实现。死信队列实现我们以前曾经讲过这次我们讲个更简单的，使用延迟插件实现。

愿天堂没有BUG（公众号同名）

157 0 0

浩泽学编程

|

3月前

|

消息中间件 Shell 数据库

RabbitMQ之延迟消息

RabbitMQ之延迟消息

浩泽学编程

62 0 0

不焦躁的程序员

|

4月前

|

消息中间件存储 RocketMQ

大白话-设计RocketMQ延迟消息

RocketMQ的延迟消息使用上非常便捷，但是不支持任意时间的延迟，这一点对于有强迫症的朋友来说就比较难受，但是搞明白为什么这么设计后，就自然释怀了。

不焦躁的程序员

139 1 1

阿兵云原生

|

9月前

|

消息中间件 Cloud Native

我们一起来学RabbitMQ 三：RabbiMQ 死信队列，延迟队列，持久化等知识点

咱们今天再来进一步学习一下 RabbitMQ 的知识点，整理了如下相关知识点

阿兵云原生

97 0 2

热门文章

最新文章

RocketMQ 流存储解析：面向流场景的关键特性与典型案例

java如何连接mqtt

【如何安装和配置RabbitMQ（转载）】

rabbitmq使用docker容器挂载宿主机配置文件时无法访问控制台

信用算力基于 RocketMQ 实现金融级数据服务的实践

2018最新蚂蚁金服面试题：Docker+秒杀设计+RocketMQ+亿级数据设计

《RocketMQ技术内幕：RocketMQ架构设计与实现原理》一导读

RocketMQ与MYSQL事务消息整合

RocketMQ系列（五）广播与延迟消息

RocketMQ 5.0：无状态代理模式的探索与实践

阿里云OpenAPI RocketMQ 5.0的PHP收发消息文档

爆款游戏如何借助 RocketMQ Serverless，打造流畅体验并节省 98% 成本？

深度剖析 RocketMQ 5.0，事件驱动：云时代的事件驱动有啥不同？

深度剖析 RocketMQ 5.0，IoT 消息：物联网需要什么样的消息技术？

深度剖析 RocketMQ 5.0，流数据库：如何实现一体化流处理？

深度剖析 RocketMQ 5.0，流存储：流场景的诉求是什么？

深度剖析 RocketMQ 5.0，消息进阶：如何支撑复杂业务消息场景？

【十七】RabbitMQ基础篇（延迟队列和死信队列实战）

【十六】RabbitMQ基础篇（下载安装并基础使用，内含各种坑问题）

深度剖析 RocketMQ 5.0，消息基础：RocketMQ 在业务消息场景的基础优势是什么？

相关课程

更多

消息队列 RocketMQ 消息集成

消息队列 MNS 入门课程

RocketMQ知识精讲与项目实战（第一阶段）

RocketMQ知识精讲与项目实战（第二阶段）

RocketMQ知识精讲与项目实战（第三阶段）

微服务实战-RocketMQ Binder

相关电子书

更多

RocketMQ Client-GO 介绍

RocketMQ Prometheus Exporter 打造定制化 DevOps 平台

基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台

相关实验场景

更多

消息队列RocketMQ版：消费异常运维排查体验

消息队列RocketMQ版：定时消息通知功能体验

消息队列RocketMQ版：基础消息收发功能体验

流密码与线性反馈移位寄存器LFSR

部署RabbitMQ

RocketMQ一站式入门使用

下一篇

部署LAMP环境（Alibaba Cloud Linux 3）