RocketMQ：支持任意延迟时间的延时消息
5星
- 浏览量: 0
- 大小:None
- 文件类型：None
简介：
RocketMQ是一款高性能、高可靠的分布式消息中间件，特别擅长处理大规模数据场景。其特色功能之一是提供灵活的延时消息服务，能够满足设置任意延迟时间的需求，广泛应用于金融交易、物流跟踪等对时间敏感的应用场景中。
RocketMQ 支持任意延迟的延时消息方案的主要特性包括支持精确到秒的任意延迟时间设置，最长可延迟一年。使用方法如下：
配置 `broker.conf` 文件中的相关参数：
- `segmentScale=60`：每个时间桶的时间范围（单位为分钟），默认值为 60 分钟；如果需要更高的延迟消息并发数，则应将此值调低。
- `dispatchLogKeepTime=72`：设置过期后的调度日志保存时长，默认为 72 小时。
生产者配置示例：
```java
DefaultMQProducer producer = new DefaultMQProducer(please_rename_unique_group_name);
producer.setNamesrvAddr(127.0.0.1:9876);
producer.start();
for (int i = 0; i < ; // 循环发送消息的代码省略
```
全部评论 (0)
还没有任何评论哟~
