消息中间件

| |

本文将深入探讨现代操作系统中进程间通信（IPC）的机制与实现。我们将从基本原理开始，逐步解析管道、信号量、共享内存及消息队列等主要技术的原理和应用。通过实际案例，我们还将展示这些技术在真实系统中的应用效果和性能表现。

| |

本文介绍了RocketMQ中消费进度的持久化机制，包括普通消息和延迟消息的消费偏移量是如何存储的。普通消息的消费进度存储于`consumerOffset.json`文件，格式为`{Topic}@{ConsumerGroup}`，而延迟消息则存储于`delayOffset.json`文件，以`{delayLevel:offset}`的形式记录。文章详细分析了相关文件内容及代码实现，并指出Broker分别以5秒和10秒的间隔进行持久化操作。

| |

大家好，我是小米，一个热爱分享技术经验的29岁程序员。本文主要探讨了解耦的概念及其在秒杀系统中的应用，特别是如何通过解耦提升系统的扩展性和容错能力。文中对比了HTTP/RPC同步调用和消息队列两种方式，分析了各自的优缺点及适用场景，帮助大家更好地选择合适的解耦方案。希望本文能让大家对解耦有更深入的理解。

| |

玩转RabbitMQ声明队列交换机、消息转换器

| | |

本文源自阿里云高级研发工程师周云峰在Apache Asia Community OverCode 2024的分享，内容涵盖从“流批一体”到“流批融合”的演进、技术解决方案及社区进展。流批一体已在API、算子和引擎层面实现统一，但用户仍需手动配置作业模式。流批融合旨在通过动态调整优化策略，自动适应不同场景需求。文章详细介绍了如何通过量化指标（如isProcessingBacklog和isInsertOnly）实现这一目标，并展示了针对不同场景的具体优化措施。此外，还概述了社区当前进展及未来规划，包括将优化方案推向Flink社区、动态调整算子流程结构等。

| |

先赞后看，南哥助你Java进阶一大半其实抖音的实时音视频技术RTC，是来源于火山引擎RTC的支持，抖音、火山引擎、巨量引擎属于字节跳动公司旗下的不同业务板块。我是南哥，一个Java学习与进阶的领路人。相信对你通关面试、拿下Offer进入心心念念的公司有所帮助。

| | |

| |

本文由程序员小米分享，详细介绍了如何通过异步处理简化秒杀请求中的业务流程，提高系统效率与稳定性。主要内容包括秒杀场景的挑战、核心思路、核心业务（生成订单、扣减库存）及次要业务（发放优惠券、增加积分）的异步处理方法，并探讨了使用消息队列的优势及优化用户体验的策略。通过异步处理，系统能更好地应对高并发请求，提升响应速度和稳定性。

| |

本文将探讨操作系统中的核心概念——进程间通信（IPC），揭示其在系统运作中的重要性及实现方式。通过分析不同类型的IPC手段，如管道、信号、共享内存等，帮助读者更好地理解操作系统的内部工作原理及其在实际应用中的表现。

| |

RabbitMQ:交换机详解(Fanout交换机、Direct交换机、Topic交换机)