SpringBoot整合RocketMQ實現(xiàn)消息發(fā)送和接收的詳細步驟
我們使用主流的SpringBoot框架整合RocketMQ來講解,使用方便快捷;
最終項目結(jié)構(gòu)如下:

具體步驟如下:
第一步:新建SpringBoot項目rocketmq-test,引入rocketmq依賴,以及項目配置
<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactId> <version>2.2.0</version> </dependency>
完整pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.5.4</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.java1234</groupId>
<artifactId>rocketmq-test</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>rocketmq-test</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.2.0</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
另外我們項目配置文件需要指定nameserver地址,以及消息生產(chǎn)者和消息消費者組;
所以配置application.yml:
rocketmq:
name-server: 127.0.0.1:9876
producer:
group: producer-demo1
consumer:
group: consumer-demo1
第二步:新建消息生產(chǎn)者Service類ProducerService
package com.java1234.rocketmq;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* 消息生產(chǎn)者
* @author java1234_小鋒
* @site www.java1234.com
* @company 南通小鋒網(wǎng)絡科技有限公司
* @create 2021-08-22 22:16
*/
@Component("producerService")
public class ProducerService {
@Autowired
private RocketMQTemplate rocketMQTemplate;
/**
* 發(fā)送簡單消息
*/
public void sendMessage(){
for(int i=0;i<1000;i++){
rocketMQTemplate.convertAndSend("java1234-rocketmq","rocketmq大爺,你好!"+i);
}
}
}
SpringBoot給我們提供了RocketMQTemplate模板類,我們利用這個類可以以多種形式發(fā)送消息;
另外這個類我們要加下@Component注解,讓Spring來管理實例,方便其他地方獲取bean來使用;
發(fā)送方法指定Topic主題java1234-rocketmq;
第三步:啟動類獲取ProducerService實例,調(diào)用發(fā)送消息方法
package com.java1234;
import com.java1234.rocketmq.ProducerService;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
@SpringBootApplication
public class RocketmqTestApplication {
public static void main(String[] args) {
ConfigurableApplicationContext run = SpringApplication.run(RocketmqTestApplication.class, args);
ProducerService producerService = (ProducerService) run.getBean("producerService");
producerService.sendMessage();
}
}
我們獲取ProducerService實例,調(diào)用sendMessage方法發(fā)送消息;
第四步:新建消息消費者Service類ConsumerService,監(jiān)聽消息,消費消息
package com.java1234.rocketmq;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
/**
* 消息消費者
* @author java1234_小鋒
* @site www.java1234.com
* @company 南通小鋒網(wǎng)絡科技有限公司
* @create 2021-08-22 22:40
*/
@RocketMQMessageListener(topic = "java1234-rocketmq",consumerGroup ="${rocketmq.consumer.group}" )
@Component
public class ConsumerService implements RocketMQListener<String> {
@Override
public void onMessage(String s) {
System.out.println("收到消息內(nèi)容:"+s);
}
}
消費者類要實現(xiàn)RocketMQListener接口,以及動態(tài)指定消息類型String。
類上要加上**@RocketMQMessageListener**注解,指定topic主題java1234-rocketmq,以及消費者組${rocketmq.consumer.group}
同樣這個類上也要加上@Component注解,讓Spring來管理bean實例;
第五步:再次啟動,測試消息消費

測試OK,成功消費!
到此這篇關(guān)于SpringBoot整合RocketMQ實現(xiàn)消息發(fā)送和接收的文章就介紹到這了,更多相關(guān)SpringBoot整合RocketMQ消息內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Java優(yōu)雅的處理金錢問題(BigDecimal)
本文主要介紹了Java優(yōu)雅的處理金錢問題(BigDecimal),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2023-06-06
java使用Apache工具集實現(xiàn)ftp文件傳輸代碼詳解
這篇文章主要介紹了java使用Apache工具集實現(xiàn)ftp文件傳輸代碼詳解,分享了詳細連接ftp server和上傳文件,下載文件的代碼,以及結(jié)果展示,具有一定借鑒價值,需要的朋友可以參考下。2017-12-12
Java Socket編程筆記_動力節(jié)點Java學院整理
Socket對于我們來說就非常實用了。下面是本次學習的筆記。主要分異常類型、交互原理、Socket、ServerSocket、多線程這幾個方面闡述2017-05-05
關(guān)于Java中攔截mybatis并輸出完整sql語句的方法
這篇文章主要介紹了關(guān)于Java中攔截mybatis并輸出完整sql語句的方法,假如項目中有很多很多的SQL我們不可能一一的去修改解決。這個時候我們就需要通過mybatis攔截SQL并且最終修改SQL,需要的朋友可以參考下2023-08-08
Springboot?對接支付寶實現(xiàn)掃碼支付功能
本文介紹了如何在Spring?Boot項目中實現(xiàn)支付寶支付功能,包括沙箱環(huán)境配置、依賴引入、配置參數(shù)、訂單類定義、測試接口編寫等步驟,通過不同場景下的請求方式(PC端、二維碼、回調(diào)處理、定時查詢支付結(jié)果),展示了如何與支付寶API進行交互,感興趣的朋友一起看看吧2025-03-03
@PathVariable、@RequestParam和@RequestBody的區(qū)別
本文主要介紹了@PathVariable、@RequestParam和@RequestBody的區(qū)別和使用,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2023-05-05
Java從數(shù)據(jù)庫中讀取Blob對象圖片并顯示的方法
這篇文章主要介紹了Java從數(shù)據(jù)庫中讀取Blob對象圖片并顯示的方法,實例分析了Java讀取數(shù)據(jù)庫中Blob對象圖片的技巧與操作方法,需要的朋友可以參考下2015-02-02

