RokectMQ 顺序性 和分布式事务

1.顺序性是根据参数的id来使其同时投递到统一队列上。

1// RocketMQ通过MessageQueueSelector中实现的算法来确定消息发送到哪一个队列上
2// RocketMQ默认提供了两种MessageQueueSelector实现：随机/Hash
3// 当然你可以根据业务实现自己的MessageQueueSelector来决定消息按照何种策略发送到消息队列中
4SendResult sendResult = producer.send(msg, new MessageQueueSelector() {
5    @Override
6    public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) {
7        Integer id = (Integer) arg;
8        int index = id % mqs.size();
9        return mqs.get(index);
10    }
11}, orderId);

 2事务

流程图

代码执行

提交事务

检查失败