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 |
|---|---|---|---|
| block/buzz Buzz is a self-hostable team workspace where humans and AI agents collaborate in shared rooms, built on a Nostr relay where every message, … | 79 | 36110 | active |
| ntfy ntfy is an open‑source HTTP‑based pub‑sub notification service written in Go. It provides a simple REST API and CLI to publish and subscrib… | 100 | 34901 | active |
| Apache Kafka Apache Kafka is an open-source distributed event streaming platform for building high-performance data pipelines, streaming analytics, and … | 76 | 33918 | stable |
| Apache Kafka Apache Kafka is an open-source distributed event streaming platform that provides durable, high‑throughput messaging. It enables real‑time … | 76 | 33918 | active |
| Dragonfly Dragonfly is a modern in-memory data store that is fully API-compatible with Redis and Memcached, built on a multi-threaded, shared-nothing… | 99 | 31779 | active |
| nautechsystems/nautilus_trader NautilusTrader is an open-source, Rust-native algorithmic trading engine with a deterministic, event‑driven core. It provides Python bindin… | 96 | 30308 | active |
| alibaba/canal Canal is an Alibaba open-source component that parses MySQL binlog to provide incremental data subscription and consumption. It masquerades… | 62 | 29740 | stable |
| Celery Celery is a Python library that provides a distributed task queue for asynchronous job processing. It supports multiple brokers, result bac… | 89 | 28937 | active |
| Valkey Valkey is a high‑performance, in‑memory key‑value datastore that can be used as a cache, primary database, or message broker. It is fully o… | 90 | 27352 | active |
| Valkey Valkey is an open-source (BSD-3-Clause), high-performance in-memory key-value data structure server forked from Redis before its license ch… | 90 | 27352 | stable |
| Dapr Dapr is a portable, open‑source runtime that abstracts common building blocks for distributed applications. It runs as a sidecar alongside … | 99 | 26136 | active |
| NSQ NSQ is a realtime distributed messaging platform that provides high‑throughput, low‑latency pub‑sub and load‑balanced message delivery. It … | 63 | 25777 | active |
| greenrobot/EventBus EventBus is a lightweight publish/subscribe event bus for Android and Java. It enables decoupled communication between components such as A… | 23 | 24688 | active |
| Redisson Redisson is a Java client and real-time data platform for Redis and Valkey, built on Netty, offering sync, async, reactive, and RxJava3 API… | 94 | 24402 | stable |
| Redisson Redisson is a Java client and real‑time data platform for Redis and Valkey. It provides thread‑safe distributed objects, caches, locks, que… | 94 | 24402 | active |
| Apache RocketMQ Apache RocketMQ is a distributed cloud-native messaging and streaming platform built for low-latency, high-throughput, financially reliable… | 88 | 22629 | stable |
| Apache RocketMQ Apache RocketMQ is a distributed, cloud‑native messaging and streaming platform that provides low‑latency, high‑throughput communication. I… | 88 | 22629 | active |
| LMAX-Exchange/disruptor LMAX Disruptor is a high-performance, lock-free inter-thread messaging library for the JVM built around a ring buffer with 'mechanical symp… | 26 | 18487 | stable |
| EMQX EMQX is a highly scalable MQTT broker and messaging platform written in Erlang, supporting MQTT 5.0/3.1.1/3.1 plus MQTT-SN, CoAP, LwM2M, an… | 98 | 16789 | stable |
| Zigbee2MQTT Zigbee2MQTT is a Node.js application that bridges Zigbee devices to MQTT, letting you control Zigbee sensors, bulbs, and switches without t… | 99 | 15741 | stable |
| Apache Pulsar Apache Pulsar is a cloud-native, distributed pub-sub messaging and streaming platform originally developed at Yahoo and now a top-level Apa… | 99 | 15346 | stable |
| RabbitMQ RabbitMQ is an open source, multi-protocol messaging and streaming broker supporting AMQP 0-9-1, AMQP 1.0, MQTT, STOMP, and its Streams pro… | 98 | 13928 | stable |
| Asynq Task Queue Asynq is a Go library for a distributed task queue backed by Redis, letting clients enqueue tasks that worker servers process concurrently.… | 66 | 13769 | stable |
| sidekiq/sidekiq Sidekiq is a simple, efficient background job processing framework for Ruby applications, using threads to handle many jobs concurrently in… | 75 | 13561 | stable |
| redpanda-data/redpanda Redpanda is a Kafka API-compatible streaming data platform written in C++ on the Seastar framework, with no ZooKeeper or JVM dependency. It… | 88 | 12571 | stable |
| IBM/sarama Sarama is an MIT-licensed Go client library for Apache Kafka, providing pure-Go implementations of Kafka producers, consumers, and administ… | 99 | 12525 | stable |
| LuckyPennySoftware/MediatR MediatR is a simple, dependency-free mediator implementation for .NET that supports in-process messaging with request/response, commands, q… | 78 | 11862 | stable |
| eclipse-mosquitto/mosquitto Eclipse Mosquitto is an open source MQTT message broker implementing MQTT versions 5.0, 3.1.1, and 3.1, written in C and suitable for devic… | 76 | 11261 | stable |
| ZeroMQ ZeroMQ (libzmq) is a high-performance, brokerless asynchronous messaging library implementing the ZMTP protocol, providing socket-like abst… | 62 | 11010 | stable |
| AutoMQ/automq AutoMQ is a cloud-native, 100% Apache Kafka-compatible streaming platform that replaces broker-local disks with S3-compatible object storag… | 94 | 10909 | active |
| Centrifugo Centrifugo is an open-source, language-agnostic real-time messaging (PUB/SUB) server written in Go that delivers messages to online users o… | 98 | 10843 | stable |
| DiceDB DiceDB is an open-source, low-latency key/value data store forked from Valkey (itself a fork of Redis), written in C. It extends Valkey wit… | 62 | 10765 | active |
| RQ RQ (Redis Queue) is a simple Python library for queueing jobs and processing them in the background with workers, backed by Redis or Valkey… | 98 | 10693 | stable |
| Watermill Watermill is a Go library for building event-driven and message-driven applications over a unified Pub/Sub API. It supports Kafka, RabbitMQ… | 89 | 9910 | active |
| gomodule/redigo Redigo is a Go client library for the Redis and Valkey databases, providing a Print-like API supporting all Redis commands. It includes con… | 43 | 9848 | stable |
| Agenda Agenda is a lightweight job scheduling library for Node.js that persists jobs in MongoDB, PostgreSQL, or Redis and supports cron-style or h… | 89 | 9708 | active |
| Apache SeaTunnel Apache SeaTunnel is a distributed, high-performance data integration platform for synchronizing massive amounts of data across hundreds of … | 90 | 9700 | stable |
| BullMQ BullMQ is a fast, robust message queue and background job processing library built on Redis (or PostgreSQL), available natively for Node.js… | 96 | 9522 | stable |
| crossoverJie/cim CIM (Cross IM) is a distributed instant messaging system for developers built with Java, Netty, and Spring Boot. It provides server and cli… | 53 | 9487 | active |
| Resque Resque is a Redis-backed Ruby library for creating background jobs, placing them on multiple queues, and processing them later with forked … | 96 | 9473 | stable |
| firebase/flutterfire FlutterFire is a collection of official Firebase plugins for Flutter apps, maintained by Google. It enables Flutter applications to integra… | 67 | 9260 | stable |
| aeron-io/aeron Aeron is an efficient, reliable message transport supporting UDP unicast, UDP multicast, and IPC, with Java, C, and C++ clients. It include… | 98 | 8915 | stable |
| redpanda-data/connect Redpanda Connect (formerly Benthos) is a declarative stream processor that moves data between hundreds of sources and sinks with transforma… | 94 | 8778 | active |
| segmentio/kafka-go kafka-go is a pure-Go Apache Kafka client library offering both low-level connection APIs and high-level Reader/Writer abstractions for pro… | 69 | 8634 | active |
| timercrack/trader An automated futures trading application built around the CTP native gateway, with a pybind11 C++ bridge to the Thost API, a Python-side ga… | 60 | 8460 | active |
| hatchet-dev/hatchet Hatchet is an open-source (MIT) orchestration engine for background tasks, AI agents, and durable workflows, available as a cloud service o… | 90 | 8158 | active |
| RichardKnop/machinery Machinery is a Go library for asynchronous task and job queues built on distributed message passing. It supports multiple brokers (RabbitMQ… | 54 | 7972 | stable |
| MassTransit/MassTransit MassTransit is a free, open-source distributed application framework for .NET that enables message-based, loosely-coupled asynchronous comm… | 77 | 7802 | active |
| deepstreamIO/deepstream.io deepstream is an open-source realtime server that synchronizes schema-less records, provides publish-subscribe events, and routes RPCs betw… | 99 | 7185 | active |
| dotnetcore/CAP CAP is a .NET library providing a lightweight event bus and a distributed transaction solution based on the Outbox pattern (local message t… | 91 | 7112 | active |
| processone/ejabberd ejabberd is an open-source, massively scalable real-time messaging platform written in Erlang/OTP that combines an XMPP server, MQTT broker… | 90 | 6733 | stable |
| Hazelcast Hazelcast is a unified real-time data platform combining distributed stream processing with a fast, in-memory data store. It lets applicati… | 80 | 6622 | stable |
| Apache Camel Apache Camel is an open-source integration framework offering 350+ connectors for databases, APIs, message brokers, and cloud services, wit… | 77 | 6371 | stable |
| Faktory Faktory is a language-agnostic background job server that stores jobs as JSON in queues for workers in any programming language to fetch an… | 87 | 6150 | active |
| Austin Austin is a unified message push platform written in Java (Spring Boot) that sends notifications across channels such as email, SMS, WeChat… | 67 | 6089 | active |
| JackJiang2011/MobileIMSDK MobileIMSDK is an original, lightweight cross-platform instant messaging (IM) communication-layer framework refined over 10 years. It uniqu… | 67 | 6087 | stable |
| coleifer/huey Huey is a lightweight Python task queue supporting Redis, Postgres, SQLite, file-system, or in-memory storage. It offers scheduled, periodi… | 96 | 6045 | active |
| Inngest Inngest is an event-driven durable execution platform for running stateful step functions and AI workflows on serverless, servers, or the e… | 95 | 5968 | active |
| dpkp/kafka-python kafka-python is a pure-Python client library for Apache Kafka with no external dependencies, providing high-level consumer, producer, and a… | 95 | 5905 | active |
| KurrentDB KurrentDB (formerly EventStoreDB) is an event-native database designed for event-driven architectures, storing data as immutable event stre… | 100 | 5873 | active |
| dockersamples/example-voting-app A sample distributed voting application composed of multiple containers (Python front-end, .NET worker, Node.js results app, Redis, Postgre… | 32 | 5828 | stable |
| edenhill/kcat kcat (formerly kafkacat) is a lightweight, non-JVM command-line tool for producing to and consuming from Apache Kafka topics, akin to netca… | 23 | 5785 | stable |
| River River is a Go library providing a fast, reliable background job queue backed by PostgreSQL or SQLite, with transactional enqueueing so jobs… | 94 | 5749 | active |
| rmax/scrapy-redis Redis-based components for Scrapy that enable distributed crawling and scraping by sharing a Redis queue across multiple spider instances. … | 66 | 5644 | active |
| Soketi Soketi is an open-source, Pusher-compatible WebSockets server built on uWebSockets.js for Node.js. It enables self-hosted real-time event b… | 23 | 5636 | active |
| PGMQ pgmq is a lightweight message queue built on PostgreSQL, providing SQS/RSMQ-like semantics via a Postgres extension and a Rust client crate… | 93 | 5340 | active |
| Dramatiq Dramatiq is a fast and reliable distributed background task processing library for Python 3.10+. It uses an actor-based API with RabbitMQ o… | 88 | 5326 | active |
| fluvio-community/fluvio Fluvio is a distributed data streaming engine written in Rust that combines a Kafka-like event streaming platform with the Stateful DataFlo… | 79 | 5256 | active |
| Mikaelemmmm/go-zero-looklook A full-stack microservices reference project built on the go-zero framework in Go, demonstrating best practices with API/RPC/MQ services an… | 66 | 5205 | active |
| blinker Blinker is an IoT solution library for embedded hardware such as Arduino, ESP8266, and ESP32, providing device-side connectivity via WiFi, … | 66 | 5204 | active |
| Akka.NET Akka.NET is an idiomatic .NET port of the Akka toolkit implementing the actor model for building highly concurrent, distributed, and fault-… | 99 | 5088 | active |
| dotnet/MQTTnet MQTTnet is a high-performance .NET library implementing the MQTT protocol (up to version 5), providing both an MQTT client and an embedded … | 85 | 5071 | active |
| apache/iggy Apache Iggy is a high-performance, persistent message streaming platform written in Rust, supporting TCP, QUIC, HTTP, and WebSocket transpo… | 92 | 5035 | active |
| AsamK/signal-cli signal-cli is an unofficial command-line, JSON-RPC, and D-Bus interface for the Signal messenger, supporting registering, verifying, sendin… | 98 | 4962 | active |
| WuKongIM/WuKongIM WuKongIM is a high-performance, channel-oriented instant messaging server written in Go that handles message persistence, replication, orde… | 87 | 4955 | active |
| nanomsg/nng NNG (nanomsg-next-generation) is a lightweight, broker-less messaging library in C implementing scalability protocols like pub/sub, request… | 96 | 4691 | stable |
| Ergo Framework Ergo Framework is a Go framework implementing the actor model with network transparency, inspired by Erlang/OTP design patterns. It provide… | 86 | 4676 | active |
| php-amqplib/php-amqplib php-amqplib is a pure PHP implementation of the AMQP 0-9-1 protocol client, primarily used to communicate with RabbitMQ message brokers. It… | 70 | 4602 | active |
| apache/rocketmq-externals The Apache RocketMQ externals repository is the community home for incubating ecosystem projects around the RocketMQ message broker, such a… | 74 | 4593 | active |
| blinker Blinker is a JavaScript/TypeScript SDK for connecting hardware devices (like Raspberry Pi) to the Blinker IoT platform via MQTT or local ne… | 34 | 4380 | active |
| jamesmh/coravel Coravel is a near-zero configuration .NET library that provides task/job scheduling, in-memory queuing, caching, event broadcasting, and ma… | 34 | 4287 | active |
| zendesk/maxwell Maxwell's Daemon is a change data capture (CDC) application that reads MySQL binlogs and emits row-level changes as JSON to Kafka, Kinesis,… | 93 | 4259 | active |
| laravel/horizon Laravel Horizon is a first-party Laravel package providing a dashboard and code-driven configuration for Laravel Redis queues. It lets team… | 99 | 4177 | stable |
| 1technophile/OpenMQTTGateway OpenMQTTGateway is an open-source firmware that turns ESP8266/ESP32 boards (and computers) into a unified MQTT gateway bridging many protoc… | 73 | 4100 | active |
| timgit/pg-boss pg-boss is a Node.js job queue built on top of PostgreSQL, using SKIP LOCKED to provide exactly-once delivery and reliable background proce… | 95 | 4059 | stable |
| bee-queue/bee-queue Bee-Queue is a simple, fast, robust job/task queue library for Node.js backed by Redis. It is designed for distributed worker pools handlin… | 72 | 4038 | active |
| Dora Dora is a Rust-based dataflow middleware framework for building real-time robotics and AI applications, where applications are modeled as d… | 95 | 4030 | active |
| Emitter Emitter is a distributed, high-performance publish-subscribe messaging platform built on the MQTT protocol, written in Go. It supports mess… | 55 | 4008 | active |
| tulios/kafkajs KafkaJS is a modern, dependency-free Apache Kafka client library for Node.js written in pure JavaScript. It provides producer and consumer … | 23 | 4005 | stable |
| Oban Oban is a robust background job processing library for Elixir, backed by PostgreSQL, SQLite3, and MySQL, with transactional job insertion, … | 95 | 3977 | stable |
| JeremyLiao/LiveEventBus LiveEventBus is an Android event bus library built on LiveData that provides lifecycle-aware message passing. It supports sticky events, de… | 32 | 3977 | stable |
| binux/pyspider pyspider is a powerful web crawler (spider) system written in Python with a built-in WebUI for script editing, task monitoring, project man… | 10 | 16755 | maintenance |
| nikoksr/notify Notify is a Go library that provides a simple, unified API for sending notifications to many messaging services such as Telegram, Slack, Di… | 97 | 3888 | active |
| pika/pika Pika is a pure-Python client library implementing the AMQP 0-9-1 protocol, including RabbitMQ extensions. It provides multiple connection a… | 95 | 3887 | stable |
| amqp-node/amqplib amqplib is an AMQP 0-9-1 library and client for Node.js, providing both low-level protocol machinery and a high-level client API. It suppor… | 98 | 3844 | stable |
| OpenHFT/Chronicle-Queue Chronicle Queue is a Java library providing microsecond-latency, persisted messaging that stores every message to disk in an append-only, z… | 94 | 3815 | stable |
| OptimalBits/bull Bull is a Redis-based job and message queue library for Node.js supporting priorities, scheduling, retries, and rate limiting. It is now in… | 72 | 16256 | maintenance |
| Tarantool Tarantool is an in-memory computing platform combining a fast NoSQL database with a Lua application server. It stores data in RAM with WAL … | 97 | 3668 | stable |
| VerneMQ VerneMQ is a high-performance, distributed MQTT message broker built on Erlang/OTP with master-less clustering for horizontal scalability a… | 93 | 3637 | stable |
| Axon Framework Axon Framework is a JVM framework for building evolutionary, message-driven microservices based on Domain-Driven Design, CQRS, and Event So… | 98 | 3622 | stable |
page 1 / 6 next →