生产消费流程
创建一条标记着topic,tag和body的消息,消息的发送时间可以选填,这是RocketMQ实现延时消息的基础,key当然也是选填,不过我建议你为其赋予业务标识的值,因为谈到消息队列,如何避免重复消费就是一个不可躲避的话题...,很遗憾RocketMQ无法保证消息不被重复消费,但是我们可以根据Message上的key在我们的业务上实现幂等性,消息可以重复,但是我们可以根据业务ID判断这条消息有没有消费的必要....long crc32Id = 666L;
// 消息ID和crc32id主要是用来防止消息重复。...// 如果要求消息绝对不重复,推荐做法是对消息体使用crc32或MD5来防止重复消息。...9条消息
// 集群订阅方式设置(不设置的情况下,默认为集群订阅方式)。