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

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

news 2026/3/28 2:30:00

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

如何用FCEUX重温经典游戏？全场景部署指南

如何用FCEUX重温经典游戏&#xff1f;全场景部署指南 【免费下载链接】fceux FCEUX, a NES Emulator 项目地址: https://gitcode.com/gh_mirrors/fc/fceux 为什么选择FCEUX模拟器&#xff1f;&#x1f3ae; 在众多NES模拟器中&#xff0c;FCEUX凭借三大核心优势脱颖而出…...

编程新知 2026/3/28 2:20:51

棉花打包机的设计【说明书（论文）+CAD+solidworks】

棉花打包机作为农业机械化领域的关键设备&#xff0c;其核心作用在于将散状棉花高效压缩成标准化包型&#xff0c;以满足运输、仓储及后续加工的工艺需求。传统打包方式依赖人工或简单机械&#xff0c;存在效率低、包型不均、劳动强度大等问题&#xff0c;而现代棉花打包机通过…...

编程新知 2026/3/28 0:57:34

突破VMware限制：在非苹果硬件上构建macOS开发环境完全指南

突破VMware限制&#xff1a;在非苹果硬件上构建macOS开发环境完全指南 【免费下载链接】unlocker 项目地址: https://gitcode.com/gh_mirrors/unloc/unlocker 实现跨平台macOS体验&#xff1a;VMware Unlocker核心价值解析 当开发者需要在Windows或Linux工作站上构建m…...

编程新知 2026/3/28 0:21:23

MicroOS：Arduino轻量级任务调度内核详解

1. MicroOS&#xff1a;面向Arduino的轻量级任务管理内核概述MicroOS是一个专为Arduino平台设计的极简型实时任务管理器&#xff0c;其核心定位并非替代FreeRTOS或Zephyr等完整RTOS&#xff0c;而是填补Arduino原生loop()单线程模型在多任务调度、精确定时与事件解耦方面的空白…...

编程新知 2026/3/28 0:19:23

经典概率题：飞机座位分配问题（LeetCode 1227）超详细解析

一、题目背景与描述这是一道非常经典的概率与逻辑推理面试题&#xff0c;也是 LeetCode 第 1227 题「飞机座位分配概率」。题目描述有 n 位乘客即将登机&#xff0c;飞机正好有 n 个座位。第一位乘客的票丢了&#xff0c;他随机选一个座位坐下。剩下的乘客&#xff1a;如果自己…...

编程新知 2026/3/27 23:48:55

vLLM-v0.17.1详细步骤：vLLM + Triton Ensemble实现多模型协同推理

vLLM-v0.17.1详细步骤&#xff1a;vLLM Triton Ensemble实现多模型协同推理 1. vLLM框架简介 vLLM是一个专为大型语言模型(LLM)设计的高性能推理和服务库&#xff0c;以其出色的吞吐量和易用性著称。这个项目最初由加州大学伯克利分校的天空计算实验室开发&#xff0c;现在已…...

编程新知 2026/3/27 21:56:02

OpenClaw备份方案：GLM-4.7-Flash自动化任务容灾保护

OpenClaw备份方案&#xff1a;GLM-4.7-Flash自动化任务容灾保护 1. 为什么需要备份OpenClaw自动化任务 去年冬天&#xff0c;我的硬盘突然崩溃&#xff0c;导致辛苦配置的OpenClaw自动化任务全部丢失。那一刻我才意识到&#xff0c;当AI助手成为日常工作的"数字员工&quo…...

编程新知 2026/3/27 21:21:48

Win10下mitie安装失败：subprocess.CalledProcessError的深度排查与实战修复

1. 问题现象与初步分析 最近在Windows10系统上折腾MITIE这个自然语言处理工具包时&#xff0c;遇到了一个让人头疼的错误。当时按照常规流程&#xff0c;先下载了mitie的源码压缩包&#xff0c;解压后执行python setup.py install&#xff0c;结果命令行突然弹出一堆红色报错&a…...

编程新知 2026/3/27 21:07:45

OpenClaw量化对比：Qwen3.5-4B-Claude-4.6-Opus-Reasoning-Distilled-GGUF不同精度版本的自动化任务表现

OpenClaw量化对比&#xff1a;Qwen3.5-4B-Claude-4.6-Opus-Reasoning-Distilled-GGUF不同精度版本的自动化任务表现 1. 测试背景与实验设计 去年在开发一个自动化文档处理流程时&#xff0c;我发现OpenClaw的任务成功率与底层模型量化精度密切相关。当时使用Q8版本处理Excel文…...

编程新知 2026/3/27 20:37:37

Charticulator：突破传统桎梏的自定义数据可视化革新——从模板依赖到自由创作

Charticulator&#xff1a;突破传统桎梏的自定义数据可视化革新——从模板依赖到自由创作 【免费下载链接】charticulator Interactive Layout-Aware Construction of Bespoke Charts 项目地址: https://gitcode.com/gh_mirrors/ch/charticulator 数据可视化工具是否常常…...

编程新知 2026/3/27 20:05:06