消息队列入门(二)消息队列的开源实现

消息队列入门(二)消息队列的开源实现

关于AMQP

AMQP 是 Advanced Message Queuing Protocol,即高级消息队列协议。AMQP不是一个具体的消息队列实现,而 是一个标准化的消息中间件协议。目标是让不同语言,不同系统的应用互相通信,并提供一个简单统一的模型和编程接口。
目前主流的ActiveMQ和RabbitMQ都支持AMQP协议。

AMQP相关的角色和职责

Producer 消息生产者

一个给exchange发送消息的程序,发送方式大致是:它首先创建一个空消息,然后填上内容、路由KEY,最后发送给exchange

Routing Key 消息特征

一个字符串,exchange用之来决定应该该消息投递给哪个queue。(开始时queue已向exchange绑定它所关心消息的routingKey)

Exchange 交换器

接收来自producers的消息,并根据该消息的routingKey,将该消息投递到正确的queues

Binding 绑定操作

前期将queue所想要的消息特征告诉exchange。Exchange以后收到消息,就按照这个规则来投递

Queue 消息容器
在MQ server(实现为broker方式)里面的queue,持有Consumer想要的消息

Consumer 消息接收者
从MQ server得到想要的消息,它负责创建、主动订阅、共享、使用、破坏queue和binding

ActiveMQ

ActiveMQ 是Apache出品,目前非常流行的开源消息中间件。ActiveMQ 支持JMS规范,同样也支持AMQP协议。
在下面的博客里,将会较深入的学习ActiveMQ的设计和应用。

RabbitMQ

RabbitMQ 是由 LShift 提供的一个 Advanced Message Queuing Protocol (AMQP) 的开源实现,开发语言是以高性能、健壮以及可伸缩性出名的 Erlang 。

RocketMQ

RocketMQ 是阿里的一款分布式、队列模型的消息中间件。
项目地址 https://github.com/alibaba/RocketMQ
软件文档 https://github.com/alibaba/RocketMQ/wiki

三种消息队列的比较 

摘自 各种消息队列对比

ActiveMQ 

优点:成熟的产品,已经在很多公司得到应用(非大规模场景)。有较多的文档。 各种协议支持较好,有多重语言的成熟的客户端;

缺点:根据其他用户反馈,会出莫名其妙的问题,会丢失消息。其重心放到activemq6.0产品—apollo上去了,目前社区不活跃,且对 5.x 维护

较少;Activemq 不适合用于上千个队列的应用场景

RabbitMQ 

优点:由于erlang语言的特性, mq性能较好;管理界面较丰富,在互联网公司也有较大规模的应用;支持 amqp 系诶,有多中语言且支持amqp 的客户端可用

缺点:erlang语言难度较大。集群不支持动态扩展。

RocketMq

优点:模型简单,接口易用(JMS的接口很多场合并不太实用)。 在阿里大规模应用。 目前支付宝中的余额宝等新兴产品均使用rocketmq。

集群规模大概在50 台左右,单日处理消息上百亿;性能非常好,可以大量堆积消息在broker 中;支持多种消费,包括集群消费、广播消费等。 开发度较活跃,版本更新很快。

缺点:产品较新,文档比较缺乏。没有在 mq核心中去实现JMS 等接口,对已有系统而言不能兼容。阿里内部还有一套未开源的 MQ API,这一层 API可以将上层应用和下层 MQ 的实现

解耦。

时间: 2024-08-03 21:50:57

消息队列入门(二)消息队列的开源实现的相关文章

队列(二)——队列的链表实现方式

1.队列的单向链表的实现方法 return只可以返回一个值,单向循环链表来实现队列的时候可以只保留一个指针,因为保留rear指针能够很方便的表示出front指针,所以保留rear指针. 另外由于链表的第一个结点处理比较特殊,所以在初始化的时候需要单独处理.链表实现的队列思想也是第一个单元作为头结点,不存放数据,rear指针指向的总是尾结点(在循环链表中也就是头结点的上一个结点). 2.实现方法 用带表头的单向循环链表来实现 #include <stdio.h> #include <mal

转载:数据结构 二项队列

0)引论 左堆的合并,插入,删除最小的时间复杂度为O(logN).二项队列就是为了对这些结果进一步提高的一种数据结构.利用二项队列,这三种操作的最坏时间复杂度为O(logN),但是插入的平均时间复杂度为O(1). 1)二项队列 二项队列不是一棵树,它是一个森林,由一组堆序的树组成的深林,叫做二项队列. 二项队列有几个性质比较重要 (a) 每一颗树都是一个有约束的堆序树,叫做二项树 (b) 高度为k的第k个二项树Bk由一个根节点和B0, B1, .......B(k-1)构成 (c) 高度为k的二

二项队列———数据结构与算法分析第二版(C)

引论 左堆的合并,插入,删除最小的时间复杂度为O(logN).二项队列就是为了对这些结果进一步提高的一种数据结构.利用二项队列,这三种操作的最坏时间复杂度为O(logN),但是插入的平均时间复杂度为O(1) 二项队列 二项队列不是一棵树,它是一个森林,由一组堆序的树组成的深林,叫做二项队列. 二项队列有几个性质比较重要 (a) 每一颗树都是一个有约束的堆序树,叫做二项树 (b) 高度为k的第k个二项树Bk由一个根节点和B0, B1, .......B(k-1)构成 (c) 高度为k的二项树的结点

数据结构Java实现07----队列:顺序队列&amp;顺序循环队列、链式队列、顺序优先队列

数据结构Java实现07----队列:顺序队列&顺序循环队列.链式队列.顺序优先队列 一.队列的概念: 队列(简称作队,Queue)也是一种特殊的线性表,队列的数据元素以及数据元素间的逻辑关系和线性表完全相同,其差别是线性表允许在任意位置插入和删除,而队列只允许在其一端进行插入操作在其另一端进行删除操作. 队列中允许进行插入操作的一端称为队尾,允许进行删除操作的一端称为队头.队列的插入操作通常称作入队列,队列的删除操作通常称作出队列. 下图是一个依次向队列中插入数据元素a0,a1,...,an-

消息队列(二)

本文是大型网站架构系列:消息队列(二),主要分享JMS消息服务,常用消息中间件(Active MQ,Rabbit MQ,Zero MQ,Kafka). 四.JMS消息服务 讲消息队列就不得不提JMS .JMS(JAVA Message Service,java消息服务)API是一个消息服务的标准/规范,允许应用程序组件基于JavaEE平台创建.发送.接收和读取消息.它使分布式通信耦合度更低,消息服务更加可靠以及异步性. 在EJB架构中,有消息bean可以无缝的与JM消息服务集成.在J2EE架构模

大型网站架构系列:消息队列(二)

本文是大型网站架构系列:消息队列(二),主要分享JMS消息服务,常用消息中间件(Active MQ,Rabbit MQ,Zero MQ,Kafka).[第二篇的内容大部分为网络资源的整理和汇总,供大家学习总结使用,最后有文章来源] 本次分享大纲 消息队列概述(见第一篇:大型网站架构系列:分布式消息队列(一)) 消息队列应用场景(见第一篇:大型网站架构系列:分布式消息队列(一)) 消息中间件示例(见第一篇:大型网站架构系列:分布式消息队列(一)) JMS消息服务 常用消息队列 参考(推荐)资料 本

大型网站架构系列:消息队列(二) (转)

本文是大型网站架构系列:消息队列(二),主要分享JMS消息服务,常用消息中间件(Active MQ,Rabbit MQ,Zero MQ,Kafka).[第二篇的内容大部分为网络资源的整理和汇总,供大家学习总结使用,最后有文章来源] 本次分享大纲 消息队列概述(见第一篇:大型网站架构系列:分布式消息队列(一)) 消息队列应用场景(见第一篇:大型网站架构系列:分布式消息队列(一)) 消息中间件示例(见第一篇:大型网站架构系列:分布式消息队列(一)) JMS消息服务 常用消息队列 参考(推荐)资料 本

大型网站架构系列:分布式消息队列(二)

本文是大型网站架构系列:消息队列(二),主要分享JMS消息服务,常用消息中间件(Active MQ,Rabbit MQ,Zero MQ,Kafka).[第二篇的内容大部分为网络资源的整理和汇总,供大家学习总结使用,最后有文章来源] 本次分享大纲 消息队列概述(见第一篇:大型网站架构系列:分布式消息队列(一)) 消息队列应用场景(见第一篇:大型网站架构系列:分布式消息队列(一)) 消息中间件示例(见第一篇:大型网站架构系列:分布式消息队列(一)) JMS消息服务 常用消息队列 参考(推荐)资料 本

大型网站架构系列:消息队列(二)(转)

大型网站架构系列:消息队列(二) 本文是大型网站架构系列:消息队列(二),主要分享JMS消息服务,常用消息中间件(Active MQ,Rabbit MQ,Zero MQ,Kafka).[第二篇的内容大部分为网络资源的整理和汇总,供大家学习总结使用,最后有文章来源] 本次分享大纲 消息队列概述(见第一篇:大型网站架构系列:分布式消息队列(一)) 消息队列应用场景(见第一篇:大型网站架构系列:分布式消息队列(一)) 消息中间件示例(见第一篇:大型网站架构系列:分布式消息队列(一)) JMS消息服务