消息队列相关技术文章

php mysql shell go vue css api接口对接支付接口对接

RocketMQ 发送全部失败：日志指向 10909，Broker 只监听了 10911

RocketMQ 发送全部失败：日志指向 10909，Broker 只监听了 10911
2026-11-03 20:01:14
灰度上线后 RocketMQ 消息发送成功率掉到 0，Broker 指标全都正常，应用日志报 connect to <ip>:10909 failed。本文从端口特征入手，说清 VIP 通道端口为何是 listenPort-2、vipChannelEnabled 默认为 true 的来源，并对比开放 10909 与客户端关闭 VIP 通道两条修复路径的取舍。
RocketMQ 消息队列排障运维 Java

Redis 8.4 XREADGROUP CLAIM：一条命令同时取空闲 pending 和新增条目

Redis 8.4 XREADGROUP CLAIM：一条命令同时取空闲 pending 和新增条目
2026-10-19 21:04:19
Redis 8.4 给 XREADGROUP 加了 CLAIM min-idle-time，一次调用同时认领空闲 pending 与读取新增条目，替掉 XAUTOCLAIM 加 XREADGROUP 的两段式消费循环。含旧循环对照、阈值与重试预算的换算、XPENDING 监控与幂等边界。
Redis 消息队列 Streams 运维队列

NATS queue groups：每条消息随机挑一个成员，组名打错会静默多出一个组

NATS queue groups：每条消息随机挑一个成员，组名打错会静默多出一个组
2026-10-10 00:03:44
拆解 NATS queue groups 的投递语义：同一 subject 上共享组名的订阅者被当成一个逻辑订阅者，每条消息随机挑恰好一个成员，不等同轮询、默认 at-most-once。含 CLI 命令、成员动态增减、与普通订阅者共存、组名打错静默变两个组等失败边界，并对照 Kafka 消费者组与 RabbitMQ。
queue groups NATS 消息队列负载均衡发布订阅 JetStream at-most-once 命令订阅消息打包投递

AgentHub：5 个 AI Agent 并行改同一仓库，消息路由、文件锁与崩溃恢复怎么落地

AgentHub：5 个 AI Agent 并行改同一仓库，消息路由、文件锁与崩溃恢复怎么落地
2026-10-04 00:03:55
解析 AgentHub 这个多 Agent 编排框架：用消息路由、投递层+应用层双 ACK、指数退避重试、幂等去重、JSONL 状态日志与文件锁，解决多个 AI Agent 并行改同一仓库时的文件冲突、消息重复执行与崩溃丢状态问题，并说明其仅支持 macOS、早期项目的边界。
AI Agent 协作多智能体消息队列代码协作 Python 崩溃决策

Kafka 4.0 落地笔记：默认 KRaft 去掉 ZooKeeper，消费者组协议换成 KIP-848

Kafka 4.0 落地笔记：默认 KRaft 去掉 ZooKeeper，消费者组协议换成 KIP-848
2026-09-22 21:03:33
Kafka 4.0 是首个完全不依赖 ZooKeeper 的大版本，默认 KRaft 运行，消费者组协议换成 KIP-848。本文梳理 KRaft 元数据路径、group.protocol 开启方式，以及 KIP-896 协议基线与 Java 11/17 两组升级约束。
Kafka 消息队列分布式运维 KIP

Kafka 4.1 发布：Queues for Kafka 进入 preview，升级只对一类 4.0 集群有额外要求

Kafka 4.1 发布：Queues for Kafka 进入 preview，升级只对一类 4.0 集群有额外要求
2026-09-14 21:05:34
Kafka 4.1（4.1.1/4.1.2 为 bugfix）三处看点：Queues for Kafka（KIP-932）进入 preview，用 share group 式协作消费让多个 consumer 分摊同一队列并带来 RENEW 确认与 lag 指标；Kafka Streams rebalance 协议改进（KIP-1071）；原生 JWT-bearer 认证（KIP-1139）。核心/Connect/客户端属无破坏性渐进升级，唯一例外是 4.0 中启用了 Queues early access 的集群。
Kafka 消息队列中间件升级运维

RabbitMQ 4.3.0 发布：Khepri 成为唯一元数据存储，Quorum 队列多项增强

RabbitMQ 4.3.0 发布：Khepri 成为唯一元数据存储，Quorum 队列多项增强
2026-09-07 04:09:05
RabbitMQ 4.3.0 发布：Khepri 成为唯一元数据存储（Mnesia 完全移除），Quorum 队列新增严格优先级、延迟重试、消费者超时等增强，CQv1 存储移除，多项弃用功能默认禁用，仅支持从 4.2.x 原地升级。
RabbitMQ 消息队列 Khepri Quorum 4.3.0 Raft 发布

Kafka 从安装到收发消息：一次覆盖架构、功能与选型边界的记录

Kafka 从安装到收发消息：一次覆盖架构、功能与选型边界的记录
2026-09-03 19:36:33
以工程师笔记视角梳理 Apache Kafka：核心架构（Producer/Broker/Topic/Partition/KRaft）、高吞吐的日志存储设计、核心功能与适用边界，并给出 3.x KRaft 安装启动命令和 kafka-python 收发消息示例，附 GitHub 项目地址。
Kafka 消息队列大数据事件流中间件

MQTT 5.0 + EMQX 深度拆解：当物联网消息总线成为 AI Agent 的「神经中枢」——从 QoS 语义、遗嘱与主题别名到 A2A over MQTT 的全链路实战

MQTT 5.0 + EMQX 深度拆解：当物联网消息总线成为 AI Agent 的「神经中枢」——从 QoS 语义、遗嘱与主题别名到 A2A over MQTT 的全链路实战
2026-08-18 19:45:20
深度拆解 MQTT 5.0 与 EMQX：QoS 0/1/2 语义、遗嘱与保留消息、主题别名、共享订阅、请求响应，EMQX 的 Erlang 架构与规则引擎、集群设计，以及 EMQX 6.2 的 A2A over MQTT 如何让 AI Agent 通过消息总线注册、发现与协作，配 Python/Go 可运行代码与生产性能优化清单。
MQTT EMQX MQTT 5.0 物联网消息队列 AI Agent A2A 发布订阅 Erlang IoT

Kafka Diskless 深度拆解：当 Broker 决定不再拥有磁盘——从 WAL Segment 到 SQLite 批次协调器的全链路架构手术

Kafka Diskless 深度拆解：当 Broker 决定不再拥有磁盘——从 WAL Segment 到 SQLite 批次协调器的全链路架构手术
2026-08-11 05:50:06
深度拆解 Apache Kafka Diskless Topics：为何跨AZ流量费占TCO大头、数据平面无序与控制平面定序的解耦设计、WAL Segment混装多分区把PUT成本降333倍、500ms延迟预算的来源、SQLite物化元数据与"注定回滚的事务"做推测执行、ISR语义重定义与Leader也会落后、随机所有者链式GC、Produce Gateway。含Java/Go/Python实战、成本核算脚本与十六条踩坑清单。
Kafka Diskless KIP-1150 对象存储 WAL Segment Diskless Coordinator SQLite 云原生存算分离跨AZ成本消息队列分布式系统架构设计 S3 流处理 KIP

Kafka Diskless Topics 深度拆解：当消息队列决定把「盘」从架构里删掉——WAL Segment、Diskless Coordinator 与 SQLite 状态机的一次成本手术

Kafka Diskless Topics 深度拆解：当消息队列决定把「盘」从架构里删掉——WAL Segment、Diskless Coordinator 与 SQLite 状态机的一次成本手术
2026-08-09 01:48:03
深度拆解 Apache Kafka Diskless Topics（KIP-1150/1163/1164）：为什么分层存储不够、WAL Segment 如何把 PUT 成本降四个数量级、Diskless Coordinator 的 SQLite 状态机与投机执行、WAL 文件归属链与孤儿 GC、ISR 语义反转、Produce Gateway，含可运行的最小引擎实现、成本测算脚本、调优清单与十条踩坑。
Kafka Diskless KIP-1150 对象存储云原生消息队列分布式系统成本优化 SQLite 流处理

Redpanda 深度拆解：当流式数据决定「扔掉 JVM 和 ZooKeeper，用 C++ 从零造一个 Kafka」——从 Seastar 线程模型到 Raft 共识，一个 52K Star 的流式平台如何用「零拷贝 + io_uring + 影子索引」重新定义实时数据管道的终极形态

Redpanda 深度拆解：当流式数据决定「扔掉 JVM 和 ZooKeeper，用 C++ 从零造一个 Kafka」——从 Seastar 线程模型到 Raft 共识，一个 52K Star 的流式平台如何用「零拷贝 + io_uring + 影子索引」重新定义实时数据管道的终极形态
2026-08-06 07:14:58
深度拆解Redpanda流式数据平台：C++从零构建、Seastar Thread-per-Core架构、io_uring异步I/O、内置Raft共识、Shadow Indexing冷热分离，一个52K Star的开源项目如何用系统级编程重新定义实时数据管道
Redpanda C++ Kafka 流式数据 io_uring Raft Seastar Shadow Indexing 消息队列实时数据

Apache Kafka KRaft 深度实战：从 ZooKeeper 到自管理集群，Raft 共识、Controller Quorum 与生产迁移全指南

Apache Kafka KRaft 深度实战：从 ZooKeeper 到自管理集群，Raft 共识、Controller Quorum 与生产迁移全指南
2026-07-27 13:44:19
深度拆解Apache Kafka KRaft模式：从Raft共识算法原理、Controller Quorum架构设计到Docker/Go代码实战，附ZooKeeper到KRaft完整迁移指南与生产调优清单
Apache Kafka KRaft Raft ZooKeeper 消息队列分布式系统 Go Kafka调优流处理

Go-Kafka 生产消费实战：异步生产者 + 批量消费 + 重试死信，百万级消息处理

Go-Kafka 生产消费实战：异步生产者 + 批量消费 + 重试死信，百万级消息处理
2026-07-21 08:15:14
Go实现Kafka百万级消息处理：segmentio/kafka-go异步生产者(channel+worker封装)提升吞吐、批量消费+手动提交保证可靠性、并发消费与分区关系、消息重试与死信队列实现，三大踩坑：分区规划、offset管理、消费者重平衡。
Go Kafka 消息队列 kafka-go 异步生产批量消费 offset管理重试机制死信队列高吞吐后端

Apache Pulsar 深度实战：当消息系统把存储与计算彻底拆开——从分层分片架构、BookKeeper 低延迟存储引擎到 Pulsar Functions 与分级存储的完整工程指南（2026）

Apache Pulsar 深度实战：当消息系统把存储与计算彻底拆开——从分层分片架构、BookKeeper 低延迟存储引擎到 Pulsar Functions 与分级存储的完整工程指南（2026）
2026-07-09 08:16:40
从架构原理到生产实战，深度拆解 Apache Pulsar 的分层分片架构、BookKeeper 低延迟存储引擎、Pulsar Functions 与分级存储。
Apache Pulsar 消息队列 BookKeeper 云原生流处理消息中间件

Redpanda 深度实战：用 C++ 与 Seastar 重写 Kafka 内核——从 Thread-per-Core 架构到生产级流平台的完全指南（2026）

Redpanda 深度实战：用 C++ 与 Seastar 重写 Kafka 内核——从 Thread-per-Core 架构到生产级流平台的完全指南（2026）
2026-07-07 23:59:09
Redpanda 深度实战：基于 C++ 与 Seastar 的 Thread-per-Core 架构，100% 兼容 Kafka 协议、无 ZooKeeper、无 JVM。从内核原理、Raft 复制、零拷贝 I/O，到多语言客户端、Schema Registry、分层存储与性能调优，构建生产级流平台的完全指南。
Redpanda Kafka 流处理消息队列分布式系统

Redis 8.8 深度解析：全新 Array 数据结构、窗口计数器限流、Streams NACK——性能暴涨 83% 背后的架构革命

Redis 8.8 深度解析：全新 Array 数据结构、窗口计数器限流、Streams NACK——性能暴涨 83% 背后的架构革命
2026-06-30 08:43:38
Redis 8.8 GA 发布：全新 Array 数据结构、原生窗口计数器限流、Streams NACK 消息拒绝机制、Hash 字段级通知、Time Series 多聚合器支持。MGET 性能提升 68%、XREADGROUP 提升 83%、持久化提速 60%。15000 字深度解析，附 15 个完整代码示例。
Redis NoSQL 性能优化数据结构缓存限流消息队列时序数据库

消息队列与任务调度：从内存队列到生产级架构的实战指南

消息队列与任务调度：从内存队列到生产级架构的实战指南
2026-06-27 13:44:00
从内存队列到生产级消息架构的完整实战指南，涵盖 Redis 队列、RabbitMQ、Kafka 三种方案，包含完整代码示例、性能对比和最佳实践。
消息队列 Redis RabbitMQ Kafka 异步处理架构设计任务调度分布式系统

NATS 消息系统深度实战：云原生通信基础设施的架构设计与生产级最佳实践（2026）

NATS 消息系统深度实战：云原生通信基础设施的架构设计与生产级最佳实践（2026）
2026-06-21 10:56:10
NATS深度实战：云原生通信基础设施的架构设计与生产级最佳实践（2026）
NATS 消息队列云原生微服务 AI推理边缘计算 JetStream Pub/Sub Request/Reply Queue Groups

NATS 深度实战：当云原生遇到了「零延迟」消息引擎——从 Pub/Sub 到 JetStream 持久化、从边缘计算到 AI 推理总线的生产级完全指南（2026）

NATS 深度实战：当云原生遇到了「零延迟」消息引擎——从 Pub/Sub 到 JetStream 持久化、从边缘计算到 AI 推理总线的生产级完全指南（2026）
2026-06-21 10:55:40
NATS深度实战：从Pub/Sub到JetStream持久化，从边缘计算到AI推理总线，生产级完全指南（2026）
NATS 消息队列云原生微服务 AI推理边缘计算 JetStream Pub/Sub Request/Reply Queue Groups

Kafka 4.0 彻底告别 ZooKeeper：KRaft 模式从原理到生产实战全解析

Kafka 4.0 彻底告别 ZooKeeper：KRaft 模式从原理到生产实战全解析
2026-06-20 12:00:08
Apache Kafka 4.0 正式告别 ZooKeeper，KRaft 模式成为唯一的集群协调方案。本文从 Raft 共识协议原理到生产级部署实战，深入剖析 Kafka 的架构变革。
Kafka KRaft ZooKeeper 消息队列分布式系统 Raft协议微服务

Kafka 4.0 KRaft 终极指南：彻底告别 ZooKeeper 的架构革命——Raft 共识、Controller 重构、百万分区与迁移实战（2026）

Kafka 4.0 KRaft 终极指南：彻底告别 ZooKeeper 的架构革命——Raft 共识、Controller 重构、百万分区与迁移实战（2026）
2026-06-18 19:53:26
Kafka 4.0 正式移除 ZooKeeper，KRaft 成为唯一模式。本文深度解析 Raft 共识原理、Controller 架构重构、合并分离部署模式对比、百万分区性能突破，给出完整的生产级部署与迁移指南。
Kafka KRaft 分布式系统消息队列 Raft

Kafka 4.0 KRaft 深度实战：当消息流彻底告别 ZooKeeper——从 Raft 共识到 Controller 架构、百万分区支持与生产级迁移完全指南（2026）

Kafka 4.0 KRaft 深度实战：当消息流彻底告别 ZooKeeper——从 Raft 共识到 Controller 架构、百万分区支持与生产级迁移完全指南（2026）
2026-06-18 19:53:06
Kafka 4.0 正式移除 ZooKeeper，KRaft 成为唯一模式。本文深度解析 Raft 共识原理、Controller 架构重构、合并分离部署模式对比、百万分区性能突破，给出完整的生产级部署与迁移指南。
Kafka KRaft 分布式系统消息队列 Raft

大家都在搜索什么？

devops 易支付一个官网+多少钱统一接受回调统一回调 python sub node 宝塔日志 mysql shell ElasticSearch css vue api接口对接 2025 支付接口对接 go php php回调