Open-source message-queue software
593 open-source libraries, tools and applications tagged message-queue, ranked by how closely message-queue is their primary purpose, then by adoption and maintenance health. Each entry links to a page with sources, use cases and when to choose or avoid it.
593 products, primary matches first, then adoption-weighted; health v2 shown.
| Product | Health v2 | Stars | Maturity |
|---|---|---|---|
| Kanal Kanal is a high-performance Rust channel library implementing CSP-style message passing with both synchronous and asynchronous APIs. It sup… | 70 | 1769 | active |
| esl/MongooseIM MongooseIM is a robust, scalable XMPP messaging server built in Erlang, designed for large enterprise instant messaging installations. It i… | 93 | 1761 | active |
| apache/eventmesh Apache EventMesh is a cloud-native, serverless event middleware for building distributed event-driven applications. It provides a unified C… | 73 | 1758 | active |
| emqx/CocoaMQTT CocoaMQTT is an MQTT v3.1.1 and v5.0 client library for iOS, macOS, tvOS, and visionOS written in Swift 5. It supports TCP and WebSocket tr… | 95 | 1753 | active |
| nanomsg/nanomsg nanomsg is a C library implementing lightweight 'scalability protocols' for common messaging patterns such as request/reply, publish/subscr… | 90 | 6297 | maintenance |
| discourse/message_bus MessageBus is a Ruby gem providing a reliable publish/subscribe messaging bus for server-to-server and server-to-web-client communication. … | 74 | 1659 | stable |
| message-db/message-db Message DB is a fully-featured event store and message store implemented in PostgreSQL, supporting Pub/Sub, event sourcing, streams, catego… | 23 | 1651 | active |
| Apache Pekko Apache Pekko is an open-source JVM framework for building concurrent, distributed, and resilient message-driven applications using the Acto… | 77 | 1647 | active |
| hashicorp/serf Serf is a decentralized service discovery and orchestration tool from HashiCorp that uses an efficient gossip protocol to manage cluster me… | 87 | 6075 | maintenance |
| Spring Integration Spring Integration extends the Spring programming model to implement Enterprise Integration Patterns, enabling lightweight messaging within… | 96 | 1629 | stable |
| wellle/rmq rmq is a message queue library for Go backed by Redis, supporting connections, queues, consumers, batching, and Redis clusters. It lets Go … | 23 | 1619 | active |
| bobohume/gonet gonet is a Go-based distributed game server framework built around an actor model with virtual actors, in-memory MMO state, and a stub-base… | 50 | 1609 | active |
| elixir-lang/gen_stage GenStage is an Elixir specification and behaviour for exchanging events between producer and consumer stages with built-in back-pressure. I… | 72 | 1591 | stable |
| 2881099/FreeIM FreeIM is a simple, high-performance WebSocket-based instant messaging component for .NET/.NETCore, supporting clustered deployment via Red… | 45 | 1582 | active |
| Rails Event Store Rails Event Store (RES) is a Ruby library for publishing, consuming, storing, and retrieving domain events, built on Active Record. It serv… | 95 | 1555 | stable |
| EdgeX Foundry EdgeX Foundry is a vendor-neutral open source framework for IoT edge computing, and this repository contains the Go implementation of its c… | 81 | 1548 | active |
| fujibee/agmsg agmsg is a bash + SQLite CLI tool that lets CLI AI coding agents (Claude Code, Codex, Gemini CLI, Copilot CLI, and others) message each oth… | 82 | 1546 | active |
| nats-io/nats.rs async-nats is a Rust client library for the NATS cloud-native messaging system, built on Tokio. It supports Core NATS, JetStream, Key-Value… | 91 | 1540 | active |
| janbjorge/pgqueuer PgQueuer is a Python library that turns an existing PostgreSQL database into a background job and task queue using FOR UPDATE SKIP LOCKED a… | 88 | 1540 | active |
| Exq Exq is a job processing library for Elixir that uses Redis as its backing store and is compatible with Resque and Sidekiq job formats. It h… | 90 | 1532 | stable |
| mxsm/rocketmq-rust An unofficial, high-performance Rust implementation of Apache RocketMQ, providing message broker, NameServer, producer, and consumer compon… | 85 | 1529 | active |
| Broadway Broadway is a PHP library providing infrastructure and testing helpers for building CQRS and event-sourced applications. It offers loosely … | 10 | 1507 | active |
| apache/inlong Apache InLong is a one-stop, full-scenario integration framework for massive data, supporting data ingestion, synchronization, and subscrip… | 86 | 1503 | stable |
| smarty/go-disruptor A Go port of the LMAX Disruptor, a high-performance inter-thread/goroutine messaging library built on a pre-allocated ring buffer. It achie… | 76 | 1498 | active |
| ESPresense ESPresense is ESP32 firmware that scans for BLE devices and reports indoor presence/positioning data over MQTT for use with Home Assistant … | 87 | 1491 | active |
| ThingsGateway/ThingsGateway ThingsGateway is an open-source, cross-platform industrial IoT edge gateway built on .NET 8 for high-performance data acquisition, edge pro… | 73 | 1484 | active |
| mosquito/aio-pika aio-pika is an asynchronous Python client library for RabbitMQ built on top of aiormq, providing an object-oriented asyncio API for AMQP 0.… | 87 | 1478 | stable |
| Pusher Channels PHP Library The official Pusher Channels JavaScript client library for subscribing to channels and receiving realtime events over WebSockets with HTTP … | 80 | 1477 | active |
| Netflix/mantis Mantis is a Netflix open-source stream processing platform written in Java for building realtime, cost-effective, operations-focused applic… | 68 | 1472 | active |
| closeio/tasktiger TaskTiger is a Python task queue library backed by Redis, supporting per-task subprocess forking, unique queues, task locking, and flexible… | 66 | 1467 | active |
| wez/govee2mqtt A Rust-based bridge that connects Govee smart lights and devices to Home Assistant via the MQTT integration. It uses LAN control, Govee's u… | 62 | 1457 | active |
| kafka-rust/kafka-rust A Rust client library for Apache Kafka providing producer and consumer APIs with offset management and TLS support via rustls. It is a crat… | 60 | 1455 | active |
| oldmoe/litestack Litestack is a Ruby gem that bundles SQLite-based data infrastructure for Ruby and Rails applications, providing a database, cache, job que… | 31 | 1454 | active |
| ruby-amqp/bunny Bunny is a mature, feature-complete Ruby client library for RabbitMQ implementing the AMQP 0-9-1 protocol. It lets Ruby applications publis… | 96 | 1425 | stable |
| procrastinate-org/procrastinate Procrastinate is a Python distributed task processing library that uses PostgreSQL as its task queue backend, supporting both sync and asyn… | 99 | 1424 | active |
| Neuron Neuron is an open-source industrial IoT connectivity server written in C that bridges factory-floor devices (PLCs, sensors, meters) with mo… | 92 | 1412 | active |
| Apache RocketMQ The official Apache RocketMQ client SDK written in pure Go, supporting publishing and consuming messages against RocketMQ brokers. It cover… | 56 | 1411 | active |
| apalis Apalis is a type-safe, extensible background processing library for Rust for building durable, distributed job and task processing systems.… | 81 | 1408 | active |
| aio-libs/aiokafka aiokafka is an asyncio-based Python client library for Apache Kafka, providing AIOKafkaProducer and AIOKafkaConsumer high-level classes. It… | 77 | 1404 | active |
| IoTSharp/IoTSharp IoTSharp is an open-source industrial IoT platform built on .NET for device access, telemetry collection, rule-chain processing, visualizat… | 82 | 1387 | active |
| Eclipse Cyclone DDS Eclipse Cyclone DDS is a performant, robust open-source C implementation of the OMG DDS (Data Distribution Service) publish-subscribe middl… | 87 | 1353 | stable |
| vmihailenco/taskq A Go library for asynchronous task/job queues with pluggable backends including Redis, AWS SQS, IronMQ, and in-memory. It turns Go function… | 27 | 1343 | active |
| synrc/n2o N2O is an embeddable message protocol loop library for WebSocket, HTTP, MQTT, and TCP servers written in Erlang. It provides process manage… | 57 | 1340 | active |
| eclipse-paho/paho.mqtt.cpp The Eclipse Paho MQTT C++ client library lets modern C++ (C++17+) applications connect to MQTT brokers to publish messages, subscribe to to… | 73 | 1332 | stable |
| disruptor-net/Disruptor-net A .NET port of the LMAX Disruptor, a high-performance inter-thread message passing framework built around a pre-allocated ring buffer with … | 53 | 1330 | active |
| Bronya0/Kafka-King Kafka-King is a modern cross-platform desktop GUI client for Apache Kafka, built with Wails and franz-go. It lets developers and administra… | 89 | 1327 | active |
| rigtorp/SPSCQueue A header-only C++11 library providing a bounded single-producer single-consumer wait-free and lock-free queue. It is optimized for high-per… | 23 | 1296 | stable |
| puniverse/quasar Quasar is a JVM library providing lightweight threads (fibers), Go-like channels, and Erlang-like actors for Java and Kotlin, using bytecod… | 23 | 4551 | maintenance |
| vercel/bidc BIDC is a TypeScript library providing bidirectional channels for asynchronous communication between JavaScript execution contexts such as … | 39 | 1280 | active |
| zerodha/dungbeetle DungBeetle is a lightweight, single-binary distributed job server for queuing and asynchronously executing heavy SQL read jobs (such as rep… | 66 | 1277 | active |
| Alpakka Akka is a JVM-based platform built on the actor model for building concurrent, distributed, and resilient applications, comprising core lib… | 91 | 1268 | active |
| encode/broadcaster A Python library providing a simple async broadcast/publish-subscribe API over multiple backends including Redis PUB/SUB, Redis Streams, Ka… | 10 | 1268 | active |
| ptrofimov/beanstalk_console A web-based admin console for the Beanstalkd work queue server, written in PHP. It provides realtime tube statistics, job inspection and ma… | 88 | 1266 | active |
| Expensify/Bedrock Bedrock is a distributed database server built by Expensify on top of SQLite, providing WAN replication, active/active automatic failover, … | 95 | 1264 | active |
| pebbe/zmq4 A Go binding (wrapper via cgo) for the native ZeroMQ version 4 messaging library. It exposes ZeroMQ sockets and patterns such as pubsub, pi… | 44 | 1264 | stable |
| Drasi Drasi is a Data Change Processing platform that monitors data sources for changes, evaluates them against continuously running Cypher queri… | 74 | 1255 | active |
| Durable Workflow Durable Workflow (formerly Laravel Workflow) is a Laravel-native durable workflow engine for defining and running long-running, fault-toler… | 96 | 1253 | active |
| nats-io/nats.py nats.py is the official asyncio-based Python client for the NATS messaging system, supporting pub/sub, request/reply, and JetStream. It als… | 96 | 1252 | active |
| faye/faye Faye is a publish-subscribe messaging library based on the Bayeux protocol, providing message servers for Node.js and Rack (Ruby) applicati… | 76 | 4383 | maintenance |
| Coffeeshop Demo A practical event-driven microservices demo application for a coffee shop, written in Go with services for products, counter, barista, and … | 23 | 4358 | maintenance |
| amqp-rs/lapin Lapin is an async AMQP 0-9-1 client library for Rust, primarily targeting RabbitMQ. It provides a futures-based API and is runtime-agnostic… | 75 | 1237 | stable |
| php-amqplib/RabbitMqBundle A Symfony bundle that integrates RabbitMQ messaging into PHP applications via the php-amqplib library. It provides producers, consumers, an… | 60 | 1230 | active |
| taoweiji/MixPush MixPush is an Android SDK that unifies integration with six vendor push platforms (Xiaomi, Huawei, Meizu, OPPO, VIVO, and Apple APNs) behin… | 45 | 1230 | active |
| Corosync Cluster Engine Corosync is a C-based Group Communication System providing a closed process group communication model with virtual synchrony guarantees, pl… | 69 | 1224 | active |
| hivemq/hivemq-community-edition HiveMQ Community Edition is a Java-based open-source MQTT broker fully supporting MQTT 3.x and MQTT 5, serving as the foundation of the Hiv… | 88 | 1214 | active |
| lcm-proj/lcm LCM (Lightweight Communications and Marshalling) is a set of libraries and tools for low-latency, high-bandwidth publish/subscribe message … | 86 | 1211 | stable |
| jookies/jasmin Jasmin is an open-source SMS gateway written in Python on top of the Twisted event-driven networking engine. It supports SMPP client/server… | 55 | 1211 | active |
| Mirth Connect Mirth Connect by NextGen Healthcare is an open-source healthcare integration engine that filters, transforms, extracts, and routes messages… | 66 | 1203 | active |
| lemunozm/message-io message-io is a Rust library that provides a fast, event-driven networking API over TCP, UDP, and WebSocket transports. It manages OS socke… | 75 | 1197 | active |
| java-up-up/damai A high-concurrency online ticket booking system (modeled after Damai/大麦网) built with SpringCloud, SpringCloud Alibaba, Kafka, Redis, Sentin… | 67 | 1187 | active |
| wind-c/comqtt Comqtt is a lightweight, high-performance MQTT broker written in Go supporting MQTT v3.0, v3.1.1, and v5.0. It can run as a standalone serv… | 87 | 1182 | active |
| taoensso/carmine Carmine is a mature, high-performance Redis client for Clojure with an idiomatic API, connection pooling, and automatic de/serialization of… | 68 | 1180 | active |
| commanded/eventstore An event store library for Elixir that uses PostgreSQL as its underlying persistence engine. It supports appending and reading event stream… | 93 | 1166 | active |
| jcubic/sysend Sysend.js is a small dependency-free JavaScript library that enables message passing and synchronization between web pages open in the same… | 52 | 1164 | active |
| EdwinVW/pitstop Pitstop is a sample Garage Management System application demonstrating software-architecture concepts such as microservices, CQRS, event so… | 76 | 1162 | active |
| IceFireDB IceFireDB is a decentralized, high-performance distributed database written in Go that bridges Web2 and Web3 ecosystems. It offers Redis-co… | 67 | 1159 | active |
| quickfix-j/quickfixj QuickFIX/J is a full-featured, 100% Java messaging engine for the FIX protocol, supporting FIX 4.0 through FIXLatest and FIXT 1.1. It provi… | 90 | 1151 | stable |
| aws-samples/aws-serverless-ecommerce-platform A sample serverless backend implementation for an e-commerce website built on AWS services like Lambda, EventBridge, AppSync, and API Gatew… | 10 | 1146 | active |
| Seneca Seneca is a microservices toolkit for Node.js that lets you organize business logic as message-based commands selected by JSON pattern matc… | 63 | 3956 | maintenance |
| Redix Redix is a fast, pipelined, resilient Redis (and Valkey) client written in pure Elixir. It provides an idiomatic interface for sending arbi… | 75 | 1141 | stable |
| IntelMQ IntelMQ is an open-source solution for IT security teams (CERTs, CSIRTs, SOCs) for collecting and processing security feeds using a message… | 57 | 1140 | active |
| griddynamics-archive/MMWormhole MMWormhole is an Objective-C library that enables message passing between an iOS or OS X app and its extensions via files written to a shar… | 23 | 3929 | maintenance |
| LibreTaxi LibreTaxi is an open-source ridesharing proof-of-concept that connects passengers and drivers through a Telegram bot instead of a dedicated… | 23 | 3921 | maintenance |
| servo/ipc-channel ipc-channel is a Rust library providing an inter-process communication implementation of Rust channels, designed as a drop-in replacement f… | 90 | 1128 | stable |
| awspring/spring-cloud-aws Spring Cloud AWS is a community-maintained Spring and Spring Boot integration project for AWS managed services such as S3, SQS, SNS, Dynamo… | 93 | 1123 | active |
| gautema/CQRSlite CQRSlite is a lightweight CQRS and Event Sourcing framework for .NET that provides building blocks like command dispatching, event publishi… | 76 | 1119 | active |
| davidyaha/graphql-redis-subscriptions A TypeScript library implementing the PubSubEngine and AsyncIterator interfaces from graphql-subscriptions on top of Redis Pub/Sub. It lets… | 29 | 1118 | active |
| aws/pgactive pgactive is a PostgreSQL extension written in C that enables active-active replication, allowing multiple database instances in a cluster t… | 87 | 1112 | active |
| symfony/messenger Symfony Messenger is a PHP component that helps applications send and receive messages to other applications or via message queues. It prov… | 93 | 1111 | stable |
| gohangout Gohangout is a Logstash-like data processing tool written in Go that consumes events (commonly from Kafka), applies configurable filters, a… | 64 | 1101 | active |
| chaps-io/gush Gush is a Ruby gem for defining and running parallel workflows as directed acyclic graphs, using Redis for storage and ActiveJob for job sc… | 47 | 1101 | active |
| iioter/iotgateway IoTGateway is a cross-platform, B/S-architecture industrial IoT gateway built on .NET that connects southbound to industrial devices (PLCs,… | 70 | 1098 | active |
| nytimes/gizmo Gizmo is a Go microservice toolkit from The New York Times providing packages for building HTTP/JSON servers and pubsub daemons with standa… | 52 | 3772 | maintenance |
| MPush MPush is an open-source real-time message push system written in Java on Netty, with a modular server, SDKs for Android, iOS, Java, and Jav… | 23 | 3767 | maintenance |
| lwmqtt An Arduino library wrapping the lwmqtt MQTT 3.1.1 client with an Arduino-style API. It supports many Arduino-compatible boards and shields … | 65 | 1094 | stable |
| edgurgel/poxa Poxa is an open-source Elixir server implementing the Pusher protocol, compatible with existing Pusher client libraries. It supports public… | 23 | 1086 | active |
| ThingLinks IoT Platform ThingLinks is an enterprise-grade, multi-tenant SaaS IoT platform built on Spring Cloud microservices with a Netty/BifroMQ-based engine sup… | 82 | 1076 | active |
| belaban/JGroups JGroups is a Java toolkit for reliable group communication and messaging between cluster nodes. It provides configurable protocol stacks co… | 76 | 1076 | stable |
| linkedin/databus Databus is LinkedIn's source-agnostic distributed change data capture (CDC) system that reliably captures and streams primary data store ch… | 32 | 3684 | maintenance |
| jeffbass/imagezmq imageZMQ is a set of Python classes that transport OpenCV images between computers using PyZMQ messaging. It enables distributed computer v… | 58 | 1073 | stable |