欢迎来到尧图网

客户服务 关于我们

您的位置:首页 > 文旅 > 美景 > 【安装指南】Centos7 在 Docker 上安装 RabbitMQ4.0.x

【安装指南】Centos7 在 Docker 上安装 RabbitMQ4.0.x

2025/5/3 6:17:26 来源:https://blog.csdn.net/m0_75022408/article/details/147671710  浏览:    关键词:【安装指南】Centos7 在 Docker 上安装 RabbitMQ4.0.x

目录

前置知识:RabbitMQ 的介绍

一、单机安装 RabbitMQ 4.0.7版本

1.1 在线拉取镜像

二、延迟插件的安装

2.1 安装延迟插件

步骤一:下载延迟插件

步骤二:将延迟插件放到插件目录

步骤三:启动延迟插件

步骤四:重启 RabbitMQ 服务

步骤五:验收成果

步骤六:手动创建延迟交换机(可选)


前置知识:RabbitMQ 的介绍

RabbitMQ 是一个开源的 ​消息代理(Message Broker)​,实现了 ​AMQP(Advanced Message Queuing Protocol)​​ 协议,用于在分布式系统中异步传递消息。

  • 核心角色​:生产者(Producer)、消费者(Consumer)、队列(Queue)、交换机(Exchange)。
  • 核心优势​:解耦、异步、削峰填谷、可靠性。

常见的MQ消息中间件有很多,例如ActiveMQRabbitMQKafkaRocketMQ等等。那么为什么我们要使用它呢?因为它能很好的帮我解决一些复杂特殊的场景:

1️⃣ 高并发的流量削峰

举个例子,假设某订单系统每秒最多能处理一万次订单,也就是最多承受的10000qps,这个处理能力应付正常时段的下单时绰绰有余,正常时段我们下单一秒后就能返回结果。但是在高峰期,如果有两万次下单操作系统是处理不了的,只能限制订单超过一万后不允许用户下单。使用消息队列做缓冲,我们可以取消这个限制,把一秒内下的订单分散成一段时间来处理,这时有些用户可能在下单十几秒后才能收到下单成功的操作,但是比不能下单的体验要好。

2️⃣ 应用解耦

以电商应用为例,应用中有订单系统、库存系统、物流系统、支付系统。用户创建订单后,如果耦合调用库存系统、物流系统、支付系统,任何一个子系统出了故障,都会造成下单操作异常。当转变成基于消息队列的方式后,系统间调用的问题会减少很多,比如物流系统因为发生故障,需要几分钟来修复。在这几分钟的时间里,物流系统要处理的内存被缓存在消息队列中,用户的下单操作可以正常完成。当物流系统恢复后,继续处理订单信息即可,中单用户感受不到物流系统的故障,提升系统的可用性。

3️⃣ 异步处理

有些服务间调用是异步的,例如 A 调用 B,B 需要花费很长时间执行,但是 A 需要知道 B 什么时候可以执行完,以前一般有两种方式,A 过一段时间去调用 B 的查询 api 查询。或者 A 提供一个 callback api, B 执行完之后调用 api 通知 A 服务。这两种方式都不是很优雅,使用消息队列,可以很方便解决这个问题,A 调用 B 服务后,只需要监听 B 处理完成的消息,当 B 处理完成后,会发送一条消息给 MQ,MQ 会将此消息转发给 A 服务。这样 A 服务既不用循环调用 B 的查询 api,也不用提供 callback api。同样B 服务也不用做这些操作。A 服务还能及时的得到异步处理成功的消息。

4️⃣ 分布式事务

以订单服务为例,传统的方式为单体应用,支付、修改订单状态、创建物流订单三个步骤集成在一个服务中,因此这三个步骤可以放在一个jdbc事务

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com

热搜词