springboot整合rocketmq应用（注解方式）+使用中遇到的坑

Posted 2023-03-11 武武杭

使用案例

• maven配置 （注意spring与mq的版本联系）

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.4.2</version>
        <relativePath/>
    </parent>
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
            <version>2.2.1</version>
        </dependency>

• yml配置

前提：1.如果mq不是自动创建topic、生产者组、消费者组，需要提前手动创建

2.若已开启自动创建，yml的配置第一次生效后，也可注释掉

rocketmq:
  name-server:  **。**。**。**:9876
  producer:  #生产者组
    group: producer-group2
    send-message-timeout: 50000
  consumer: #消费者组
    group: consumer-group2

• 创建生产者

@Autowired
    private RocketMQTemplate rocketMQTemplate;//注入Mq

//方法内--发送消息示例：
SendResult sendResult = rocketMQTemplate.syncSend(JmsConfig.TOPIC, JSONUtil.toJsonStr(tbMessageLog));

RocketMQTemplate更多的 方法介绍可查看下面文章：

https://loveworld.blog.csdn.net/article/details/126991767

• 创建消费者监听

@RocketMQMessageListener(consumerGroup = "consumer-group", topic = "second_topic",selectorExpression = "process3",selectorType = SelectorType.TAG
,messageModel = MessageModel.BROADCASTING) //消费模式：默认 CLUSTERING （ CLUSTERING：负载均衡 ）（ BROADCASTING：广播机制 ）
public class MessageConsumer4 implements RocketMQListener<String> 
    @Override
    public void onMessage(String message) 
    

使用中遇到的坑

前提：单模块项目，有些坑在多模块中可以实现

1. 注解模式如何引用多个生产者组？

答：没找到办法，但是非注解模式可以，不用spring管理的mq，使用java调用mq的方式能行。

2. 注解模式如何引用多个消费者组？

答：可以，前提是要先创建消费者组，然后yml里不要配置，监听器的consumerGroup填写不同消费者组名。

3. 注解模式同一个消费者组，同一个主题能否创建多个消费者？

答：可以创建，但会报错，无法使用，多模块微服务可以，每个微服务中创建一个消费者（同一个消费者组，同一个topic）；

4. 注解模式同一个消费者组，创建多个topic？

答：可以，RocketMQMessageListener 的 consumerGroup相同，但topic不同。

5. 消费者默认返回体与自定义消息返回体如何实现？

答：消费者默认返回体，监听器使用 RocketMQListener<T>；自定义消息返回体，监听器使用 RocketMQReplyListener<T, R>，T：消息体，R：返回体，发送消息调用rocketMQTemplate.sendAndReceive方法才能接收到指定回复的消息；

注意：两种监听方式，rocketMQTemplate的基本方法都能发送成功，不存在RocketMQListener与RocketMQReplyListener限制发送消息的方法必须用那种。