初识MQ

参考视频:白鹤翔_rabbitmq全面解析【史上最佳】

MQ:消息队列

MQ的衡量指标:服务性能、数据的存储、集群架构

1.ActiveMQ

一、介绍

1.ActiveMQ是Apache出品的,最流行的开源消息总线,是一种完全支持JMS规范的消息中间件

2.其丰富的api、多种集群架构模式使得它成为一种老牌的消息中间件,在中小企业中应用广泛。

二、模式

2.KAFKA

一、介绍

kafka是LinkedIn开源的分布式发布-订阅消息系统,目前属于Apache的顶级项目。kafka的主要特点是基于pull模式来处理消息消费,追求高吞吐量,一开始的目的就是用于日志收集和传输。

0.8版本开始支持复制,不支持事务,对消息的重复、丢失、错误没有严格的要求,适合产生大量数据的互联网服务的数据收集业务。

kafka主要关注性能,对数据的可靠性要求不高。只是对内存的使用,不会做磁盘的持久化。

二、模式

 3.RocketMQ

一、介绍

RocketMQ是阿里开源的消息中间件,也是Apache的顶级项目。它是纯java开发,具有高吞吐量、高可用性、适合大规模分布式系统应用。

RocketMQ的思路起源于kafka,他对消息的可靠性传输和事务做了优化,目前在阿里广泛应用于交易、充值、流计算、消息   推送、日志

流式处理、binglog分发等场景。

RocketMQ支持的功能比较完善,但它的痛点是商业化的,收费的

二、模式

 4.RabbitMQ

一、介绍

RabbitMQ是Erlang语言开发的开源消息队列系统,基于AMQP协议来实现。AMQP的主要特征是面向消息、队列、路由(包括点对点和发布/订阅)、可靠性、安全。AMQP协议更多用在企业系统内,对数据一致性、稳定性和可靠性要求很高的场景,

对性能和吞吐量的要求还在其次。

RabbitMQ是一个完善、高可用、高性能、高稳定性、集群恢复、节点宕掉修复、磁盘损坏修复很齐全的中间件。

二、架构

 

三、优点

1.开源、性能优秀,稳定性保障

2.提供可靠性消息投递模式(confirm)、返回模式(return)

3.与SpringAMQP完美结合、API丰富

4.集群模式丰富,表达式配置,HA模式,镜像队列模型

5.保证数据不丢失的前提做到高可靠性、可用性

四、RabbitMQ高性能的原因

1.Erlang语言最初用于交换机领域的架构模式,这样使得RabbitMQ在Broker之间进行数据交互的性能是非常优秀的

2.Erlang的优点:Erlang有着和原生Socket一样的延迟

五、AMQP协议

AMQP:高级消息队列协议

AMQP定义:是具有现在特征的二进制协议。是一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。

六、AMQP模型

 七、AMQP核心概念

1.Server:又称broker,接受客户端的连接,实现AMQP实体服务

2.Connection:连接,应用程序与broker的连接

3.Channel:网络信道,几乎所有的操作都在Channel中进行,Channel是进行消息读写的通道。客户端可建立多个Channel,每个Channel代表一个会话任务。

4.Message:消息,服务器和应用程序之间传送的数据,由propertiesbody组成。properties可以对消息进行修饰,比如消息的优先级、延迟等高级特性;body则是消息体内容。

5.Virtual host:虚拟地址,用于进行逻辑分离,是最上层的消息路由。一个Virtual host里面可以有若干个Exchange和Queue,同一个Virtual host里面不能有相同名称的Exchange和Queue。

6.Exchange:交换机,接收消息,根据路由键转发消息到绑定的队列

7.Binding:Exchange和Queue之间的虚拟连接,binding中可以包含Routingkey

8.Routingkey:一个路由规则,虚拟机可用它来确定如何路由一个特定消息。

9.Queue:也称为Message Queue,消息队列,保存消息并将它们转发给消费者

八、RabbirMQ的整体架构

 九、RabbirMQ消息是如何流转的

原文地址:https://www.cnblogs.com/zheaven/p/11797447.html