正文

rocketmq集成springboot(代码片段)

YanYang  YanYang  2022-12-25  147

关键词：

RocketMQ

RocketMQ 集成 SpringBoot
总结

RocketMQ 集成 SpringBoot

1. 项目配置

1.1 新建项目

新建两个 SpringBoot 项目，项目名分别为：springboot-rocketmq-consumer、springboot-rocketmq-producter；

1.2 引入依赖

两个项目都导入下面 jar 包

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
</dependency>

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.0.3</version>
</dependency>

2. 生产者实现

springboot-rocketmq-producter 的配置文件 application.properties

rocketmq.name-server=127.0.0.1:9876
rocketmq.producer.group=my-group
server.port=8081

生产者实现代码

@RestController
public class HelloController 
    @Autowired
    private RocketMQTemplate rocketMQTemplate;
    @RequestMapping("01-hello")
    public String sendMsg(String message,String age) throws Exception
        /**
         * 第一个参数 : topic ":" tag，主题后面是标签
         * 第二个参数 : message 消息内容
         */
        //底层是对 原生API 的封装, msg不需要转换成byte[],底层转
        // syncSend 同步请求 ,其他的就是方法名的改变
   		SendResult sendResult = rocketMQTemplate.syncSend("01-boot:", message);
        System.out.println(sendResult.getMsgId());
        System.out.println(sendResult.getSendStatus());
        return "success";

3. 消费者实现

springboot-rocketmq-consumer 的配置文件 application.properties
```
rocketmq.name-server=127.0.0.1:9876
server.port=8082
```

生产者实现代码

@Component
@RocketMQMessageListener(
        topic = "01-boot",  	//获取 msg 的主题,对应msg所在的主题		
        consumerGroup = "wolfcode-consumer"		//消费者分组
)
public class HelloConsumer implements RocketMQListener<MessageExt> 
    /**
     * 消费者会一直监听指定主题下面的消息,如果消息来了就执行 onMessage 方法
     * 参数是消息内容
     * @param msg 消息内容
     */
    @Override
    public void onMessage(MessageExt messageExt) 
         System.out.println("消费消息"+messageExt);

总结

以上就是配置 Nacos 注册中心的总结了，代码仅供参考，欢迎讨论交流。
上篇博客：消息中间件 - RocketMQ 详解（从软件安装到案例实现）

rocketmq集成springboot(代码片段)

RocketMQRocketMQ集成SpringBoot1.项目配置1.1新建项目1.2引入依赖2.生产者实现3.消费者实现总结RocketMQ集成SpringBoot1.项目配置1.1新建项目新建两个SpringBoot项目，项目名分别为：springboot-rocketmq-consumer、springboot-rocketmq-producter；1... 查看详情

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

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

(十九)atp应用测试平台——springboot集成rocketmq案例实战(代码片段)

...容是关于RocketMQ消息中间键的实战内容，主要介绍在springboot项目中如何集成使用RocketMQ消息中间键，包括消息的发送、消息的接收以及RocketMQ的一些配置说明，以及效果说明。话不多说，开始实战内容。正文搭建Roc... 查看详情

2rocketmq源码解析之与springboot集成(代码片段)

...构、概念、安装以及使用方式。现在大多数项目都是基于SpringBoot。因为它很方便的自动装配机制，所以现在构建项目都是基于SpringBoot。下面我们来分析一下RocketMQ是如何集成SpringBoot的。RocketMQ主要由Producer、Broker、Consumer三... 查看详情

rabbitmq入门springboot集成rabbitmq(代码片段)

前言本文主要参考了UnderstandingAMQP,theprotocolusedbyRabbitMQ要学习rabbitmq，就要先学习amqp协议，amqp全称AdvancedMessageQueuingProtocol(AMQP)，rabbitmq实现了amqp，当然rocketmq也实现了amqp。amqp中有几个重要的概念ÿ 查看详情

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(代码片段)

springboot集成rocketmq实现消息实时推送（待完成中。。。）

最近用SpringBoot集成RocketMQ实现消息实时推送，一直卡在本地启动RocketMQ失败。现在先记录一下，以后看时间解决。当然，如果有好心的朋友，可以提供解决方案(#^.^#)。我用的是Apache包，SpringBoot有RocketMQstarter，这个后面再讲。1<... 查看详情

springboot整合rocketmq(代码片段)

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

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

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

消息中间件-rocketmq详解（从软件安装到案例实现）(代码片段)

...费模式有两种五、延时消息六、消息过滤七、RocketMQ集成SpringBoot总结内容参考博文：查看详情

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

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

微服务springcloudalibaba项目搭建（七rocketmq集成）(代码片段)

RocketMQ介绍RocketMQ是一个队列模型的消息中间件，具有高性能、高可靠、高实时、分布式的特点。它是一个采用Java语言开发的分布式的消息系统，由阿里巴巴团队开发，在2016年底贡献给Apache，成为了Apache的一个顶... 查看详情

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

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

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

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

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

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

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

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

6springboot整合rocketmq发送异步消息(代码片段)

发送异步消息是指producer向broker发送消息时指定消息发送成功及发送异常的回调方法，调用API后立即返回，producer发送消息线程不阻塞，消息发送成功或失败的回调任务在一个新的线程中执行。相对发送同步消息，... 查看详情