系列一、MQ简介

一、MQ简介

1.1、概述

        MQ(Message Queue),是一种提供消息队列服务的中间件,也称为消息中间件,是一套提供了消息(消息即数据,一般消息的体量不会很大生产、存储、消费全过程的API软件系统。

1.2、应用场景

        MQ常用的应用场景主要分为以下三种,即:流量削峰、异步解耦、数据搜集,下面一 一介绍。

1.2.1、流量削峰

        MQ可以将系统的超量请求暂存其中,以便系统后期可以慢慢进行处理,从而避免了请求的丢失或系统被压垮。

1.2.2、异步解耦

        上游系统对下游系统的调用若为同步调用,则会大大地降低系统的吞吐量与并发度,且系统耦合度较高,而异步调用则会解决这些问题。所以两层之间若要实现由同步到异步的转化,一般性做法就是,在这两层之间添加一个MQ层。

1.2.3、数据搜集

        分布式系统会产生海量级数据流,例如:业务日志、监控数据、用户行为等。针对这些数据流进行实时或者批量采集汇总,然后对这些数据流进行大数据分析,是当前互联网平台的必备技术。通过MQ完成此类数据搜集是最好的选择。

1.3、常见的MQ产品

(一)、ActiveMQ

        ActiveMQ是使用Java语言开发的一款MQ产品。早期很多公司与项目中都在使用,但是现在的社区活跃度已经很低了,现在的项目中也已经很少使用了。

(二)、RabbitMQ

        RabbitMQ是使用ErLang语言开发的一款MQ产品。其吞吐量较Kafka和RocketMQ要低,且由于其不是Java语言开发,所以公司内部对其实现定制化开发难度较大。

(三)、RocketMQ

        RocketMQ是使用Java语言开发的一款MQ产品。经过数年阿里巴巴双11的考验,性能与稳定性非常高,其没有遵循任何常见的MQ协议,而是使用自研协议。对于Spring Cloud          Alibaba,其支持RabbitMQ、Kafka,但建议使用RocketMQ。

(四)、Kafka

        Kafka是使用Scala/Java语言开发的一款MQ产品。其最大的特点就是高吞吐量,常用于大数据领域的实时计算、日志采集等场景,其没有遵循任何常见的MQ协议,而是使用自研协议。

1.4、ActiveMQ vs RabbitMQ vs RocketMQ vs Kafka

1.5、MQ常见协议

1.5.1、概述

        般情况下MQ的实现都要遵循一些常规性协议,常见的协议如下:

1.5.2、各种协议

(一)、JMS

        JMS(Java Message Service:Java消息服务),是Java平台上有关MOM(Message Oriented Middleware:面向消息的中间件)的技术规范,它便于系统中的Java应用程序进行消息交换,并且提供标准的生产、发送、接收消息的接口,简化企业应用的开发。ActiveMQ是该协议的典型实现。

(二)、STOMP

         STOMP(Streaming Text Oriented Message Protocol:面向流文本的消息协议),是一种MOM设计的简单文本协议。STOMP提供一个可互操作的连接格式,允许客户端与任意STOMP消息代理(Broker)进行交互。ActiveMQ是该协议的典型实现,RabbitMQ通过插件可以支持该协议。

(三)、AMQP

        AMQP(Advanced Message Queuing Protocol:高级消息队列协议),一个提供统一消息服务的应用层标准,是应用层协议的一个开放标准,是一种MOM设计。基于此协议的客户端与消息中间件可传递消息,并不受客户端/中间件不同产品、不同开发语言的限制。RabbitMQ是该协议的典型实现。

(四)、MQTT

        MQTT(Message Queuing Telemetry Transport:消息队列遥测传输),是IBM公司开发的一个即时通讯协议,是一种二进制协议,主要用于服务器和低功耗IoT(物联网)设备间的通信。该协议支持所有平台,几乎可以把所有物联网物品和外部连接起来,被用来当做传感器和制动器的通信协议。RabbitMQ通过插件可以支持该协议。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/297066.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Plantuml之组件图语法介绍(二十二)

简介: CSDN博客专家,专注Android/Linux系统,分享多mic语音方案、音视频、编解码等技术,与大家一起成长! 优质专栏:Audio工程师进阶系列【原创干货持续更新中……】🚀 优质专栏:多媒…

【论文解读】3D视觉标定的显式文本解耦和密集对齐(CVPR 2023)

来源:投稿 作者:橡皮 编辑:学姐 论文链接:https://arxiv.org/abs/2209.14941 开源代码:https://github.com/yanmin-wu/EDA 图1所示。文本解耦,密集对齐的3D视觉标定。文本中的不同颜色对应不同的解耦分量。…

LLaMA开源大模型源码分析!

Datawhale干货 作者:宋志学,Datawhale成员 花了一晚上照着transformers仓库的LLaMA源码,把张量并行和梯度保存的代码删掉,只留下模型基础结构,梳理了一遍LLaMA的模型结构。 今年四月份的时候,我第一次接触…

Java内存区域与内存溢出异常

Java与C++之间有一堵由内存分配和垃圾收集技术所围成的高墙,墙外面的人想进去,墙里面的人却想出来。 2.1 概述 对于从事C、C++程序开发的开发人员来说,在内存管理领域,他们即是拥有最高权力的“皇帝”,又是从事最基础工作的劳动人民——即拥有每一个对象的“所有权”,又…

MySQL部署之yum安装

MySQL https://www.mysql.com //mysql官网 yum安装步骤 yum安装 清理环境 [rootmysql ~]# yum erase mariadb mariadb-server mariadb-libs mariadb-devel -yuserdel -r mysql[rootmysql ~]# rm -rf /etc/my* && rm -rf /var/lib/mysql && rm -rf /use/bin/m…

计算机视觉基础(10)——深度学习与图像分类

前言 传统视觉算法采用手工设计特征与浅层模型,而手工设计特征依赖于专业知识,且泛化能力差。深度学习的出现改变了这一状况,为视觉问题提供了端到端的解决方案。在之前的课程中,我们已经学习了图像分类的传统知识。在本节课中&am…

便捷记账本,批量筛选需要的账目明细

你是否曾因为无法管理自己的财务而感到烦恼?如果你正在寻找一款简单易用的记账软件,那么晨曦记账本将是你的不二之选,一起来看看这款软件是怎么使用的吧。 所需工具: 一个【晨曦记账本】软件 操作步骤: 步骤1&…

机器学习之实验过程01

import pandas as pd import numpy as np import matplotlib.pyplot as plt data_path = /home/py/Work/labs/data/SD.csv # 请确保您的数据文件路径是正确的 df = pd.read_csv(data_path) df.head() # 创建散点图 # 创建散点图 plt.figure(figsize=(10, 6)) plt.scat…

拓扑排序算法总结

知识概览 求图的拓扑序是图的宽搜的一个很经典的应用,拓扑序列是针对有向图来说的。 拓扑序列的定义是: 如果说一个点的序列满足对于图中的每条有向边(x, y),x都出现在y的前面,那就称这个序列是这个图的拓扑序列。 备注&#xff…

【Linux】Linux常见指令解析上

目录 1. 前言2. ls指令3. pwd指令4. cd指令3.1 cd常见快捷指令 4. touch指令5. mkdir指令6. rmdir指令 && rm指令 (重要)6.1 rmdir指令6.2 rm指令 7. man指令 1. 前言 这篇文章我们将详细介绍一下Linux下常见的基本指令。 2. ls指令 语法: ls [选…

FPFA.一种二倍频电路代码描述以及测量详情

一、前言 1、因为需要倍频电路所以找了个二倍频的电路,通过fpga实际测量发现经过倍频后的电路峰值降低。不过这个也正常,因为该电路只要过触发点就会开始发生波形变化,而电路的触发值不是峰值。​​​​​​​ 2、继续对电路做倍频后信号做二…

linux操作系统——进程(二) 进程状态

进程状态 你真正的理解了进程的状态嘛?特别是操作系统教材中学过的进程状态,你真的理解了吗? 教材上关于进程状态的说明 下面我们以下图为例: 这是教材上对操作系统的说明,但是它并没有详细的说明,这些状态具体是什么&#xf…