理解Topic

定义

topic为主题，是 Apache Rocket MQ 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。

主题的作用主要如下：

• 定义数据的分类隔离： 在 Apache RocketMQ 的方案设计中，建议将不同业务类型的数据拆分到不同的主题中管理，通过主题实现存储的隔离性和订阅隔离性。
• 定义数据的身份和权限： Apache RocketMQ 的消息本身是匿名无身份的，同一分类的消息使用相同的主题来做身份识别和权限管理。

Docker安装Rabbit MQ

从仓库找到rabbitmq

使用docker search rabbitmq命令查看仓库中rabbitmq的版本

使用pull命令拉取镜像

使用docker pull rabbitmq，这个命令会拉到最新版本的rabbit mq

如下为下载成功效果

查看镜像

使用docker images查看本地的镜像列表，

AMQP 0-9-1模型解释

队列、交换器和绑定统称为AMQP 实体。

消息被发送到exchanges（exchanges比作邮箱或邮局），exchanges使用binding的rules分配副本到queue，然后，broker传递消息给订阅这个队列的客户，或客户根据需要从队列拉取消息，

网络不可靠，应用程序可能无法处理消息，因此 AMQP 0-9-1 模型有一个 消息确认的概念：当消息传递给消费者时，消费者会自动通知代理，或者在应用程序开发人员选择时立即通知代理。这样做。当使用消息确认时，代理仅在收到该消息（或消息组）的通知时才会从队列中完全删除该消息。

使用消息队列的优缺点

使用消息队列的优缺点
优点：解耦、异步、削峰
缺点：

• 系统可用性降低，系统引入的外部依赖越多，越容易挂掉
• 系统复杂度提高
• 一致性问题

如何保证一致性

如何保证消息队列的高可用？

RabbitMQ的高可用

RabbitMQ对于高可用是基于主从的方式进行实现的。其中有三种工作模式：单机模式、普通集群模式、镜像集群模式

1. 单机模式：就是 Demo 级别的，一般就是本地启动了玩玩儿，没人生产用单机模式。
2. 普通集群模式：在多台机器上启动多个RabbitMQ实例，每个机器启动一个。创建的每一个Queue，只会存在一个MQ实例上，但是每个实例都同步Queue的元数据（即Queue的标识信息）。消费时，就算连接到其他MQ实例上，也会根据内部Queue元数据从对应的Queue所在实例上拉取数据过来。（这种方式只是通过集群部署的方式提高了消息的吞吐量,但是并没有考虑到高可用）
3. 镜像集群模式：才是所谓的 RabbitMQ 的高可用模式。在镜像模式下，创建的Queue，无论元数据还是Queue里的消息都会存在于多个实例上。即每个RabbitMQ节点都有这个Queue的一个完整的镜像，包含Queue全部的数据。每次写消息到Queue时，都会自动把消息同步到多个实例上的Queue上。

1.什么是幂等

按数学表达式就是
$f(x) = f( f(x) )$

概述

文章摘自官网，系统架构图

消息生产

生产者（Producter）：Apache RocketMQ 中用于产生消息的运行实体，一般集成于业务调用链路的上游。生产者是轻量级匿名无身份的。

消息存储

• 主题（Topic）Apache RocketMQ 消息传输和存储的分组容器，主题内部由多个队列组成，消息的存储和水平扩展实际是通过主题内的队列实现的。
• 队列（MessageQueue）：Apache RocketMQ 消息传输和存储的实际单元容器，类比于其他消息队列中的分区。 Apache RocketMQ 通过流式特性的无限队列结构来存储消息，消息在队列内具备顺序性存储特征。
• 消息（Message）：Apache RocketMQ 的最小传输单元。消息具备不可变性，在初始化发送和完成存储后即不可变。