消息中间件QMQ

[帝国文明]

QMQ 是去哪儿网内部广泛使用的消息中间件，自2012年诞生以来在去哪儿网所有业务场景中广泛的应用，包括跟交易息息相关的订单场景； 也包括报价搜索等高吞吐量场景。目前在公司内部日常消息 qps 在 60W 左右，生产上承载将近 4W+ 消息 topic ，消息的端到端延迟可以控制在 10ms 以内。

在设计背景里，已经描述了QMQ没有采用基于partition存储模型，但是在学习Kafka和RocketMQ的存储实现方式后，有很多地方是值得借鉴的：顺序append文件，提供很好的性能；顺序消费文件，使用offset表示消费进度，成本极低；将所有subject的消息合并在一起，减少parition数量，可以提供更多的subject(RocketMQ)。

下图是QMQ中各组件及其交互图:meta server提供集群管理和集群发现的作用；server 提供实时消息服务；delay server 提供延时/定时消息服务，延时消息先在delay server排队，时间到之后再发送给server；producer 消息生产者；consumer 消息消费者。

项目地址： https://github.com/qunarcorp/qmq