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: 2 days ago - Pushed at: about 2 months ago - Stars: 77,743 - Forks: 19,210

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: 192 MB - Last synced at: 4 days ago - Pushed at: 5 days ago - Stars: 69,505 - Forks: 24,049

nsqio/nsq

A realtime distributed messaging platform

Language: Go - Size: 13.6 MB - Last synced at: 19 days ago - Pushed at: 4 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: 45.5 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 17,266 - Forks: 1,577

OptimalBits/bull

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

Language: JavaScript - Size: 3.96 MB - Last synced at: 20 days ago - Pushed at: 6 months ago - Stars: 15,955 - Forks: 1,436

emqx/emqx

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

Language: Erlang - Size: 90.3 MB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 14,873 - Forks: 2,317

redpanda-data/connect

Fancy stream processing made operationally mundane

Language: Go - Size: 34.7 MB - Last synced at: 7 days ago - Pushed at: 9 days ago - Stars: 8,367 - Forks: 873

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: 19 days ago - Pushed at: 2 months ago - Stars: 4,077 - Forks: 242

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.7 MB - Last synced at: 19 days ago - Pushed at: about 1 month ago - Stars: 3,313 - Forks: 398

superstreamlabs/memphis

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

Language: Go - Size: 468 MB - Last synced at: 11 days ago - Pushed at: about 1 year ago - Stars: 3,303 - Forks: 225

pgmq/pgmq

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

Language: PLpgSQL - Size: 1.63 MB - Last synced at: 7 days ago - Pushed at: 14 days ago - Stars: 3,254 - Forks: 91

celery/kombu

Messaging library for Python.

Language: Python - Size: 8.48 MB - Last synced at: 4 days ago - Pushed at: 6 days ago - Stars: 3,009 - Forks: 952

qunarcorp/qmq

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

Language: Java - Size: 6.92 MB - Last synced at: 11 days ago - Pushed at: over 1 year ago - Stars: 2,819 - Forks: 705

svix/svix-webhooks

The open source and enterprise-ready webhooks service 🦀

Language: Rust - Size: 11.3 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 2,729 - Forks: 188

bloomberg/blazingmq

A modern high-performance open source message queuing system

Language: C++ - Size: 70.4 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 2,675 - Forks: 142

liftbridge-io/liftbridge

Lightweight, fault-tolerant message streams.

Language: Go - Size: 18 MB - Last synced at: 11 days ago - Pushed at: about 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: 5 days ago - Pushed at: 5 days ago - Stars: 2,473 - Forks: 365

poundifdef/smoothmq

An improved drop-in replacement for SQS

Language: Go - Size: 4.95 MB - Last synced at: 3 days ago - Pushed at: 4 months ago - Stars: 2,216 - Forks: 50

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: 19 days ago - Pushed at: 29 days 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: 18 days ago - Pushed at: 6 months ago - Stars: 2,124 - Forks: 70

smrchy/rsmq

Redis Simple Message Queue

Language: JavaScript - Size: 329 KB - Last synced at: 11 days ago - Pushed at: almost 4 years ago - Stars: 1,779 - Forks: 122

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: 18 days ago - Pushed at: about 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: 11 days ago - Pushed at: about 1 year ago - Stars: 1,638 - Forks: 63

wellle/rmq

Message queue system written in Go and backed by Redis

Language: Go - Size: 1.68 MB - Last synced at: 18 days ago - Pushed at: 6 months ago - Stars: 1,590 - Forks: 209

PansonPanson/Java-Notes

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

Size: 469 KB - Last synced at: 23 days ago - Pushed at: about 6 years ago - Stars: 1,570 - Forks: 286

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: almost 7 years ago - Stars: 1,529 - Forks: 45

vmihailenco/taskq

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

Language: Go - Size: 709 KB - Last synced at: 4 days ago - Pushed at: about 1 month ago - Stars: 1,283 - Forks: 107

lemunozm/message-io

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

Language: Rust - Size: 695 KB - Last synced at: 7 days ago - Pushed at: 3 months ago - Stars: 1,171 - Forks: 79

taoensso/carmine

Redis client + message queue for Clojure

Language: Clojure - Size: 2.67 MB - Last synced at: 7 days ago - Pushed at: about 1 month ago - Stars: 1,168 - Forks: 134

Qihoo360/huststore

High-performance Distributed Storage

Language: C - Size: 30.4 MB - Last synced at: 15 days ago - Pushed at: almost 7 years ago - Stars: 828 - Forks: 174

geofmureithi/apalis

Simple, extensible multithreaded background job and message processing library for Rust

Language: Rust - Size: 1.96 MB - Last synced at: 17 days ago - Pushed at: 22 days ago - Stars: 782 - Forks: 64

cloudamqp/lavinmq

Ultra quick message queue and streaming server

Language: Crystal - Size: 7.22 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 729 - Forks: 40

adyliu/jafka

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

Language: Java - Size: 2.8 MB - Last synced at: 2 months ago - Pushed at: over 2 years ago - Stars: 720 - Forks: 321

rmqtt/rmqtt

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

Language: Rust - Size: 10.1 MB - Last synced at: 5 days ago - Pushed at: 9 days ago - Stars: 691 - Forks: 88

tobymao/saq

Simple Async Queues

Language: Python - Size: 935 KB - Last synced at: 17 days ago - Pushed at: 23 days ago - Stars: 677 - Forks: 48

kubemq-io/kubemq-community

KubeMQ is a Kubernetes native message queue broker

Language: Go - Size: 3.96 MB - Last synced at: 4 days ago - Pushed at: over 2 years ago - Stars: 669 - Forks: 47

robustmq/robustmq

RobustMQ is a next-generation, high-performance, cloud-native, converged message queue that is compatible with multiple mainstream message queuing protocols and has complete Serveless capabilities.

Language: Rust - Size: 39.4 MB - Last synced at: 7 days ago - Pushed at: 8 days ago - Stars: 665 - Forks: 116

WeBankBlockchain/WeEvent

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

Language: Java - Size: 37.6 MB - Last synced at: 10 days ago - Pushed at: 4 months ago - Stars: 643 - 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: 3 days ago - Pushed at: 6 months ago - Stars: 643 - Forks: 106

weyoss/redis-smq

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

Language: TypeScript - Size: 8.7 MB - Last synced at: 11 days ago - Pushed at: 12 days ago - Stars: 630 - Forks: 64

bogdanovich/siberite

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

Language: Go - Size: 2.23 MB - Last synced at: about 2 months ago - Pushed at: 8 months ago - Stars: 589 - Forks: 25

nats-io/nats-operator 📦

NATS Operator for Kubernetes (deprecated)

Language: Go - Size: 11.7 MB - Last synced at: about 1 month ago - Pushed at: over 1 year ago - Stars: 572 - Forks: 114

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: 3 days ago - Pushed at: 12 days ago - Stars: 571 - Forks: 55

inngest/inngest-js

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

Language: TypeScript - Size: 10 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 562 - Forks: 57

FinVolution/pmq

信也科技MQ消息系统

Language: Java - Size: 8.49 MB - Last synced at: about 1 month ago - Pushed at: over 2 years ago - Stars: 486 - Forks: 175

xuxueli/xxl-mq

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

Language: Java - Size: 13.3 MB - Last synced at: 10 days ago - Pushed at: 14 days ago - Stars: 466 - Forks: 237

MengRao/tcpshm

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

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

nats-io/nats.c

A C client for NATS

Language: C - Size: 12.7 MB - Last synced at: 7 days ago - Pushed at: 27 days ago - Stars: 420 - Forks: 145

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: about 2 months ago - Pushed at: about 2 months ago - Stars: 387 - Forks: 15

softwaremill/kmq

Kafka-based message queue

Language: Scala - Size: 451 KB - Last synced at: about 17 hours ago - Pushed at: 5 days ago - Stars: 337 - Forks: 45

HDT3213/delayqueue

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

Language: Go - Size: 158 KB - Last synced at: 7 days ago - Pushed at: 3 months ago - Stars: 336 - Forks: 57

mizrael/OpenSleigh

OpenSleigh is a Saga management library for .NET Core.

Language: C# - Size: 2.67 MB - Last synced at: 21 days ago - Pushed at: about 2 months ago - Stars: 322 - 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: 7 days ago - Pushed at: 7 months ago - Stars: 319 - Forks: 86

fishtrip/watchman

A simple message queue callback center

Language: Go - Size: 11.7 KB - Last synced at: 12 months ago - Pushed at: over 7 years ago - Stars: 289 - Forks: 69

vardius/message-bus

Go simple async message bus

Language: JavaScript - Size: 2.03 MB - Last synced at: 14 days ago - Pushed at: over 4 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: about 2 months ago - Stars: 271 - 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: 23 days ago - Pushed at: 7 months ago - Stars: 259 - Forks: 14

repejota/phpnats

A PHP client for the NATSio cloud messaging system.

Language: PHP - Size: 352 KB - Last synced at: 8 days ago - Pushed at: about 2 years ago - Stars: 236 - Forks: 99

socialpandas/sidekiq_monitor

Advanced monitoring for Sidekiq

Language: Ruby - Size: 911 KB - Last synced at: 7 days ago - Pushed at: about 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: about 17 hours ago - Pushed at: over 3 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: over 1 year ago - Pushed at: almost 3 years ago - Stars: 216 - Forks: 67

wolforest/rocketmq Fork of apache/rocketmq

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

Language: Java - Size: 51.4 MB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 213 - Forks: 5

icsharp/Hangfire.Topshelf

Best practice for hangfire samples

Language: C# - Size: 887 KB - Last synced at: about 1 month ago - Pushed at: over 8 years ago - Stars: 207 - Forks: 62

polarstreams/polar

Lightweight & elastic kubernetes-native event streaming system

Language: Go - Size: 1.05 MB - Last synced at: 23 days ago - Pushed at: 7 months ago - Stars: 206 - Forks: 15

AutoCSer/AutoCSer

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

Language: C# - Size: 301 MB - Last synced at: about 1 month ago - Pushed at: 4 months ago - Stars: 157 - Forks: 55

softwaremill/mqperf

Language: Scala - Size: 939 KB - Last synced at: 2 months ago - Pushed at: about 1 year ago - Stars: 147 - Forks: 37

Clivern/Hippo

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

Language: Go - Size: 113 KB - Last synced at: 6 days ago - Pushed at: about 1 month ago - Stars: 145 - Forks: 7

rxmqjs/rxmq.js

JavaScript pub/sub library based on RxJS

Language: JavaScript - Size: 530 KB - Last synced at: 5 days ago - Pushed at: about 5 years ago - Stars: 144 - Forks: 20

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: about 2 months ago - Pushed at: about 7 years ago - Stars: 139 - Forks: 14

runreveal/kawa

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

Language: Go - Size: 1010 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 129 - Forks: 3

conduitframework/conduit

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

Language: Elixir - Size: 396 KB - Last synced at: 14 days ago - Pushed at: 6 months ago - Stars: 129 - Forks: 17

stomp-php/stomp-php

Stomp PHP Client

Language: PHP - Size: 552 KB - Last synced at: 18 days ago - Pushed at: 18 days ago - Stars: 127 - Forks: 61

goptics/varmq

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

Language: Go - Size: 6.54 MB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 122 - Forks: 7

yjjnls/RAS-MSG

Reliable asynchronous message system ensuring eventually consistency for distributed system.

Language: JavaScript - Size: 329 KB - Last synced at: over 1 year ago - Pushed at: almost 7 years ago - Stars: 121 - Forks: 15

rednafi/hook-slinger

A generic service to send, retry, and manage webhooks

Language: Python - Size: 2.88 MB - Last synced at: 14 days ago - Pushed at: about 1 month ago - Stars: 117 - Forks: 11

streamnative/aop

AMQP on Pulsar protocol handler

Language: Java - Size: 1.84 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 115 - Forks: 46

makasim/php-fpm-queue

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

Language: PHP - Size: 8.79 KB - Last synced at: 2 months ago - Pushed at: about 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: 12 months ago - Pushed at: over 2 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: 12 months ago - Pushed at: over 1 year ago - Stars: 109 - Forks: 27

alash3al/go-pubsub

An in-process simple publish/subscribe library for golang

Language: Go - Size: 34.2 KB - Last synced at: about 1 month ago - Pushed at: about 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: 10 days ago - Pushed at: 29 days ago - Stars: 106 - Forks: 20

lcarsde/lcarsde

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

Language: Kotlin - Size: 331 KB - Last synced at: 29 days ago - Pushed at: 3 months ago - Stars: 100 - Forks: 3

realtux/dispenserd

Yet another job queue, but better, but maybe not

Language: Go - Size: 57.6 KB - Last synced at: about 2 months ago - Pushed at: about 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: about 2 months ago - Pushed at: almost 5 years ago - Stars: 88 - Forks: 6

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: 14 days ago - Pushed at: about 1 month 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: 4 months ago - Pushed at: 4 months ago - Stars: 83 - Forks: 2

fortress-build/nervemq

Portable, SQS-compatible message queue backed by SQLite

Language: Rust - Size: 1.07 MB - Last synced at: 23 days ago - Pushed at: 6 months ago - Stars: 81 - Forks: 2

queer/singyeong 📦

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

Language: Elixir - Size: 3.68 MB - Last synced at: 7 days ago - Pushed at: about 2 years ago - Stars: 79 - Forks: 4

siadat/ipc

Pure Go wrapper for System V message queue

Language: Go - Size: 33.2 KB - Last synced at: 3 days ago - Pushed at: almost 4 years ago - Stars: 73 - Forks: 18

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: 7 months ago - Pushed at: about 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: 14 days ago - Pushed at: over 7 years ago - Stars: 71 - Forks: 2

Muhammad-Magdi/pgmq-js

Postgres Message Queue (PGMQ) JavaScript Client Library

Language: TypeScript - Size: 135 KB - Last synced at: 1 day ago - Pushed at: 9 months ago - Stars: 70 - 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: about 1 year ago - Pushed at: over 3 years ago - Stars: 70 - Forks: 7