• 了解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集群的各个组件,它负责存储集群的元数据、监控集群状态以及进行故障恢复等工作。

    特点对比和总结

    特点RabbitMQActiveMQRocketMQKafka
    公司Pivotal SoftwareApacheAlibabaApache
    开发语言ErlangJavaJavaScala
    协议支持AMQP,XMPP,SMTP,STOMPOpenWire,STOMP,REST,XMPP,AMQPRocketMQ协议Kafka协议
    可用性一般
    单机吞吐量一般非常高
    消息延迟微秒级毫秒级毫秒级毫秒以内
    消息可靠性一般一般

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

  • 相关阅读:
    leetcode 刷题 log day 53
    DBeaver下载安装与使用
    TypeScript学习总结(一)
    巧用网络分析仪的校准
    【C++】C++的类型转换
    EDA程序设计--计时器设计
    【unity】【VR】如何给Character添加自由的手臂动作
    【C/C++笔试练习】二维数组、二维数组的访问,解引用,地址计算、计算糖果、进制转换
    Spring Authorization Server入门 (十七) Vue项目使用授权码模式对接认证服务
    【数据结构与算法】总结篇:中缀表达式转后缀表达式 与 表达式树
  • 原文地址:https://blog.csdn.net/DU9999999/article/details/133438486