搜索结果
查询Tags标签： 积压，共有 9条记录-
如何解决消息队列的延时以及过期失效问题？
如何解决消息队列的延时以及过期失效问题？消息队列满了以后该怎么处理？有几百万消息持续积压几小时，说说怎么解决？面试官心理分析 你看这问法，其实本质针对的场景，都是说，可能你的消费端出了问题，不消费了；或者消费的速度极其慢。接着就坑爹了，可能你的消息队列…
2022/8/29 6:25:11 人评论 次浏览 -
MQ的基本概念
MQ全称 Message Queue（消息队列），是在消息的传输过程中保存消息的容器。多用于分布式系统之间进 行通信。MQ 的优势和劣势 优势:应用解耦 系统的耦合性越高，容错性就越低，可维护性就越低。使用 MQ 使得应用间解耦，提升容错性和可维护性。 异步提速 提升用户体验和系…
2022/2/27 23:54:07 人评论 次浏览 -
rocketmq消息积压监控java代码实现
最近在做彩信下发，需要下发的内容是以消息的形式存放在rocektMQ,遇上彩信消息未下发的情况，需要实时去查各topic的消息积压量 1、启动时装配监控客户端的bean @Component public class MQAdminExtConfig {private static final Logger log = LoggerFactory.getLogger(MQ…
2021/10/25 11:39:45 人评论 次浏览 -
rocketmq消息积压监控java代码实现
最近在做彩信下发，需要下发的内容是以消息的形式存放在rocektMQ,遇上彩信消息未下发的情况，需要实时去查各topic的消息积压量 1、启动时装配监控客户端的bean @Component public class MQAdminExtConfig {private static final Logger log = LoggerFactory.getLogger(MQ…
2021/10/25 11:39:45 人评论 次浏览 -
我这三年被kafka坑惨了
前言 我的上家公司是做餐饮系统的，每天中午和晚上用餐高峰期，系统的并发量不容小觑。为了保险起见，公司规定各部门都要在吃饭的时间轮流值班，防止出现线上问题时能够及时处理。 我当时在后厨显示系统团队，该系统属于订单的下游业务。用户点完菜下单后，订单系统会通过…
2021/8/20 23:08:38 人评论 次浏览 -
我这三年被kafka坑惨了
前言 我的上家公司是做餐饮系统的，每天中午和晚上用餐高峰期，系统的并发量不容小觑。为了保险起见，公司规定各部门都要在吃饭的时间轮流值班，防止出现线上问题时能够及时处理。 我当时在后厨显示系统团队，该系统属于订单的下游业务。用户点完菜下单后，订单系统会通过…
2021/8/20 23:08:38 人评论 次浏览 -
Java Kafka 消费积压监控
Java Kafka 消费积压监控 后端代码： Monitor.java代码：package com.suncreate.kafkaConsumerMonitor.service;import com.suncreate.kafkaConsumerMonitor.model.ConsumerInfo; import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.clie…
2021/7/1 9:21:15 人评论 次浏览 -
我用kafka两年踩过的一些非比寻常的坑 【转载】
大家好，我是苏三，又和大家见面了。 前言 我的上家公司是做餐饮系统的，每天中午和晚上用餐高峰期，系统的并发量不容小觑。为了保险起见，公司规定各部门都要在吃饭的时间轮流值班，防止出现线上问题时能够及时处理。 我当时在后厨显示系统团队，该系统属于订单的下游业…
2021/5/18 10:55:44 人评论 次浏览 -
消息队列产生严重消息堆积怎么处理？
1. 为什么产生消息堆积？ 大多是因为 Consumer 出问题了，没有及时发现，或者故障恢复需要较长的时间，导致大量消息积压在 MQ 中。 2. 消息堆积会有什么后果呢？ 2.1 消息被丢弃 例如 RabbitMQ 有一个消息过期时间 TTL，过期的消息会被扔掉，这样消息就彻底没有了。 2.2 …
2021/5/17 10:27:59 人评论 次浏览
