安装

1.下载

2.配置环境变量

变量名:ROCKETMQ_HOME
变量值:解压路径

3.启动

> start mqnamesrv.cmd #启动NAMESERVER
> start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true #启动BROKER

4.图形化界面(可选)

集成

1.生产者—引入依赖

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

2.生产者—修改配置文件

rocketmq:
  name-server: localhost:9876
  producer:
    group: my-producer-group
    topic: my-topic

1.消费者—引入依赖

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

2.消费者—修改配置文件

rocketmq:
  name-server: localhost:9876
  consumer:
    group: my-consumer-group
    topic: my-topic