一、前言
消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。
RocketMQ官方文档： https://github.com/apache/rocketmq/tree/master/docs/cn
二、安装
2.1 maven配置
maven中conf/settings.xml的mirrors加上阿里镜像，否则有些包可能下载不了。
<mirror>
<id>aliyun-maven</id>
<mirrorOf>*</mirrorOf>
<name>aliyun maven</name>
<url>http://maven.aliyun.com/nexus/content/groups/public</url>
</mirror>
下载RocketMQ，https://github.com/apache/rocketmq/releases
2.2 编译打包
mvn -Prelease-all -DskipTests clean install -U
需要Java和Maven环境
编译成功后运行文件在distribution/target/rocketmq-4.8.0目录下
2.3 启动集群管理NameServer
# mac
sh mqnamesrv
# windows
mqnamesrv
2.4 启动Broker
# mac
sh mqbroker -n localhost:9876
# windows
mqbroker -n localhost:9876
三、使用
3.1 pom.xml添加如下maven依赖：
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.2.0</version>
</dependency>
3.2 application.properties配置
生产者：
# rocketmq 相关
rocketmq.name-server=127.0.0.1:9876
rocketmq.producer.group=provider-group
消费者：
# rocketmq 相关
rocketmq.name-server=127.0.0.1:9876
rocketmq.consumer.group=consumer-group
3.3 生产者发送消息
@GetMapping("send/{msg}")
public String send(@PathVariable String msg) {
MessageBuilder<String> builder = MessageBuilder.withPayload(msg);
Message<String> message = builder.build();
rocketMQTemplate.send("test-topic", message);
System.out.println("生产者发送：" + msg);
return msg;
}
- 这里发送字符串，生产中可以写自定义类对象。
3.4 消费者接收消息
@Component
@RocketMQMessageListener(consumerGroup = "consumer-group", topic = "test-topic")
public class TestMQListener implements RocketMQListener<String> {
@Override
public void onMessage(String s) {
System.out.println("消费者收到：" + s);
}
}
- group和topic要和配置文件对应
3.5 测试
http://localhost:7777/send/helloworld
请求可以看到生产者和消费者打印的消息
四、结语
源码地址：https://github.com/tigerleeli/xiaohuge-blog/tree/master/spring-cloud-alibaba-rocketmq
后面有时间写一下RocketMQ的集群部署和消息类型，比如怎么发送事务消息等。大家也可以去官网看看。
同步微信公众号：
