开源消息队列与流处理，已测试

实时分布式消息平台

测试发现：All 10 NSQ daemon and utility binaries compile and run on linux/amd64 with Go 1.25.14; 18 test targets pass under both normal and race-detection modes; the live daemon cluster handles publish/stat operations correctly. 6 分钟。

高性能可观测性数据管道。

测试发现：A preserved Vector binary reports version 0.59.0-dev-custom-3ce1054, validates a YAML config, and successfully processed three sentinel log records through demo_logs, remap, and console with no stderr output. 78 分钟。

用于 NATS.io 的高性能服务器，这是云原生和边缘原生的消息系统。

测试发现：After installing Go 1.26.8, the server builds, reports v2.16.0-dev, serves /healthz with HTTP 200 while JetStream is enabled, completes real pub/sub and JetStream round trips, and exits 0 on SIGTERM; the targeted regression suites passed 37 tests with zero failures. 76 分钟。

在 Go 中轻松构建事件驱动应用。

测试发现：The Watermill Go library builds and its full test suite passes; the quickstart and realtime-feed examples run end-to-end against a real Kafka 3.7.2 broker running inside this container, consuming and producing real messages on real topics. 21 分钟。

面向 agentic AI 的事件流平台。可大规模实时持续摄取、转换并提供事件流。

测试发现：RisingWave 3.2.0-alpha builds from source, runs in single-node playground mode, and serves PostgreSQL-wire-protocol SQL queries on port 4566 with full DDL, DML, and materialized view support. 57 分钟。

用于 Python 的消息传递库。

测试发现：kombu 5.7.0a1 is installed in a /tmp/venv virtual environment with all core and optional transport dependencies (redis, mongodb, sqs, azure, gcpubsub, pyro, yaml, msgpack, sqlalchemy, pgmq, consul, zookeeper) and all 2086 unit tests pass on Python 3.12.3. 5 分钟。

面向 Go 的轻量级流式处理库

测试发现：Go 1.22.2 installed, project builds with go build and passes all 100+ tests with go test -count=1 ./... 20 分钟。

仿照 Yahoo! Pipes 的 Python 流处理引擎

测试发现：All 903 tests pass, the `run-pipe` CLI outputs correct results for demo/simple1 pipelines, and the compile/gen-config/codegen tools regenerate successfully with ruff 0.16.5 formatting. 26 分钟。

类型安全、可扩展、高性能的 Rust 后台处理库

测试发现：The apalis workspace builds, all 127 tests pass (apalis: 18 tests, apalis-core: 86 tests, apalis-workflow: 9 tests, plus integration and doc-tests), and in-memory-backend examples (basic, deps-injection, unique-jobs-example) execute end-to-end without error. 8 分钟。

高效、易用且快速的 PHP JSON 流解析器

测试发现：All 841 PHPUnit tests pass on PHP 8.0.30 with dependencies installed via Composer. 4 分钟。

快速且易于使用的事件驱动网络库。

测试发现：The crate message-io v0.19.0 compiles without errors; all 85 tests pass across TCP, framed-TCP, UDP, and WebSocket transports; the ping-pong example runs end-to-end verifying real bidirectional socket communication. 2 分钟。

Rust 的零成本且类型安全的响应式扩展，支持高性能单线程（Local）和线程安全（Shared）两种上下文，已为 WASM 和 Tokio 做好准备。

测试发现：Rust 1.99.0 was installed, rxRust v1.0.0-rc.5 compiles and all tests pass (452 unit, 29 integration, 190 doctests). 1 分钟。

构建事件驱动微服务的框架

测试发现：Spring Cloud Stream 5.1.0-SNAPSHOT compiles, installs and passes 958 tests (0 failures) across core, kafka, kafka-streams, pulsar and schema-registry modules; a real RabbitMQ 3.12.1 broker runs locally and serves AMQP and its management API; only the Rabbit binder integration suite cannot run because its... 62 分钟。

MQTT 服务器/MQTT 代理 - 面向 5G 时代 IoT 的可扩展分布式 MQTT 消息代理

测试发现：rmqtt/0.25.0 MQTT broker built from source with Rust 1.99.0 on Ubuntu 24.04 x86_64. Release binary at target/release/rmqttd (31 MB). Broker starts on ports 1883 (MQTT), 8883 (MQTT/TLS), 6060 (HTTP API), 8080 (WS), 8443 (WSS), 9443 (QUIC), 11883 (internal), 5363 (gRPC). MQTT v3.1.1 connections, QoS0/QoS1 pub/sub... 25 分钟。

简单异步队列

测试发现：SAQ installs in editable mode with all extras, its 298-test suite passes against live Redis and Postgres servers built from source in this container, and a running example worker processed a real job to completion (result 42) while its web UI answered HTTP 200. 8 分钟。

构建能够灵活混合 SQL、批处理和流处理范式的平台

测试发现：Go toolchain, etcd, and the 37 non-rocksdb packages build cleanly; 313 tests pass; a real etcd + gazette serve broker accepted gazctl journal creation, append, and read round-trips, and persisted decodable fragments to the file store; only the RocksDB-backed consumer-store packages remain unbuildable for lack of... 37 分钟。

一个快速且简单的分布式发布-订阅消息系统 (mq)

测试发现：Jafka 3.0.8 builds from source, all 70 unit tests pass, and the broker starts on port 9092 accepting TCP connections. 9 分钟。

在终端直接播放全球任意电台:zap:

测试发现：radio-active 4.0.2 installs, all 16 tests pass, the CLI launches with --version and --help, searches the radio-browser API, and gracefully handles missing last station data. 3 分钟。

一个用于 NATS 的 C 客户端

测试发现：The cnats library built, installed to /work/repo/install, and its full 333-test suite passed against a real nats-server v2.15.1, with live publish/subscribe delivering 3 messages through the examples and an installed-library consumer program initializing with version 3.15.0-beta. 14 分钟。

Flow-IPC：现代 C++ 高速进程间通信（IPC）工具包

测试发现：Project builds from source with Conan dependencies; flow library unit tests (15/15), IPC core link test, IPC transport structured link test, and IPC SHM unit tests (53/56) pass on real hardware with real IPC primitives. 55 分钟。

面向异构架构的异步 SDR 运行时

测试发现：FutureSDR v0.8.0 builds and tests pass on Rust nightly 1.101.0; flowgraph runtime executes correctly with the minimal example, control port listens on 127.0.0.1:1337, and blocks initialize/run/terminate as expected. 15 分钟。

一个使用 Go 和 goleveldb 编写的简单 HTTP 消息队列，就像使用 C 和 Tokyo Cabinet 编写的 httpsqs 一样。

测试发现：httpmq v0.5 compiled from source with Go 1.22.4, runs as an HTTP server on port 1218 using LevelDB, and all documented queue operations (put, get, status, view, reset) work correctly. 4 分钟。

Go 简单异步消息总线

测试发现：Go 1.27.3 toolchain installed under /home/runner/go-toolchain; unit/race/vet/staticcheck suites pass; shutdown HTTP example served 202 on POST /signup, logged the handler, and exited cleanly on SIGTERM. 6 分钟。

专为事件流应用程序构建的无服务器框架。

测试发现：Go 1.25.0 installed, project builds, controller test suite passes all 57 specs using real Kubernetes envtest binaries. 8 分钟。

适用于并发 Go 程序的最简单的内存型、分布式、存储无关的消息队列

测试发现：VarMQ builds and all 93 tests pass across 7 modules (config, distributed, job, main, metrics, mux, queue, workers, and internal components); benchmarks also execute successfully. 2 分钟。

[READ-ONLY] 用于 Symfony 的消息队列 bundle。RabbitMQ、Amazon SQS、Redis、服务总线、异步事件、基于 MQ 的 RPC 等等。

测试发现：composer install completed with 152 packages; unit suite passes 87/87 and functional suite passes 38/38 using the file transport with real message send/consume/ack; the Symfony console app boots and enqueue:setup-broker prints 'Broker set up'. 35 分钟。

快速轻量的日志、指标和追踪处理器，适用于 Linux、BSD、OSX 和 Windows

测试发现：Fluent Bit v5.1.3 builds from source. Binary launches at /work/repo/build/bin/fluent-bit. 96/97 internal tests pass; the flb-it-network IPv6 test fails because IPv6 is disabled in the container. 36 分钟。

从第一性原理构建的分布式 log 流式引擎

测试发现：A 3-node Walrus cluster runs with Raft consensus (node 1 Leader, nodes 2 and 3 Followers), all three nodes accept topic registration and message put/get operations, with full 3-node membership in Raft metrics. 64 分钟。

csp 是一个高性能的响应式流处理库，使用 C++ 和 Python 编写。

测试发现：csp 0.19.1 installed from PyPI into a venv, ran the bid-ask spread example producing correct output, and 1600/1628 tests pass after installing tzdata, anywidget, and python-rapidjson. 38 分钟。

面向事件驱动服务的异步 Python 框架，为 Kafka、RabbitMQ、NATS、Redis 和 MQTT 提供轻量客户端，可完整访问原生 broker 功能，并开箱即用地提供 AsyncAPI 文档、内存测试和可观测性。

测试发现：FastStream 0.7.7 is installed and all in-memory test suites pass: 4526 non-connected tests pass across Kafka, RabbitMQ, NATS, Redis, Confluent, and MQTT brokers, with CLI, ASGI, and AsyncAPI documentation generation working correctly. 42 分钟。

超低延迟的基于图的流处理框架

测试发现：The core Rust crate wingfoil v9.0.0 builds, all 477 tests pass, and the hello_graph example runs correctly producing historical and realtime output. 8 分钟。

Redis 简单消息队列

测试发现：RSMQ 0.13.0 installed and all 93 tests pass against Redis 7.2.0 on 127.0.0.1:6379; send/receive/delete verified via real Redis. 6 分钟。

Apache StreamPipes - 一个自助式（工业级）IoT 工具箱，使非技术用户能够连接、分析和探索 IoT 数据流。

测试发现：Maven builds all non-integration modules successfully, 1073 backend unit tests pass with zero failures, the Angular UI builds to dist, and the backend jar starts and initializes Tomcat on port 8030 before stopping because the CouchDB service is not available in this container. 45 分钟。

用于 Bun 的高性能任务队列。默认使用 SQLite，扩展时使用 PostgreSQL multi-broker。支持 DLQ、cron、SQLite S3 备份以及原生 MCP。无需 Redis。

测试发现：Bunqueue v2.9.5 is fully installed and operational: the library compiles, all 8740 active tests pass, typecheck is clean, the embedded queue processes jobs end-to-end, and the TCP/HTTP server starts and binds on the configured ports. 51 分钟。

一个现代的、高性能的开源消息队列系统

测试发现：BlazingMQ broker, CLI tool, and storage tool binaries are built and functional with 212/212 unit tests passing. 75 分钟。

Flink 学习博客

测试发现：flink-learning builds successfully with 94/94 modules. 7 unit tests pass in flink-learning-common. Integration tests requiring Kafka/Cassandra/Redis/DingTalk cannot execute without external services. 52 分钟。

基于 Go 的 Kafka 风格消息流。构建于 NATS 之上。单个二进制文件，无需 JVM，无需 ZooKeeper。

测试发现：The binary builds, all unit tests pass, and the server starts with embedded NATS, binds to port 9292, elects itself metadata leader, and logs normal operation. 21 分钟。

iWF 是一个 Workflow-As-Code 微服务编排平台，提供编排编码框架和服务，用于构建弹性、容错、可扩展的长时间运行流程。

测试发现：iwf-server binary builds, all 23 unit tests pass, blobstore integration tests pass against moto S3 mock, and the server starts on port 8801 connected to a local Temporal dev server, responding with HTTP 200 on healthcheck and workflow start API. 16 分钟。

开源且企业就绪的 webhooks 服务

测试发现：Python client library installs and passes all applicable unit tests (31/31), webhook verification module works end-to-end, CLI tool runs correctly via npx and produces valid signatures. 13 分钟。

用于 PHP、Symfony、Laravel、Magento 的消息队列、任务队列、广播、WebSockets 软件包。开发仓库：由 Forma-Pro 提供。

测试发现：PHP 8.2.13 and Composer 2.10.3 installed; all 169 Composer dependencies resolved and vendor autoloader generated; RdKafkaConnectionFactory input validation fixed to throw LogicException before librdkafka check; core enqueue test suite passes 1153/1154 tests; full 3136-test suite runs with 134 errors and 11 failures... 17 分钟。

Kurento WebRTC 媒体服务器

测试发现：无法验证；log 显示了它停在哪里。 8 分钟。

AI 时代的通信基础设施：一个二进制文件、一个代理、一个存储层、任何协议。

测试发现：无法验证；log 显示了它停在哪里。 21 分钟。

面向开发人员的事件流处理，用于收集和转换动态数据，以驱动响应式数据密集型应用。

测试发现：无法验证；log 显示了它停在哪里。 87 分钟。

流处理与复杂事件处理引擎

测试发现：无法验证；log 显示了它停在哪里。 87 分钟。