首页 > 其他分享 >【IT老齐046】RabbitMQ队列解决消息积压问题

【IT老齐046】RabbitMQ队列解决消息积压问题

时间:2024-03-18 14:46:18浏览次数:24  
标签:信审 积压 队列 RabbitMQ 老齐 死信 消息 046

【IT老齐046】RabbitMQ队列解决消息积压问题

场景

每天上午10点,全国2万多名客户经理集中录入上一日JK单据到BorrowSale系统,峰值能达到500单/s。但信审系统任务重,最多只支持到60单/s,每日会导致大量消息积压

1710730144579

解决方案

工作队列

RabbitMQ改为工作队列模式,将消息送给9个信审系统实例并行完成。但信审系统不愿配合,以预算不足为由拒绝

1710730116071

死信队列

  • 什么是死信?
    • 即过期或无法处理的消息。
  • 死信是怎么产生的?
    • 消费者拒绝接受,且没有重新入列的消息
    • 队列满了,无法入列的消息
    • 消息设置了TTL过期时间,超过有效时间后的消息
    • 队列设置了TTL过期时间,超过有效时间后的消息

依赖RabbitMQ的“死信队列”特性,将死信消息自动送达死信队列中,BS前台接收到死信消息,1小时后重新发送,等待闲时由信审系统进行处理。
这样便实现了在不增加资源的前提下,对信审系统资源,进行“削峰填谷”

1710730320536

标签:信审,积压,队列,RabbitMQ,老齐,死信,消息,046
From: https://www.cnblogs.com/faetbwac/p/18080350

相关文章

  • 【IT老齐048】Kafka高性能原因
    【IT老齐048】Kafka高性能磁盘顺序读写定期批量删除指定数据页缓存Kafka避免使用JVM,直接使用操作系统的页缓存特性提高处理速度,进而避免了JVMGC带来的性能损耗。Kafka采用字节紧密存储,避免产生对象,这样可以进一步提高空间利用率零拷贝批量操作......
  • window7系统 rabbitmq服务启动不了
    问题描述:解决方案:1.检查win7是否是sp1版本桌面计算机鼠标右键属性,打开系统属性窗口,如下图所示:2.如果不是,下载windows6.1-kb976932-x64补丁安装,安装完成后重启电脑3.电脑重启后,下载vcredist_x64或者vcredist_x86软件安装(根据系统32位还是64位,下载不同的安装包安装),安装完成......
  • 【NC23046】华华教月月做数学
    题目华华教月月做数学考虑数据溢出的问题思路题目要求很简单,就是算aaa的bb......
  • 自学rabbitmq入门到精通
    交换机的fault(发布与订阅模式)因为消息是由生产者发送给excahnge,exchange发送给队列,然后由队列发送给消费者的。展示使用图形化界面使用fanout模式。创建交换机然后创建三个队列,绑定对应的交换机,发现给交换机发送消息给队列,3个队列同都收到了消息direct模式 相对......
  • RabbitMq 集成到 SpringBoot
    1.最低配置使用1.添加依赖<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId><version>2.3.2.RELEASE</version></dependency><dependency>&......
  • RabbitMQ入门
    RabbitMq入门目录RabbitMq入门1.MQ1.1同步调用1.2异步调用1.3MQ技术选型2.RabbitMQ2.1安装2.2收发消息(交换机、队列)2.3数据隔离2.3.1用户管理2.3.2VirtualHost3.SpringAMQP3.1创建项目3.2快速入门3.2.1消息发送3.2.2消息接收3.2.3总结3.3WorkQueues模型3.3.1消费者消息推送限制3......
  • Python实现http接口请求数据后,往RabbitMQ里面插入数据
    python实现http接口请求数据服务后,往RABBITmq里面插入数据importtimeimportrequestsimportpikaimportdatetimebase_url='https://www.okx.com'api_url='/api/v5/market/history-mark-price-candles'#时间颗粒度[1m/3m/5m/15m/30m/1H/2H/4H]time_unit=[......
  • yii2+rabbitmq实现队列(windows)
    1.安装Erlang官方网站,https://erlang.org/download/otp_versions_tree.html,选择和rabbitmq适配的2.安装RabbitMQ官方网站,windows:https://www.rabbitmq.com/docs/install-windows3.安装下载的Erlang和RabbitMQ 碰到的问题:1.开启rabbitmq服务时dos窗口一闪而逝,看了服务进程......
  • 开源.NET8.0小项目伪微服务框架(分布式、EFCore、Redis、RabbitMQ、Mysql等)
    1、前言为什么说是伪微服务框架,常见微服务框架可能还包括服务容错、服务间的通信、服务追踪和监控、服务注册和发现等等,而我这里为了在使用中的更简单,将很多东西进行了简化或者省略了。年前到现在在开发一个新的小项目,刚好项目最初的很多功能是比较通用的,所以就想着将这些功能......
  • L1-046 整除光棍
    模拟竖式除法。最好在纸上写一写,111/13,1111/13,1111/13。每次结果的余数后面加一个1就相当于是在被除数后面加了一个1.还有,a数组要开的足够大。#include<bits/stdc++.h>usingnamespacestd;intmain(){ intn,single=1; cin>>n; intcnt=1;//1有多少位 while(single<......