消息持久化 共 2 篇文章

Python异步队列asyncio.Queue在消费者崩溃后的消息丢失
2026-06-12 00:43:37
Python异步队列asyncio.Queue在消费者崩溃后的消息丢失 在基于 asyncio.Queue 构建的生产者消费者系统中,消费者协程意外崩溃是一个常见但棘手的问题。默认情况下,asyncio.Queue 提供的“取出即消费”的语义,意味着当一个任务从队列中被取出(queue.get)后,
Python异步队列 消息丢失 消费者崩溃
50 0
Redis Pub/Sub消息丢失的原因与Stream的持久化替代
2026-05-10 20:25:54
Redis Pub/Sub 消息丢失的原因与 Stream 的持久化替代 Redis 的 Pub/Sub(发布/订阅)模式是构建实时消息系统的常用工具。它允许发布者将消息发送到频道,而所有订阅该频道的订阅者都能收到消息。然而,它有一个致命的弱点:消息可能丢失。本文将深入分析 Redis Pub/Su
Redis Pub/Sub 消息丢失
154 0