WQS 是微博开源的消息服务中间件。
多租户支持;
多 IDC 支持;
多协议支持 memcached、http 1/2、motan
轻客户端。(去 zk 依赖、无 partition 感知)
支持 pub/sub、long polling、pipeline;
支持 TTL;
支持 filter。
WQS 目前支持多 IDC 部署,创建队列时选取响应的配置表明该队列是否需要多 IDC 功能支持,当 WQS 集群跨 IDC 部署时:
Producer 通过 WQS 实例写消息会时写到与自身实例部署在同一 IDC 内的 Kafka 集群上。
Consumer 通过 WQS 实例读消息时,该实例会根据 Queue 的配置来执行响应的行为。
当 Queue 未配置多 IDC 同步时,该实例只会从该实例部署的 IDC 的 Kafka 集群中读取消息
当 Queue 配置多 IDC 同步时,该实例会从用户所配置的 IDC 内的 Kafka 集群上读取消息,且不同 IDC 的 WQS 实例读取同一 Kafka 集群时,会采用相同的 consumer-group-ID。
为兼容老版本配置,则本地 IDC 的 Kafka 配置为:
其他 IDC 的配置为:
例如远端 IDC 的名称为`abc`则:
如果你要创建一个队列,要支持多 IDC 数据同步,队列名为`abc`,IDC分别为`idc1`、`idc2`,则创建命令为
- 授权协议:
- Apache 2.0
- 开发语言:
- Google Go 查看源码»
- 操作系统:
- 跨平台