RocketMQ 消费进度持久化
本文介绍了RocketMQ中消费进度的持久化机制，包括普通消息和延迟消息的消费偏移量是如何存储的。普通消息的消费进度存储于`consumerOffset.json`文件，格式为`{Topic}@{ConsumerGroup}`，而延迟消息则存储于`delayOffset.json`文件，以`{delayLevel:offset}`的形式记录。文章详细分析了相关文件内容及代码实现，并指出Broker分别以5秒和10秒的间隔进行持久化操作。
抢购不再卡顿！揭秘异步处理如何优化秒杀流程！
本文由程序员小米分享，详细介绍了如何通过异步处理简化秒杀请求中的业务流程，提高系统效率与稳定性。主要内容包括秒杀场景的挑战、核心思路、核心业务（生成订单、扣减库存）及次要业务（发放优惠券、增加积分）的异步处理方法，并探讨了使用消息队列的优势及优化用户体验的策略。通过异步处理，系统能更好地应对高并发请求，提升响应速度和稳定性。
RocketMQ消息回溯实践与解析
在分布式系统和高并发应用的开发中，消息队列扮演着至关重要的角色，而RocketMQ作为阿里巴巴开源的一款高性能消息中间件，以其高吞吐量、高可用性和灵活的配置能力，在业界得到了广泛应用。本文将围绕RocketMQ的消息回溯功能进行实践与解析，分享工作学习中的技术干货。