消息队列-月伴飞鱼

行动起来，活在当下

累计撰写 126 篇文章
累计创建 31 个标签
累计收到 1 条评论

目录CONTENT

以下是消息队列相关的文章

2025-04-16
在 Kafka 消费端，如果使用非公平锁来保证相同 key 顺序处理，这对 Kafka 消费有什么影响？在 Kafka 消费端，如果使用非公平锁（ReentrantLock 默认非公平）来保证相同 key 顺序处理，可能会导致以下问题：热点 key 竞争严重时，部分线程可能长期拿不到锁，影响消费效率。消息在 Kafka 中堆积，因为部分 key 的消息无法及时消费。 max.poll.inte
- 2025-04-16
- 6
- 0
- 1
- KAFKA
- 消息队列
2025-04-01
RocketMQ发送消息默认是同步的还是异步的？ RocketMQ 发送消息默认是异步的。详细说明：同步发送：在同步发送模式下，客户端在发送消息时会等待消息发送成功的响应。即，发送操作是阻塞的，直到消息发送成功或失败才会返回。异步发送：在异步发送模式下，客户端发送消息后不会等待响应，而是通过回调函数来接收发送结果。发送操作是非阻塞的，客户
- 2025-04-01
- 7
- 0
- 1
- 消息队列
- RocketMQ
2025-03-29
KAFKA消费加锁是加公平锁好还是非公平锁好？在 Kafka 消费端对相同 key 的消息加锁，目的是保证相同 key 的消息按顺序处理。那么，应该使用公平锁还是非公平锁，取决于业务需求和并发场景。公平锁 vs. 非公平锁
- 2025-03-29
- 11
- 0
- 1
- KAFKA
- 消息队列
2025-03-26
RocketMQ队列和消费者是如何计算对应关系的？在 RocketMQ 中，消息队列（Queue）与消费者（Consumer）之间的对应关系由消费者组（Consumer Group）和负载均衡机制（Load Balancing）决定。以下是具体的计算方式及原理整理。 1. 核心概念 (1) 消息队
- 2025-03-26
- 6
- 0
- 1
- 消息队列
- RocketMQ
2025-03-21
KAFKA消费者消费消息慢，会对KAFKA有什么影响？ Kafka 消费者消费消息慢（10 多分钟），会对 Kafka 产生以下影响： 1. 分区滞后（Lag 增大）影响：消费者消费速率低于生产速率时，consumer lag（积压消息数）会持续增加。若消费积压过大，可能导致磁盘占用增加，甚至影响生产者写入性能。查看 Lag： kafka-con
- 2025-03-21
- 13
- 0
- 1
- KAFKA
- 消息队列
2025-03-19
死信队列队列里的消息是会一直保存吗？死信队列（DLQ）中的消息不会一直保存。它们通常会根据不同的消息队列系统的配置和策略，达到一定的条件后被删除。具体情况如下： 1. RocketMQ 死信队列（DLQ）：消息在无法被正常消费时（如超过最大重试次数、消息过期等），会被送入死信队列。存储时间（TTL）：死信队列中的消息有一定的过期
- 2025-03-19
- 10
- 0
- 1
- 消息队列
2025-03-16
KAFKA如何设置一个Topic只对应一个Partition？在 Kafka 中，设置一个 Topic 只对应一个 Partition 的方法如下：创建 Topic 时设置分区数为 1 使用 kafka-topics.sh 工具在创建 Topic 时，通过指定分区数为 1 来实现： kafka-topics.sh --create \ --bootstrap
- 2025-03-16
- 10
- 0
- 1
- 消息队列
- KAFKA
2025-03-15
RocketMQ消息重试的原理是什么？ RocketMQ 的消息重试机制旨在确保消息可靠消费，即使在消费失败的情况下，通过重试机制保证消息最终被成功处理。以下是其原理及实现的具体说明。 1. 消息重试的触发条件当消费者消费消息失败时，RocketMQ 会根据消费结果判断是否需要重试：消费者返回 RECONSUME_LATER 或 S
- 2025-03-15
- 7
- 0
- 1
- 消息队列
- RocketMQ
2025-03-10
RocketMQ顺序消息如何增加吞吐量？ RocketMQ顺序消息（Ordered Message）保证消息严格按照顺序消费，但顺序消费天然会限制消息吞吐量。如果需要提高吞吐量，可以从以下几个维度进行优化：增加队列数（合理划分队列粒度）顺序消息在RocketMQ中是基于单个Queue顺序消费的，队列越多，并发消费能力就越强。实践：
- 2025-03-10
- 16
- 0
- 1
- RocketMQ
- 消息队列
2025-03-07
RocketMQ和Kafka的零拷贝有什么区别？ Linux中的零拷贝技术 mmap + write mmap 和 sendfile 是 Linux 中常见的零拷贝技术，通过减少数据复制的次数来提高文件传输性能。 mmap mmap 是一种内存映射技术，可以通过映射文件到进程的内存空间来共享数据，减少了传统 I/O 操作中的数据复制次数。与传统
- 2025-03-07
- 6
- 0
- 1

1
2