rocketmq顺序发送

RocketMQ是一个高可用、高容错、高性能、分布式消息中间件系统。在实际应用中，有时候需要保证消息发送的顺序性，这时候就可以使用RocketMQ的顺序发送功能。

RocketMQ的顺序发送主要有以下几个步骤：

1.创建单独的发送组

在RocketMQ中，顺序发送需要创建一个单独的发送组，这个发送组中所有的消息都按照一定的顺序发送。创建发送组需要在producer端进行设置，代码如下：

DefaultMQProducer producer = new DefaultMQProducer("producer_group");
producer.setSendMsgTimeout(3000);
producer.setNamesrvAddr("localhost:9876");

producer.start();

在创建producer时，设置了一个名称为“producer_group”的发送组。

2.为消息设置消息队列选择器

在发送消息时，需要为消息设置一个消息队列选择器，这个选择器会根据消息的顺序属性将消息发送到指定的消息队列中。代码如下：

Message message = new Message("topic_name", "tag_name", "order_key", "order".getBytes());

SendResult result = producer.send(message, new MessageQueueSelector() {
    public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) {
        int index = Integer.parseInt(arg.toString());
        return mqs.get(index);
    }
}, 0);//顺序发送的消息必须要使用同步发送的方式

System.out.println(result);

在这里，我们为消息设置了一个消息队列选择器，在选择消息队列时，我们通过arg参数来确定消息要发送到哪个队列中，arg参数的值代表消息要发送到的队列的编号。

3.设置队列选择器的选择逻辑

最后一步，我们需要定义消息队列选择器的选择逻辑。选择逻辑需要满足以下两个条件：

1）返回的消息队列列表中必须包含指定的队列个数，这个数字可以是固定的，也可以是动态的。

2）返回的所有队列中必须有一个队列是发送过数据的，这样才能保证消息发送的有序性。如果找不到已经发送过的队列，那么消息就会阻塞，直到有可用的队列。

代码如下：

class OrderQueueSelector implements MessageQueueSelector {

    private AtomicInteger queueIndex = new AtomicInteger(0);

    @