ActiveMQ消息中间件简介

670e19549e694b2b8bd67f0e6b3c4582.jpg一、ActiveMQ简介

 

  ActiveMQ是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ是一个完全支持JMS1.1和J2EE1.4规范的JMS Provide实现。尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中仍然扮演这特殊的地位。

 

二、ActiveMQ应用场景

  消息队列在大型电子商务类网站,如京东、淘宝、去哪儿等网站有这深入的应用。

 

队列的主要作用:消除高并发访问高峰,加快网站的响应速度。

 

在不使用消息队列的情况下,用户的请求数据直接写入数据库,在高并发的情况下,对数据库造成巨大的压力,同时也使系统响应延迟加剧;

 

早使用队列后,用户的请求发给队列后立即返回;

 

例如:当然不能直接给客户提示订单提交成功,在淘宝上提示:"您提交了订单,请等等系统确认"

 

再由消息队列的消费者进程从消息队列中获取数据库,异步写入数据库。

 

由于消息队列的服务处理速度远快于数据库,因此用户的响应延迟可能得到有效改善。

 

流程图解,如下图:

 

 

 

三、消息队列说明

  消息队列中间是分布式系统中重要的组件,主要解决应用耦合、异步消息、流量消峰等问题;

 

实现高性能,高可用,可伸缩和最终一致性架构;是大型分布式系统不可缺少的中间件。

 

目前在生产环境使用较多的消息队列:ActiveMQ、RabbitMQ、Kafka、ZeroMQ、MetaMQ、RocketMQ等。

 

四、消息队列应用场景

1,异步处理

场景说明:用户注册后,需要发注册邮件和注册短信。传统的做法有两种方式:串行方式、并行方式;

 

(1)串行方式:将注册信息写入数据库成功后,发生注册邮件,再发生注册短信。以上三个任务完成后,返回给客户端。

 

 

 

(2)并行方式:将注册信息写入数据库成功后,发生注册邮件的同时,发生注册短信,以上三个任务完成后,返回给客户端,与串行的差别是,并行的方式可以提高处理时间;

 

 

 

假设三个业务节点每个使用50ms,不考虑网络等其他开销,则串行方式的耗时是150ms;并行的耗时是100ms;

 

因为CPU在单位时间内处理的请求数是一定的,假设CPU 1秒内吞吐量是100次;则串行方式1秒内CPU可以处理的请求量是7次(1000/150);并行方式可处理请求量是10次(1000/100);

 

综上所述,传统的方式系统的性能(并发量、吞吐量、响应时间)会有瓶颈。如何解决这个问题?

 

引入消息队列,将不是必须的业务逻辑,异步处理,改造后的架构如下图:

 

 

 

安装上述约定,用户的响应时间相当于是注册信息写入数据库的时间,也是就是50ms.

 

注册邮件,发短信写入消息队列后,直接放回,因此写入消息队列的速度很快,基本可以忽略。

 

采用消息队列后用户的响应数据可能就是50ms。所以基于此架构,系统的吞吐量提高到每秒20QPS;比串行提高了3倍,比并行提高了2倍。

 

2,应用解耦

场景说明:用户下单后,订单系统需要通知库存系统。传统的做法:订单系统调用库存系统接口。如下图:

 

 

 

传统模式的缺点:

 

  1>.假如库存系统无法访问,则订单减库存将失败,从而导致订单失败;

 

  2>.订单系统与库存系统耦合;

 

如何解决以上问题?引入应用消息队列后的方案,如下图:

 

 

 

  1>.订单系统:用户下单后,订单系统完成持久化处理,将消息写入消息队列,返回用户订单下单成功,请等等物流配送。

 

  2>.库存系统:订阅下单的消息,采用拉/推的方式,获取下单信息,库存系统根据下单信息,进行库存操作。

 

  3>.假如在下单时库存系统不能正常使用,也不影响正常下单。因为下单后,订单系统写入消息队列就不再关系其他的后续操作了,实现订单系统与库存系统的应用解耦。

 

3,流量消峰

流量消峰也是消息队列中的常用场景,一般在秒数或者团抢活动中使用广泛。

 

应用场景:秒数活动,一般因为流量过大,导致流量暴增,应用容易挂掉。为解决这个问题,一般需要在应用前端假如消息队列。

 

(1)可以控制活动人数。

 

(2)可以缓解短时间内高流量压垮应用;

 

 

 

引入消息队列:

 

  1>.用户的请求,服务器接收后,首先写入消息队列。假如消息队列长度超过最大数量,则直接抛弃用户请求或者跳转到错误页面;

 

  2>.秒杀业务根据消息队列的请求信息,再做后续处理;

 

4,消息通讯

 消息通讯是指:消息队列一般都内置了高效的通讯机制,因此也可以用在纯的消息通讯。比如实现点对点的消息队列或者聊天室等。

 

(1)点对点通讯

 

 

 

客户端A和客户端B使用同一队列,进行消息通讯。

 

(2)聊天室通讯(发布订阅)

 

 

 

客户端A、客户端B、客户端N订阅同一主题,进行消息发布和接收,实现类是聊天室效果。

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

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

相关文章

云计算模式的区域LIS系统源码,基于ASP.NET+JQuery、EasyUI+MVC技术架构开发

云计算模式的区域LIS系统源码 云LIS系统源码,自主版权 LIS系统是专为医院检验科的仪器设备能与计算机连接。可通过LIS系统向仪器发送指令,让仪器自动操作和接收仪器数据。并快速的将检验仪器中的数据导入到医生工作站中进行管理,且可将检验结…

springboot项目打jar包,运行时提示jar中没有主清单属性

可能性一&#xff1a; 没有在pom中加入maven插件 在pom中加入下方代码即可。 <build><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><version>3.8.1</ve…

扩展Nginx的无限可能:掌握常见扩展模块和第三方插件的使用方法

Nginx是一款高性能的开源Web服务器和反向代理服务器。它具有模块化的架构&#xff0c;可以通过扩展模块和插件来增强其功能。在本文中&#xff0c;我将围绕Nginx的扩展模块和插件进行讲解&#xff0c;并提供一些常见的扩展模块和第三方插件的示例。 一、Nginx扩展模块 Nginx的…

AltiumDesigner原理图编译错误报告信息解释

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 前言一、ViolationsAssociated with Buses 有关总线电⽓错误的各类型&#xff08;共 12 项&#xff09;二、ViolationsAssociated Components 有关元件符号电⽓错误…

039-第三代软件开发-PDF阅读器

第三代软件开发-PDF阅读器 文章目录 第三代软件开发-PDF阅读器项目介绍PDF阅读器1 初始化PDF view2 qml 中使用3 创建模块 关键字&#xff1a; Qt、 Qml、 pdf、 LTDev、 本地 项目介绍 欢迎来到我们的 QML & C 项目&#xff01;这个项目结合了 QML&#xff08;Qt Met…

如何快速排查SSD IO延迟抖动问题?

一块固态硬盘设计背后&#xff0c;有硬件控制器&#xff0c;NAND闪存颗粒、DRAM&#xff0c;还有固件FTL算法等。SSD设计的本身其实是一件特别复杂的过程&#xff0c;需要考虑各种客户需求且要保证可靠性、性能、稳定性。 针对SSD的相关性能测试&#xff0c;SNIA也有专门针对SS…

【RabbitMQ 实战】12 镜像队列

一、镜像队列的概念 RabbitMQ的镜像队列是将消息副本存储在一组节点上&#xff0c;以提高可用性和可靠性。镜像队列将队列中的消息复制到一个或多个其他节点上&#xff0c;并使这些节点上的队列保持同步。当一个节点失败时&#xff0c;其他节点上的队列不受影响&#xff0c;因…

MIT Kimera-VIO-ROS 安装

前言 我安装Kimera-VIO-ROS的时间是2023.10.28。由于已经离Kimera发布过去两年&#xff0c;所以遇到版本不同步问题&#xff0c;Kimera-VIO&#xff0c;Kimera-VIO-ROS&#xff0c;GTSAM的版本需要精心挑选。 Kimera-VIO在2021.07.01之后没有更新&#xff0c;git commit版本为…

docker服务CPU飙高排查

Docker服务CPU飙高排查 什么是Docker服务CPU飙高&#xff1f; Docker是一个开源的容器化平台&#xff0c;它允许开发者将应用程序及其依赖项打包成一个独立的容器&#xff0c;以保证应用程序在不同的环境中都能够运行。然而&#xff0c;有时我们可能会遇到Docker服务CPU飙高的…

漏洞复现-showdoc文件上传_v2.8.3_(CNVD-2020-26585)

showdoc文件上传_v2.8.3_CNVD-2020-26585 漏洞信息 showdoc 2.8.3 以下版本中存在安全漏洞CNVD-2020-26585文件上传漏洞 描述 ShowDoc是一个非常适合IT团队的在线API文档、技术文档工具。通过showdoc&#xff0c;你可以方便地使用markdown语法来书写出美观的API文档、数据字…

Redis持久化机制的三种方式:RDB、AOF和混合持久化

Redis持久化机制的三种方式&#xff1a;RDB、AOF和混合持久化 Redis是一种高性能的内存数据结构存储系统&#xff0c;它提供了丰富的数据结构和操作&#xff0c;如键值对、列表、集合、哈希表等。然而&#xff0c;由于Redis是内存存储&#xff0c;一旦服务器停止运行&#xff…

java后端返回给前端不为空的属性

问题背景&#xff1a; 目前遇到的一个问题。一个对象里面定义了数组、集合、和字符串属性等&#xff0c;但是返回给前端的时候数组和集合都是空的&#xff0c;前端接收到的是“” 一个空字符。然后保存的时候又把空字符传给后端&#xff0c;出现了数据结构不匹配导致报错。 解…

Java8与JDK1.8与JDK8之间的关系是什么?

1.Java8等价于JDK8 2.JDK8或者JDK1.8是由于自从JDK1.5/JDK5命名方式改变后遗留的历史问题。所以JDK8或者JDK1.8是等价的。 2004年9月30日&#xff0c;J2SE1.5发布。为了表示该版本的重要性&#xff0c;J2SE 1.5更名为Java SE 5.0&#xff0c;从此开始&#xff0c;如下图像jav…

如何进行渗透测试以提高软件安全性?

对于各种规模的企业和组织来说&#xff0c;软件安全是一个至关重要的问题。随着网络攻击越来越复杂&#xff0c;软件中的漏洞越来越多&#xff0c;确保你的软件安全比以往任何时候都更重要。提高软件安全性的一个有效方法是渗透测试&#xff08;penetration testing&#xff09…

雨云游戏云面板服使用教程我的世界Forge服务端开服教程(翼龙面板)

雨云面板服目前支持一键开服的游戏有&#xff1a;Minecraft Java版、Minecraft 基岩版、泰拉瑞亚、饥荒&#xff0c;还提供纯Java/Linux环境&#xff08;Docker&#xff09;&#xff0c;方便开自己开其他游戏服。 其中Minecraft Java版支持一键开服的有Arclight、Mohist、CatS…

环形链表 II

一、题目描述 题目链接&#xff1a;力扣&#xff08;LeetCode&#xff09;官网 - 全球极客挚爱的技术成长平台 二、题解 对于本题&#xff0c;我们可以得到以下结论&#xff1a; 让一个指针从链表起始位置开始遍历链表&#xff0c;同时让一个指针从判环时相遇点的位置开始绕…

原始流,缓冲流性能比较

一.低级字节流一个一个字节复制 1.代码 package org.example;import java.io.*;public class day13 {//原视频路径private static final String file1 "D:\\temp\\day05\\改名.mp4";//目的视频路径private static final String file2 "D:\\temp\\day05\\不改…

Ant-design-vue Table 列表 columns 将作为导出功能入参

将 Table 列表 columns 将作为导出功能入参&#xff0c;由于 columns 数据跟入参存在差异&#xff0c;因此我们抽离公共方法进行处理。 const handleExportColumnsData function (columns []) {if (!columns.length) return []return columns.filter(item > item.dataInde…

windows下OOM排查

如下有一段代码 package com.lm.demo.arthas.controller;import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController;import java.util.A…

C++学习day--24 推箱子游戏图像化开发

环境要求&#xff1a; 1、VS2015以上 2、成功安装并配置图形库 项目注意事项&#xff1a;代码复制好以后&#xff0c;把下面的字符集改为多字节字符集 第 1 节 项目需求 实现一款推箱子游戏&#xff0c;效果如下图所示 , 具体规则&#xff1a; 1. 箱子只能推动而不能拉动…