其他分享
首页 > 其他分享> > SpringBoot整合RocketMQ,顺序消息

SpringBoot整合RocketMQ,顺序消息

作者:互联网

目录

引言

总有那么一种业务需求是要有先后顺序来执行

问题分析

例:在A系统下了一个订单,需要推到B系统去生成订单和发货单,并且是要先生成订单再生成发货单,如果按正常情况去先发造成订单的消息到MQ,再发生成发货单的消息到MQ会出现的几种问题;

RocketMq顺序消息

生产者

/**
 * 顺序消息
 */
@Test
public void demo2() {
    for (int i = 0; i < 10; i++) {
        String key = String.valueOf(i % rocketMQTemplate.getProducer().getDefaultTopicQueueNums());
        String msg = "订单  " + i + "  " + IdUtil.getSnowflake(1, 1).nextId();
        rocketMQTemplate.syncSendOrderly("topic-C", msg, key);
        msg = "发货单  " + i + "  " + IdUtil.getSnowflake(1, 1).nextId();
        rocketMQTemplate.syncSendOrderly("topic-C", msg, key);
    }
}

消费者

package com.lik.listener;

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.MessageModel;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

@Slf4j
@Component
@RocketMQMessageListener(consumerGroup = "consumer-group-4", topic = "topic-C")
public class TestConsumer7 implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        log.info("消费者7: " + message);
    }
}

@Slf4j
@Component
@RocketMQMessageListener(consumerGroup = "consumer-group-4", topic = "topic-C")
public class TestConsumer8 implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        log.info("消费者8: " + message);
    }
}

消费结果

在这里插入图片描述
在这里插入图片描述

小结

从上图可看出订单和发货单都是顺序消费的,重点在于生产者syncSendOrderly方法和主题,以及第3个参数,同一类的消息发到同一个队列。

标签:顺序,SpringBoot,发货单,topic,订单,消息,RocketMQ,String
来源: https://blog.csdn.net/ZLK1142/article/details/122676120