https://github.com/apache/rocketmq-spring/releases/tag/2.0.0https://github.com/apache/rocketmq-spring/archive/2.0.0.zip #源碼地址（或者使用資料中的源碼） https://github.com/apache/rocketmq-spring #進入源碼目錄，執行如下命令 mvn clean install <?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 http://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.1.0.RELEASE</version></parent><groupId>cn.learn.rocketmq</groupId><artifactId>learn-rocketmq</artifactId><version>1.0-SNAPSHOT</version><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></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.0</version></dependency><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>4.3.2</version></dependency></dependencies><build><plugins><!-- java編譯插件 --><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><version>3.2</version><configuration><source>1.8</source><target>1.8</target><encoding>UTF-8</encoding></configuration></plugin></plugins></build></project> # Spring boot application spring.application.name = learn-rocketmqspring.rocketmq.nameServer=localhost:9876 spring.rocketmq.producer.group=my-group package cn.learn.rocketmq.spring;import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component;@Component public class SpringProducer {// 注入rocketMQ的模板@Autowiredprivate RocketMQTemplate rocketMQTemplate;/*** 發送消息** @param topic* @param msg*/public void sendMsg(String topic, String msg) {this.rocketMQTemplate.convertAndSend(topic, msg);}} public void convertAndSend(D destination, Object payload) throws MessagingException {this.convertAndSend(destination, payload, (Map)null);} package cn.learn.rocketmq.spring;import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner;@RunWith(SpringRunner.class) @SpringBootTest public class TestSpringRocketMQ {@Autowiredprivate SpringProducer springProducer;@Testpublic void testSendMsg(){String msg = "我的第2個SpringRocketMQ消息!";this.springProducer.sendMsg("spring-my-topic", msg);System.out.println("發送成功");}} package cn.learn.rocketmq.spring;import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication public class MyApplication {public static void main(String[] args) {SpringApplication.run(MyApplication.class, args);} }

?

總結

以上是生活随笔為你收集整理的SpringBoot整合RocketMQ之环境搭建以及Producer发送消息的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。