QMQ

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

主要提供以下特性：

异步实时消息
延迟/定时消息(支持任意秒级)
广播消息(每个Consumer都收到相同消息，比如本地cache更新)
基于Tag的服务端过滤
Consumer端幂等处理支持
Consumer端filter
消费端支持按条ack消息
死信消息
结合Spring annotation使用的简单API
提供丰富的监控指标
接入OpenTracing
事务消息
Consumer的处理能力也可以方便扩容缩容
Server可以随心所欲扩容缩容
Java Client, .NET Client
读写分离
消息投递轨迹
历史消息的自动备份
有序消息(即将开源)

JDK最低版本要求

Client: 1.7及其以上版本
Server: 1.8及其以上版本

Maven

qmq的客户端已经发布到maven中央仓库，可以通过下面的方式获取

<dependency>
    <groupId>com.qunar.qmq</groupId>
    <artifactId>qmq</artifactId>
    <version>{see maven}</version>
</dependency>

快速开始

你可以通过设计背景了解设计QMQ的初衷和它与其他消息队列的不同。阅读架构概览了解QMQ的存储模型

文档

技术支持

欢迎关注QMQ官方公众号

公众号

QQ群

QMQ技术交流群(2)	QMQ技术交流群(1)
群号:1018190609	群号:915826408(已满)

Project Name	Stars	Repos Using This	Packages Using This	Most Recent Commit	Total Releases	Latest Release	Open Issues	License	Language
Springboot Labs	17,808			4 months ago			42		Java
一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024
Flink Learning	13,801			2 months ago			8	apache-2.0	Java
flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
Benthos	6,835		12	13 hours ago	51	November 24, 2023	402	mit	Go
Fancy stream processing made operationally mundane
Watermill	6,256		192	21 days ago	48	September 24, 2023	92	mit	Go
Building event-driven applications the easy way in Go.
Cap	6,247	10	269	a day ago	205	November 24, 2023	12	mit	C#
Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern
Surging	3,206	7	30	8 months ago	27	April 21, 2019	251	mit	C#
Surging is a micro-service engine that provides a lightweight, high-performance, modular RPC request pipeline. support Event-based Asynchronous Pattern and reactive programming ,The service engine supports http, TCP, WS,Grpc, Thrift,Mqtt, UDP, and DNS protocols. It uses ZooKeeper and Consul as a registry, and integrates it. Hash, random, polling, Fair Polling as a load balancing algorithm, built-in service governance to ensure reliable RPC communication, the engine contains Diagnostic, link tracking for protocol and middleware calls, and integration SkyWalking Distributed APM
Qmq	2,712	3	2	5 months ago	44	April 12, 2023	49	apache-2.0	Java
QMQ是去哪儿网内部广泛使用的消息中间件，自2012年诞生以来在去哪儿网所有业务场景中广泛的应用，包括跟交易息息相关的订单场景；也包括报价搜索等高吞吐量场景。
Gochat	2,415			4 days ago			26	mit	Go
goim server write by golang !🚀
Vanus	2,313		7	5 days ago	3	September 07, 2023	57	apache-2.0	Go
Vanus is a Serverless, event streaming system with processing capabilities. It easily connects SaaS, Cloud Services, and Databases to help users build next-gen Event-driven Applications.
Enqueue Dev	2,127			a month ago			33	mit	PHP
Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro

Qmq

QMQ

JDK最低版本要求

Maven

快速开始

文档

技术支持

欢迎关注QMQ官方公众号

QQ群

开源协议

用户(已经在生产使用)

Stars History