PMQ是拍拍贷研发一款分布式消息队列,能够保证消息的不丢失,具有部署和运维简单的特性。消息队列采用mysql数据库进行消息存储,能够非常方便和简单的进行水平扩展。
消息队列基于Spring Boot开发,打包后可以直接运行,不需要额外安装Tomcat等应用容器。
消息队列原生客户端不依赖任何框架,能够运行于所有Java1.8+运行时环境,同时对Spring Mvc/Spring Boot环境也有额外支持。
本地快速部署请参见 wiki 快速部署
消息队列具有以下特点:
- 支持动态重平衡
- 支持动态修改偏移量
- 支持动态修改线程数
- 支持动态修改延迟时间
- 支持动态设置黑白名单
- 支持动态修改批量消费条数
- 支持消息发送令牌防止乱发
- 支持动态启停消费
- 支持自助创建topic,自助扩容
- 支持自助创建消费者组
- 支持自助添加和解除定于消息者组
- 支持一个应用订阅多个消费者组
- 失败消息重新消费
- 支持消息无缝迁移