配置文件详解

部署架构图

nameserver和broker

部署架构示意图

领域模型

mq部署架构图

实际应用过程中的架构图

领域模型

1. 什么是主题?

   

2. 消息队列

   

3. 什么是消息？

   

4. 什么是生产者？

   

5. 什么是消费者？

   

6. 什么是消费者分组？

   

7. mq中几个关键概念

   
   

RocketMQ是什么？

RocketMQ官网：

什么是mq?

mq能做什么？

消费者.

消息.

消息队列.

关键概念.

号称要达到99.999%的可用性(五个9).

RocketMQ 模型.

笔记

1、一般情况下一个主题Topic下会存在多个消息队列。

2、消息队列实际上是一条条消息的承载者。

3、消息队列对应实际消息的存储，对数据进行持久化保存。

4、

1、Topic是逻辑概念

2、至于数据怎么存储Topic并不管。具体操作是由消息队列决定的。

3、队列是消息存储和传输的实际容器，业务消息的最小存储单元。

4、MQ的所有主题都是由多个队列组成，以此实现队列数量的水平拆分和队列内部的流式存储。

假设上游一秒钟生产10万条数据，下游每秒钟处理1万条数据，这会造成大入口小出口问题。那么该怎么办呢？

首先可以初始化多过消费者，并归属于同一个消费者组。生产的消息会通过负载均衡分配到每一个消费者组的消费者上，这样就解决了大入口小出口的问题。

1、ActiveMQ第一款MQ消息中间件。

2、Kafka消息队列中间件，提供超大的消息吞吐，应用场景：日志分析，海量数据分析。对于单个消息的处理实时性相对弱一些，主要用于大数据场景。

3、RocketMQ主要用于传统的业务系统，强调的是实时性，单个消息处理的实时性，主要用于开发过程中。

跨进程、跨系统可靠稳定、高效且易用。

1、c#->消息队列->业务系统。

2、订阅发布功能，例如：气象局发布信息到消息队列，终端应用订阅消息队列主题数据，可以实现一对多关系。

3、削峰、限流、日志处理、流程跟踪。

业务痛点：

可靠性差、接口压力大、数据响应不及时、出现异常难以确权。

分析不同阶段可能出现的问题

幂等消费: 处理一条消息,和处理多条相同的消息,所得到的效果与预期是相符的

课程总结

MQ消息三阶段

22

111

topic

mq是什么 能做啥

11