了解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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.xdnf.cn/news/145988.html

如若内容造成侵权/违法违规/事实不符,请联系一条长河网进行投诉反馈,一经查实,立即删除!

相关文章

Vuex状态管理

一、Vuex简介&安装 简介 vuex是使用vue中必不可少的一部分,基于父子、兄弟组件,我们传值可能会很方便,但是如果是没有关联的组件之间要使用同一组数据,就显得很无能为力,那么vuex就很好的解决了我们这种问题&…

【数据结构】外部排序、多路平衡归并与败者树、置换-选择排序(生成初始归并段)、最佳归并树算法

目录 1、外部排序 1.1 基本概念 1.2 方法 2、多路平衡归并与败者树 2.1 K路平衡归并 2.2 败者树 3、置换-选择排序(生成初始归并段)​编辑 4、最佳归并树 4.1 理论基础​编辑 4.2 构造方法 ​编辑 5、各种排序算法的性质 1、外部排序 1.1 基本概…

简易磁盘自动监控服务

本文旨在利用crontab定时任务(脚本请参考附件)来监控单个服务节点上所有磁盘使用情况,一旦超过既定阈值则会通过邮件形式告警相关利益人及时介入处理。 1. 开启SMTP服务 为了能够成功接收告警信息,需要邮件接收客户都安开启SMTP服务。简要流程请参考下…

数字孪生智慧能源:风光储一体化能源中心

自“双碳”目标提出以来,我国能源产业不断朝着清洁低碳化、绿色化的方向发展。其中,风能、太阳能等可再生能源在促进全球能源可持续发展、共建清洁美丽世界中被寄予厚望。风能、太阳能具有波动性、间歇性、随机性等特点,主要通过转化为电能再…

中国逐年干燥度指数数据集

简介: 中国逐年干燥度指数,空间分辨率为1km,时间为1901-2022,为比值,没有单位。该数据集是基于中国1km逐月潜在蒸散发(PET)和降水量(PRE)采用比值法计算式得到&#xff…

Go_原子操作和锁

原子操作和锁 本文先探究并发问题,再探究锁和原子操作解决问题的方式,最后进行对比。 并发问题 首先,我们看一下程序 num该程序表面看上去一步就可以运行完成,但是实际上,在计算机中是分三步运行的,如下…

PHP 二手物品交易网站系统mysql数据库web结构apache计算机软件工程网页wamp

一、源码特点 PHP 二手物品交易网站系统是一套完善的web设计系统,对理解php编程开发语言有帮助,系统具有完整的源代码和数据库,系统主要采用B/S模式开发。 代码下载 https://download.csdn.net/download/qq_41221322/88385559 二、功能介…

分析各种表达式求值过程

目录 算术运算与赋值 编译器常用的两种优化方案 常量传播 常量折叠 加法 Debug编译选项组下编译后的汇编代码分析 Release开启02执行效率优先 减法 Release版下优化和加法一致,不再赘述 乘法 除法 算术结果溢出 自增和自减 关系运算与逻辑运算 JCC指…

What is an HTTP Flood DDoS attack?

HTTP 洪水攻击是一种针对 Web 和应用程序服务器的第 7 层分布式拒绝服务 (DDoS) 攻击。HTTP 洪水攻击通过使用 HTTP GET 或 HTTP POST 请求执行 DDoS 攻击。这些请求是有效的,并且针对可用资源,因此很难防范 HTTP 洪水攻击。 匿名…

你熟悉Docker吗?

你熟悉Docker吗? 文章目录 你熟悉Docker吗?快速入门Docker安装1.卸载旧版2.配置Docker的yum库3.安装Docker4.启动和校验5.配置镜像加速5.1.注册阿里云账号5.2.开通镜像服务5.3.配置镜像加速 部署MySQL镜像和容器命令解读 Docker基础常用命令数据卷数据卷…

在SpringBoot中利用Redis实现互斥锁

在SpringBoot中利用Redis实现互斥锁 基本知识 前提条件,有一个能够在Springboot中使用Redis的项目,或者能够直接开也行 为什么要实现互斥锁:当我们利用Redis存储热点数据时,突然就过期失效或者被删除了,导致大量请求同…

Vue以及整合ElementUI

初始化vue项目 #vue 脚手架使用 webpack 模板初始化一个 appname 项目 vue init webpack appname启动 vue 项目 #项目的 package.json 中有 scripts,代表我们能运行的命令 npm start npm run dev #启动项目 npm run build:将项目打包项目结构 运行流程…

顺序表(7.24)

1.线性表 线性表 ( linear list ) 是 n 个具有相同特性的数据元素的有限序列。 线性表是一种在实际中广泛使用的数据结构,常见的线性表:顺序表、链表、栈、队列、字符串... 线性表在逻辑上是线性结构,也就说是连续的一…

ssm+vue的4S店预约保养管理系统(有报告)。Javaee项目,ssm vue前后端分离项目。

演示视频: ssmvue的4S店预约保养管理系统(有报告)。Javaee项目,ssm vue前后端分离项目。 项目介绍: 采用M(model)V(view)C(controller)三层体系结…

aarch64 平台 musl gcc 工具链手动编译方法

目标 手动编译一个 aarch64 平台的 musl gcc 工具链 musl libc 与 glibc、uclibc 等,都是 标准C 库, musl libc 是基于系统调用之上的 标准C 库,也就是用户态的 标准C 库。 musl libc 轻量、开源、免费,是一些 操作系统的选择,当前 Lite-OS 与 RT-Smart 等均采用自制的 mu…

【网络原理】初始网络,了解概念

文章目录 1. 网络通信1.1 局域网LAN1.2 广域网WAN 2. 基础概念2.1 IP2.2 端口号 3. 认识协议4. 五元组5. 协议分层5.1 分层的作用5.2 OSI七层模型5.3 TCP/IP五层(四层)模型 6. 封装和分用 1. 网络通信 计算机与计算机之间是互相独立,是独立模…

配置pytorchGPU虚拟环境-python3.7

cuda版本的pytorch包下载地址戳这里 winR->输入cmd->输nvcc -V回车 cuda 11.0 输入以下命令来查找 CUDA 的安装路径: Windows: where nvcc 输入以下命令来查找 cuDNN 的版本号: Windows: where cudnn* cuDNN 8.0 本机安装的是cuda 11.0&…

Python海洋专题五之水深地形图海岸填充

Python海洋专题五之水深地形图海岸填充 海洋与大气科学 上期读取nc水深文件,并出图 但是存在一些不完美,本期修饰 本期内容 障眼法:把大于零的数据填充为陆地的灰色; 把等于零的数据画等深线为陆地和海洋的分界线!…

YOLOv8改进算法之添加CA注意力机制

1. CA注意力机制 CA(Coordinate Attention)注意力机制是一种用于加强深度学习模型对输入数据的空间结构理解的注意力机制。CA 注意力机制的核心思想是引入坐标信息,以便模型可以更好地理解不同位置之间的关系。如下图: 1. 输入特…

C语言数据结构之排序整合与比较(冒泡,选择,插入,希尔,堆排序,快排及改良,归并排序,计数排序)

前言:排序作为数据结构中的一个重要模块,重要性不言而寓,我们的讲法为下理论掌握大致的算法结构,再上代码及代码讲解,助你一臂之力。 一,冒泡 冒泡排序应该是大家学习以来第一个认识的排序方法&#xff0…