消息队列
已收录文章：15篇
-
Redis Stream 消费组出现 pending 积压时，先用 XPENDING 看数量和空闲时间，再用 XAUTOCLAIM 接管超时消息，最后通过幂等、分批和回滚把积压安全排空。494 收藏
-
Golang · Go问答 | 2个月前 | golang · 消息队列 · 性能优化 · websocket · 高并发 · Go WebSocket广播 Go慢客户端 WebSocket发送队列 Go Hub分片 WebSocket背压Go WebSocket 广播卡顿，常常不是 CPU 不够，而是一条慢连接把广播路径堵住了。本文从一个房间广播现场出发，说明为什么要给每个客户端独立发送队列、如何确定队列满时的业务策略，以及何时需要按房间分片 Hub，并给出可观测的检查项。146 收藏
-
Redis Streams 消费者在确认消息前宕机时，消息会留在待确认列表。本文说明如何通过 XAUTOCLAIM 有节制地接管超时消息，并监控重试与清理结果。110 收藏