Technical Blog
Architecture design, engineering practice and technical insights from the RobustMQ team
AMQP Progress: Core Functionality Mostly Done, Consume Is What's Left
Read more →How AMQP's Ack Maps Onto RobustMQ's Storage Model
The Kafka Protocol, Implemented in Rust, Is Here
A Quick Update on What's Been Happening with RobustMQ's Kafka
What Are the New Assumptions for Communication Infrastructure in the Agent Era
a16z and YC's Views on AI-Era Infrastructure
Agent Communication: Why Registration and Communication Can Coexist
RPC over Message Queue May Be the Best Communication Method for Agents
Broker + SDK: A Complete Solution for Agent Async Communication
A2A Ecosystem Survey: Finding mq9's Value
What mq9 SDK Is Trying to Do
The mq9 Protocol MCP Server and Eight Typical Scenarios
The main Agent tracks the running status of several Workers....
mq9 MCP User Guide
mq9 MCP Server — Technical Design
RobustMQ Supporting Vector Search and Full-Text Search: Some Thoughts
mq9-hermes plugin: Some Technical Thoughts
mq9 as a Service Registry: Some Thoughts
RobustMQ 0.4.0 Released
The release of 0.4.0 marks RobustMQ's transition from "stead...
mq9 and A2A: A Few Rounds of Thinking
Technical Design: Building RobustMQ Test Agent on Hermes Agent
mq9 Protocol Design: Q&A
This question deserves a direct answer, because it wasn't ac...
Is mailbox the right abstraction?
After going through all of that, I keep arriving at the same...
What Should the Future of Messaging Look Like: Some Thoughts
When the industry talks about multi-protocol support, the na...
Looking for Someone to Build mq9 Together
Every one of the items below is something we want to do, and...
mem0 Filled the Memory Layer. mq9 Is Here for the Messaging Layer.
You might ask: isn't the messaging layer already solved by K...
Connecting Two LangGraph Agents with mq9
pip install langgraph langchain-openai langchain-mq9...
Adding Agent Discovery and Async Communication to A2A with mq9
Deploy one RobustMQ instance on the internal network and you...
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**: The orchestrator periodically requests eac...
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 Document
**mail_address**: The communication address defined by the u...
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...
RobustMQ 0.3.0 RELEASE Officially Released
0.3.0 marks RobustMQ's move from "finding direction" to "adv...
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...