消息队列-持续更新中

news/2025/2/22 6:37:13

消息队列

0、消息队列官方参考文档

MQ官方参考文档
RocketMQ 官方文档: https://rocketmq.apache.org/docs/quick-start/
RocketMQ 中国开发者中心:http://rocketmq.cloud/zh-cn/
Kafka 官方文档: http://kafka.apache.org/documentation/
RabbitMQ 官方文档: https://www.rabbitmq.com/documentation.html

1、为什么需要消息队列

(1)异步处理:
比如秒杀场景需要5个步骤:风险控制、库存锁定、生成订单、短信通知、数据统计
如果同步处理完这5个步骤再返回秒杀结果,耗时较长
使用MQ时,可以只完成风险控制、库存锁定步骤,发送MQ消息,订单服务、短信服务、数据统计服务消费该消息
好处:秒杀期间把资源用于秒杀请求,秒杀结束后再处理后续步骤
在这里插入图片描述

(2)流量控制:
秒杀场景,使用消息队列隔离网关和后端服务,防止后端系统被打爆
在这里插入图片描述

(3)服务接耦:
如电商系统中,订单服务需要讲订单数据同步到下游的支付系统、风控系统、客服系统等
如果使用接口调用,需要维护与多个下游系统的接口交互
使用MQ,订单服务只需要把订单实时数据及变更发送到消息队列,下游服务订单主题

2、如何选择消息队列

在这里插入图片描述
Kafka更关注的是整体的吞吐量,设计思想为批量和异步
RocketMQ的设计选择更多的是尽量及时处理请求
所以RocketMQ响应时延更低,配置合理时,可达2~3毫秒


http://www.niftyadmin.cn/n/5861816.html

相关文章

伪404兼容huawei生效显示404

根据上述思考,以下是详细的中文分步说明: --- **步骤 1:获取目标设备的User-Agent信息** 首先,我们需要收集目标设备的User-Agent字符串,包括: 1. **iPhone设备的User-Agent**: Mozi…

大数据组件(四)快速入门实时数据湖存储系统Apache Paimon(3)

Paimon的下载及安装,并且了解了主键表的引擎以及changelog-producer的含义参考: 大数据组件(四)快速入门实时数据湖存储系统Apache Paimon(1) 利用Paimon表做lookup join,集成mysql cdc等参考: 大数据组件(四)快速入门实时数据…

电力通信物联网应用,国密网关守护电力数据安全

电力国密网关是用于保护电力调度数据网路由器和电力系统的局域网之间通信安全的电力专用网关机,主要为上下级控制系统之间的广域网通信提供认证与加密服务,实现数据传输的机密性、完整性。 国密算法网关功能特点 身份认证:对接入的设备和用户…

Docker Swarm 内置的集群编排

在现代容器化应用中,容器编排(Container Orchestration)是至关重要的,它负责自动化容器的部署、扩展、负载均衡和管理。Docker Swarm 是 Docker 提供的原生集群管理和容器编排工具,允许用户通过 Docker CLI 在多个 Doc…

rk3588/3576板端编译程序无法运行视频推理

图片推理可以,但是视频不行,运行视频推理报错:segment fault. 我遇到的问题原因是ffmpeg安装有问题,可以先在板端运行:ffmpeg -version ffmpeg version 4.2.4-1ubuntu1.0firefly6 Copyright (c) 2000-2020 the FFmpe…

出行项目案例

spark和kafka主要通过Scala实现,Hadoop和HBase主要基于java实现。 通过该项目,主要达到以下目的: (1)通用的数据处理流程,入门大数据领域 (2)真实体验大数据开发工程师的工作 &a…

matlab 专家pid和普通pid控制对比

1、内容简介 matlab149-专家pid和普通pid控制对比 可以交流、咨询、答疑 2、内容说明 略 3、仿真分析 略 4、参考论文 略

一个Flutter跨4端开发的案例

哈喽,我是老刘 老刘做Flutter开发6年多了,在手机端的案例见到很多,PC端的确实比较少。 Flutter也的确不是PC端开发的首选。 不过前段时间无意见发现一个Flutter跨Windows、Mac、Android和iOS四个端的典型例子,百度输入法。 事情是…