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 |
|---|---|---|---|
| deviceinsight/kafkactl kafkactl is a Go-based command-line interface for managing Apache Kafka clusters, supporting operations on topics, consumer groups, ACLs, b… | 99 | 1071 | active |
| lensesio/stream-reactor Stream Reactor is a collection of Apache 2.0 licensed Kafka Connect sinks and sources maintained by Lenses.io since 2016. It provides conne… | 98 | 1069 | active |
| spring-cloud/spring-cloud-stream Spring Cloud Stream is a Java framework for building event-driven microservices connected via messaging systems like Kafka and RabbitMQ. It… | 91 | 1069 | active |
| apache/celeborn Apache Celeborn is an elastic, high-performance intermediate data service for big data compute engines, focused on managing shuffle and spi… | 90 | 1066 | active |
| hookdeck/outpost Outpost is open-source outbound webhook and event delivery infrastructure that lets SaaS platforms reliably send events to their customers'… | 86 | 1066 | active |
| apache/artemis Apache Artemis is a multi-protocol, high-performance message broker supporting AMQP 1.0, MQTT 3.1.1/5, STOMP, OpenWire, and JMS. It provide… | 76 | 1064 | active |
| librdkafka Confluent's Golang client for Apache Kafka, providing high-level Producer and Consumer APIs with support for balanced consumer groups. It i… | 95 | 1063 | stable |
| yiisoft/yii2-queue A Yii2 framework extension for running tasks asynchronously via queues, with drivers for DB, Redis, RabbitMQ/AMQP, Beanstalk, ActiveMQ, and… | 66 | 1063 | active |
| qqxx6661/log-record A Java Spring Boot starter library that records operation/audit logs declaratively via a single @OperationLog annotation, without invading … | 64 | 1063 | active |
| spatie/laravel-failed-job-monitor A Laravel package that sends notifications via mail and Slack when a queued job fails, hooking into Laravel's JobFailed event and native no… | 76 | 1056 | active |
| eCAL eCAL is a high-performance, brokerless middleware for interprocess communication on a single machine or across a network, offering publish-… | 95 | 1055 | active |
| lasp-lang/partisan Partisan is a scalable, TCP-based membership system and distribution layer for the BEAM that replaces Distributed Erlang with pluggable ove… | 68 | 1055 | active |
| walkor/GatewayWorker GatewayWorker is a PHP framework built on Workerman for rapidly developing long-connection applications using a Gateway/Worker process mode… | 35 | 1048 | stable |
| videoflow/videoflow Videoflow is a Python framework for building distributed video and stream processing pipelines as directed acyclic graphs of producers, pro… | 96 | 1041 | active |
| cloudamqp/lavinmq LavinMQ is a high-performance message queue and streaming server implementing the AMQP 0-9-1 and MQTT protocols, written in Crystal. It is … | 99 | 1027 | active |
| felipeDS91/whatsapp-api A self-hosted REST API built with Node.js, Express, and whatsapp-web.js that lets applications send WhatsApp messages programmatically via … | 57 | 1026 | active |
| rmqtt/rmqtt RMQTT is a scalable, distributed MQTT message broker written entirely in safe Rust, supporting MQTT v3.1/v3.1.1/v5.0 with millions of concu… | 97 | 1017 | active |
| Inngest The official TypeScript/JavaScript SDK for Inngest, a platform for building reliable, event-driven workflows and background jobs without ma… | 95 | 1016 | active |
| sidequestjs/sidequest Sidequest is a Redis-free background job processor for Node.js that persists jobs in your existing PostgreSQL, MySQL, SQLite, or MongoDB da… | 83 | 1016 | active |
| mehdihadeli/food-delivery-microservices A practical, cloud-native food delivery application built with .NET Aspire and .NET 10, demonstrating microservices architecture using Doma… | 77 | 1010 | active |
| php-resque php-resque is a PHP port of GitHub's Resque library for creating Redis-backed background jobs, queueing them, and processing them with fork… | 32 | 3411 | maintenance |
| wagslane/go-rabbitmq A Go library that wraps the rabbitmq/amqp091-go client with a higher-level, RabbitMQ-focused API. It adds automatic reconnection, flow cont… | 76 | 1002 | active |
| Tencent/phxpaxos PhxPaxos is a C++ library implementing the Paxos consensus protocol for state synchronization across a multi-node cluster, battle-tested in… | 23 | 3379 | maintenance |
| zaiyunduan123/springboot-seckill A high-concurrency flash-sale (seckill) system built with SpringBoot, MySQL, Redis, RabbitMQ, and Guava. It demonstrates caching, rate limi… | 32 | 3291 | maintenance |
| eclipse-paho/paho.mqtt.golang The Eclipse Paho MQTT 3.1/3.1.1 client library for Go, enabling applications to connect to an MQTT broker to publish messages and subscribe… | 67 | 3131 | maintenance |
| eclipse-paho/paho.mqtt.android Eclipse Paho Android Service is an MQTT client library written in Java for Android applications, supporting MQTT 3.1/3.1.1 with features li… | 32 | 3101 | maintenance |
| zesterer/flume Flume is a Rust library providing a safe, fast multi-producer, multi-consumer (MPMC) channel for passing messages between threads. It is a … | 72 | 3077 | maintenance |
| python-arq/arq arq is a Python job queuing and RPC library built on asyncio and Redis, designed as a fast, modern successor to rq. It supports deferred ex… | 72 | 3014 | maintenance |
| LTS Light Task Scheduler LTS (light-task-scheduler) is a Java distributed scheduled job framework supporting real-time, scheduled, and Cron tasks with horizontally … | 23 | 2992 | maintenance |
| qunarcorp/qmq QMQ is a distributed message queue middleware developed and battle-tested at Qunar since 2012, supporting async, delayed/scheduled, broadca… | 23 | 2821 | maintenance |
| SOHU-Co/kafka-node kafka-node is a Node.js client library for Apache Kafka 0.9 through 0.11, providing producers, consumers, consumer groups, stream-based API… | 23 | 2650 | maintenance |
| gocraft/work gocraft/work is a Go library for enqueuing and processing durable background jobs backed by Redis, similar to Sidekiq. It supports retries,… | 23 | 2523 | maintenance |
| nats-io/nats-streaming-server NATS Streaming Server (STAN) is a lightweight, high-performance reliable streaming platform built on top of the NATS messaging system, prov… | 10 | 2523 | maintenance |
| gocelery/gocelery A Go client/server implementation of the Celery distributed task queue protocol, supporting Redis and AMQP brokers. It lets Go applications… | 23 | 2487 | maintenance |
| square/tape Tape is a Java library from Square providing QueueFile, a fast, transactional, file-based FIFO queue with atomic O(1) add/remove operations… | 10 | 2454 | maintenance |
| QNJR-GROUP/EasyTransaction EasyTransaction is a Java/Spring framework providing a unified solution for distributed transactions across microservices and SOA systems. … | 23 | 2348 | maintenance |
| alibaba/tair Tair is a distributed key-value storage system developed by Alibaba, offering fast in-memory (MDB) and persistent (LDB) storage engines. It… | 23 | 2313 | maintenance |
| eclipse-paho/paho.mqtt.java The Eclipse Paho Java Client is an MQTT client library for the JVM and Android, providing both asynchronous (MqttAsyncClient) and synchrono… | 23 | 2297 | maintenance |
| twitter-archive/distributedlog Apache DistributedLog is a high-throughput, low-latency replicated log service offering durability, replication, and strong ordering guaran… | 10 | 2202 | maintenance |
| Eclipse iceoryx Eclipse iceoryx is a C++ inter-process communication (IPC) middleware that provides true zero-copy data transfer via shared memory, with pu… | 87 | 2194 | maintenance |
| AndroidKnife/RxBus RxBus is an event bus library for Android/JVM built on RxJava, inspired by Otto and EventBus. It supports @Produce/@Subscribe annotations, … | 32 | 2129 | maintenance |
| andrewjfreyer/monitor A shell-based application that performs passive Bluetooth Low Energy (BTLE) presence detection of beacons, cell phones, and other Bluetooth… | 23 | 2116 | maintenance |
| Tencent/phxqueue PhxQueue is a high-availability, high-throughput distributed queue built on the Paxos consensus protocol, developed by Tencent and used in … | 23 | 1894 | maintenance |
| Koed00/django-q Django Q is a native multiprocessing distributed task queue for Django, supporting asynchronous, scheduled, cron, and repeated tasks with D… | 23 | 1878 | maintenance |
| tangxuehua/enode ENode is a C# application framework for building DDD, CQRS, event sourcing, and event-driven architecture style applications on .NET. It en… | 32 | 1804 | maintenance |
| zanePerfor Performance Monitoring Platform zanePerfor is a self-hosted frontend performance monitoring and analytics platform built on Node.js (Egg), Vue, MongoDB, Redis, and Kafka. … | 32 | 1798 | maintenance |
| kilim/kilim Kilim is a Java library providing lightweight threads (fibers/continuations) via bytecode weaving, enabling millions of concurrent tasks wi… | 32 | 1783 | maintenance |
| OryxProject/oryx Oryx 2 is a Java framework implementing the lambda architecture on Apache Spark and Apache Kafka, specialized for real-time large-scale mac… | 10 | 1782 | maintenance |
| vanus-labs/vanus Vanus is an open-source, cloud-native, serverless message queue with built-in event processing capabilities, written in Go. It connects Saa… | 23 | 1698 | maintenance |
| mailboxer/mailboxer Mailboxer is a Ruby on Rails gem that adds a private messaging system to web applications. It supports multi-participant conversations, sys… | 23 | 1633 | maintenance |
| Xiaofei-it/HermesEventBus HermesEventBus is an Android library that extends greenrobot's EventBus to support event posting across processes via IPC, built on top of … | 23 | 1617 | maintenance |
| strangeioc/strangeioc StrangeIoC is a super-lightweight, highly extensible Inversion-of-Control (IoC) framework written specifically for C# and Unity3D. It provi… | 23 | 1612 | maintenance |
| Clivern/Beaver Beaver is a self-hosted real-time messaging server written in Go that provides WebSocket-based pub/sub messaging backed by Redis. It is use… | 67 | 1586 | maintenance |
| matryer/vice Vice is a Go library that lets you use plain Go channels transparently over message queue technologies like NATS, Redis, NSQ, and Amazon SQ… | 23 | 1541 | maintenance |
| a2888409/face2face face2face is an asynchronous, non-blocking real-time instant messaging (IM) server built on Netty and Java NIO. It splits the system into t… | 32 | 1536 | maintenance |
| dotnet-architecture/eShopOnDapr A sample .NET distributed eCommerce application based on eShopOnContainers, rebuilt to use Dapr building blocks for microservice communicat… | 10 | 1526 | maintenance |
| nanomsg/mangos-v1 Mangos v1 is a pure Go implementation of the nanomsg Scalability Protocols (SP) messaging system, supporting Req/Rep, Pub/Sub, Pair, Bus, P… | 10 | 1519 | maintenance |
| squaremo/rabbit.js A Node.js library providing a simple, socket-oriented API for messaging via RabbitMQ, built on amqplib. It supports publish/subscribe, push… | 32 | 1514 | maintenance |
| ChirpStack v3 ChirpStack Network Server is an open-source LoRaWAN network server written in Go, responsible for handling and de-duplicating uplink data f… | 10 | 1513 | maintenance |
| ideawu/icomet iComet is a high-concurrency comet/server-push messaging server written in C++ with libevent, designed to handle a million concurrent conne… | 32 | 1508 | maintenance |
| iamduo/workq Workq is a standalone job scheduling and processing server written in Go that communicates over a simple text-based TCP protocol. It suppor… | 10 | 1498 | maintenance |
| tj/axon Axon is a message-oriented socket library for Node.js heavily inspired by ZeroMQ. It provides lightweight messaging patterns such as push/p… | 32 | 1491 | maintenance |
| dromara/myth Myth is a Java framework that resolves distributed transactions using reliable messages, ensuring RPC calls eventually execute by sending t… | 32 | 1473 | maintenance |
| haxpax/gosms A self-hosted local SMS gateway written in Go that sends SMS messages through attached GSM modems. It exposes an HTTP API for pushing messa… | 32 | 1466 | maintenance |
| weiboad/kafka-php Kafka-php is a pure PHP client library for Apache Kafka supporting producer and consumer functionality against Kafka brokers 0.8+ (consumer… | 10 | 1427 | maintenance |
| hfbin/Seckill A Java flash-sale (seckill) system built with SpringBoot, Mybatis, Redis, and RabbitMQ, demonstrating high-concurrency e-commerce flash-sal… | 32 | 1426 | maintenance |
| liukelin/canal_mysql_nosql_sync A demo application showing real-time synchronization of MySQL data into Redis, Memcached, and MongoDB using Alibaba's Canal binlog parser a… | 23 | 1411 | maintenance |
| jrallison/go-workers A Go library for running Sidekiq-compatible background job workers backed by Redis. It provides reliable queueing via BRPOPLPUSH, retries, … | 32 | 1379 | maintenance |
| tleyden/open-ocr OpenOCR is a self-hosted OCR-as-a-Service REST API built in Go on top of Tesseract, containerized with Docker. It uses RabbitMQ for scalabl… | 32 | 1373 | maintenance |
| scrapinghub/frontera Frontera is a Python web crawling framework that implements a scalable crawl frontier, storing and prioritizing links extracted by crawlers… | 30 | 1334 | maintenance |
| killme2008/Metamorphosis Metamorphosis (MetaQ) is a high-availability, high-performance distributed messaging middleware written in Java, originally developed at Ta… | 32 | 1329 | maintenance |
| didi/DDMQ DDMQ is a distributed messaging middleware built by DiDi on top of Apache RocketMQ, offering low-latency, high-throughput, highly available… | 10 | 1314 | maintenance |
| CITA CITA is a high-performance, open-source blockchain kernel written in Rust, designed for enterprise consortium chains. It uses a microservic… | 23 | 1302 | maintenance |
| NATS JavaScript client NATS is an open‑source, cloud‑native messaging system that provides ultra‑low latency pub/sub, request/reply, and streaming capabilities. I… | 72 | 442 | active |
| xtaci/gonet gonet is a game server skeleton written in Go, providing a multi-server architecture with Game Servers, a Hub Server for packet forwarding,… | 10 | 1285 | maintenance |
| zendesk/ruby-kafka A pure-Ruby client library for Apache Kafka providing producer and consumer APIs with support for consumer groups, batching, compression, p… | 65 | 1281 | maintenance |
| fusesource/mqtt-client A Java MQTT client library providing blocking, futures-based, and callback APIs for MQTT publish/subscribe messaging. It handles automatic … | 32 | 1276 | maintenance |
| hasura/skor Skor is a small C utility that listens to PostgreSQL LISTEN/NOTIFY events via triggers and forwards row changes (INSERT/UPDATE/DELETE) as J… | 32 | 1243 | maintenance |
| jzyong/game-server A distributed Java game server framework for chess/card and MMORPG games, providing cluster registry, gateway, hall, game logic, and monito… | 45 | 1228 | maintenance |
| istresearch/scrapy-cluster Scrapy Cluster is a distributed web scraping framework built on Scrapy that uses Redis to coordinate crawl requests and Kafka as a data bus… | 10 | 1222 | maintenance |
| Bernard Bernard is a multi-backend PHP library for creating background jobs that are processed later via queues and long-running worker processes. … | 23 | 1214 | maintenance |
| zhihu/kids Kids is a log aggregation system written in C++ that collects and distributes messages across machines, inspired by Facebook's Scribe with … | 23 | 1213 | maintenance |
| BriData/DBus DBus is a Java-based data bus platform that captures incremental changes from databases (via log-based CDC) and log sources in a non-intrus… | 23 | 1212 | maintenance |
| ouqiang/delay-queue A Redis-based delay queue service written in Go, inspired by Youzan's delay queue design. It exposes an HTTP API for pushing delayed jobs a… | 23 | 1194 | maintenance |
| QueueClassic/queue_classic queue_classic is a Ruby gem providing a simple, efficient background job queue backed by PostgreSQL instead of a separate service like Redi… | 23 | 1187 | maintenance |
| eclipse-paho/paho.mqtt.javascript Eclipse Paho JavaScript client is a browser-based MQTT client library that connects to MQTT brokers over WebSockets. It is part of the Ecli… | 23 | 1184 | maintenance |
| banq/jdonframework JdonFramework is a Java framework for Domain-Driven Design that supports pub-sub asynchronous domain events without external message middle… | 23 | 1165 | maintenance |
| rs/pushd Pushd is a self-hosted unified push notification server that lets backend applications send notifications to mobile and web clients across … | 32 | 1155 | maintenance |
| Parsely/pykafka PyKafka is a programmer-friendly Apache Kafka client for Python offering both high-level and low-level producer/consumer APIs, optionally a… | 10 | 1120 | maintenance |
| travisjeffery/jocko Jocko is a distributed commit log service implementing the Kafka protocol in Go, with built-in coordination via Serf discovery and Raft con… | 57 | 5009 | experimental |
| riker-rs/riker Riker is an Actor Model framework for Rust for building concurrent, resilient applications with actor supervision, pub/sub messaging, and e… | 32 | 1073 | maintenance |
| DrmagicE/gmqtt Gmqtt is a flexible, high-performance MQTT broker written in Go that fully implements MQTT protocol V3.x and V5. It offers a plugin mechani… | 53 | 1049 | maintenance |
| gotthardp/lorawan-server An open-source LoRaWAN server written in Erlang that combines network-server and application-server functionality for private LoRaWAN netwo… | 23 | 1005 | maintenance |
| russellromney/honker A SQLite loadable extension plus multi-language bindings that add Postgres-style NOTIFY/LISTEN semantics, durable task queues, event stream… | 78 | 3029 | experimental |
| nubskr/walrus Walrus is a distributed log streaming engine written in Rust, built on a high-performance write-ahead-log storage engine with segment-based… | 57 | 1933 | experimental |
| sandglass/sandglass Sandglass is a distributed, horizontally scalable, persistent message queue that orders messages by time. It supports asynchronous task exe… | 10 | 1524 | experimental |
| Automattic/kue Kue is a feature-rich priority job queue for Node.js backed by Redis, supporting delayed jobs, retries with backoff, job progress events, a… | 23 | 9418 | abandoned |
| robinhood/faust Faust is a Python stream processing library that ports the ideas of Kafka Streams to Python, using asyncio for high-performance distributed… | 23 | 6823 | abandoned |
| square/otto Otto is an enhanced Guava-based event bus library for Java, specialized for Android, that decouples application components via synchronous … | 10 | 5107 | abandoned |
| streadway/amqp A Go client library implementing the AMQP 0.9.1 protocol, primarily targeting RabbitMQ as the message broker server. It is explicitly unmai… | 32 | 4925 | abandoned |