加速mq消费的方式一

最近在线上出现mq消费慢的情况,

问题原因

1.消费处理本身就很慢,并且一次不成功,比如:上传文件操作,

2.重试多次还不成功;

解决办法;

创建一套新的mq,如果重试次数是1~20的,就放到中间车道;

重试次数20~100次的,就放到第三套环境中;

方案2

相同一套代码,监听不通的队列,

监听器1

/*** task实例启动的监听器** @author wenjianye*/
@Slf4j
@Component
@RabbitListener( queues = RabbitConsts.EXECUTE_TASK_INSTANCE_RETRY_TIMES_LESS_QUEUE)
public class ExecuteTaskInstanceRetryTimesLessListener extends AbstractRabbitHandler<ExecuteTaskInstanceParam> {@Autowiredprivate ExecuteTaskInstanceListenerHandle taskInstanceManageListenerHandle;@Overrideprotected ExecuteTaskInstanceParam transfer(Message message) {return super.transferFromJson(message);}@Overrideprotected MessageHandler<ExecuteTaskInstanceParam> getMessageHandler() {return this.taskInstanceManageListenerHandle;}@Overrideprotected void onError(ExecuteTaskInstanceParam message, Exception e) {log.error("task实例启动消息 {} 处理失败", JSON.toJSONString(message), e);super.basicReject(message, true);}

监听器2和3 只有一行代码不一样

@RabbitListener( queues = RabbitConsts.EXECUTE_TASK_INSTANCE_RETRY_TIMES_MORE_QUEUE)

@RabbitListener( queues = RabbitConsts.EXECUTE_TASK_INSTANCE_QUEUE)

可以通过配置指定,

加速mq消费的方式一相关推荐

mq消费的几种方式（从消费者角度出发）
从消费者的角度出发,分析一下消息消费的两种方式: push方式 pull方式 push方式消息消费的过程: 1. mq接收到消息 2. mq主动将消息推送给消费者(消费者需提供一个消费接口) mq属 ...
程序员过关斩将--真的可以用版本号的方式来保证MQ消费消息的幂等性？
灵魂拷问 MQ消息的消费为什么有时候要求幂等性? 你们都说可以用版本号来解决幂等性消费? 什么才是消息幂等性消费的根本性问题? 随着系统的复杂性不断增加,多数系统都会引入MQ来进行解耦,其实从引入MQ ...
保证MQ消费消息的幂等性，真可以用版本号的方式？
作者 | 菜v菜来源 | 架构师修行之路(ID:jiagoushixiuxing) 头图 | CSDN 下载自东方IC 灵魂拷问 MQ消息的消费为什么有时候要求幂等性? 你们都说可以用版本号来解决 ...
linux异构内存,Linux内核添加异构内存管理（HMM）将带来加速GPU的新方式，还有可能带来其他类型的机器学习硬件。...
一项旨在让机器学习或其他基于GPU的应用得以大幅提升性能的内存管理功能已开发了很长一段时间,不过现在它即将进入到Linux内核的某下一个版本中. 异构内存管理(HMM)让设备的驱动程序可以为受制于自身 ...
内含福利｜云栖攻略·解锁视频消费新方式
9月19日~9月22日杭城6万人大Party即将再度开启! 2场主论坛 / 170+场前沿峰会和分论坛涵盖众多前沿创新领域超过50%的分论坛只讲技术与产品你还在等什么呢? 今天为大家推荐的是 ...
Android中禁用硬件加速的几种方式
禁用硬件加速度 Android提供了四中级别的禁用硬件加速度的方式: Application 对整个应用禁用硬件加速度在AndroidManifest.xml中为application标签添加如下属 ...
对“中年油腻”Say No！家门口的精神生活消费新方式
因作家冯唐的一篇<如何避免成为一个油腻的中年猥琐男>的文章,"中年油腻"一词掀起了互联网的集体狂欢.百度百科对它的解释是:"中年油腻",是指那些不注 ...
网页视频加速-使用扩展程序方式-Global Speed
1.使用背景: 有些网页播放的视频没有倍速按键,但是又想倍速播放视频怎么办? 2.解决方案:使用网页的一个扩展程序-Global Speed即可 3.具体操作步骤: 1)下载扩展程序 2)打开浏览器扩 ...
阿里二面：千万级、亿级数据，如何性能优化？教科书级答案来了
说在前面在尼恩指导了几百个小伙伴的面试,在这些过程中, 非常.非常高频的一个面试题: 千万级数据,如何做性能优化? 亿级数据,如何做性能优化? 最近,有个小伙伴阿里二面,又遇到了这个问题. 其实,尼 ...

加速mq消费的方式一

加速mq消费的方式一相关推荐

最新文章

热门文章