您可以捐助,支持我们的公益事业。

1元 10元 50元





认证码:  验证码,看不清楚?请点击刷新验证码 必填



  求知 文章 文库 Lib 视频 iPerson 课程 认证 咨询 工具 讲座 Model Center   Code  
会员   
   
 
     
   
 订阅
  捐助
消息中间件简介及ActiveMQ 下载、安装
 
作者: Woo_home
  1788  次浏览      15
 2020-7-7 
 
编辑推荐:
本文主要讲解了什么是消息中间件?消息中间件引出产生背景,消息中间件的定义、常用的消息中间件有哪些?及ActiveMQ 下载、安装。

来自于csdn,,由火龙果软件Anna编辑、推荐。

什么是消息中间件?

上面提到过消息中间件,那么什么是消息中间件呢?

消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流,并基于数据通信来进行 分布式系统 的集成。通过提供消息传递和消息排队模型,它可以在分布式环境下扩展进程间的通信

消息中间件引出产生背景

一、系统之间接口耦合比较严重

系统之间直接调用实际工程落地和存在问题

微服务架构后,链式调用是我们在写程序时候的一般流程,为了完成一个整体功能会将其拆分成多个函数(或子模块),比如模块 A 调用模块 B,模块 B 调用模块 C,模块 C 调用模块 D。但在大型分布式应用中,系统间的 RPC 交互繁杂,一个功能背后要调用上百个接口并非不可能,从单机架构过渡到分布式服务架构的通例,这种架构会有哪些问题?

系统之间接口耦合比较严重

每新增一个下游功能,都要对上有相关接口进行改造;

举个例子:假如系统 A 要发送数据给系统 B 和 C,发送给每个系统的数据可能有差异,因此系统 A 对要发送给每个系统的数据进行了组装,然后逐一发送;

当代码上线后又新增了一个需求:

把数据也发送给 D,新上了一个 D 系统也要接受 A 系统的数据,此时需要修改 A 系统,让它感知到 D 的存在,同时把数据处理好 A 再给 D。在这个过程中你会发现,每接入一个下游系统,都要对 A 系统进行代码改造,开发联调的效率很低。其整体架构如下图

二、面对大流量并发时,容易被冲垮

每个接口模块的吞吐量能力是有限的,这个上限能力如果堤坝,当大流量(洪水)来临时,容易被冲垮

举个例子秒杀业务:

上游系统发起下单购买操作,就是下单一个操作

下游系统完成秒杀业务逻辑

(读取订单、库存检查、库存冻结、余额检查、余额冻结、订单生成、余额扣减、库存扣减、生成流水、余额解冻、库存解冻)

三、等待同步存在性能问题

RPC 接口基本上是 同步调用,整体服务性能遵循 “木桶理论”,即 整体系统的耗时取决于链路中 最慢的 那个接口

比如 A 调用 B/C/D 都是 50ms,但此时 B 又调用了 B1,花费 2000 ms,那么直接就拖累了整个服务性能

如何解决?

要做到系统解耦,当新的模块接进来时,可以做到代码改动最小;能够解耦

设置流量缓冲池,可以让后端系统按照自身吞吐能力进行消费,不被冲垮;能够削峰

强弱依赖梳理能将非关键调用链路的操作异步化并提升整体系统的吞吐能力;能够异步

消息中间件的定义

面向消息的中间件(Message-Oriented Middleware)MOM 能够很好的解决以上问题

是指利用高效可靠的消息传递机制进行平台无关的数据交流,并基于数据通信来进行分布式系统的集成。通过提供 消息传递 和 消息排队 模型在分布式环境下提供应用解耦、弹性伸缩、冗余存储、流量削峰、异步通信、数据同步等功能

大致的过程是这样的:

发送者把消息发送给消息服务器,消息服务器将消息存放在若干个 队列 / 主题 中,在合适的时候,消息服务器会将消息转发给接收者。在这个过程中,发送和接收是异步的,也就是发送无需等待,而且发送者和接收者的生命周期也没有必然关系;尤其在发布 pub / 订阅 sub 模式下,也可以完成一对多的通信,即让一个消息有多个接收者

特点

采用异步处理模式

消息发送者可以发送一个消息而无须等待响应。消息发送者将消息发送到一条虚拟的通道(主题或队列上);消息接收者则订阅或监听该通道。一条信息可能最终转发给一个或者多个消息接收者,这些接收者都无需对消息发送者做出同步回应,整个过程都是异步的

案例:

也就是说,一个系统跟另一个系统之间进行通信的时候,假如系统 A 希望发送一个消息给系统 B,让它去

处理

但是系统 A 不关注系统 B 到底怎么处理或者有没有处理好,所以系统 A 把消息发送给 MQ,然后就不管这条消息了,接着系统 B 从 MQ 里消费出来处理即可。至于怎么处理,是否处理完毕,什么时候处理,都是系统 B 的事,与系统 A 无关

这样的一种通信方式,就是所谓的 “异步” 通信方式对于系统 A 来说,只要把消息发送给 MQ,然后系统 B 就会异步的去进行处理了,系统 A 不需要 “同步” 的等待系统 B 处理完。这样的好处是什么呢?两个字:解耦

应用系统之间解耦合

常用的消息中间件有哪些?

ActiveMQ 官网

ActiveMQ 官网地址

ActiveMQ下载

下载地址

根据对应的版本下载即可

下载之后解压的目录结构如下(本文基于 Windows 环境):

ActiveMQ 最主要的功能

实现高可用

高性能

可伸缩

易用和安全的企业级面向消息服务的系统

启动 ActiveMQ

进入到 ActiveMQ 的 bin 目录输入以下命令即可启动 ActiveMQ

activemq start

访问 ActiveMQ 的 admin 页面

启动之后访问 http://localhost:8161/admin/ 即可访问 ActiveMQ 的 admin 页面

如果需要输入用户名和密码的可以在 ActiveMQ 的 conf 目录下查看 jetty-realm.properties 文件,默认是用户名和密码都是 admin

 

   
1788 次浏览       15
相关文章

企业架构、TOGAF与ArchiMate概览
架构师之路-如何做好业务建模?
大型网站电商网站架构案例和技术架构的示例
完整的Archimate视点指南(包括示例)
相关文档

数据中台技术架构方法论与实践
适用ArchiMate、EA 和 iSpace进行企业架构建模
Zachman企业架构框架简介
企业架构让SOA落地
相关课程

云平台与微服务架构设计
中台战略、中台建设与数字商业
亿级用户高并发、高可用系统架构
高可用分布式架构设计与实践