ActiveMQ消息中间件简介

news2024/11/14 14:31:11

63988fb544f3432f93bea1e251a0cb3f.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.coloradmin.cn/o/594499.html

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

相关文章

3Dmax云渲染如何使用?一文带你了解云渲染

3ds Max是Autodesk公司推出的一款专业计算机图形和三维动画软件,被广泛应用于建筑、室内设计、电影、游戏、广告、工业设计等领域。它提供丰富的模型建模、纹理编辑、灯光设置、渲染等功能,可以制作出高质量的三维模型、动画和静态渲染。它具有强大的扩展…

【1++的Linux】之Linux权限

👍作者主页:进击的1 🤩 专栏链接:【1的Linux】 文章目录 一,什么是Linux权限?二,Linux权限管理2.1 文件访问者的分类2.2 文件类型和访问权限2.3 修改文件权限2.4 掩码的作用及其设置 三&#xf…

前沿技术|人工智能的崛起和发展历程

前言: 人工智能的作用是使计算机能够模仿人类智能和学习能力,从而实现自动化、智能化和优化决策的目标。 文章目录 人工智能背景介绍发展状态未来展望 总结 人工智能 背景 人工智能(Artificial Intelligence,AI)的产生…

29Maven高级

一、分模块设计与开发 1、介绍 2、tlias-pojo模块 然后把pojo复制过去。pom中加入lombok依赖 引入tlias-pojo依赖 3、tlias-utils模块 tlias-utils的pom.xml <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.…

高频面试八股文原理篇(一)hashmap原理相关

目录 引言 面试题&#xff1a;hashmap原理 原理 JDK7时HashMap的数据结构 jdk8中hashMap数据结构 hashMap怎么设置初始值的大小 jdk7和jdk8中HashMap的区别 为什么放在hashMap集合key部分的元素需要重写equals方法&#xff1f; concurrenthashmap为什么线程安全 高频面…

Linux文件的扩展属性

文件属性 Linux文件属性分为常规属性与扩展属性&#xff0c;其中扩展属性有两种&#xff1a;attr与xattr. 一般常规的文件属性由stat API 读取&#xff0c;一般是三种权限&#xff0c;ower, group&#xff0c;时间等。 扩展属性attr 用户态API ioctl(fd, FS_IOC32_SETFLAGS …

从零开始学习JavaScript:轻松掌握编程语言的核心技能②

从零开始学习JavaScript&#xff1a;轻松掌握编程语言的核心技能② 一&#xff0c;JavaScript 函数1.1 JavaScript 函数语法1.2 局部 JavaScript 变量1.3 全局 JavaScript 变量 二&#xff0c;JavaScript 作用域2.1JavaScript 局部作用域 三&#xff0c;JavaScript 事件3.1HTML…

Linux——磁盘文件的理解 + inode详解 + 软硬链接 +动静态库

索引 磁盘文件的理解inode软硬链接动静态库理解动态链接与地址无关生成动静态库使用静态库使用动态库动态链接再次理解&#xff01; 磁盘文件的理解 之前讲述的都是内存级的文件&#xff0c;但是系统中最多的还是磁盘级的文件&#xff0c;大量的文件自然也需要被管理&#xff…

【算法】08 耦合 Lorenz 63 模式的参数估计实验

摘要 本实验通过建立基于耦合 Lorenz 63 模式的孪生实验框架&#xff0c;使用集合调整卡尔曼滤波器EAKF实现参数估计&#xff0c;测试参数估计开始的不同阶段、观测误差、同化频率、协方差膨胀等方法细节对于参数估计结果的影响。 耦合 Lorenz 63 模式 Lorenz 63 模式是Lore…

Postman实战:轻松搞定接口自动化测试

随着移动互联网的发展&#xff0c;接口自动化测试已经成为软件测试领域中不可或缺的一部分。而作为最流行的API开发工具之一&#xff0c;Postman凭借其简单易用、功能强大的特点赢得了越来越多开发者和测试人员的青睐。 想要掌握Postman的接口自动化测试技能&#xff0c;只需要…

JDK 下载与安装

首先下载 jdk 最新版本。可以去 http://java.sun.com/j2se/1.4.2/download.html 版本一&#xff1a;适合 win7oracle 版本 java 下载最新的 jdk 版本&#xff0c; 打开界面后。选择 J2SE v 1.4.2_08 SDK 拦目下面的 Download J2SE SDK&#xff0c; 然后选择 Accept License…

6设计指令流水线-3【FPGA模型机课程设计】

6设计指令流水线-3【FPGA模型机课程设计】 前言推荐6设计指令流水线-3安排测试与结果 指令流水线理论MIPS的一种简单实现基本的MIPS流水线 指令流水线实现MIPS五段流水CPU设计 基于单周期CPU的流水线设计乘除流水线的设计原子流水线的设计代码设计EX_Mem 附录0 框架 最后 前言 …

理论+实操|一文掌握 RFM 模型在客户数据洞察平台内的落地实战

确定用户价值是整个用户运营过程中极其重要的一环。传统的工作流程中&#xff0c;业务人员向数据部门提出数据需求&#xff0c;等待返回结果后再进行价值分析是主要的准备工作&#xff0c;但这个过程非常耗时。为了提高工作效率&#xff0c;业务人员经常会基于自己对用户的理解…

链表【+逆序链表】、循环队列、堆栈讲解(链表头和尾插法)

文章目录 一、链表&#xff08;1&#xff09;链表简单介绍&#xff08;2&#xff09;链表的创建&#xff08;3&#xff09;数据的插入【1】头插法【2】尾插法 &#xff08;4&#xff09;链表的删除&#xff08;5&#xff09;源代码实现 二、队列&#xff08;循环队列&#xff0…

热闹炸了,公司居然公然鼓励员工玩游戏

池塘边的榕树上&#xff0c;知了在声声叫着夏天&#xff0c;操场边的秋千上&#xff0c;只有蝴蝶停在上面..........每逢儿童节到来之时&#xff0c;东东总是会回想起儿时的自己&#xff0c;面对那即将到来的节日&#xff0c;兴奋异常。 因为在这一天全校会给我们放上一天假&am…

Android进阶之路 - 字体阴影、文字阴影

最近几个月都挺忙&#xff0c;忙着工作&#xff0c;忙着成长… 一直以来我认为在开发中首当其冲的肯定是需求、功能&#xff0c;然后才是UI细节&#xff1b;所以我自己一般不太会去深究一些看不明显的UI&#xff0c;不过这俩日同事提醒我文字有阴影效果&#xff0c;细看之下果然…

Java000——超好用的工具推荐

下面介绍工具直接安装即可&#xff0c;基本上都是一路next&#xff08;有需要选择安装路径则选择自己的安装目录即可&#xff09; Everything Everything用于搜索电脑本地文件、文件夹&#xff0c;快速高效 下载地址 Snipaste截图工具 下载地址 notepad 轻量级文本编写查看…

C++11 右值引用

文章目录 一. 左值&#xff1f;右值&#xff1f;二. 右值引用的使用三. 万能引用&完美转发四. 移动构造&移动赋值结束语 一. 左值&#xff1f;右值&#xff1f; C中&#xff0c;对于左值&#xff0c;右值&#xff0c;我们可能会理解为 赋值符号左边是左值&#xff0c…

木棒 DFS经典题 剪枝优化 满注释版 java

&#x1f351; 算法题解专栏 &#x1f351; 题目地址 乔治拿来一组等长的木棒&#xff0c;将它们随机地砍断&#xff0c;使得每一节木棍的长度都不超过 50 50 50 个长度单位。 然后他又想把这些木棍恢复到为裁截前的状态&#xff0c;但忘记了初始时有多少木棒以及木棒的初始…