Architecture design, engineering practice and technical insights from the RobustMQ team
The main Agent tracks the running status of several Workers....
This question deserves a direct answer, because it wasn't ac...
After going through all of that, I keep arriving at the same...
When the industry talks about multi-protocol support, the na...
Every one of the items below is something we want to do, and...
You might ask: isn't the messaging layer already solved by K...
pip install langgraph langchain-openai langchain-mq9...
Deploy one RobustMQ instance on the internal network and you...
Gateway is not a protocol — it's an access method. It sits a...
mq9 is a messaging protocol designed specifically for async ...
pip install langchain langchain-openai langchain-mq9...
RobustMQ currently has unit tests and basic integration test...
**One: Unified storage, multiple protocol views**...
This is an open question, and we do not have all the answers...
I'm actively building multi-agent systems right now, so let ...
We conducted a thorough research pass, examining existing ap...
When a client issues a SUB, the subscription is synced to al...
Some teams recognized the transport problem and started reac...
You'll notice that all the scenarios above — real-time, asyn...
mq9 is the communication transport layer that RobustMQ desig...
Let's go through them one by one....
**HTTP polling**: The orchestrator periodically requests eac...
**Challenge:** You say the core need for Agent communication...
What has been the hottest direction in the message queue spa...
In the previous post I said communication takes far richer f...
mq9 has a single core abstraction: **Mailbox (MAILBOX)**....
mq9 has a single core abstraction: **Mailbox (MAILBOX)**....
**mail_address**: The communication address defined by the u...
Despite being called a mailbox, it is not an application — i...
Huang Dongxu's first core judgment is: when the user shifts ...
This demo only covers MQTT publishing with basic subscriptio...
When planning RobustMQ's application directions, our focus w...
Query the overall JetStream status of the server. Request pa...
Problems with fully replacing the runtime (tokio → compio):...
While load-testing the RobustMQ MQTT Broker, we noticed a st...
These two problems look different on the surface, but they c...
In traditional software, data flows are designed in advance ...
The core motivation for planning a rule engine in RobustMQ c...
Over the past while, we've been pushing forward RobustMQ's r...
The conclusion from the previous article, [Raft State Machin...
In the previous article, [Raft State Machine Performance Inv...
RobustMQ supports multiple protocols including MQTT and Kafk...
RobustMQ's Meta Service is built on OpenRaft and is responsi...
2025 was the year RobustMQ went from "figuring out the direc...
0.3.0 marks RobustMQ's move from "finding direction" to "adv...
AI training’s main challenge is GPU utilization. According t...
Over the past year developing RobustMQ, AI-assisted programm...
The storage engine is the heart of a message queue. It deter...
As someone developing a message queue, I keep an eye on vari...
While developing RobustMQ, I often think: where is there roo...
Over the past year+ developing RobustMQ, AI-assisted program...
I've been looking at MQ and AI lately, and MCP Server has be...
Apache Iggy is a persistent message streaming platform writt...
Ursa is a proprietary messaging engine from StreamNative, po...
In September 2025, StreamNative released Orca Agent Engine, ...
While researching AI infrastructure recently, I noticed some...
I've written a fair amount lately about RobustMQ's storage l...
During my time working on RobustMQ, I've often felt a bit un...
A friend recently asked: What's RobustMQ's breakthrough inno...
I've been thinking about RobustMQ's fit and role in edge sce...
While designing RobustMQ, we kept asking: Can one unified ar...
In the previous article "RobustMQ: Some Thoughts on Message ...
The storage engine is the heart of a message queue—it determ...
Lately I've been thinking: "We have lots of ideas, but code ...
Over the past few months, many people have asked me: There a...
Today I saw the news that IBM acquired Confluent for $11 bil...
While working on RobustMQ, I've been thinking: When AI can g...
While building RobustMQ, we've been thinking about a questio...
After months of deep reflection, we have clarified RobustMQ'...
Continuing from the previous article, to satisfy various sce...
If you follow the message queue space, you'll notice that ma...
RobustMQ's storage layer adopts a pluggable architecture. Th...
Meta Service is RobustMQ's built-in metadata storage compone...
When first encountering the RobustMQ architecture, the diagr...
In our previous article "Glad to Have the Chance to Show You...
RobustMQ wrote its first line of code in October 2023. This ...
In [RobustMQ: Technical Design Philosophy Overview](02.md), ...
From the day the project started, we set a big goal for Robu...
Since the inception of the RobustMQ project, we have continu...
This article mainly introduces the key concept of Roles for ...
In [《RobustMQ: Redefining the Future of Cloud-Native Message...
In daily architecture design and system operations, have you...