常见消息中间件描述

简介: 常见消息中间件描述

1 ActiveMQ
ActiveMQ 是 Apache 下的一个子项目,使用完全支持 JMS1.1 和 J2EE1.4 规范的 JMS Provider 实现,少量代码就可以高效地实现高级应用场景,并且支持可插拔的传输协议,如:in-VM, TCP, SSL, NIO, UDP, multicast, JGroups and JXTA transports。

ActiveMQ 支持常用的多种语言客户端如 C++、Java、.Net,、Python、 Php、 Ruby 等。

现在的 ActiveMQ 分为两个版本:

ActiveMQ Classic
ActiveMQ Artemis
这里的 ActiveMQ Classic 就是原来的 ActiveMQ,而 ActiveMQ Artemis 是在 RedHat 捐赠的 HornetQ 服务器代码的基础上开发的,两者代码完全不同,后者支持 JMS2.0,使用基于 Netty 的异步 IO,大大提升了性能,更为神奇的是,后者不仅支持 JMS 协议,还支持 AMQP 协议、STOMP 以及 MQTT,可以说后者的玩法相当丰富。

因此大家在使用时,建议直接选择 ActiveMQ Artemis。

2 RabbitMQ
RabbitMQ 算是 AMQP 体系下最为重要的产品了,它基于 Erlang 语言开发实现,估计很多人被 RabbitMQ 的安装折磨过,松哥建议安装 RabbitMQ 直接用 Docker,省心省力(公号后台回复 docker 有教程)。

RabbitMQ 支持 AMQP、XMPP、SMTP、STOMP 等多种协议,功能强大,适用于企业级开发。

关于 RabbitMQ,松哥最近发了十来篇教程了,这里就不再啰嗦了。

2.3 RocketMQ
RocketMQ 是阿里开源的一款分布式消息中间件,原名 Metaq,从 3.0 版本开始改名为 RocketMQ,是阿里参照 Kafka 设计思想使用 Java 语言实现的一套 MQ。RocketMQ 将阿里内部多款 MQ 产品(Notify、Metaq)进行整合,只维护核心功能,去除了所有其他运行时依赖,保证核心功能最简化,在此基础上配合阿里上述其他开源产品实现不同场景下 MQ 的架构,目前主要用于订单交易系统。

RocketMQ 具有以下特点:

保证严格的消息顺序。
提供针对消息的过滤功能。
提供丰富的消息拉取模式。
高效的订阅者水平扩展能力。
实时的消息订阅机制。
亿级消息堆积能力
对于 Java 工程师而言,这也是一种经常会用到的 MQ。

4 Kafka
Kafka 是 Apache 下的一个开源流处理平台,由 Scala 和 Java 编写。Kafka 是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者在网站中的所有动作(网页浏览,搜索和其他用户的行动)流数据。Kafka 的目的是通过 Hadoop 的并行加载机制来统一线上和离线的消息处理,也是为了通过集群来提供实时的消息。

Kafka 具有以下特性:

快速持久化:通过磁盘顺序读写与零拷贝机制,可以在O(1)的系统开销下进行消息持久化。
高吞吐:在一台普通的服务器上既可以达到 10W/s 的吞吐速率。
高堆积:支持 topic 下消费者较长时间离线,消息堆积量大。
完全的分布式系统:Broker、Producer、Consumer 都原生自动支持分布式,通过 Zookeeper 可以自动实现更加复杂的负载均衡。
支持 Hadoop 数据并行加载。
大数据开发中大家可能会经常接触 Kafka,Java 开发中也会接触,但是相对来说可能接触的少一些。

5 ZeroMQ
ZeroMQ 号称最快的消息队列系统,它专门为高吞吐量/低延迟的场景开发,在金融界的应用中经常使用,偏重于实时数据通信场景。ZeroMQ 不是单独的服务,而是一个嵌入式库,它封装了网络通信、消息队列、线程调度等功能,向上层提供简洁的 API,应用程序通过加载库文件,调用 API 函数来实现高性能网络通信。

ZeroMQ 的特性:

无锁的队列模型:对于跨线程间的交互(用户端和 session)之间的数据交换通道 pipe,采用无锁的队列算法 CAS,在 pipe 的两端注册有异步事件,在读或者写消息到 pipe 时,会自动触发读写事件。
批量处理的算法:对于批量的消息,进行了适应性的优化,可以批量的接收和发送消息。
多核下的线程绑定,无须 CPU 切换:区别于传统的多线程并发模式,信号量或者临界区,ZeroMQ 充分利用多核的优势,每个核绑定运行一个工作者线程,避免多线程之间的 CPU 切换开销。
6 其他
另外还有如 Redis 也能做消息队列,松哥之前也发过文章和大家介绍用 Redis 做普通消息队列和延迟消息队列

相关文章
|
监控 Shell Go
如何自己写一个telegraf的插件
之前有个特殊需求要自己搞一个telegraf的插件,就顺手写了这个小指南,go初学者级别吧
2001 0
|
2月前
|
人工智能 安全 Shell
让 DeepSeek Harness 安全读懂 Git:dsh-plugin-git-inspect
一个面向 DeepSeek Harness 的只读 Git 检查插件,提供状态、差异、提交、冲突、blame、stash 和 worktree 等 10 个工具,并限制命令范围、输出大小和执行时间。
|
6月前
|
编解码 自然语言处理 文字识别
LLaDA2.0-Uni 开源: 打破 AR 桎梏,dLLM定义原生多模态统一新范式
LLaDA2.0-Uni是全球首个开源的多模态MoE离散扩散大模型(dLLM),以16B参数统一实现图像理解、生成与编辑。突破性采用全离散扩散建模,摆脱自回归依赖,支持并行解码与任意分辨率;语义视觉Token+定制Diffusion Decoder,8步即出高质量图。已在21项基准登顶,全面开源。
910 1
LLaDA2.0-Uni 开源: 打破 AR 桎梏,dLLM定义原生多模态统一新范式
|
4月前
|
人工智能 开发框架 自然语言处理
AI智能体的开发与上线
本文系统梳理AI智能体从构想到上线的六阶段非线性工程:需求界定、技术选型、能力组装、效果评测、灰度发布、持续迭代。覆盖提示词设计、知识库挂载、插件集成、安全测试与闭环优化,助力高效落地合规智能体。(239字)
|
物联网 Java API
什么是智慧校园电子班牌系统?如何与学校现有系统对接?
智慧校园电子班牌系统是教育信息化的重要工具,集校园管理、家校互动、教学辅助于一体。它支持信息展示、智能考勤、家校留言、教学互动等功能,提升校园管理效率与教学质量。系统通过RESTful API、WebSocket等接口,与学校教务系统、一卡通、安防系统等无缝对接,实现数据实时同步与统一管理。模块化设计便于集成,保障信息互联互通,助力智慧校园建设。
898 6
|
7月前
|
安全 Go API
Go 1.26 go fix 实战:一键现代化你的Go代码
2026年Go 1.26重磅升级`go fix`:从静态补丁工具跃升为智能重构引擎!支持全项目扫描、自动适配`errors.AsType`/`io.ReadAll`等新特性,提升性能与类型安全。本文带你三步上手、避坑实战,轻松实现代码现代化。(239字)
851 10
|
7月前
|
SQL 关系型数据库 MySQL
击穿 MySQL 事务隔离级别:底层实现原理 + 生产级架构选型避坑指南
本文深度解析MySQL事务隔离级别,从SQL标准定义出发,结合InnoDB底层的MVCC、undo log、Read View与锁机制,详解脏读、不可重复读、幻读三大异常及4种隔离级别的实现差异,辅以可复现SQL示例与Spring Boot实战代码,提供生产环境选型指南与避坑方案。
490 1
|
8月前
|
SQL XML JSON
Notepad++高效排版技巧:从代码到文本的全方位优化指南
本文详解Notepad++高效文本处理技巧:列模式编辑、正则替换(如清理空行/格式化日期)、宏录制自动化、核心插件(JSON Viewer/TextFX)及多文件批量处理,助程序员与数据工作者大幅提升效率。(239字)
1144 3
|
缓存 数据库连接 数据库
缓存三剑客(穿透、击穿、雪崩)
缓存穿透指查询数据库和缓存中都不存在的数据,导致请求直接冲击数据库。解决方案包括缓存空对象和布隆过滤器。缓存击穿是大量请求访问同一个失效的热点数据,使数据库瞬间压力剧增,解决方法有提前预热、设置永不过期、加锁限流等。缓存雪崩是大量key同时失效,导致所有请求直达数据库,可通过引入随机过期时间缓解。三者分别对应单点爆破、全面崩塌等问题,需根据场景选择合适策略优化系统性能与稳定性。
804 0
|
10月前
|
canal 缓存 关系型数据库
微服务原理篇(Canal-Redis)
本文介绍了ES索引同步的常见方案,重点讲解Canal+MQ数据同步机制。通过解析MySQL的binlog日志,Canal模拟slave伪装接入主库,实现增量数据捕获,并结合RabbitMQ保证消息顺序性地同步至Elasticsearch。同时探讨了缓存一致性问题,提出使用分布式锁(如Redis)控制并发写操作,避免双写不一致。还涵盖Redis持久化、集群模式、过期淘汰策略及缓存三剑客(穿透、雪崩、击穿)的解决方案,系统梳理了高并发场景下的数据同步与缓存保障技术体系。
1152 0
 微服务原理篇(Canal-Redis)

热门文章

最新文章