WQS消息服务中间件
WQS 是微博开源的消息服务中间件。
功能特性
多租户支持;
多 IDC 支持;
多协议支持 memcached、http 1/2、motan
轻客户端。(去 zk 依赖、无 partition 感知)
支持 pub/sub、long polling、pipeline;
支持 TTL;
支持 filter。
多 IDC 部署
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 配置为:
kafka.zookeeper.connect=localhost:2181 kafka.zookeeper.root= #本地IDC的名称,只能是英文字母和数字 kafka.idc=idc
其他 IDC 的配置为:
kafka.remote.<your idc name>.zookeeper.connect=xxx.xxx.xxx.xxx:2181/
例如远端 IDC 的名称为abc
则:
kafka.remote.abc.zookeeper.connect=xxx.xxx.xxx.xxx:2181/
创建队列
如果你要创建一个队列,要支持多 IDC 数据同步,队列名为abc
,IDC分别为idc1
、idc2
,则创建命令为
curl -X PUT "http://127.0.0.1:8080/queues/abc" -d '{"idcs":["idc1","idc2"]}'
评论
Open-MQ消息中间件
Open-MQ是一个开源的消息中间件,类似IBM的WebSphereMQ(MQSeries),采用C++和Qt库编写的,支持Windows、Unix以及MacOS平台,支持JMS。
Open-MQ消息中间件
0
DotNetMQ.NET消息中间件
DotNetMQ是一个开源的消息中间件,主要特性:持久化和非持久化消息传输Guaranteeddeliveryofpersistentmessageseveninasystemcrash.Automa
DotNetMQ.NET消息中间件
0
QMQ消息中间件
QMQ是去哪儿网内部广泛使用的消息中间件,自2012年诞生以来在去哪儿网所有业务场景中广泛的应用,包括跟交易息息相关的订单场景;也包括报价搜索等高吞吐量场景。目前在公司内部日常消息qps在60W左右,
QMQ消息中间件
0
UberMQJMS 消息中间件
UberMQ完全实现了JavaMessageService规范。UberMQ是因为现有的许多JMS提供商已经违背了分布式计算的核心原则:快速与简单而开发的。
UberMQJMS 消息中间件
0