正文

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

武武杭  武武杭  2023-03-11  736

关键词：

使用案例

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)

使用中遇到的坑

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

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

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

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

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

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

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

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

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

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

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

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

springboot整合rocketmq

参考技术A运行脚本org.apache.rocketmq.common.message.MessageExt属性说明: 查看详情

rocketmq（20）——整合springboot(代码片段)

整合SpringBootApacheRocketMQ提供了对SpringBoot的支持，目前最新的整合版本使用的是RocketMQ4.5.1版本，使用SpringBoot是2.0.5版本。整合SpringBoot需要引入rocketmq-spring-boot-starter依赖，目前最新版本是2.0.3。<dependency><groupId>org.apache.rock... 查看详情

rocketmq（20）——整合springboot(代码片段)

rocketmq（二十四）整合springboot(代码片段)

1、官网RocketMQ为SpringBoot提供了整合方案，官网地址如下，上面提供了详细的整合步骤及案例。https://github.com/apache/rocketmq-spring官方详细文档（可以切换不同的版本）https://github.com/apache/rocketmq-spring/blob/release-2.0.1 查看详情

springboot整合rocketmq实现入门案例

...习了Spring整合RocketMQ的第一个案例！现在我们来学习SpringBoot如何整合RocketMQ实现更加简单的使用！文章目录1创建maven项目2配置文件3生产者4消费者5测试1创建maven项目创建一个maven项目。引入sp 查看详情

springboot整合rocketmq(代码片段)

项目环境jdk：1.8rocketmq：4.5.1springboot：2.6.3引入依赖<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId>& 查看详情

4springboot整合rocketmq实现消息发送和接收(代码片段)

我们使用主流的SpringBoot框架整合RocketMQ来讲解，使用方便快捷；最终项目结构如下：具体步骤如下：第一步：新建SpringBoot项目rocketmq-test，引入rocketmq依赖，以及项目配置<dependency> <groupId>org.apac... 查看详情

springboot2.x整合rocketmq4.x

开发生产者代码第一步：创建很普通的SpringBoot项目第二步：加入相关依赖<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>4.3.0</version></ 查看详情

springboot整合rocketmq的各种消息类型，生产者，消费者(代码片段)

文章目录Springboot整合使用pom依赖yml整合使用同步消息消费者异步消息消费者单向消息消费者延时消息消费者顺序消息消费者sql92过滤消息消费者事物消息消费者@RocketMQMessageListener参数解释我的rocketmq各种集群方案安装Springboot... 查看详情

[原创]springboot整合rocketmq消息队列

参考技术A什么情况下的异步操作需要使用消息队列而不是多线程?StartNameServerStartBrokerWindows下安装RocketMq：https://www.jianshu.com/p/4a275e779afaRocketMq名词解释：https://my.oschina.net/javamaster/blog/2051703解释Push与Pull区别：https://www.jianshu.com/p/f0... 查看详情

springboot整合prometheus

...操作系统、MySQL、Redis、Flink、RocketMQ/RabbitMQ/Kafka、K8S等。SpringBoot整合Prometheus一般使用的是actuator这个项目，actuator是SpringBoot的子项目，为应用提供了强大的监控能力。SpringBoo 查看详情

springboot整合springsecurity示例实现前后分离权限注解

SpringBoot整合SpringSecurity示例实现前后分离权限注解+JWT登录认证作者：Sans_juejin.im/post/5da82f066fb9a04e2a73daec 一.说明SpringSecurity是一个用于Java企业级应用程序的安全框架,主要包含用户认证和用户授权两个方面.相比较Shiro而言,... 查看详情

11springboot整合rocketmq实现事务消息(代码片段)

事务消息是RocketMQ提供的非常重要的一个特性，在4.x版本之后开源，可以利用事务消息轻松地实现分布式事务。RocketMQ在其消息定义的基础上，对事务消息扩展了两个相关的概念：Half(Prepare)Message——半消息(预处理... 查看详情

springboot实战项目整合阿里云rocketmq消息队列实现发送普通消息，延时消息(代码片段)

原文地址：Springboot实战项目整合阿里云RocketMQ消息队列实现发送普通消息，延时消息--附代码-学不会丶-博客园一.为什么选择RocketMQ消息队列？（可跳过看三的整合代码实例）首先RocketMQ是阿里巴巴自研出来的&#... 查看详情

springboot整合mybatis(注解)

springboot整合mybatis(注解)1.pom.xml:<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation=" 查看详情

springboot-注解方式整合mybatis(代码片段)

SpringBoot整合Mybatis一.注解方式整合Mybatis1.创建Air的Mapper接口@ComponentScanpublicinterfaceAirMapperList<Air>selectAll();AirselectOneById(Integerid);2.添加Mybatis注解针对增删改查：@Insert，@De 查看详情

9springboot整合rocketmq实现顺序消息(代码片段)

rocketmq默认发送的消息是进入多个消息队列，然后消费端多线程并发消费，所以默认情况，不是顺序消费消息的；有时候，我们需要实现顺序消费一批消息，比如电商系统，订单创建，支付，完... 查看详情

八.rocketmq极简入门-在springboot中使用rocketmq(代码片段)

前言现在开发项目都是基于SpringBoot，新项目很少使用Spring，所以我们学习一门技术除了要会原生API，还不得不考虑和SpringBoot集成，本篇文章为SpirngBoot整合RocketMQ案例SpringBoot集成RocketMQ导入依赖这里使用整合RocketMQ... 查看详情