Technical Blog
Architecture design, engineering practice and technical insights from the RobustMQ team
Adding Agent Discovery and Async Communication to A2A with mq9
Deploy one RobustMQ instance on the internal network and you...
Read more →RobustMQ Gateway: A Minimal Access Layer for a Multi-Protocol Ecosystem
Gateway is not a protocol — it's an access method. It sits a...
Solving A2A Async Reliable Communication with mq9
mq9 is a messaging protocol designed specifically for async ...
Async Communication in LangChain Agents with mq9
pip install langchain langchain-openai langchain-mq9...
RobustMQ Test Agent: Technical Design Document
RobustMQ currently has unit tests and basic integration test...
The Philosophy Behind RobustMQ
**One: Unified storage, multiple protocol views**...
What Should a Messaging System Look Like in the Age of AI — Thoughts and Explorations on mq9
This is an open question, and we do not have all the answers...
Four Perspectives on "Agent Communication: The mq9-Based Agent Mailbox"
I'm actively building multi-agent systems right now, so let ...
Agent Communication: Agent Mailboxes Built on mq9
We conducted a thorough research pass, examining existing ap...
RobustMQ NATS Queue Group Subscription Design
When a client issues a SUB, the subscription is synced to al...
A Deep Survey of Agent Async Communication Solutions
Some teams recognized the transport problem and started reac...
Agent Communication Inside a Company: Real Scenarios for mq9
You'll notice that all the scenarios above — real-time, asyn...
mq9 and A2A: The Relationship Between Transport Layer and Application Layer
mq9 is the communication transport layer that RobustMQ desig...
The State and Future of Agent Communication: Where mq9 Fits
Let's go through them one by one....
mq9 vs Existing Solutions: Eight Scenarios Side by Side
**HTTP polling**: Primary Agent periodically requests each s...
Five Sharp Questions: A Self-Interrogation on mq9
**Challenge:** You say the core need for Agent communication...
The Next Decade of Message Queues: Forget Kafka
What has been the hottest direction in the message queue spa...
Our Answer: mq9
In the previous post I said communication takes far richer f...
mq9: What It Is
mq9 has a single core abstraction: **Mailbox (MAILBOX)**....
mq9: RobustMQ's Communication Layer Designed for AI Agents
mq9 has a single core abstraction: **Mailbox (MAILBOX)**....
$mq9.AI.* Protocol Design
| Command | Subject | Direction | Description |...
Agent Mailbox: Our Thinking and Positioning
Despite being called a mailbox, it is not an application — i...
Infrastructure for the Agent Era: Reflections After Reading Two Articles by Huang Dongxu
Huang Dongxu's first core judgment is: when the user shifts ...
RobustMQ Milestone: Unified Storage, Multi-Protocol Native Consumption — It Works
This demo only covers MQTT publishing with basic subscriptio...
RobustMQ at the Edge: Thinking Through Adaptation for Edge Scenarios
When planning RobustMQ's application directions, our focus w...
RobustMQ AI: AI Capability Extension Planning Based on the NATS Protocol
NATS JetStream Protocol Reference
Query the overall JetStream status of the server. Request pa...
NATS Client Protocol Reference
In-Depth Technical Analysis and Reflections on FlowMQ
FlowMQ Technical Architecture Analysis and Speculation
RobustMQ's Hybrid Architecture Exploration: tokio + Storage Layer Extraction
Problems with fully replacing the runtime (tokio → compio):...
Tokio Scheduling Jitter and io_uring: From Iggy's Exploration to RobustMQ's Thinking
While load-testing the RobustMQ MQTT Broker, we noticed a st...
RobustMQ MQTT Performance Tuning: From DashMap Nested Lock Contention to ArcSwap
These two problems look different on the surface, but they c...
RobustMQ Multi-Protocol Architecture: Protocol Parsing from MQTT to Kafka and AMQP
Design of the RobustMQ Rate Limiting Module
An Edge Case with QoS 2 in Cluster Mode
Where Does a Messaging System's Boundary Lie?
How Will Infrastructure Change in the Age of AI Agents?
In traditional software, data flows are designed in advance ...
RobustMQ Rule Engine and AI Integration: Technical Design and Boundary Thinking
The core motivation for planning a rule engine in RobustMQ c...
Building Infrastructure Software in the AI Era: Lower Barriers, Restructured Moats
Over the past while, we've been pushing forward RobustMQ's r...
RobustMQ Raft State Machine Performance Breakthrough: Batch Semantics + Concurrency Governance, from 20k to 140k ops/s
The conclusion from the previous article, [Raft State Machin...
RobustMQ Raft State Machine Continued Optimization: Re-Validating Groups, Heartbeat Clocks, and Runtime Threads
In the previous article, [Raft State Machine Performance Inv...
RobustMQ Rule Engine Design Thinking
RobustMQ supports multiple protocols including MQTT and Kafk...
RobustMQ Raft State Machine Performance Investigation: The Problem Isn't RocksDB — It's Queuing
RobustMQ's Meta Service is built on OpenRaft and is responsi...
RobustMQ 2026: What We're Building
2025 was the year RobustMQ went from "figuring out the direc...
Eight Use Cases for RobustMQ in AI Scenarios
RobustMQ: Next-Gen Communication Infrastructure Built for AI
AI training’s main challenge is GPU utilization. According t...
AI-Era Foundational Software Development: How Energy Allocation Has Changed
Over the past year developing RobustMQ, AI-assisted programm...
Three Storage Modes in RobustMQ
The storage engine is the heart of a message queue. It deter...
NATS: Technically Elegant, Clearly Limited Ceiling
As someone developing a message queue, I keep an eye on vari...
In Message Queues, Revolutionary Innovation Is Hard to Come By
While developing RobustMQ, I often think: where is there roo...
How I Collaborate with AI When Developing RobustMQ
Over the past year+ developing RobustMQ, AI-assisted program...
Message Queues and MCP Server: Useful But Not Core
I've been looking at MQ and AI lately, and MCP Server has be...
Apache Iggy: Rewriting the Message Stream Platform in Rust
Apache Iggy is a persistent message streaming platform writt...
StreamNative Ursa: LakeHouse-Native Architecture Based on Object Storage
Ursa is a proprietary messaging engine from StreamNative, po...
What Is StreamNative Orca Agent Engine
In September 2025, StreamNative released Orca Agent Engine, ...
AI Strategy of Message Queue Giants: What StreamNative, Confluent, and Redpanda Are Doing
While researching AI infrastructure recently, I noticed some...
Thinking While Building: A Note on RobustMQ Writing
I've written a fair amount lately about RobustMQ's storage l...
The "Unsexy" Nature of Foundation Software and Its Real Value
During my time working on RobustMQ, I've often felt a bit un...
RobustMQ Design Philosophy: Why We Choose Composition Over Innovation
A friend recently asked: What's RobustMQ's breakthrough inno...
Some Thoughts on RobustMQ in Edge Scenarios
I've been thinking about RobustMQ's fit and role in edge sce...
RobustMQ vs NATS: Memory Mode
While designing RobustMQ, we kept asking: Can one unified ar...
RobustMQ Storage Layer Design (Part 2): From Philosophy to Solution
In the previous article "RobustMQ: Some Thoughts on Message ...
RobustMQ Storage Layer: Design and Implementation of File Segment
The storage engine is the heart of a message queue—it determ...
RobustMQ Is an Exploration
Lately I've been thinking: "We have lots of ideas, but code ...
RobustMQ: We Want to Be the Definers, Not the Followers
Over the past few months, many people have asked me: There a...
IBM Acquires Confluent: Talking About RobustMQ
Today I saw the news that IBM acquired Confluent for $11 bil...
Reflections on AI Coding
While working on RobustMQ, I've been thinking: When AI can g...
RobustMQ: Reflections and Exploration in AI Scenarios
While building RobustMQ, we've been thinking about a questio...
RobustMQ: Strategic Thinking on Building the Next-Generation Unified Message Platform
After months of deep reflection, we have clarified RobustMQ'...
RobustMQ Storage Layer Design
Continuing from the previous article, to satisfy various sce...
14.md
RobustMQ: Thoughts on Message Queue Storage Layer Design
If you follow the message queue space, you'll notice that ma...
Storage Layer Storage Adapter Architecture
RobustMQ's storage layer adopts a pluggable architecture. Th...
RobustMQ MQTT Broker System Architecture
Meta Service System Architecture
Meta Service is RobustMQ's built-in metadata storage compone...
RobustMQ: Single Binary Architecture Design
When first encountering the RobustMQ architecture, the diagr...
🎉 RobustMQ 0.2.0 RELEASE Official Launch
In our previous article "Glad to Have the Chance to Show You...
RobustMQ: Glad to Have the Chance to Show You Something Different
RobustMQ wrote its first line of code in October 2023. This ...
RobustMQ Overall Architecture Overview
In [RobustMQ: Technical Design Philosophy Overview](02.md), ...
Self-Reflection: Can We Really Become the Next Generation Messaging Infrastructure?
From the day the project started, we set a big goal for Robu...
Product Thinking and Positioning for RobustMQ
Since the inception of the RobustMQ project, we have continu...
03: Introduction to RobustMQ Roles
This article mainly introduces the key concept of Roles for ...
02: RobustMQ: Overview of Technical Design Philosophy
In [《RobustMQ: Redefining the Future of Cloud-Native Message...
RobustMQ: Redefining the Future of Cloud-Native Message Queues with Rust
In daily architecture design and system operations, have you...