AutoMQ is a cloud-native fork of Kafka by separating storage to S3 and EBS. 10x cost-effective. Autoscale in seconds. Single-digit ms latency.

Parallel Apache Kafka client wrapper with per message ACK, client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.

Orchestrate end-to-end encryption, cryptographic identities, mutual authentication, and authorization policies between distributed applications – at massive scale.

Bot for Tchap (the messaging app of the French State) using Albert, the French administration Artificial Intelligence agent

The dm3 protocol | New standard of web3 messaging | Decentralized ENS-based registry | Secure end-to-end encryption | Easy dApp integration

即时通讯(IM)系统

The most scalable open-source MQTT broker for IoT, IIoT, and connected vehicles

A modern high-performance open source message queuing system

Open source RabbitMQ: core server and tier 1 (built-in) plugins

An ultra-lightweight and blazing-fast Messaging broker/bus for IoT edge & SDV

SimpleX - the first messaging network operating without user identifiers of any kind - 100% private by design! iOS, Android and desktop apps 📱!

zenoh unifies data in motion, data in-use, data at rest and computations. It carefully blends traditional pub/sub with geo-distributed storages, queries and computations, while retaining a level of time and space efficiency that is well beyond any of the mainstream stacks.

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.

RabbitMQ JMS client

Iggy is the persistent message streaming platform written in Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing millions of messages per second.

即时通讯，聊天，野火IMAndroid客户端，支持Android 4.x —— 最新

A distributed MQTT message broker based on Erlang/OTP. Built for high quality & Industrial use cases.

Ready-to-use Chat UI Components for Android

The cloud-native configuration driven runtime that helps developers implement composite microservices.

Distributed system project with nodes using vector clocks for message timestamping. I implemented unicast and broadcast messaging, ensuring accurate vector clock updates and message synchronization. I achieved communication between processes and learned about distributed systems, RPC, and socket programming, despite initial challenges with socket r