‘壹’ rabbitmq消息中间件
消息中间件
消息中间件，又称消息队列，其核心功能在于利用高效可靠的消息传递机制进行分布式系统间的数据交流，依托数据通信机制集成分布式系统。当下主流的消息中间件有RabbitMQ、Kafka、ActiveMQ、RocketMQ等。
消息中间件的主要作用体现在以下几个方面：
1、**消息中间件的两种模式**：
- **P2P模式**：包含消息队列（Queue）、发送者(Sender)、接收者(Receiver)三个角色。每个消息被发送到特定的队列，接收者从中获取消息。队列保留消息直至被消费或超时。
- **Pub/Sub模式**：包含主题（Topic）、发布者（Publisher）、订阅者（Subscriber）三个角色。多个发布者将消息发送至Topic，系统将消息传递给多个订阅者。
**常用中间件介绍与对比**：
- **Kafka**：LinkedIn开源的分布式发布-订阅消息系统，主要特点是追求高吞吐量，起始目的用于日志收集和传输。自0.8版本开始支持复制，不支持事务，对消息的重复、丢失、错误没有严格要求，适用于产生大量数据的互联网服务的数据收集业务。
- **RabbitMQ**：基于Erlang语言开发的开源消息队列系统，使用AMQP协议实现。AMQP重点在于面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。更多适用于企业系统内对数据一致性、稳定性和可靠性要求较高的场景。
- **RocketMQ**：阿里开源的消息中间件，纯Java开发，具有高吞吐量、高可用性、适合大规模分布式系统应用的特点。对消息的可靠传输及事务性进行优化，广泛应用于交易、充值、消息推送、日志流式处理、binglog分发等场景。
RabbitMQ相较于Kafka在可靠性方面更为出色，而Kafka更适合处理高IO吞吐量的场景，通常应用于大数据日志处理或对实时性（少量延迟）、可靠性（少量丢数据）要求稍低的场景，如ELK日志收集。
RabbitMQ集群**：
- **简介**：RabbitMQ基于Erlang开发，集群构建非常便捷，因为Erlang天生支持分布式。但RabbitMQ本身不支持负载均衡，支持高并发、可扩展性，支持AJAX、持久化，适用于分布式系统中存储转发消息。
- **特点**：模式分为**单模式**、**普通模式（默认集群模式）**、**镜像模式**（将需要的队列复制到多个节点，属于RabbitMQ的HA方案，适合业务可靠性要求较高的场合）。实现镜像模式需先构建普通集群模式，再配置镜像模式以实现高可用。
**集群基本概念**：RabbitMQ集群包括内存节点和磁盘节点。内存节点将数据保存在内存中，磁盘节点则将数据保存在磁盘上。集群中可以共享用户、虚拟主机、队列、交换机等，所有数据和状态都需要在所有节点上复制。
**面试注意点**：集群中有两种节点：内存节点（只保存状态到内存，持久化队列内容将被保存到磁盘）与磁盘节点（保存状态到内存和磁盘，推荐使用）。内存节点虽然不写入磁盘，但在集群中，仅需一个磁盘节点来保存状态即可，避免状态、消息等丢失。
- **普通集群准备环境**：
- 三台服务器联网，RabbitMQ集群节点必须在同一网段内。若跨广域网，效果会变差。关闭防火墙和selinux。
- 三台机器均需创建用户，开启用户远程登录，查看端口（注意如果是云服务器，需要添加安全组端口放行）。
- 访问管理控制台：192.168.50.138:15672，使用默认用户guest，密码guest登录。
**开始部署集群**：三台机器操作如下步骤：
- 创建数据存放目录和日志存放目录。
- 拷贝erlang.cookie文件。
- 将mq-2、mq-3作为内存节点加入mq-1节点集群中。
- 查看集群状态，登录web管理控制台，创建新队列。
- 镜像集群配置**：在任意一台机器上设置策略，确保队列同步至其他节点。镜像队列基于普通集群模式，设置策略为匹配所有队列、复制模式为所有节点。完成队列镜像集群部署。至此，所有队列设置为镜像队列，各节点状态保持一致。
‘贰’ 如何查rocketmq 每日量
通过rocketmq控制台查看。
除了控制台查看，还可以通过主机地址进行查看，具体步骤如下：1、首先登陆nameserver主机地址。2、执行以下命令（shmqadminconsumerProgress-gconsumeGroupNameeg：shmqadminconsumerProgress-gtest）查看。3、出来的结果BrokerOffset为生产的条数，ConsumerOffset为消费的条数，Diff为堆积的条数。
RocketMQ是阿里巴巴开源的分布式消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。它里面有几个区别于标准消息中件间的概念，如Group、Topic、Queue等。系统组成则由Procer、Consumer、Broker、NameServer等。