function: message-queue
582 products, primary matches first, then adoption-weighted; health v2 shown.
| Product | Health v2 | Stars | Maturity |
|---|---|---|---|
| qqxx6661/log-record A Java Spring Boot starter library that records operation/audit logs declaratively via a single @OperationLog annotation, without invading … | 68 | 1060 | active |
| hookdeck/outpost Outpost is open-source outbound webhook and event delivery infrastructure that lets SaaS platforms reliably send events to their customers'… | 84 | 1052 | 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… | 82 | 1049 | 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 | 1047 | active |
| walkor/GatewayWorker GatewayWorker is a PHP framework built on Workerman for rapidly developing long-connection applications using a Gateway/Worker process mode… | 38 | 1046 | stable |
| eclipse-ecal/ecal eCAL is a high-performance, brokerless middleware for interprocess communication on a single machine or across a network, offering publish-… | 87 | 1045 | 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… | 77 | 1040 | active |
| librdkafka Confluent's Golang client for Apache Kafka, providing high-level Producer and Consumer APIs with support for balanced consumer groups. It i… | 92 | 1038 | stable |
| videoflow/videoflow Videoflow is a Python framework for building distributed video and stream processing pipelines as directed acyclic graphs of producers, pro… | 66 | 1034 | 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 … | 61 | 1025 | 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 | 1011 | active |
| chrisboulton/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 |
| mehdihadeli/food-delivery-microservices A practical, cloud-native food delivery application built with .NET Aspire and .NET 10, demonstrating microservices architecture using Doma… | 77 | 1006 | 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 | 3374 | 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 | 3280 | 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… | 70 | 3118 | 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 | 3099 | 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 … | 75 | 3069 | 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… | 78 | 3004 | maintenance |
| ltsopensource/light-task-scheduler LTS (light-task-scheduler) is a Java distributed scheduled job framework supporting real-time, scheduled, and Cron tasks with horizontally … | 23 | 2996 | maintenance |
| qunarcorp/qmq QMQ is a distributed message queue middleware developed and battle-tested at Qunar since 2012, supporting async, delayed/scheduled, broadca… | 23 | 2824 | 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 | 2651 | 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 | 2526 | 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 | 2522 | 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 | 2484 | 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 | 2455 | maintenance |
| QNJR-GROUP/EasyTransaction EasyTransaction is a Java/Spring framework providing a unified solution for distributed transactions across microservices and SOA systems. … | 23 | 2350 | 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 | 2312 | 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 | 2294 | maintenance |
| twitter-archive/distributedlog Apache DistributedLog is a high-throughput, low-latency replicated log service offering durability, replication, and strong ordering guaran… | 10 | 2203 | maintenance |
| eclipse-iceoryx/iceoryx Eclipse iceoryx is a C++ inter-process communication (IPC) middleware that provides true zero-copy data transfer via shared memory, with pu… | 94 | 2157 | 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 | 2111 | 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 | 1877 | 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 | 1805 | maintenance |
| wangweianger/zanePerfor zanePerfor is a self-hosted frontend performance monitoring and analytics platform built on Node.js (Egg), Vue, MongoDB, Redis, and Kafka. … | 32 | 1800 | maintenance |
| kilim/kilim Kilim is a Java library providing lightweight threads (fibers/continuations) via bytecode weaving, enabling millions of concurrent tasks wi… | 32 | 1782 | 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 | 1635 | 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 | 1614 | 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 | 1581 | 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 | 1539 | 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 | 1537 | maintenance |
| dotnet-architecture/eShopOnDapr A sample .NET distributed eCommerce application based on eShopOnContainers, rebuilt to use Dapr building blocks for microservice communicat… | 10 | 1530 | 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 | 1520 | 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 | 1515 | maintenance |
| brocaar/chirpstack-network-server 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 | 1510 | 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 | 1497 | 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 | 1492 | maintenance |
| dromara/myth Myth is a Java framework that resolves distributed transactions using reliable messages, ensuring RPC calls eventually execute by sending t… | 32 | 1477 | 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 | 1468 | 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 | 1429 | maintenance |
| hfbin/Seckill A Java flash-sale (seckill) system built with SpringBoot, Mybatis, Redis, and RabbitMQ, demonstrating high-concurrency e-commerce flash-sal… | 32 | 1425 | 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 | 1410 | 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… | 34 | 1332 | 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 | 1316 | maintenance |
| citahub/cita CITA is a high-performance, open-source blockchain kernel written in Rust, designed for enterprise consortium chains. It uses a microservic… | 23 | 1301 | maintenance |
| 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 | 1286 | 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… | 66 | 1282 | 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 | 1277 | 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… | 49 | 1227 | 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 | 1225 | maintenance |
| bernardphp/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 |
| 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 | 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 | 1214 | 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 | 1186 | 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 | 1167 | 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… | 60 | 5012 | 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 | 1070 | 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… | 57 | 1046 | 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 | 1004 | maintenance |
| russellromney/honker A SQLite loadable extension plus multi-language bindings that add Postgres-style NOTIFY/LISTEN semantics, durable task queues, event stream… | 81 | 3015 | 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… | 62 | 1923 | experimental |
| sandglass/sandglass Sandglass is a distributed, horizontally scalable, persistent message queue that orders messages by time. It supports asynchronous task exe… | 10 | 1523 | 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 | 9426 | 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 | 6825 | abandoned |
| square/otto Otto is an enhanced Guava-based event bus library for Java, specialized for Android, that decouples application components via synchronous … | 10 | 5113 | 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 | 4926 | abandoned |
| knolleary/pubsubclient PubSubClient is an Arduino C++ client library providing simple MQTT publish/subscribe messaging over the Arduino Ethernet Client API. It wo… | 62 | 4014 | abandoned |
| facebookarchive/scribe Scribe is a server for aggregating log data streamed in real time from a large number of clients, designed to be scalable and reliable. It … | 10 | 3908 | abandoned |
| apache/incubator-heron Apache Heron is a realtime, distributed, fault-tolerant stream processing engine originally developed at Twitter as a successor to Apache S… | 10 | 3628 | abandoned |
| superstreamlabs/memphis Memphis.dev is a scalable, developer-friendly data streaming platform and message broker for building event-driven and real-time applicatio… | 54 | 3439 | abandoned |
| ha/doozerd Doozer is a highly-available, fully consistent distributed data store for small amounts of critical in-memory data, built on a consensus al… | 32 | 3251 | abandoned |
| moscajs/mosca Mosca is a Node.js MQTT broker that can run standalone or be embedded in any Node.js application. It supports MQTT 3.1/3.1.1 with QoS 0 and… | 10 | 3182 | abandoned |
| twitter-archive/kestrel Kestrel is a simple, distributed message queue system written in Scala, originally developed at Twitter and based on Starling. It offers fa… | 10 | 2753 | abandoned |
| lagom/lagom Lagom is an open-source reactive microservices framework for the JVM, available in both Java and Scala APIs, built on Akka and Play. It pro… | 23 | 2627 | abandoned |
| docker-archive-public/docker.libchan libchan is an ultra-lightweight Go networking library that lets network services communicate like goroutines over channels, supporting mess… | 10 | 2448 | abandoned |
| jondot/sneakers Sneakers is a high-performance background processing framework for Ruby built on RabbitMQ, letting developers define workers that consume q… | 23 | 2238 | abandoned |