消息队列
已收录文章：25篇
-
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 收藏
-
WebSocket 上线后常见问题不是连接不上，而是断线后状态混乱、消息丢失、重复重连。本文按完整工作流拆解心跳检测、退避重试、恢复订阅和离线消息补发。365 收藏
-
数据库 · Redis | 3个月前 | Redis · 消息队列 · Stream · redis 消息队列 Redis Stream 消费组 XREADGROUP XACK XPENDING XAUTOCLAIM用订单异步处理场景讲清楚 Redis Stream 的实用队列模型：生产者写入消息，消费组分配任务，Worker 处理成功后 ACK，失败或超时的消息进入待确认列表，再通过 XPENDING 和 XAUTOCLAIM 做重投。187 收藏
-
1.redis 用zset做消息队列如何处理消息积压 改变消费者的消费能力： 可以增加消费者的数量，或者优化消费者的消费能力，使其能够更快地处理消息。同时，可以根据消息队列中消息的345 收藏
-
作者 | 丕天Redis是目前最受欢迎的kv类数据库，当然它的功能越来越多，早已不限定在kv场景，消息队列就是Redis中一个重要的功能。Redis从2010年发布1.0版本就具备一个消息队列的雏形，随着10407 收藏
-
前言 在学习过程中发现redis的zset还可以用来实现轻量级的延时消息队列功能，虽然可靠性还有待提高，但是对于一些对数据可靠性要求不那么高的功能要求完全可以实现。本次主要采用了redis中368 收藏
-
在做项目过程中，实现websocket得时候，不知道哪里写的不太合适，客户端消息收到一定程度，剩下的消息收不到，修改了缓冲区大小，还是没有解决问题，后面因为项目结束期比较紧张，没有时161 收藏
-
Redis5.0带来了Stream类型。从字面上看是流类型，但其实从功能上看，应该是Redis对消息队列（MQ，Message Queue）的完善实现。 基于redis实现消息队列的方式有很多： PUB/SUB，订阅/发布模式基于List的260 收藏
-
分布式系统中必备的一个中间件就是消息队列，通过消息队列我们能对服务间进行异步解耦、流量消峰、实现最终一致性。 目前市面上已经有 RabbitMQ、RochetMQ、ActiveMQ、Kafka 等，有人会问114 收藏
-
golang监听消息队列rabbitmq任务脚本，当rabbimq消息队列断开连接后自动重试，重新唤起协程执行任务 需求背景： goalng常驻内存任务脚本监听rbmq执行任务 任务脚本由supervisor来管理 当rabbitmq长时间323 收藏