初探Spring Boot与RocketMQ的亲密合作：发送者和接收者配置小秘籍

2023-09-06 23:56:59

Spring Boot 与 RocketMQ 的联姻：照亮分布式系统的夜空

消息发送者配置秘籍

配置消息发送者是与 RocketMQ 建立连接的关键。掌握以下秘籍，让消息发送畅通无阻：

必备配置：
- rocketmq.nameServerAddress：NameServer 地址，多个地址用分号分隔。
- rocketmq.producer.groupName：生产者组名，用于消费者订阅。
- rocketmq.producer.maxMessageSize：最大消息尺寸，超过后消息会被压缩。
- rocketmq.producer.sendMsgTimeout：发送消息超时时间。
提升效率：
- rocketmq.producer.compressMsgBodyOverHowmuch：超过该阈值的消息会被压缩。
- rocketmq.producer.retryTimesWhenSendFailed：发送失败时的重试次数。
自定义消息：
- rocketmq.producer.defaultTopicQueueNums：默认主题队列数量。
- rocketmq.producer.createTopicKey：创建主题的 Key。

消息接收者配置秘籍

让消息接收者做好准备，迎接即将到来的消息洪流。掌握以下秘籍，确保消息不漏掉：

基础配置：
- rocketmq.consumer.groupName：消费者组名，与生产者组名对应。
- rocketmq.consumer.namesrvAddr：NameServer 地址。
- rocketmq.consumer.topic：订阅主题。
- rocketmq.consumer.tag：订阅 Tag，可使用 "||" 分隔订阅多个 Tag。
消费模式选择：
- rocketmq.consumer.messageModel=CLUSTERING：集群消费模式，默认值。
- rocketmq.consumer.messageModel=BROADCASTING：广播消费模式，所有消费者都能收到消息。
可靠消息传递：
- rocketmq.consumer.maxReconsumeTimes：最大重试次数。
- rocketmq.consumer.consumeConcurrentlyMaxSpan：最大并发消费 Span。
- rocketmq.consumer.consumeThreadMin：最小消费线程数。
- rocketmq.consumer.consumeThreadMax：最大消费线程数。

定时/延时消息

RocketMQ 5.x 版本新增的定时/延时消息功能，让消息传递更灵活。

开启定时/延时消息：
- rocketmq.producer.scheduleMessageFixTimestamp：启用固定时间定时消息。
- rocketmq.producer.scheduleMessageDelayLevel：设置延迟等级。
时间掌控：
- rocketmq.producer.fixedDelayMoment：指定固定时间点，单位毫秒。
- rocketmq.producer.fixedTimestamp：指定延迟时间，单位毫秒。