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，消息队列的内容就暂时告一段落了，文章中只是演示了最简单的收发消息，在实际应用中需要考虑的问题远比这要多。



此是spring-boot-route系列的第十五篇文章，这个系列的文章都比较简单，主要目的就是为了帮助初次接触Spring Boot 的同学有一个系统的认识。本文已收录至我的github，欢迎各位小伙伴star！



github：https://github.com/binzh303/spring-boot-route



点关注、不迷路



如果觉得文章不错，欢迎关注、*点赞*、收藏，你们的支持是我创作的动力，感谢大家。



如果文章写的有问题，请不要吝啬，欢迎留言指出，我会及时核查修改。



如果你还想更加深入的了解我，可以微信搜索「Java旅途」进行关注。回复「1024」即可获得学习视频及精美电子书。每天7:30准时推送技术文章，让你的上班路不在孤独，而且每月还有送书活动，助你提升硬实力！