了解ActiveMQ、RabbitMQ、RocketMQ和Kafka的特点

ActiveMQ

ActiveMQ是一种基于JMS（Java消息服务）规范的消息中间件，由Apache基金会开发和维护
核心组件和特点：

1. Broker（代理）：ActiveMQ的核心组件是Broker，它负责接收、存储和路由消息，可以配置为单个实例或者集群，提供高可用性和可扩展性。

2. Producer（生产者）和Consumer（消费者）：Producer负责发送消息，而Consumer负责接收和处理消息。

3. Destination（目的地）：目的地是消息的最终接收位置，可以是队列（Queue）或主题（Topic）。队列实现了点对点模式，每个消息只能被一个消费者接收；主题实现了发布-订阅模式，每个消息可以被多个消费者接收。

4. Message（消息）：消息是在生产者和消费者之间传递的数据单元。它包含了消息的内容、属性和元数据等信息。

5. Connector（连接器）：连接器是用于与其他系统或协议进行集成的组件，如JMS、REST、AMQP等。

RabbitMQ

RabbitMQ是一种开源的AMQP（高级消息队列协议）消息中间件，使用Erlang语言编写，最早于2007年发布，由Rabbit Technologies Ltd.开发，现在是Pivotal Software的一部分。

核心组件：

1. 生产者（Producer）：生产者是消息的发送方，它负责创建并发送消息到RabbitMQ的消息队列。生产者将消息发送到交换机，并指定一个路由键（Routing Key）来决定消息的路由方式。

2. 消息队列（Message Queue）：用于存储消息，以便消费者可以按需从队列中获取并处理消息，消息队列采用先进先出（FIFO）的原则，确保消息按照顺序进行处理。

3. 消费者（Consumer）：消费者是消息的接收方，它负责从消息队列中获取消息，并进行相应的处理。消费者可以订阅一个或多个队列，以接收特定类型的消息，并对消息进行业务逻辑的处理。

4. 交换机（Exchange）：交换机是消息的分发中心。它接收来自生产者的消息，并根据预定义的规则（如路由键、绑定等）将消息路由到一个或多个消息队列中。

RocketMQ

RocketMQ是由阿里巴巴开发的分布式消息中间件（Java语言），最早于2012年发布。

核心组件：

1. 生产者（Producer）：负责产生消息并发送给RocketMQ的消息队列。生产者通过发送消息到指定的Topic（主题）来进行消息的发布。

2. 消费者（Consumer）：从RocketMQ的消息队列中获取消息并进行处理，消费者可以按照一定的规则订阅感兴趣的Topic，并接收该Topic下的消息进行消费。

3. 消息队列（Message Queue）：用于存储消息的缓冲区。消息队列将生产者发送的消息进行存储，并按照一定的规则进行分发给消费者。

4. 主题（Topic）：主题是消息的逻辑分类，一个主题可以对应一个或多个消息队列，生产者将消息发送到指定的主题，而消费者则订阅感兴趣的主题来接收消息。

5. 订阅（Subscription）：消费者通过订阅特定的主题来接收该主题下的消息，订阅可以按照标签（Tag）或表达式（Expression）进行过滤，以满足不同的消费需求。

Kafka

Kafka是一种分布式流处理平台和消息中间件（Scala语言编写），最早由LinkedIn公司开发，2011年LinkedIn将Kafka开源，并将其交给Apache软件基金会进行管理。

核心组件：

1. 主题（Topic）：主题是消息的逻辑分类，生产者将消息发送到特定的主题，消费者订阅并从主题中读取消息。

2. 分区（Partition）：主题可以被分成多个分区，每个分区是消息的有序序列，分区允许Kafka对消息进行水平扩展和并行处理。

3. 生产者（Producer）：生产者负责将消息发布到指定主题，生产者可以选择将消息发送到特定的分区，也可以让Kafka根据指定的分区策略自动选择分区。

4. 消费者（Consumer）：消费者从指定的主题订阅消息，并按照一定的顺序消费消息，消费者可以以不同的消费组（Consumer Group）进行组织，每个消费组都可以独立地消费消息。

5. 代理服务器（Broker）：代理服务器是Kafka集群中的节点，负责存储和管理消息，每个分区都会在集群中的多个代理服务器之间进行复制，以提供高可用性和容错性。

6. ZooKeeper：ZooKeeper是Kafka使用的协调服务，用于管理和协调Kafka集群的各个组件，它负责存储集群的元数据、监控集群状态以及进行故障恢复等工作。

特点对比和总结

特点	RabbitMQ	ActiveMQ	RocketMQ	Kafka
公司	Pivotal Software	Apache	Alibaba	Apache
开发语言	Erlang	Java	Java	Scala
协议支持	AMQP，XMPP，SMTP，STOMP	OpenWire,STOMP，REST,XMPP,AMQP	RocketMQ协议	Kafka协议
可用性	高	一般	高	高
单机吞吐量	一般	差	高	非常高
消息延迟	微秒级	毫秒级	毫秒级	毫秒以内
消息可靠性	高	一般	高	一般

追求可用性：Kafka、 RocketMQ 、RabbitMQ
追求可靠性：RabbitMQ、RocketMQ
追求吞吐能力：RocketMQ、Kafka
追求消息低延迟：RabbitMQ、Kafka