当前位置： 首页 > news >正文

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

news 文章来源：https://blog.csdn.net/DU9999999/article/details/133438486 2024/10/30 23:15:34

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

相关文章：

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

ActiveMQ ActiveMQ是一种基于JMS（Java消息服务）规范的消息中间件，由Apache基金会开发和维护 核心组件和特点： Broker（代理）：ActiveMQ的核心组件是Broker，它负责接收、存储和路由消息…...

编程日记 2023/10/1 1:19:42

第七章 用户和组管理

7.1 Linux中的用户和组的分类 用户类别 超级用户（0） root 系统用户(1-999) 一般用户(1000-60000) 组类别 管理组 root 基本组（默认组/主组） 附加组（额外组） 7.2 用户管理 7.2.1 添加新用户 语法 useradd 【…...

编程日记 2023/10/1 1:18:41

给奶牛做直播之三

​一、前言 上一篇给牛奶做直播之二 主要讲用RTMP搭建点播服务器，整了半天直播还没上场，今天不讲太多理论的玩意，奶牛今天放假了也不出场，就由本人亲自上场来个直播首秀，见下图，如果有兴趣的话&#xff0…...

编程日记 2023/10/1 1:17:40

【Java 进阶篇】MySQL 数据控制语言（DCL）：管理用户权限

MySQL 是一个强大的关系型数据库管理系统，提供了丰富的功能和选项来管理数据库和用户。数据库管理员（DBA）通常使用数据控制语言（Data Control Language，简称 DCL）来管理用户的权限和访问。 本文将详细介绍…...

编程日记 2023/10/1 1:15:39

WPF 03

staticResource和dynamicResource的区别 首先看一个案例 MainWindow.xaml <Window x:Class"WpfDay03.MainWindow"xmlns"http://schemas.microsoft.com/winfx/2006/xaml/presentation"xmlns:x"http://schemas.microsoft.com/winfx/2006/xaml&quo…...

编程日记 2023/10/1 1:13:37

Android 使用kotlin+注解+反射+泛型实现MVP架构

一&#xff0c;MVP模式的定义 ①Model&#xff1a;用于存储数据。它负责处理领域逻辑以及与数据库或网络层的通信。 ②View&#xff1a;UI层&#xff0c;提供数据可视化界面&#xff0c;并跟踪用户的操作&#xff0c;以便通知presenter。 ③Presenter&#xff1a;从Model层获…...

编程日记 2023/10/1 1:12:36

数据结构——堆（C语言）

本篇会解决一下几个问题&#xff1a; 1.堆是什么&#xff1f; 2.如何形成一个堆&#xff1f; 3.堆的应用场景 堆是什么&#xff1f; 堆总是一颗完全二叉树堆的某个节点总是不大于或不小于父亲节点 如图&#xff0c;在小堆中&#xff0c;父亲节点总是小于孩子节点的。 如图&a…...

编程日记 2023/10/1 1:11:35

B058-SpringBoot

目录 springboot概念与作用入门案例springboot运行方式热部署配置文件Profile多环境支持整合测试-springboot-testSpringboot-web1.返回json数据2.返回页面&#xff08;模板技术&#xff09;thymeleaf1.导入thymeleaf依赖2.模板文件3.controller4.启动类 SSM整合1.导包2.项目目…...

编程日记 2023/10/1 1:10:34

龙迅LT9611UXC 2PORT MIPICSI/DSI转HDMI（2.0）转换器+音频，内置MCU

龙迅LT9611UXC 1.描述&#xff1a; LT9611UXC是一个高性能的MIPI DSI/CSI到HDMI2.0转换器。MIPI DSI/CSI输入具有可配置的单 端口或双端口&#xff0c;1高速时钟通道和1~4高速数据通道&#xff0c;最大2Gbps/通道&#xff0c;可支持高达16Gbps的总带 宽。LT9611UXC支持突发…...

编程日记 2023/10/1 1:06:30

STM32存储左右互搏 I2C总线读写FRAM MB85RC1M

STM32存储左右互搏 I2C总线读写FRAM MB85RC1M 在较低容量存储领域&#xff0c;除了EEPROM的使用&#xff0c;还有铁电存储器FRAM的使用&#xff0c;相对于EEPROM, 同样是非易失性存储单元&#xff0c;FRAM支持更高的访问速度&#xff0c; 其主要优点为没有EEPROM持续写操作跨页…...

编程日记 2023/10/1 1:05:30

1340. 跳跃游戏 V；2039. 网络空闲的时刻；2767. 将字符串分割为最少的美丽子字符串

1340. 跳跃游戏 V 核心思想&#xff1a;动态规划记忆化搜索。定义dfs(i)&#xff0c;表示从i开始最多可以访问多少个下标&#xff0c;然后统计往左跳和往右边跳的最大值&#xff0c;思路其实比较简单&#xff0c;但是代码我感觉还是不太好想。 2039. 网络空闲的时刻 核心思想…...

编程日记 2023/10/1 1:03:27

ElementUI之CUD+表单验证

目录 前言&#xff1a; 增删改查 表单验证 前言&#xff1a; 继上篇博客来写我们的增删改以及表单验证 增删改查 首先先定义接口 数据样式&#xff0c;我们可以去elementUI官网去copy我们喜欢的样式 <!-- 编辑窗体 --><el-dialog :title"title" :visib…...

编程日记 2023/10/1 1:02:27

Linux：nginx---web文件服务器

我这里使用的是centos7系统 nginx源码包安装 Linux&#xff1a;nginx基础搭建&#xff08;源码包&#xff09;_鲍海超-GNUBHCkalitarro的博客-CSDN博客https://blog.csdn.net/w14768855/article/details/131445878?ops_request_misc%257B%2522request%255Fid%2522%253A%25221…...

编程日记 2023/10/1 1:01:26

go 端口转发 代理V2 --chatGPT

问&#xff1a;broker(localPort, targetPort), 实现远程访问localPort的http代理转发到目标机器 gpt: 要实现一个简单的 HTTP 代理服务器&#xff0c;你可以使用 Go 的 net/http 包来处理 HTTP 请求和响应。以下是一个示例&#xff0c;演示如何创建一个 HTTP 代理服务器将本地…...

编程日记 2023/10/1 1:00:25

idea环境下如何打包可运行jar？

工作中有时候偶尔写一些工具类、小程序&#xff0c;可是java程序员制作一个可运行jar实在折腾&#xff0c;利用idea开发环境&#xff0c;可以快速打包自己的可运行jar。具体怎么操作呢&#xff1f; 创建一个空白的java项目并完成自己的程序开发 完成java代码&#xff1a; /**…...

编程日记 2023/10/1 0:59:24

基于FFmpeg的Android播放器

基于FFmpeg的Android播放器 文章目录 基于FFmpeg的Android播放器1. 前言2. 编译相关组件库3. 解码器4. 解码流程5. 音频输出6. 视频输出&#xff08;需要优化&#xff09; 1. 前言 FFmpeg是一个最有名的开源的编解码库&#xff0c;实现了通常的编解码逻辑。它还能够根据平台特…...

编程日记 2023/10/1 0:56:21

osgPBR(十五）镜面IBL--查看不同级别的HDR环境贴图

首先&#xff0c;设置可以使用Mipmap&#xff0c;启用三线性过滤&#xff0c;设置最大级别和最小级别 osg::ref_ptr<osg::TextureCubeMap> tcm new osg::TextureCubeMap; tcm->setTextureSize(128, 128);tcm->setFilter(osg::Texture::MIN_FILTER, osg::Texture:…...

编程日记 2023/10/1 0:55:20

Docker的学习记录

Docker是一个被广泛使用的开源容器引擎&#xff0c;基于Go语言&#xff0c;遵从Apache2.0协议开源。 docker的三个概念&#xff1a;容器、镜像和仓库。 镜像&#xff08;Image&#xff09;&#xff1a;镜像是Docker中的一个模板。通过 Docker镜像 来创建 Docker容器&#xff…...

编程日记 2023/10/1 0:52:17

Android Jetpack组件架构：ViewModel的原理

Android Jetpack组件架构&#xff1a;ViewModel的原理 导言 本篇文章是关于介绍ViewModel的&#xff0c;由于ViewModel的使用还是挺简单的&#xff0c;这里就不再介绍其的基本应用&#xff0c;我们主要来分析ViewModel的原理。 ViewModel的生命周期 众所周知&#xff0c;一般…...

编程日记 2023/10/1 0:50:14

数据分析（python）学习笔记1.0

《利用Python进行数据分析》（原书第2版） 《利用Python进行数据分析》（原书第2版） 《利用Python进行数据分析》（原书第2版） 社区和会议 除了网络搜索，科学、数据相关的Python邮件列表对于解决问题也非常有帮助。可以看看下列邮件列表： pydata：与数据分析和pandas相…...

编程日记 2023/10/1 0:48:13

SW免安装的toolbox只读问题

把SOLIDWORKSDATA 整体复制到另外的目录&#xff0c;然后这里设置目录位置。不然原始位置有只读属性...

编程日记 2023/10/1 0:45:10

nodejs在pdf中绘制表格

需求 之前我已经了解过如何在pdf模板中填写字段了 nodejs根据pdf模板填入中文数据并生成新的pdf文件https://blog.csdn.net/ArmadaDK/article/details/132456324 但是当我具体使用的时候&#xff0c;我发现我的模板里面有表格&#xff0c;表格的长度是不固定的&#xff0c;所…...

编程日记 2023/10/1 0:44:09

使用不同尺寸的传感器拍照时，怎么保证拍出同样视场范围的照片？

1、问题背景 使用竞品机做图像效果对比时&#xff0c;我们通常都会要求拍摄的照片要视场范围一致&#xff0c;这样才具有可比性。之前我会考虑用同样焦距、同样分辨率的设备去拍照对比就可以了&#xff0c;觉得相机的视场范围只由镜头焦距来决定。 但如果对于不同尺寸的传感器…...

编程日记 2023/10/1 0:40:06

01-工具篇-windows与linux文件共享

一般来说绝大部分PC上装的系统均是windows&#xff0c;为了开发linux程序&#xff0c;会在PC上安装一个Vmware的虚拟机&#xff0c;在虚拟机上安装ubuntu18.04&#xff0c;由于windows上的代码查看软件、浏览器&#xff0c;通信软件更全&#xff0c;我们想只用ubuntu进行编译&a…...

编程日记 2023/10/1 0:39:04

医疗实施-住院流程详解

住院就诊流程详解 1.病人入院登记2.病人进入病区3.医生操作病人4.医嘱录入与审核执行5. 医嘱收费前在对应业务系统的操作5.1.药物医嘱5.2.检查检验医嘱5.3.手术医嘱 6.住院医嘱费用的产生7. 医嘱收费后在对应业务系统的操作8. 病人出院 这篇文章是基于我的文章《医疗实施-住院就…...

编程日记 2023/10/1 0:38:03

本地连接服务器 jupyter notebook

本地连接服务器 jupyter notebook 一、前提工作二、服务器操作三、Windows 操作 一、前提工作 准备一台Linux云服务器新建一个用户&#xff0c;并切换到此用户安装 Anaconda 二、服务器操作 远程服务器上安装和配置 Jupyter Notebook&#xff1a; pip3 install jupyter接着…...

编程日记 2023/10/1 0:36:02

Android 使用Kotlin封装RecyclerView

文章目录 1.概述2.运行效果图3.代码实现3.1 扩展RecyclerView 3.2 扩展Adapter3.3 RecyclerView装饰绘制3.3.1 以图片实现分割线3.3.2 画网格线3.3.3空白的分割线3.3.4 不同方向上的分割线 3.4 使用方法 1.概述 在一个开源项目上看到了一个Android Kotlin版的RecyclerView封装…...

编程日记 2023/10/1 0:35:01

WPF 实现点击按钮跳转页面功能

方法1. 配置环境 首先添加prism依赖项&#xff0c;配置好所有文件。需要配置的有两个文件&#xff1a;App.xaml.cs和App.xaml App.xaml.cs using System.Data; using System.Linq; using System.Threading.Tasks; using System.Windows;namespace PrismDemo {/// <summa…...

编程日记 2023/10/1 0:34:00

关于http网络通信数据包封装的过程

当我们谈论网络通信时&#xff0c;数据在从源到目的地传输的过程中会通过多层网络协议。在每一层&#xff0c;都会添加一些头信息&#xff08;和有时尾信息&#xff09;来帮助处理和传输数据。这个过程被称为"封装"&#xff08;Encapsulation&#xff09;。简单来说&…...

编程日记 2023/10/1 0:30:57

关于RabbitMQ你了解多少？

关于RabbitMQ你了解多少&#xff1f; 文章目录 关于RabbitMQ你了解多少&#xff1f;基础篇同步和异步MQ技术选型介绍和安装数据隔离SpringAMQP快速入门Work queues交换机Fanout交换机Direct交换机Topic交换机 声明队列和交换机MQ消息转换器 高级篇消息可靠性问题发送者的可靠性…...

编程日记 2023/10/1 0:28:55

哪个网站做h5好/手游推广渠道平台

基于微信小程序的食堂订餐点餐管理系统项目简介项目获取开发环境项目技术运行截图项目简介 基于ssm框架管理前端使用vue&#xff0c;用户使用微信小程序的食堂订餐点餐小程序共分为三个角色&#xff1a;系统管理员、商家、用户 管理员角色包含以下功能&#xff1a; 首页展示、…...

编程日记 2024/10/30 20:02:53

热门视频素材/宁波网站seo诊断工具

在用eclipse开发时&#xff0c;经常遇到卡死的情况&#xff0c;其中一种就是右下角出现&#xff1a;“Remote System Explorer Operation”&#xff0c;解决方案如下&#xff1a; 第一步&#xff1a;Eclipse -> Preferences -> General -> Startup and Shutdown.不要勾…...

编程日记 2024/10/30 17:43:40

网站维护费用包括哪些/seo网站自动发布外链工具

分析 JUnit 框架源代码 理解 JUnit 测试框架实现原理和设计模式 文档选项打印本页 将此页作为电子邮件发送 级别&#xff1a; 中级 何 正华 , 软件工程师, IBM徐 晔 (yexucn.ibm.com ), 软件工程师, IBM, Software Group 2009 年 5 月 31 日 本文细致地描述了 JUnit 的代码实现…...

编程日记 2024/10/30 15:27:29

有道云笔记 wordpress/自己做网站

亲爱的《烈焰手游》玩家&#xff1a;您们好!感谢大家从《烈焰》手游的支持与厚爱!为了给大家提供更加优质的游戏环境&#xff0c;感受更多的游戏乐趣&#xff0c;提高游戏的可玩性和互动性&#xff0c;应广大玩家的需求&#xff0c;我们将对部分服进行合服操作&#xff0c;以下…...

编程日记 2024/10/30 15:11:15

长宁做手机网站建设/百度笔记排名优化

void CADOConn::CloseRecordset() { if(m_pRecordset->GetState()adStateOpen) //判断记录集状态是否为打开状态 { m_pRecordset->Close(); //关闭记录集 } }转载于:https://www.cnblogs.com/friendan/archive/2011/11/22/2838236.html...

编程日记 2024/10/30 11:25:50

泉州企业做网站/seo顾问合同

1.插件介绍 activate-power-mode插件。 根据Atom的插件activate-power-mode的效果移植到IDEA上。 效果如下图&#xff1a; 2.安装方式 第一种方式&#xff0c;是在IDEA上搜索插件进行安装&#xff0c;会适配当前IDEA的版本。 第二种安装方式是使用离线插件进行安装。 插件…...

编程日记 2024/10/30 9:56:53