开源中间件与消息队列全家桶
本帖精选消息队列与中间件工具,涵盖发布订阅、异步任务、事件驱动等,是微服务架构和企业级系统的核心基础设施。
- apache/kafka — 28K★ | Java | 分布式流平台,高吞吐量/持久化/分区/消费者组,Confluent/KSQLDB,事件溯源/CQRS
- rabbitmq/rabbitmq-server — 12K★ | Erlang | AMQP消息代理,Exchange类型(direct/fanout/topic),vhost虚拟主机/Memory/Disk告警
- redis/redis — 67K★ | C | 内存数据库+消息队列,String/Hash/List/Set/ZSet,Pub/Sub发布订阅,Redis Streams流
- nats-io/nats-server — 14K★ | Go | 轻量高性能消息系统,Pub/Sub/Request-Reply,JetStream持久化,NATS Service Mesh
- zeromq/libzmq | C++ | 嵌入式网络库,套接字模式REQ/REP/PUB/SUB/PUSH/PULL,inproc/ipc/tcp传输
- django/django-rq | Python | Django Redis队列,RQ(Redis Queue)后台任务,@job装饰器,rqdashboard监控
- sidekiq/sidekiq | Ruby | Ruby后台任务,线程并发/Redis队列,Sidekiq Pro企业版特性
- bee-queue/bee-queue | JavaScript | Node.js后台任务,Bull队列/Redis后端,Priority优先级/延迟任务/DLQ死信队列
核心功能
• Kafka: kafka-topics.sh,kafka-console-producer/consumer,ksqlDB流SQL,Kafka Connect数据集成
• RabbitMQ: rabbitmqctl status,rabbitmq-plugins enable,DLX死信交换机, Shovel迁移数据
• Redis: redis-cli,PUBLISH/SUBSCRIBE,XADD/XREADGROUP Stream消费,BLPOP阻塞读取
• NATS: nats-server &,nats-pub/nats-sub,jetstream stream/consumer,nkv键值存储
适用场景
• 微服务异步通信
• 日志实时采集
• 事件驱动架构
• 消息广播通知
• 后台任务处理
游客,本帖隐藏的内容需要积分高于 20 才可浏览,您当前积分为 0 |