关于java:springbootroute十五整合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/s…

点关注、不迷路

如果感觉文章不错，欢送 关注 、 点赞 、 珍藏，你们的反对是我创作的能源，感激大家。

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

如果你还想更加深刻的理解我，能够微信搜寻「Java 旅途」进行关注。回复「1024」即可取得学习视频及精美电子书。每天 7:30 准时推送技术文章，让你的下班路不在孤单，而且每月还有送书流动，助你晋升硬实力！