spring-boot-route（十五）整合RocketMQ

RocketMQ简介

RocketMQ是阿里巴巴开源的消息中间件。目前已经贡献给Apache软件基金会，成为Apache的顶级项目。

rocketMQ基本概念

1. Producer Group

生产者组：是一类生产者的集合，一般发送同一类消息而且发送逻辑一致。

2. Producer

生产者：负责发送消息，有三种消息发送模式。

• 同步发送：收到确认后再发送下一条消息
• 异步发送：发送后，不等待确认继续发送下一条
• 单向发送：只负责发送消息，没法确认而且没有回调，适合收集日志

3. Consumer Group

消费者组：是一类消费者的集合，一般消费同一类消息而且消费逻辑一致。

4. Consumer

消息者：负责消费消息，有两种消费模式

• 拉取型消费：主动从消息服务器拉取信息，只要批量拉取到消息，用户应用就会启动消费过程
• 推送型消费：实际上也是拉取消息，只不过是将拉取逻辑进行了封装，将消息到达时执行的回调接口留给用户来实现

5. Broker

消息服务器：存储消息

6. NameServer

做用和zookeeper相似，用来保存broker相关元素，并给producer和consumer查找broker消息，Producer 在发送消息前会根据 Topic 到 NameServer 获取到 Broker 的路由信息，Consumer 也会定时获取 Topic 的路由信息。

7. Topic

消息主题

8. Tag

标签，Topic的二级分类，也能够理解为消息队列，主题被划分为一个或多个子主题，即消息队列。一个 Topic 下能够设置多个消息队列，发送消息时执行该消息的 Topic ，RocketMQ 会轮询该 Topic 下的全部队列将消息发出去。

Spring Boot整合Rocketmq

1. 引入依赖

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

2. 配置rocketmq信息

rocketmq:
  name-server: 127.0.0.1:9876
  producer:
    group: my-producer-group

3. 构建生产者

@RestController
public class Producer {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    @GetMapping("send")
    public void send(){

        rocketMQTemplate.convertAndSend("first-topic","你好,Java旅途");
    }
}

4. 构建消费者

@Component
@RocketMQMessageListener(topic = "first-topic",consumerGroup = "my-consumer-group")
@Slf4j
public class Consumer implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        log.info("我收到消息了！消息内容为："+message);
    }
}

emmm，消息队列的内容就暂时告一段落了，文章中只是演示了最简单的收发消息，在实际应用中须要考虑的问题远比这要多。

---

本文示例代码已上传至github，点个star支持一下！

Spring Boot系列教程目录

spring-boot-route（一）Controller接收参数的几种方式

spring-boot-route（二）读取配置文件的几种方式

spring-boot-route（三）实现多文件上传

spring-boot-route（四）全局异常处理

spring-boot-route（五）整合swagger生成接口文档

spring-boot-route（六）整合JApiDocs生成接口文档

spring-boot-route（七）整合jdbcTemplate操做数据库

spring-boot-route（八）整合mybatis操做数据库

spring-boot-route（九）整合JPA操做数据库

spring-boot-route（十）多数据源切换

spring-boot-route（十一）数据库配置信息加密

spring-boot-route（十二）整合redis作为缓存

spring-boot-route（十三）整合RabbitMQ

spring-boot-route（十四）整合Kafka

spring-boot-route（十五）整合RocketMQ

spring-boot-route（十六）使用logback生产日志文件

spring-boot-route（十七）使用aop记录操做日志

spring-boot-route（十八）spring-boot-adtuator监控应用

spring-boot-route（十九）spring-boot-admin监控服务

spring-boot-route（二十）Spring Task实现简单定时任务

spring-boot-route（二十一）quartz实现动态定时任务

spring-boot-route（二十二）实现邮件发送功能

spring-boot-route（二十三）开发微信公众号

这个系列的文章都是工做中频繁用到的知识，学完这个系列，应付平常开发绰绰有余。若是还想了解其余内容，扫面下方二维码告诉我，我会进一步完善这个系列的文章！