www.zhifeiya.cn

敲码拾光专注于编程技术，涵盖编程语言、代码实战案例、软件开发技巧、IT前沿技术、编程开发工具，是您提升技术能力的优质网络平台。

MessageQueue 即消息队列，是一种在软件系统中用于异步传输和存储消息的组件，它允许不同的应用程序、模块或服务之间通过发送和接收消息来进行通信和协作，以实现解耦、削峰填谷和异步处理等功能，提高系统的可扩展性、稳定性和性能。

17
1月

Kafka消费者组偏移量丢失：原因、恢复方案及注意事项全解析

本文详细解析Kafka消费者组偏移量丢失的原因、恢复方案及应用场景，助力解决Kafka消息消费中的核心问题。偏移量作为Kafka消费位置的“书签”，其丢失易引发数据漏处理或重复消费，常见诱因包括消费者异常退出、集群故障及配置错误。文中提供手动重置偏移量、从头消费、外部存储恢复等实用方案，搭配Java代码示例直观演示操作。同时分析各方案优缺点，强调数据一致性、性能影响及外部存储维护要点，为实时数据分析、金融交易等场景提供可靠指导，保障Kafka消息队列系统稳定运行与数据准确处理。
MessageQueue Kafka
04
1月

RabbitMQ默认消息队列问题，解决措施大公开

本文深入探讨了 RabbitMQ 默认消息队列存在的常见问题，包括消息丢失、性能瓶颈和消息堆积等，并针对这些问题给出了详细的解决措施，如消息持久化、集群部署、增加消费者数量等。此外，还介绍了 RabbitMQ 的应用场景、技术优缺点以及注意事项，帮助读者全面了解和使用 RabbitMQ。
RabbitMQ Cluster MessageQueue HAProxy Deployment
03
1月

Kafka消息积压？解决默认分区分配的问题

本文深入探讨Kafka消息积压问题的根源，详细分析默认分区分配策略的缺陷，并提供StickyAssignor和自定义分配策略的完整解决方案。通过实际代码示例展示如何优化消费者性能，包含Java Spring Boot配置、Kubernetes扩缩容策略等实战内容，帮助开发者彻底解决高并发场景下的消息积压难题。
HighConcurrency MessageQueue Java
29
12月

解决RabbitMQ默认消息队列堆积的策略

本文详细介绍了解决RabbitMQ默认消息队列堆积的策略，包括增加消费者数量、优化消费者处理逻辑、提高服务器性能、消息分类和优先级处理以及消息拆分和批量处理等。结合丰富的示例代码，分析了这些策略的应用场景、优缺点和注意事项，能帮助开发者更好地应对消息队列堆积问题，确保系统的稳定运行。
RabbitMQ MessageQueue Java SpringBoot
29
12月

Java 分布式事务深度对比：2PC 协议缺陷、TCC 模式补偿逻辑与本地消息表可靠性

本文深入对比了 Java 分布式事务中的 2PC 协议、TCC 模式和本地消息表。详细介绍了它们的应用场景、原理、优缺点和注意事项，并给出了相应的示例代码。2PC 协议能保证强一致性，但存在性能和单点故障问题；TCC 模式性能高、可扩展性强，但开发成本大；本地消息表数据一致性高、实现简单，但有消息处理延迟问题。通过本文，读者可以根据具体业务需求选择合适的分布式事务处理方式。
Transaction DistributedDeployment MessageQueue Java SpringBoot
24
12月

消息队列 RabbitMQ 死信队列：死信原因分析、处理策略与重试机制

本文深入探讨了RabbitMQ死信队列，详细分析了死信产生的原因，如消息被拒绝、过期、队列达到最大长度等。介绍了处理死信的策略，包括人工干预和自动重试，还讲解了重试机制，如固定间隔重试和指数退避重试。同时，阐述了死信队列的应用场景、技术优缺点和注意事项，帮助开发者更好地使用RabbitMQ死信队列，提高系统的稳定性和可靠性。
RabbitMQ MessageQueue PublishSubscribe Middleware
22
12月

Java消息队列：消息积压处理，消费能力优化

本文详细探讨了Java消息队列中消息积压处理和消费能力优化的问题。首先分析了消息积压的原因，包括生产者生产速度过快、消费者处理能力不足和网络问题等。接着介绍了处理消息积压的方法，如增加消费者数量、优化消费者代码和水平扩展消息队列。然后阐述了消费能力优化的策略，如批量消费、异步处理和优化消息处理逻辑。还介绍了应用场景、技术优缺点和注意事项。通过这些方法和策略，可以有效提高系统的性能和稳定性。
ThreadPool MessageQueue Java Async Kafka
21
12月

Java操作RabbitMQ：事务消息，确保消息可靠投递​

本文详细介绍了Java操作RabbitMQ事务消息，以确保消息可靠投递。首先阐述了RabbitMQ事务消息的概念和工作原理，接着介绍了其常见应用场景，如订单系统、数据同步和日志记录等。通过完整的Java示例演示了发送和接收事务消息的过程，并对代码进行了详细解释。还分析了事务消息的优缺点和注意事项，同时介绍了关联技术如发布确认机制、死信队列和消息重试机制。帮助开发者深入理解和掌握该技术，在实际应用中选择合适的消息投递方式。
RabbitMQ MessageQueue Java
20
12月

消息队列 RocketMQ 部署：NameServer 集群、Broker 主从与消息轨迹追踪

本文详细讲解了消息队列RocketMQ的部署，涵盖NameServer集群、Broker主从架构与消息轨迹追踪。阐述了各部分的应用场景、技术优缺点和注意事项，并给出详细部署步骤和示例代码。NameServer集群可提高可用性，Broker主从架构保障可靠性，消息轨迹追踪便于监控和排查问题。通过合理部署和注意相关要点，能确保RocketMQ系统高效稳定运行。
MessageQueue RocketMQ Broker
16
12月

Lua Redis 发布订阅深度应用：消息订阅机制、发布订阅模式缺陷与可靠消息实现

本文深入探讨了Lua Redis发布订阅的深度应用，详细介绍了消息订阅机制，分析了发布订阅模式的缺陷，如消息丢失、顺序问题和缺乏持久化支持等。同时，给出了可靠消息实现的方法，如结合消息队列和利用Redis持久化机制。还阐述了其应用场景、技术优缺点和注意事项。通过丰富的示例代码，帮助读者更好地理解和运用相关技术。
Redis MessageQueue PublishSubscribe Lua Middleware