消息队列
已收录文章：25篇
-
文章 · java教程 | 1个月前 | 消息队列 · Java · 事务 · 架构设计 · Spring Boot · spring boot 最终一致性 事务消息表 Outbox Pattern 订单通知订单状态写入数据库后再发送通知，最容易出现数据库成功而消息丢失的窗口。本文用 Spring Boot 和 outbox_event 表，把业务写入与待发送事件放进同一个事务，再用独立发送器处理重试、幂等和失败回退。498 收藏
-
Redis Stream 消费组出现 pending 积压时，先用 XPENDING 看数量和空闲时间，再用 XAUTOCLAIM 接管超时消息，最后通过幂等、分批和回滚把积压安全排空。494 收藏
-
Python logging 的 QueueHandler 能把业务线程和日志写入解耦，但队列满、监听线程退出顺序不对时会出现丢日志。本文拆开背压处理、队列容量和优雅退出的边界，给出可复现的验收代码。473 收藏
-
Redis Stream 消费组出现消息堆积时，先用 XPENDING 判断待处理消息的数量、最老时间和消费者归属，再用 XAUTOCLAIM 接管超时消息，最后按小批量确认、失败重试和监控恢复顺序处理。439 收藏
-
作者 | 丕天Redis是目前最受欢迎的kv类数据库，当然它的功能越来越多，早已不限定在kv场景，消息队列就是Redis中一个重要的功能。Redis从2010年发布1.0版本就具备一个消息队列的雏形，随着10407 收藏
-
Redis Streams 使用 XREADGROUP 时，空结果不一定代表没有消息。本文从 BLOCK 超时、已确认消息和 XPENDING 消费者状态三条线核对消息是否真正读到，并给出可复查的命令与边界。382 收藏
-
前言 在学习过程中发现redis的zset还可以用来实现轻量级的延时消息队列功能，虽然可靠性还有待提高，但是对于一些对数据可靠性要求不那么高的功能要求完全可以实现。本次主要采用了redis中368 收藏
-
WebSocket 上线后常见问题不是连接不上，而是断线后状态混乱、消息丢失、重复重连。本文按完整工作流拆解心跳检测、退避重试、恢复订阅和离线消息补发。365 收藏
-
Redis BZMPOP 能从多个有序集合中按最低或最高分值批量弹出成员，空集合时还能等待生产者写入。本文通过最小命令、返回结构、COUNT 边界和超时路径，说明它与 BZPOPMIN、ZMPOP 的差异以及上线前的阻塞连接检查。348 收藏
-
1.redis 用zset做消息队列如何处理消息积压 改变消费者的消费能力： 可以增加消费者的数量，或者优化消费者的消费能力，使其能够更快地处理消息。同时，可以根据消息队列中消息的345 收藏
-
在 Redis Streams 下游，ACK 只是消费确认，不是消息删除；pending 列表、last-delivered-id 与重试窗口一起决定消息是否真正安全出队。本文用 redis-cli 的最小链路验证常见误区和可上线检查点。339 收藏
-
golang监听消息队列rabbitmq任务脚本，当rabbimq消息队列断开连接后自动重试，重新唤起协程执行任务 需求背景： goalng常驻内存任务脚本监听rbmq执行任务 任务脚本由supervisor来管理 当rabbitmq长时间323 收藏