ActiveMQ;RabbitMQ;ZeroMQ

中间件类型:

  • Embedded middleware: As the name suggests, this typeof middleware handles embedded applications (software or firmware)。
  • RPC middleware: RPC (Remote Procedure Call)middleware communicates with applications using calls。
  • Object request broker: Here, applications can sendand receive objects, like CORBA。
  • SQL-oriented data access middleware: Primarily meantfor database-related applications, this class of middleware sits betweenapplications that communicate with databases, like JDBC,ODBC。
  • Message-oriented middleware(MOM): Message-oriented middleware mediate thecommunication or messages, between applications。

常见的三款开源消息中间件:

ActiveMQ

ActiveMQ是Apache开发的开源消息中间件,Java实现,基于JMS1.1及J2EE 1.4规范。

RabbitMQ

RabbitMQ 是由 LShift 提供的一个 Advanced MessageQueuing Protocol (AMQP) 的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 写成,因此也是继承了这些优点。

ZeroMQ

ZeroMQ是由iMatix公司使用C语言开发的高性能消息中间件,是对socket的封装,在发送端缓存消息。

ActiveMQ架构

  • Queue Region是P2P消息模型,Topic Region是Publish/Subscribe模型。
  • Connectors负责消息通信,支持OpenWire, Stomp,REST,WS Notification, XMPP等协议。
  • Network Services负责存储转发,集群等服务。
  • Message Store负责消息的存储,支持内存、文件、内嵌数据库和外部数据库等四种消息持久化方式。

ActiveMQ特点

支持多语言:Java, C, C++,C#, Ruby, Perl, Python, PHP

消息模型:

Point to Point
Publish/Subscribe

协议支持情况:

支持OpenWire,Stomp,REST,WS Notification,XMPP。
对于python仅支持Stomp 协议。
不支持AMQP协议。
支持STOMP 1.0,不支持STOMP 1.1。 

支持Spring,可以很容易集成到Spring,并用Spring脚本配置。

支持Clustering built-in with autodiscovery,可以互相自动发

有Apache的支持,持续发展的优势明显。

支持Python的clients,都是很微小的开源项目,编程较复杂,不灵活:

Pyactivemq——基本已经不在维护,活跃度为低。
stomppy——推荐使用,rhel还有相应的rpm包,活跃度为中。 

需要消息服务器存储转发消息。

消息延时是10ms级别。

RabbitMQ架构

  • RabbitMQ包括虚拟主机(virtualhost),交换机(exchange),队列(queue)和绑定(binding)四个概念。
  • virtualhost:持有一组exchange、queue及bingding,可以做权限控制。
  • Queue:存放消息,由consumer建立,并绑定到Exchange。
  • Exchange:根据绑定的规则进行消息转发。
  • Binding:绑定规则。

RabbitMQ特点

  1. AMQP协议的开源实现,使用Erlang编写,维护时有语言障碍。
  2. 通过plugin完全支持STOMP 协议。
  3. 有Vmware的支持,RabbitMQ在云计算领域应该会有更多的特殊支持,架构会更适合云应用。
  4. 有SpringSource的商业支持,包括技术支持,培训。
  5. 支持持久化,不过只能使用它自己的数据库,不能使用mysql等。
  6. Python客户端是pika,编程灵活简单;java的客户端编程灵活简单
  7. 需要消息服务器存储转发消息。
  8. 消息延时是10ms级别。

ActiveMQRabbitMQ性能测试对比

持久化性能对比

非持久化性能对比

ZerorMQ特点

  • 是对socket的封装与扩展,API和socket编程的方式基本一致,支持请求-响应、Publish/Subscribe等消息模式。
  • 仅支持异步I/O,为了提高性能通过新建的线程发送消息。
  • 不需要单独的消息服务器来存储转发消息,重点放在消息的传输上,性能高于TCP。
  • 支持C, C++, Java,Python等20多种语言。Java的开发包是jzmq,python的开发包是pyzmq。
  • 消息延时是微秒级别。
  • 由imatix开发,并可以提供支持与培训。 imatix 是AMQP协议最初的creator,并开发了开源的OpenAMQ ,但是在2010年imatix 宣布iMatix to drop OpenAMQ support by 2011, AMQP it now believes it is “fundamentally flawed and unfixable”。目前主要将精力集中到ZeroMQ。

zeroMQ——摘自zguide

  • Itturns out that building reusable messaging systems is really difficult, whichis why few FOSS projects ever tried, and why commercial messaging products arecomplex, expensive, inflexible, and brittle. In 2006 iMatix designed AMQP whichstarted to give FOSS developers perhaps the first reusable recipe for amessaging system. AMQP works better than many other designs butremains relatively complex, expensive, and brittle.It takes weeks to learn to use, and months to create stable architectures thatdon‘t crash when things get hairy.
  • Mostmessaging projects, like AMQP, that try to solve this long list of problems ina reusable way do so by inventing a new concept, the "broker", thatdoes addressing, routing, and queuing. This results in a client-server protocolor a set of APIs on top of some undocumented protocol, that let applicationsspeak to this broker. Brokers are an excellent thing in reducing the complexityof large networks. But addingbroker-based messaging to a product like Zookeeper would make it worse, notbetter. It would mean adding an additional big box, and a new single point offailure. A broker rapidly becomes a bottleneck and a new risk to manage. Ifthe software supports it, we can add a second, third, fourth broker and makesome fail-over scheme. People do this. It creates more moving pieces, more complexity,more things to break.
  • Anda broker-centric set-up needs its own operations team. You literally need towatch the brokers day and night, and beat them with a stick when they startmisbehaving. You need boxes, and you need backup boxes, and you need people tomanage those boxes. It is only worth doing for large applications with manymoving pieces, built by several teams of people, over several years.
  • Sosmall to medium application developers are trapped. Either they avoid networkprogramming, and make monolithic applications that do not scale. Or they jumpinto network programming and make brittle, complex applications that are hardto maintain. Or they bet on a messaging product, and end up with scalableapplications that depend on expensive, easily broken technology. There has beenno really good choice, which is maybe why messaging is largely stuck in thelast century and stirs strong emotions. Negative ones for users, gleeful joyfor those selling support and licenses.
  ActiveMQ RabbitMQ ZeroMQ
遵循规范 JMS1.1及J2EE 1.4 AMPQ ---
架构模型 消息代理架构Broker 消息代理架构Broker C/S架构
实现语言 Java Erlang C/C++
支持消息协议 Stomp AMPQ、Stomp等 ---
主要推动力量 Apache、Redhat Lshift、Vmware、SpringSource iMatix
支持编程语言 C,Java,Python C,Java,Python C,Java,Python
编程复杂度 复杂 简单 中等
持久化 支持 支持,不支持第三方数据库 发送端缓存
性能 Normal Normal High
内存使用率 High High Normal

 

时间: 2024-10-24 11:12:43

ActiveMQ;RabbitMQ;ZeroMQ的相关文章

Java消息队列总结只需一篇解决ActiveMQ、RabbitMQ、ZeroMQ、Kafka

一.消息队列概述 消息队列中间件是分布式系统中重要的组件,主要解决应用解耦,异步消息,流量削锋等问题,实现高性能,高可用,可伸缩和最终一致性架构.目前使用较多的消息队列有ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ 二.消息队列应用场景 以下介绍消息队列在实际应用中常用的使用场景.异步处理,应用解耦,流量削锋和消息通讯四个场景. 2.1异步处理 场景说明:用户注册后,需要发注册邮件和注册短信.传统的做法有两种 1.串行的方式:2.并行方式 a.串行

转载:消息队列软件产品大比拼(MSMQ、ActiveMQ、RabbitMQ、ZeroMQ)

转载:http://www.cnblogs.com/amityat/archive/2011/08/31/2160293.html

RabbitMQ,Apache的ActiveMQ,阿里RocketMQ,Kafka,ZeroMQ,MetaMQ,Redis也可实现消息队列,RabbitMQ的应用场景以及基本原理介绍,RabbitMQ基础知识详解,RabbitMQ布曙

消息队列及常见消息队列介绍 2017-10-10 09:35操作系统/客户端/人脸识别 一.消息队列(MQ)概述 消息队列(Message Queue),是分布式系统中重要的组件,其通用的使用场景可以简单地描述为: 当不需要立即获得结果,但是并发量又需要进行控制的时候,差不多就是需要使用消息队列的时候. 消息队列主要解决了应用耦合.异步处理.流量削锋等问题. 当前使用较多的消息队列有RabbitMQ.RocketMQ.ActiveMQ.Kafka.ZeroMQ.MetaMq等,而部分数据库如Re

activemq、rabbitmq、kafka原理和比较

一.activemq 虽然是java写的消息队列,但是提供Java, C, C++, C#, Ruby, Perl, Python, PHP各种客户端,所以语言上是没什么问题的.配置和使用,基本上是java xml这一套.同时对jms.spring之类的支持很友好. 而且因为是Java写的,所以可以作为一个jar包,放到java项目里,用代码启动和配置,这个对于java开发者而言是不是相当爽?毕竟还是有些场景,需要我们把队列放到自己项目内部,随项目启动而启动的.而且,还可以类似拓展tomcat一

Kafka、ActiveMQ、RabbitMQ、RocketMQ 有什么优缺点?

面试题 1.为什么使用消息队列? 2.消息队列有什么优点和缺点? 3.Kafka.ActiveMQ.RabbitMQ.RocketMQ 都有什么区别,以及适合哪些场景? 面试官心理分析 其实面试官主要是想看看: 第一,你知不知道你们系统里为什么要用消息队列这个东西?不少候选人,说自己项目里用了 Redis.MQ,但是其实他并不知道自己为什么要用这个东西.其实说白了,就是为了用而用,或者是别人设计的架构,他从头到尾都没思考过.没有对自己的架构问过为什么的人,一定是平时没有思考的人,面试官对这类候选

控件--ComboBox;RadionButton;Timer;DataGridView

ComboBox:组合框---属性: Text:选中的值 Items:组合框中的项 Add:添加单个的值 AddRange:添加多个的值 SelectedIndex:索引值 SelectedValue:隐藏值 DropDownStyle:下拉框样式 Remove:删除 Clear:清除 例: //选中文本框的值 var txt=this.ComboBox.Text; //添加单个的值 this.ComboBox.Add("小黑"); //添加多个的值 string[]strs={&qu

DNS各种基本配置(正向解析区域、反向解析区域;主/从;子域;基本安全控制)

DNS服务器所提供的服务是完成将主机名和转换为IP地址的工作.为什么需要将主机名转换为IP地址的工作呢?这是因为,当网络上的一台客户机访问某一服务器上的资源时,用户在浏览器地址栏中输入的是人类便于识记的主机名和域名.而网络上的计算机之间实现连接却是通过每台计算机在网络中拥有的惟一的IP地址来完成的,这样就需要在用户容易记忆的地址和计算机能够识别的地址之间有一个解析,DNS服务器便充当了地址解析的重要角色. 域名严格意义上的称呼为FQDN(Full Qualified Domain Name).域

正向解析区域、反向解析区域;主/从;子域;基本安全控制

  正向解析区域.反向解析区域:主/从:子域:基本安全控制 一.背景: DNS服务器所提供的服务是完成将主机名和转换为IP地址的工作.为什么需要将主机名转换为IP地址的工作呢?这是因为,当网络上的一台客户机访问某一服务器上的资源时,用户在浏览器地址栏中输入的是人类便于识记的主机名和域名.而网络上的计算机之间实现连接却是通过每台计算机在网络中拥有的惟一的IP地址来完成的,这样就需要在用户容易记忆的地址和计算机能够识别的地址之间有一个解析,DNS服务器便充当了地址解析的重要角色. 正向解析就是通过域

hadoop学习;datajoin;chain签名;combine()

hadoop有种简化机制来管理job和control的非线性作业之间的依赖,job对象时mapreduce的表现形式.job对象的实例化可通过传递一个jobconf对象到作业的构造函数中来实现. x.addDeopendingJob(y)意味着x在y完成之前不会启动. 鉴于job对象存储着配置和依赖信息,jobcontrol对象会负责监管作业的执行,通过addjob(),你可以为jobcontrol添加作业,当所有作业和依赖关系添加完成后,调用jobcontrol的run()方法,生成一个线程提