如何制作网站,手机网站开发环境,大连网站外包,平面设计公司电话【RockerMQ】001-RockerMQ 概述 文章目录【RockerMQ】001-RockerMQ 概述一、MQ 概述1、MQ 简介2、MQ 用途限流削峰异步解耦数据收集3、常见 MQ 产品概述对比4、MQ 常见协议二、RocketMQ 概述1、简介2、发展历史一、MQ 概述
1、MQ 简介
MQ#xff0c;Message Queue#xff0…【RockerMQ】001-RockerMQ 概述 文章目录【RockerMQ】001-RockerMQ 概述一、MQ 概述1、MQ 简介2、MQ 用途限流削峰异步解耦数据收集3、常见 MQ 产品概述对比4、MQ 常见协议二、RocketMQ 概述1、简介2、发展历史一、MQ 概述
1、MQ 简介
MQMessage Queue是一种提供消息队列服务的中间件也称为消息中间件是一套提供了消息生产、存储、消费全过程API的软件系统。消息即数据。一般消息的体量不会很大。
2、MQ 用途
限流削峰
MQ 可以将系统的超量请求暂存其中以便系统后期可以慢慢进行处理从而避免了请求的丢失或系统被压垮。 自提升系统的消化能力一口气吃完容易噎死慢慢吃算是一种任务调度 异步解耦
上游系统对下游系统的调用若为同步调用则会大大降低系统的吞吐量与并发度且系统耦合度太高。而异步调用则会解决这些问题。所以两层之间若要实现由同步到异步的转化一般性做法就是在这两层间添加一个 MQ 层。 自任务调度性质更强 数据收集
分布式系统会产生海量级数据流如业务日志、监控数据、用户行为等。针对这些数据流进行实时或批量采集汇总然后对这些数据流进行大数据分析这是当前互联网平台的必备技术。通过 MQ 完成此类数据收集是最好的选择。 自MQ 记录了所有的消息像是一个账本或者日志可以据此分析各项数据 3、常见 MQ 产品
概述
ActiveMQActiveMQ 是使用 Java 语言开发一款 MQ 产品。早期很多公司与项目中都在使用。但现在的社区活跃度已经很低。现在的项目中已经很少使用了。RabbitMQRabbitMQ是使用 ErLang 语言开发的一款 MQ 产品。其吞吐量较 Kafka 与 RocketMQ 要低且由于其不是 Java 语言开发所以公司内部对其实现定制化开发难度较大。KafkaKafka 是使用 Scala/Java 语言开发的一款 MQ 产品。其最大的特点就是高吞吐率常用于大数据领域的实时计算、日志采集等场景。其没有遵循任何常见的 MQ 协议而是使用自研协议。对于 Spring Cloud Netflix其仅支持 RabbitMQ 与 Kafka。RocketMQRocketMQ 是使用 Java 语言开发的一款 MQ 产品。经过数年阿里双 11 的考验性能与稳定性非常高。其没有遵循任何常见的 MQ 协议而是使用自研协议。对于 Spring Cloud Alibaba其支持 RabbitMQ、Kafka但提倡使用 RocketMQ。
对比
关键词ACTIVEMQRABBITMQKAFKAROCKETMQ开发语言JavaErLangJavaJava单机吞吐量万级万级十万级十万级Topic--百级Topic时会影响系统吞吐量千级Topic时会影响系统吞吐社区活跃度低高高高
4、MQ 常见协议
一般情况下MQ的实现是要遵循一些常规性协议的。常见的协议如下
JMS JMSJava Messaging Service Java 消息服务。是 Java 平台上有关 MOMMessage OrientedMiddleware面向消息的中间件 PO/OO/AO的技术规范它便于消息系统中的 Java 应用程序进行消息交换并且通过提供标准的产生、发送、接收消息的接口简化企业应用的开发。ActiveMQ 是该协议的典型实现。 STOMP STOMPStreaming Text Orientated Message Protocol面向流文本的消息协议是一种 MOM 设计的简单文本协议。STOMP提供一个可互操作的连接格式允许客户端与任意 STOMP 消息代理Broker进行交互。ActiveMQ 是该协议的典型实现RabbitMQ 通过插件可以支持该协议。 AMQP AMQPAdvanced Message Queuing Protocol高级消息队列协议一个提供统一消息服务的应用层标准是应用层协议的一个开放标准是一种 MOM 设计。基于此协议的客户端与消息中间件可传递消息并不受客户端/中间件不同产品不同开发语言等条件的限制。 RabbitMQ 是该协议的典型实现。 MQTT MQTTMessage Queuing Telemetry Transport消息队列遥测传输是 IBM 开发的一个即时通讯协议是一种二进制协议主要用于服务器和低功耗 IoT物联网设备间的通信。该协议支持所有平台几乎可以把所有联网物品和外部连接起来被用来当做传感器和致动器的通信协议。 RabbitMQ 通过插件可以支持该协议。 二、RocketMQ 概述
1、简介
RocketMQ 是一个统一消息引擎、轻量级数据处理平台。RocketMQ是一款阿里巴巴开源的消息中间件。 2016 年 11 月 28 日阿里巴巴向 Apache 软件基金会捐赠 RocketMQ成为 Apache 孵化项目。 2017 年 9 月 25 日Apache 宣布 RocketMQ 孵化成为 Apache 顶级项目TLP 成为国内首个互联网中间件在 Apache 上的顶级项目。
官网地址http://rocketmq.apache.org
2、发展历史 2007 年阿里开始五彩石项目Notify 作为项目中交易核心消息流转系统应运而生。Notify 系统是 RocketMQ 的雏形。 消息流转系统我觉得消息也就是事件嘛要做什么事情先产生一个消息存储起来然后交给服务器完成 2010 年B2B 大规模使用 ActiveMQ 作为阿里的消息内核。阿里急需一个具有海量堆积能力的消息系统。 看来 ActiveMQ 不够用这也是其社区活跃度低、逐渐被淘汰的原因吧。 2011 年初Kafka 开源。淘宝中间件团队在对 Kafka 进行了深入研究后开发了一款新的 MQMetaQ。、 使用 ActiveMQ 研究 Kafka 开发出 MetaQ 新的工具 吸收旧工具优点 弥补旧工具不足 扩展新功能。 2012 年MetaQ 发展到了 v3.0 版本在它基础上进行了进一步的抽象形成了 RocketMQ然后就将其进行了开源。 新工具迭代更新多个版本后基本稳定 开源东西太烂的话不好意思拿出来 2015 年阿里在 RocketMQ 的基础上又推出了一款专门针对阿里云上用户的消息系统 Aliware MQ。 这属于阿里云定制版了吧 2016 年双十一RocketMQ 承载了万亿级消息的流转跨越了一个新的里程碑。 11 月 28 日阿里巴巴向 Apache 软件基金会捐赠 RocketMQ成为 Apache 孵化项目。 星火燎原 2017 年 9 月 25 日Apache 宣布 RocketMQ孵化成为 Apache 顶级项目TLP 成为国内首个互联网中间件在 Apache 上的顶级项目。 有点羽化登仙的意思
