RocketMQ(二) java使用

参见官方中文文档：https://github.com/apache/rocketmq/blob/master/docs/cn/RocketMQ_Example.md

springboot-start 文档 https://github.com/apache/rocketmq-spring/wiki/%E6%B6%88%E6%81%AF%E8%BD%A8%E8%BF%B9

一、springboot快速使用Demo

1.1 添加pom依赖

1
2
3
4
5
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.2.3</version>
</dependency>

1.2 配置文件

1
2
3
4
5
# rocketMq配置
rocketmq:
  name-server: ip:port
  producer:
      group: my-group

1.3