Hàng đợi tin nhắn và streaming mã nguồn mở, đã được kiểm thử

Một nền tảng nhắn tin phân tán theo thời gian thực

Kết quả test: 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 phút.

Một data pipeline hiệu suất cao cho dữ liệu observability.

Kết quả test: 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 phút.

Máy chủ hiệu suất cao cho NATS.io, hệ thống nhắn tin gốc đám mây và biên.

Kết quả test: 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 phút.

Xây dựng ứng dụng hướng sự kiện một cách dễ dàng bằng Go.

Kết quả test: 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 phút.

Nền tảng truyền phát sự kiện cho AI agent. Liên tục thu thập, chuyển đổi và phục vụ các luồng sự kiện theo thời gian thực, ở quy mô lớn.

Kết quả test: 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 phút.

Thư viện nhắn tin cho Python.

Kết quả test: 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 phút.

Một thư viện xử lý stream nhẹ cho Go

Kết quả test: Go 1.22.2 installed, project builds with go build and passes all 100+ tests with go test -count=1 ./... 20 phút.

Một công cụ xử lý luồng dữ liệu bằng Python được mô phỏng theo Yahoo! Pipes.

Kết quả test: 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 phút.

Thư viện xử lý nền type-safe, mở rộng được và hiệu suất cao cho Rust

Kết quả test: 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 phút.

PHP JSON stream parser hiệu quả, dễ sử dụng và nhanh chóng.

Kết quả test: All 841 PHPUnit tests pass on PHP 8.0.30 with dependencies installed via Composer. 4 phút.

Thư viện mạng event-driven nhanh và dễ sử dụng.

Kết quả test: 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 phút.

Zero-cost & Type-safe Reactive Extensions cho Rust. Hỗ trợ cả ngữ cảnh đơn luồng hiệu suất cao (Local) và an toàn luồng (Shared). Sẵn sàng cho WASM & Tokio.

Kết quả test: Rust 1.99.0 was installed, rxRust v1.0.0-rc.5 compiles and all tests pass (452 unit, 29 integration, 190 doctests). 1 phút.

Framework để xây dựng Event-Driven Microservices

Kết quả test: 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 phút.

MQTT Server/MQTT Broker - MQTT Message Broker phân tán, có khả năng mở rộng cho IoT trong kỷ nguyên 5G

Kết quả test: 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 phút.

Hàng đợi bất đồng bộ đơn giản

Kết quả test: 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 phút.

Xây dựng các nền tảng có thể linh hoạt kết hợp các mô hình xử lý SQL, batch và stream

Kết quả test: 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 phút.

một hệ thống messaging phân tán publish-subscribe nhanh và đơn giản (mq)

Kết quả test: Jafka 3.0.8 builds from source, all 70 unit tests pass, and the broker starts on port 9092 accepting TCP connections. 9 phút.

Nghe bất kỳ đài radio nào trên khắp thế giới ngay từ terminal:zap:

Kết quả test: 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 phút.

Một client C cho NATS

Kết quả test: 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 phút.

[Start here!] Flow-IPC - Bộ công cụ C++ hiện đại cho giao tiếp liên tiến trình tốc độ cao (IPC)

Kết quả test: 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 phút.

Một Runtime SDR bất đồng bộ cho các kiến trúc không đồng nhất.

Kết quả test: 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 phút.

Một hàng đợi tin nhắn HTTP đơn giản được viết bằng Go với goleveldb, giống như httpsqs được viết bằng C với Tokyo Cabinet.

Kết quả test: 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 phút.

Bus thông điệp bất đồng bộ đơn giản viết bằng Go

Kết quả test: 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 phút.

Framework serverless được thiết kế chuyên dụng cho các ứng dụng event streaming.

Kết quả test: Go 1.25.0 installed, project builds, controller test suite passes all 57 specs using real Kubernetes envtest binaries. 8 phút.

Hàng đợi tin nhắn đơn giản nhất, trong bộ nhớ, phân tán và không phụ thuộc lưu trữ, cho chương trình Go đồng thời của bạn

Kết quả test: 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 phút.

[READ-ONLY] Bundle hàng đợi tin nhắn cho Symfony. RabbitMQ, Amazon SQS, Redis, Service bus, sự kiện bất đồng bộ, RPC qua MQ và nhiều hơn nữa.

Kết quả test: 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 phút.

Bộ xử lý logs, metrics và traces nhanh và nhẹ cho Linux, BSD, OSX và Windows

Kết quả test: 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 phút.

Engine streaming log phân tán được xây dựng từ các nguyên lý cơ bản

Kết quả test: 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 phút.

csp là một thư viện xử lý luồng phản ứng hiệu suất cao, được viết bằng C++ và Python.

Kết quả test: 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 phút.

Khung Python bất đồng bộ cho các dịch vụ hướng sự kiện. Một client mỏng cho Kafka, RabbitMQ, NATS, Redis và MQTT với quyền truy cập đầy đủ vào các tính năng...

Kết quả test: 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 phút.

framework xử lý luồng dựa trên đồ thị với độ trễ cực thấp

Kết quả test: 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 phút.

Hàng đợi tin nhắn đơn giản trên Redis

Kết quả test: 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 phút.

Apache StreamPipes - Một bộ công cụ IoT (công nghiệp) tự phục vụ để cho phép người dùng không chuyên kết nối, phân tích và khám phá các luồng dữ liệu IoT.

Kết quả test: 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 phút.

Hàng đợi công việc hiệu suất cao cho Bun. Mặc định dùng SQLite, chuyển sang PostgreSQL multi-broker khi bạn mở rộng. DLQ, cron, sao lưu SQLite lên S3 và MCP...

Kết quả test: 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 phút.

Một hệ thống hàng đợi tin nhắn mã nguồn mở hiện đại, hiệu suất cao.

Kết quả test: BlazingMQ broker, CLI tool, and storage tool binaries are built and functional with 212/212 unit tests passing. 75 phút.

Blog học Flink. Có các ví dụ học tập về Flink Connector, Metrics, Library, DataStream API, Table API & SQL, cùng chia sẻ các dự án lớn ứng dụng Flink trong...

Kết quả test: 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 phút.

Message streaming kiểu Kafka trong Go. Được xây dựng trên NATS. Một binary duy nhất, không cần JVM, không cần ZooKeeper.

Kết quả test: 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 phút.

iWF là một nền tảng điều phối microservice theo mô hình Workflow-As-Code, cung cấp một khung lập trình điều phối và dịch vụ để xây dựng các quy trình dài hạn...

Kết quả test: 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 phút.

Dịch vụ webhooks mã nguồn mở và sẵn sàng cho doanh nghiệp

Kết quả test: 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 phút.

Các gói Message Queue, Job Queue, Broadcasting, WebSockets cho PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - được cung cấp bởi Forma-Pro.

Kết quả test: 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 phút.

Máy chủ truyền thông Kurento WebRTC

Kết quả test: không kiểm chứng được; log cho thấy dự án dừng ở đâu. 8 phút.

Cơ sở hạ tầng truyền thông cho kỷ nguyên AI: một binary, một broker, một storage layer, bất kỳ protocol nào.

Kết quả test: không kiểm chứng được; log cho thấy dự án dừng ở đâu. 21 phút.

Xử lý luồng sự kiện dành cho nhà phát triển để thu thập và chuyển đổi dữ liệu đang chuyển động, phục vụ các ứng dụng phản hồi nhanh và xử lý nhiều dữ liệu.

Kết quả test: không kiểm chứng được; log cho thấy dự án dừng ở đâu. 87 phút.

Trình xử lý luồng và công cụ xử lý sự kiện phức tạp

Kết quả test: không kiểm chứng được; log cho thấy dự án dừng ở đâu. 87 phút.