消息队列
已收录文章：15篇
-
文章 · java教程 | 2星期前 | 消息队列 · Java · 事务 · 架构设计 · Spring Boot · spring boot 最终一致性 事务消息表 Outbox Pattern 订单通知订单状态写入数据库后再发送通知，最容易出现数据库成功而消息丢失的窗口。本文用 Spring Boot 和 outbox_event 表，把业务写入与待发送事件放进同一个事务，再用独立发送器处理重试、幂等和失败回退。498 收藏
-
Redis Stream 消费组出现 pending 积压时，先用 XPENDING 看数量和空闲时间，再用 XAUTOCLAIM 接管超时消息，最后通过幂等、分批和回滚把积压安全排空。494 收藏
-
作者 | 丕天Redis是目前最受欢迎的kv类数据库，当然它的功能越来越多，早已不限定在kv场景，消息队列就是Redis中一个重要的功能。Redis从2010年发布1.0版本就具备一个消息队列的雏形，随着10407 收藏
-
前言 在学习过程中发现redis的zset还可以用来实现轻量级的延时消息队列功能，虽然可靠性还有待提高，但是对于一些对数据可靠性要求不那么高的功能要求完全可以实现。本次主要采用了redis中368 收藏
-
WebSocket 上线后常见问题不是连接不上，而是断线后状态混乱、消息丢失、重复重连。本文按完整工作流拆解心跳检测、退避重试、恢复订阅和离线消息补发。365 收藏
-
1.redis 用zset做消息队列如何处理消息积压 改变消费者的消费能力： 可以增加消费者的数量，或者优化消费者的消费能力，使其能够更快地处理消息。同时，可以根据消息队列中消息的345 收藏
-
golang监听消息队列rabbitmq任务脚本，当rabbimq消息队列断开连接后自动重试，重新唤起协程执行任务 需求背景： goalng常驻内存任务脚本监听rbmq执行任务 任务脚本由supervisor来管理 当rabbitmq长时间323 收藏
-
前言 NSQ是Go语言编写的，开源的分布式消息队列中间件，其设计的目的是用来大规模地处理每天数以十亿计级别的消息。NSQ 具有分布式和去中心化拓扑结构，该结构具有无单点故障、故障容错260 收藏
-
Redis5.0带来了Stream类型。从字面上看是流类型，但其实从功能上看，应该是Redis对消息队列（MQ，Message Queue）的完善实现。 基于redis实现消息队列的方式有很多： PUB/SUB，订阅/发布模式基于List的260 收藏
-
数据库 · Redis | 2个月前 | Redis · 消息队列 · Stream · 消费组 · redis 消息队列 Redis Stream 消费组 XREADGROUP XACK XPENDING XAUTOCLAIM用订单异步处理场景讲清楚 Redis Stream 的实用队列模型：生产者写入消息，消费组分配任务，Worker 处理成功后 ACK，失败或超时的消息进入待确认列表，再通过 XPENDING 和 XAUTOCLAIM 做重投。187 收藏
-
在做项目过程中，实现websocket得时候，不知道哪里写的不太合适，客户端消息收到一定程度，剩下的消息收不到，修改了缓冲区大小，还是没有解决问题，后面因为项目结束期比较紧张，没有时161 收藏
-
数据库 · Redis | 2天前 | Redis · 消息队列 · Stream · 故障恢复 · 消费者组 · redis streams 消息重试 消费者组 XAUTOCLAIM 积压消息 PELRedis Streams 消费者组出现积压时，XAUTOCLAIM 可以把超过最小空闲时间的 pending 消息交给健康消费者继续处理。本文用故障接管场景说明 start 游标、COUNT、JUSTID、重试次数和删除幽灵消息的验收边界。148 收藏