Queue Awesome

• nats-io/nats-server
  • liftbridge-io/liftbridge
    • vs. NATS Streaming
  • nats-io/nats-streaming-server
    • 已废弃 - 使用 jetstream - nats 启动添加 -js
    • Protocol Buffer 编码
    • 持久化
    • QoS
    • 流控
• redpanda-data/redpanda
  • BSL, C++,Go
  • Kafka compatible
  • No Zookeeper
• confluentinc/ksql
  • Confluent Community License, Java
• cashapp/pranadb
  • Apache-2.0, Go
• RabbitMQ
  • AMQP, MQTT, STOMP, HTTP
• nsqio/nsq
  • 开发相对没有那么活跃

Protocol

• STOMP - Simple Text Oriented Message Protocol
  • 端口 61613
  • 类 HTTP
  • 基于文本 frame 通讯
  • Client: SEND, SUBSCRIBE/UNSCRIBE, ACK/NACK
  • Server: MESSAGE, RECEIPT, ERROR
  • 1.1 - 支持心跳, NACK, Virtual Host
  • 1.2 - 2012-10-22
    • 支持 \r\n 而不只是 \n， ACK 头
    • 支持重复 Frame 头, content-length & content-type 头
    • 要求服务端支持 STOMP frame
    • 链接驻留
    • 订阅和事务的 Scope 和唯一标识
    • RECEIPT
• MQTT - Message Queue Telemetry Transport
  • 端口 1883
  • 由 IBM 为嵌入式设备 Telemetry 设计
  • 适用于 Low Bandwid、High Latency、Data Limit、Fragile Connection 场景
  • 二进制格式 - 2 byte 头
  • Pub/Sub
  • 可靠 - QOS
  • 安全 - Auth、TLS/SSL
  • 简单
  • Connect/Disconnect + Publish + Subscribe/Unscribe
• AMQP - Advanced Message Queue Protocol
  • 端口 5672
  • 2006 JP Morgan
  • 作为中间件 - 解决业务耦合问题
  • 设计为可替代的消息中间件 - 很多实现
  • 0.9.1 和 1.0 不兼容 - RabbitMQ 为 0.9.1, ActiveMQ 为 1.0
• Openwire
  • 端口 61616

Server

• 考虑选择的标准
  • 队列特性
    • 分发保证
      • At Least Once
      • At Most Once
      • Exactly Once
    • 模式
      • Pull
      • Push
      • Request/Replay
      • Consumer Group/负载均衡
    • 优先级
    • 消息保留和持久化
      • 介质 - 文件、内存、分片、副本、DB
      • TTL - Rentention
      • 长短期存储 - 归档
    • Filter
    • Dedup
    • Message Size
    • Flow control - rate matching/limiting
    • 多租户 - 分片/Topic/Subject
  • 场景
    • 事务
    • 嵌入式
    • RPC
    • Event
    • IPC
  • 集成能力
    • AMQP, MQTT, STOMP, HTTP, WebSocket, Kafka
  • 集群容错
  • 路由分发能力
  • 部署模式
  • 服务特性
    • 安全
    • AuthN
    • AuthZ