message-queue | Topic | Ecosyste.ms: Repos

Topic: "message-queue"

doocs/advanced-java

😮 Core Interview Questions & Answers For Experienced Java(Backend) Developers | 互联网 Java 工程师进阶知识完全扫盲：涵盖高并发、分布式、高可用、微服务、海量数据处理等领域知识

Language: Java - Size: 25.4 MB - Last synced at: 17 days ago - Pushed at: 29 days ago - Stars: 78,516 - Forks: 19,296

redis/redis

For developers, who are building real-time data-driven applications, Redis is the preferred, fastest, and most feature-rich cache, data structure server, and document and vector query engine.

Language: C - Size: 196 MB - Last synced at: about 11 hours ago - Pushed at: 3 days ago - Stars: 72,023 - Forks: 24,366

nsqio/nsq

A realtime distributed messaging platform

Language: Go - Size: 13.6 MB - Last synced at: 7 months ago - Pushed at: 10 months ago - Stars: 25,299 - Forks: 2,910

nats-io/nats-server

High-Performance server for NATS.io, the cloud and edge native messaging system.

Language: Go - Size: 51.2 MB - Last synced at: 9 days ago - Pushed at: 10 days ago - Stars: 18,656 - Forks: 1,691

OptimalBits/bull

Premium Queue package for handling distributed jobs and messages in NodeJS.

Language: JavaScript - Size: 3.96 MB - Last synced at: about 2 months ago - Pushed at: 12 months ago - Stars: 16,144 - Forks: 1,437

emqx/emqx

The most scalable and reliable MQTT broker for AI, IoT, IIoT and connected vehicles

Language: Erlang - Size: 99.3 MB - Last synced at: 6 days ago - Pushed at: 8 days ago - Stars: 15,596 - Forks: 2,410

redpanda-data/connect

Fancy stream processing made operationally mundane

Language: Go - Size: 35.6 MB - Last synced at: 8 days ago - Pushed at: 9 days ago - Stars: 8,516 - Forks: 901

goldbergyoni/nodejs-testing-best-practices

Beyond the basics of Node.js testing. Including a super-comprehensive best practices list and an example app (April 2025)

Language: JavaScript - Size: 24.5 MB - Last synced at: 5 days ago - Pushed at: 8 months ago - Stars: 4,233 - Forks: 275

pgmq/pgmq

A lightweight message queue. Like AWS SQS and RSMQ but on Postgres.

Language: PLpgSQL - Size: 1.68 MB - Last synced at: 4 days ago - Pushed at: 6 days ago - Stars: 4,184 - Forks: 121

vernemq/vernemq

A distributed MQTT message broker based on Erlang/OTP. Built for high quality & Industrial use cases. The VerneMQ mission is active & the project maintained. Thank you for your support!

Language: Erlang - Size: 20.8 MB - Last synced at: 6 days ago - Pushed at: 12 days ago - Stars: 3,484 - Forks: 420

superstreamlabs/memphis

Memphis.dev is a highly scalable and effortless data streaming platform

Language: Go - Size: 468 MB - Last synced at: 7 days ago - Pushed at: over 1 year ago - Stars: 3,417 - Forks: 229

celery/kombu

Messaging library for Python.

Language: Python - Size: 8.76 MB - Last synced at: 8 days ago - Pushed at: 11 days ago - Stars: 3,084 - Forks: 972

bloomberg/blazingmq

A modern high-performance open source message queuing system

Language: C++ - Size: 105 MB - Last synced at: about 9 hours ago - Pushed at: 2 days ago - Stars: 3,064 - Forks: 159

svix/svix-webhooks

The open source and enterprise-ready webhooks service 🦀

Language: Rust - Size: 13.1 MB - Last synced at: 5 days ago - Pushed at: 6 days ago - Stars: 3,004 - Forks: 219

qunarcorp/qmq

QMQ是去哪儿网内部广泛使用的消息中间件，自2012年诞生以来在去哪儿网所有业务场景中广泛的应用，包括跟交易息息相关的订单场景；也包括报价搜索等高吞吐量场景。

Language: Java - Size: 6.92 MB - Last synced at: 2 months ago - Pushed at: about 2 years ago - Stars: 2,820 - Forks: 706

liftbridge-io/liftbridge

Lightweight, fault-tolerant message streams.

Language: Go - Size: 18 MB - Last synced at: 6 months ago - Pushed at: over 1 year ago - Stars: 2,602 - Forks: 110

rebus-org/Rebus

:bus: Simple and lean service bus implementation for .NET

Language: C# - Size: 450 MB - Last synced at: 2 days ago - Pushed at: 22 days ago - Stars: 2,580 - Forks: 371

poundifdef/smoothmq

An improved drop-in replacement for SQS

Language: Go - Size: 4.95 MB - Last synced at: 6 days ago - Pushed at: 10 months ago - Stars: 2,269 - Forks: 51

php-enqueue/enqueue-dev

Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro

Language: PHP - Size: 19.3 MB - Last synced at: 7 months ago - Pushed at: 7 months ago - Stars: 2,189 - Forks: 442

streamdal/plumber

A swiss army knife CLI tool for interacting with Kafka, RabbitMQ and other messaging systems.

Language: Go - Size: 50.6 MB - Last synced at: 5 months ago - Pushed at: 12 months ago - Stars: 2,137 - Forks: 71

smrchy/rsmq

Redis Simple Message Queue

Language: JavaScript - Size: 329 KB - Last synced at: about 1 month ago - Pushed at: over 4 years ago - Stars: 1,796 - Forks: 120

vanus-labs/vanus

Vanus is a Serverless, event streaming system with processing capabilities. It easily connects SaaS, Cloud Services, and Databases to help users build next-gen Event-driven Applications.

Language: Go - Size: 5.74 MB - Last synced at: 7 months ago - Pushed at: over 1 year ago - Stars: 1,703 - Forks: 95

message-db/message-db

Microservice native message and event store for Postgres

Language: Shell - Size: 260 KB - Last synced at: 3 days ago - Pushed at: over 1 year ago - Stars: 1,644 - Forks: 63

wellle/rmq

Message queue system written in Go and backed by Redis

Language: Go - Size: 1.68 MB - Last synced at: 15 days ago - Pushed at: 12 months ago - Stars: 1,605 - Forks: 209

PansonPanson/Java-Notes

:books: 计算机科学基础知识、Java开发、后端/服务端、面试相关 :books: computer-science/Java-development/backend/interview

Size: 469 KB - Last synced at: 5 months ago - Pushed at: over 6 years ago - Stars: 1,570 - Forks: 287

sandglass/sandglass 📦

Sandglass is a distributed, horizontally scalable, persistent, time sorted message queue.

Language: Go - Size: 4.76 MB - Last synced at: about 1 month ago - Pushed at: over 7 years ago - Stars: 1,528 - Forks: 45

robustmq/robustmq

New generation of cloud-native and AI-native messaging infrastructure.

Language: Rust - Size: 54 MB - Last synced at: 15 days ago - Pushed at: 16 days ago - Stars: 1,401 - Forks: 200

vmihailenco/taskq

Golang asynchronous task/job queue with Redis, SQS, IronMQ, and in-memory backends

Language: Go - Size: 709 KB - Last synced at: about 2 months ago - Pushed at: 7 months ago - Stars: 1,320 - Forks: 106

lemunozm/message-io

Fast and easy-to-use event-driven network library.

Language: Rust - Size: 698 KB - Last synced at: 7 days ago - Pushed at: 3 months ago - Stars: 1,185 - Forks: 82

taoensso/carmine

Redis client + message queue for Clojure

Language: Clojure - Size: 2.61 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1,178 - Forks: 134

apalis-dev/apalis

Type-safe, extensible, and high-performance background processing library for Rust

Language: Rust - Size: 2.07 MB - Last synced at: 14 days ago - Pushed at: 19 days ago - Stars: 973 - Forks: 79

rmqtt/rmqtt

MQTT Server/MQTT Broker - Scalable Distributed MQTT Message Broker for IoT in the 5G Era

Language: Rust - Size: 10.9 MB - Last synced at: 3 days ago - Pushed at: 7 days ago - Stars: 831 - Forks: 102

Qihoo360/huststore

High-performance Distributed Storage

Language: C - Size: 30.4 MB - Last synced at: 7 months ago - Pushed at: over 7 years ago - Stars: 828 - Forks: 174

cloudamqp/lavinmq

Ultra quick message queue and streaming server

Language: Crystal - Size: 8.67 MB - Last synced at: about 2 hours ago - Pushed at: about 3 hours ago - Stars: 826 - Forks: 42

inngest/inngest-js

The developer platform for easily building reliable workflows with zero infrastructure for TypeScript & JavaScript

Language: TypeScript - Size: 11.9 MB - Last synced at: about 6 hours ago - Pushed at: 1 day ago - Stars: 786 - Forks: 96

tobymao/saq

Simple Async Queues

Language: Python - Size: 1010 KB - Last synced at: 9 days ago - Pushed at: 12 days ago - Stars: 759 - Forks: 60

adyliu/jafka

a fast and simple distributed publish-subscribe messaging system (mq)

Language: Java - Size: 2.8 MB - Last synced at: about 1 hour ago - Pushed at: 5 months ago - Stars: 721 - Forks: 320

kubemq-io/kubemq-community

KubeMQ is a Kubernetes native message queue broker

Language: Go - Size: 3.96 MB - Last synced at: 9 days ago - Pushed at: almost 3 years ago - Stars: 668 - Forks: 47

weyoss/redis-smq

A simple high-performance Redis message queue for Node.js.

Language: TypeScript - Size: 10.9 MB - Last synced at: 8 days ago - Pushed at: 11 days ago - Stars: 646 - Forks: 63

WeBankBlockchain/WeEvent

Event-Driven Architecture Based on Blockchain.基于区块链的事件驱动架构

Language: Java - Size: 37.8 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 645 - Forks: 116

youzan/nsq

A realtime distributed messaging platform (forked from https://github.com/nsqio/nsq)

Language: Go - Size: 25.9 MB - Last synced at: 4 months ago - Pushed at: 12 months ago - Stars: 642 - Forks: 107

indeedeng/iwf

iWF is a Workflow-As-Code microservice orchestration platform offering an orchestration coding framework and service for building resilient, fault-tolerant, scalable long-running processes

Language: Go - Size: 12.5 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 614 - Forks: 57

bogdanovich/siberite

Siberite is a simple, lightweight, leveldb backed message queue written in Go.

Language: Go - Size: 2.23 MB - Last synced at: 2 months ago - Pushed at: about 1 year ago - Stars: 588 - Forks: 25

nats-io/nats-operator 📦

NATS Operator for Kubernetes (deprecated)

Language: Go - Size: 11.7 MB - Last synced at: 4 months ago - Pushed at: about 2 years ago - Stars: 570 - Forks: 114

xuxueli/xxl-mq

A lightweight distributed message queue framework.(轻量级分布式消息队列XXL-MQ)

Language: Java - Size: 13.7 MB - Last synced at: 6 days ago - Pushed at: 8 days ago - Stars: 492 - Forks: 240

FinVolution/pmq

信也科技MQ消息系统

Language: Java - Size: 8.49 MB - Last synced at: about 2 months ago - Pushed at: almost 3 years ago - Stars: 490 - Forks: 174

nats-io/nats.c

A C client for NATS

Language: C - Size: 13.9 MB - Last synced at: 9 days ago - Pushed at: 13 days ago - Stars: 448 - Forks: 156

MengRao/tcpshm

A connection-oriented persistent message queue framework based on TCP or SHM(shared memory)

Language: C++ - Size: 223 KB - Last synced at: about 2 years ago - Pushed at: over 5 years ago - Stars: 432 - Forks: 120

Flow-IPC/ipc

[Start here!] Flow-IPC - Modern C++ toolkit for high-speed inter-process communication (IPC)

Language: C++ - Size: 162 MB - Last synced at: 8 months ago - Pushed at: 8 months ago - Stars: 387 - Forks: 15

HDT3213/delayqueue

Simple, reliable, installation-free distributed delayed delivery message queue in Go. 简单、可靠、免安装的分布式延时投递消息队列

Language: Go - Size: 159 KB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 383 - Forks: 64

softwaremill/kmq

Kafka-based message queue

Language: Scala - Size: 456 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 337 - Forks: 44

mizrael/OpenSleigh

OpenSleigh is a Saga management library for .NET Core.

Language: C# - Size: 2.61 MB - Last synced at: 10 days ago - Pushed at: about 1 month ago - Stars: 330 - Forks: 39

sysulq/httpmq

A simple HTTP message queue written in Go with goleveldb, just like httpsqs written in C with Tokyo Cabinet.

Language: Go - Size: 1.15 MB - Last synced at: 6 months ago - Pushed at: about 1 year ago - Stars: 319 - Forks: 86

fishtrip/watchman

A simple message queue callback center

Language: Go - Size: 11.7 KB - Last synced at: over 1 year ago - Pushed at: about 8 years ago - Stars: 289 - Forks: 69

vardius/message-bus

Go simple async message bus

Language: JavaScript - Size: 2.03 MB - Last synced at: 7 months ago - Pushed at: almost 5 years ago - Stars: 276 - Forks: 46

php-enqueue/enqueue-bundle

[READ-ONLY] Message queue bundle for Symfony. RabbitMQ, Amazon SQS, Redis, Service bus, Async events, RPC over MQ and a lot more

Language: PHP - Size: 574 KB - Last synced at: 4 days ago - Pushed at: 8 months ago - Stars: 274 - Forks: 34

PaulGilmartin/django-pgpubsub

A distributed task processing framework for Django built on top of the Postgres NOTIFY/LISTEN protocol.

Language: Python - Size: 277 KB - Last synced at: about 1 month ago - Pushed at: about 1 year ago - Stars: 263 - Forks: 15

repejota/phpnats

A PHP client for the NATSio cloud messaging system.

Language: PHP - Size: 352 KB - Last synced at: 3 days ago - Pushed at: over 2 years ago - Stars: 239 - Forks: 97

socialpandas/sidekiq_monitor

Advanced monitoring for Sidekiq

Language: Ruby - Size: 911 KB - Last synced at: about 1 month ago - Pushed at: over 10 years ago - Stars: 230 - Forks: 35

ShellRechargeSolutionsEU/akka-rabbitmq

RabbitMq client in Scala and Akka actors

Language: Scala - Size: 211 KB - Last synced at: 29 days ago - Pushed at: almost 4 years ago - Stars: 229 - Forks: 65

MengRao/SPSC_Queue

A highly optimized single producer single consumer message queue C++ template

Language: C++ - Size: 54.7 KB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 216 - Forks: 67

wolforest/rocketmq Fork of apache/rocketmq

生产在用，读得懂的RocketMQ分支; 2本小书 + 500张图 + 2W多行注释，...

Language: Java - Size: 51.6 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 215 - Forks: 5

polarstreams/polar

Lightweight & elastic kubernetes-native event streaming system

Language: Go - Size: 1.05 MB - Last synced at: 5 months ago - Pushed at: about 1 year ago - Stars: 207 - Forks: 15

icsharp/Hangfire.Topshelf

Best practice for hangfire samples

Language: C# - Size: 887 KB - Last synced at: 7 months ago - Pushed at: almost 9 years ago - Stars: 207 - Forks: 62

goptics/varmq

A Simplest Storage-Agnostic and Zero-dep Message Queue for Your Concurrent Go Program

Language: Go - Size: 74.5 MB - Last synced at: 2 months ago - Pushed at: 5 months ago - Stars: 159 - Forks: 10

AutoCSer/AutoCSer

AutoCSer is a high-performance RPC framework. AutoCSer 是一个以高效率为目标向导的整体开发框架。主要包括 TCP 接口服务框架、TCP 函数服务框架、远程表达式链组件、前后端一体 WEB 视图框架、ORM 内存索引缓存框架、日志流内存数据库缓存组件、消息队列组件、二进制 / JSON / XML 数据序列化等一系列无缝集成的高性能组件。

Language: C# - Size: 305 MB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 158 - Forks: 55

softwaremill/mqperf

Language: Scala - Size: 939 KB - Last synced at: 4 months ago - Pushed at: over 1 year ago - Stars: 148 - Forks: 38

rxmqjs/rxmq.js 📦

JavaScript pub/sub library based on RxJS

Language: JavaScript - Size: 530 KB - Last synced at: about 2 months ago - Pushed at: over 5 years ago - Stars: 145 - Forks: 20

runreveal/kawa

A blazingly fast event stream processing library powering the reveald event processing daemon.

Language: Go - Size: 1 MB - Last synced at: 9 days ago - Pushed at: 13 days ago - Stars: 144 - Forks: 3

Clivern/Hippo

💨A well crafted go packages that help you build robust, reliable, maintainable microservices.

Language: Go - Size: 114 KB - Last synced at: 17 days ago - Pushed at: 17 days ago - Stars: 144 - Forks: 7

wang502/gores

:construction_worker: Redis-backed library for creating background jobs in Go. Placing jobs in multiple queues, and process them later asynchronously.

Language: Go - Size: 85 KB - Last synced at: 8 months ago - Pushed at: over 7 years ago - Stars: 139 - Forks: 14

skyaktech/tlq

Tiny Little Queue - A minimal message queue server in Rust.

Language: Rust - Size: 101 KB - Last synced at: 24 days ago - Pushed at: 25 days ago - Stars: 132 - Forks: 5

conduitframework/conduit

A message queue framework, with support for middleware and multiple adapters.

Language: Elixir - Size: 396 KB - Last synced at: 2 months ago - Pushed at: about 1 year ago - Stars: 129 - Forks: 18

stomp-php/stomp-php

Stomp PHP Client

Language: PHP - Size: 555 KB - Last synced at: 3 days ago - Pushed at: 6 days ago - Stars: 128 - Forks: 62

yjjnls/RAS-MSG

Reliable asynchronous message system ensuring eventually consistency for distributed system.

Language: JavaScript - Size: 329 KB - Last synced at: about 2 years ago - Pushed at: over 7 years ago - Stars: 121 - Forks: 15

streamnative/aop

AMQP on Pulsar protocol handler

Language: Java - Size: 1.9 MB - Last synced at: 16 days ago - Pushed at: 16 days ago - Stars: 120 - Forks: 46

rednafi/hook-slinger

A generic service to send, retry, and manage webhooks

Language: Python - Size: 2.94 MB - Last synced at: 4 days ago - Pushed at: 6 days ago - Stars: 119 - Forks: 11

makasim/php-fpm-queue

Use php-fpm as a simple built-in async queue

Language: PHP - Size: 8.79 KB - Last synced at: 5 months ago - Pushed at: over 4 years ago - Stars: 115 - Forks: 3

absolute8511/nsq Fork of nsqio/nsq

A realtime distributed messaging platform.

Language: Go - Size: 29.4 MB - Last synced at: over 1 year ago - Pushed at: almost 3 years ago - Stars: 113 - Forks: 12

nats-io/go-nats-examples 📦

Single repository for go-nats example code. This includes all documentation examples and any common message pattern examples.

Language: Go - Size: 952 KB - Last synced at: 4 months ago - Pushed at: about 2 years ago - Stars: 112 - Forks: 30

lcarsde/lcarsde

lcarsde is the LCARS Desktop Environment, which consists of lcarswm and additional tool applications. This repository contains general information.

Language: Kotlin - Size: 404 KB - Last synced at: 27 days ago - Pushed at: 27 days ago - Stars: 110 - Forks: 5

alash3al/go-pubsub

An in-process simple publish/subscribe library for golang

Language: Go - Size: 34.2 KB - Last synced at: 7 months ago - Pushed at: over 5 years ago - Stars: 107 - Forks: 20

php-enqueue/amqp-lib

[READ-ONLY] The queue-interop compatible AMQP protocol impl. Based on php amqp lib.

Language: PHP - Size: 166 KB - Last synced at: 6 months ago - Pushed at: 7 months ago - Stars: 106 - Forks: 20

realtux/dispenserd

Yet another job queue, but better, but maybe not

Language: Go - Size: 57.6 KB - Last synced at: 8 months ago - Pushed at: over 5 years ago - Stars: 90 - Forks: 7

eao197/so-5-5

SObjectizer: it's all about in-process message dispatching!

Language: C++ - Size: 4.78 MB - Last synced at: 8 months ago - Pushed at: over 5 years ago - Stars: 88 - Forks: 6

fortress-build/nervemq

Portable, SQS-compatible message queue backed by SQLite

Language: Rust - Size: 1.07 MB - Last synced at: 3 months ago - Pushed at: 12 months ago - Stars: 85 - Forks: 3

Salaah01/django-action-triggers

A Django library for asynchronously triggering actions in response to database changes. It supports integration with webhooks, message brokers (e.g., Kafka, RabbitMQ), and can trigger other processes, including AWS Lambda functions.

Language: Python - Size: 3.5 MB - Last synced at: 7 months ago - Pushed at: 8 months ago - Stars: 83 - Forks: 1

lcarsde/lcarswm

DEPRECATED - USE https://github.com/lcarsde/lcarsde. lcarswm (LCARS Window Manager) is a window manager that is supposed to look like an LCARS interface. It's written in Kotlin and utilizing XLib.

Language: Kotlin - Size: 4.85 MB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 83 - Forks: 2

queer/singyeong 📦

신경 - Cloud-native messaging/pubsub with powerful routing

Language: Elixir - Size: 3.68 MB - Last synced at: about 1 month ago - Pushed at: over 2 years ago - Stars: 81 - Forks: 4

Muhammad-Magdi/pgmq-js

Postgres Message Queue (PGMQ) JavaScript Client Library

Language: TypeScript - Size: 135 KB - Last synced at: about 2 months ago - Pushed at: about 1 year ago - Stars: 74 - Forks: 3

siadat/ipc

Pure Go wrapper for System V message queue

Language: Go - Size: 33.2 KB - Last synced at: about 1 month ago - Pushed at: over 4 years ago - Stars: 73 - Forks: 18

dymmond/asyncmq

Supercharge your async applications with tasks so fast, you’ll think you’re bending time itself.

Language: Python - Size: 882 KB - Last synced at: 26 days ago - Pushed at: 26 days ago - Stars: 72 - Forks: 4

vmware-archive/transport-go 📦

Transport is a full stack, simple, fast, expandable application event bus for your applications. It provides a standardized and simple API, implemented in multiple languages, to allow any individual component inside your applications to talk to one another. This is the Golang implementation of the Transport library.

Language: Go - Size: 922 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 72 - Forks: 19

alexpusch/queuelite.js

Super simple Node.js message queue for fun and prototyping

Language: JavaScript - Size: 56.6 KB - Last synced at: about 2 months ago - Pushed at: about 8 years ago - Stars: 71 - Forks: 2

4paradigm/pafka Fork of apache/kafka

Pafka is originated from the OpenAIOS project to leverage an optimized tiered storage access strategy to improve overall performance for streaming/messaging system.

Language: Java - Size: 111 MB - Last synced at: over 1 year ago - Pushed at: almost 4 years ago - Stars: 70 - Forks: 7