SpringBoot整合RocketMQ之环境搭建以及Producer发送消息

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发送消息相关推荐

RocketMQ源码解析：Producer发送消息+Broker消息存储
文章目录 1. Producer 发送消息 2. Broker 接收消息 1. Producer 发送消息先上一段简单的生产者代码 public static void main(String[] ...
springboot整合rocketMQ记录实现发送普通消息，延时消息
一.为什么选择RocketMQ消息队列?(可跳过看三的整合代码实例) 首先RocketMQ是阿里巴巴自研出来的,也已开源.其性能和稳定性从双11就能看出来,借用阿里的一句官方介绍:历年双 11 购物狂 ...
Springboot整合RocketMQ实战
本文来说下Springboot如何整合RocketMQ. 文章目录概述 Springboot整合RocketMQ 引入pom依赖 yaml文件简单实例本文小结概述消息队列rocketmq是A ...
Springboot整合Rocketmq系列教程
Springboot整合Rocketmq系列教程本教程是基于Springboot2.6.3整合Rocketmq5.0,其中涉及了Rocketmq的安装,消息的发送及消费的代码实现. 本文不会对roc ...
RocketMQ单机环境搭建
大家好,我是冰河~~ 今天,带来一篇搭建RocketMQ单机环境的文章,为后面的分布式事务专栏做准备.RocketMQ是阿里巴巴开源的一款高性能分布式消息中间件,有关RocketMQ的详细讲解,后面会 ...
RocketMQ 实战-SpringBoot整合RocketMQ同步消息、异步消息、单向消息
官方样例:https://gitee.com/apache/rocketmq/blob/master/docs/cn/RocketMQ_Example.md 1. 同步消息 producer向 bro ...
RocketMQ单机环境搭建测试+springboot整合
1.资源下载官网:下载 | RocketMQ 这里选择使用编译后可以直接用的下载后解压:略 2.更改配置主要是更改 conf/broker.conf 的配置,记得添加上下面这几行,否则消息发送失 ...
SpringBoot整合RocketMQ，三种测试附带源码【rocketmq-spring-boot-starter】
我们整合boot项目的时候都是引入 xxx-start 依赖,但是现在大多数的整合RocketMQ都还不是这样. 我花了一天时间使用rocketmq-spring-boot-starter整合,使得操 ...
spring-boot（2）--环境搭建
spring-boot环境搭建 1.下载:spring-tool-suite-3.9.2.RELEASE-e4.7.2-win32-x86_64 http://spring.io/tools/sts/ ...

SpringBoot整合RocketMQ之环境搭建以及Producer发送消息

SpringBoot整合RocketMQ之环境搭建以及Producer发送消息相关推荐

最新文章

热门文章