WQS 消息服务中间件 WQS

agolangf • 3535 次点击    
这是一个分享于 的项目,其中的信息可能已经有所发展或是发生改变。
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 查看源码»
操作系统:
跨平台
3535 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传