rocketmq顺序消息的分析

顺序消息是指的是一组需要有序的消息集合，在同一参照系下才有意义。rocketmq的顺序消息主要是分为两个方面：

product保证将一组有序的消息发送到同一个messageQueue下
consumer消费时保证同一时刻一个消费组下只有一个线程在消费消息

范围

分区顺序：单个messagequeue中的消息是有序的
全局顺序：单个Topic中的消息都是有序的

原理

发送时是如何保证顺序的？

发送时是通过MessageQueueSelector在生产者一端保证顺序的

java

SendResult result = producer.send(message, new MessageQueueSelector() {
    @Override
    public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) {
        return mqs.get(0);
    }
},finalI);

MessageQueueSelector.select的执行时间是在DefaultMQProducerImpl.send时，会调用传入的MessageQueueSelector并执行select方法获取到messageQueue队列进行传值

ps.普通消息调用时候不会手动选择messageQueue，而是通过**selectOneMessageQueue()**方法进行选择的

java

int index = tpInfo.getSendWhichQueue().getAndIncrement();
for (int i = 0; i < tpInfo.getMessageQueueList().size(); i++) {
    int pos = Math.abs(index++) % tpInfo.getMessageQueueList().size();
    if (pos < 0)
        pos = 0;
    MessageQueue mq = tpInfo.getMessageQueueList().get(pos);
    if (latencyFaultTolerance.isAvailable(mq.getBrokerName())) {
        if (null == lastBrokerName || mq.getBrokerName().equals(lastBrokerName))
            return mq;
    }
}