/pmq

拍拍贷mq消息系统

Primary LanguageJavaApache License 2.0Apache-2.0

PMQ 拍拍贷微服务消息队列介绍

PMQ是拍拍贷研发一款分布式消息队列,能够保证消息的不丢失,具有部署和运维简单的特性。消息队列采用mysql数据库进行消息存储,能够非常方便和简单的进行水平扩展。

消息队列基于Spring Boot开发,打包后可以直接运行,不需要额外安装Tomcat等应用容器。

消息队列原生客户端不依赖任何框架,能够运行于所有Java1.8+运行时环境,同时对Spring Mvc/Spring Boot环境也有额外支持。

本地快速部署请参见 wiki 快速部署

Screenshots

PMQ交互图

Features

消息队列具有以下特点:

  1. 支持动态重平衡
  2. 支持动态修改偏移量
  3. 支持动态修改线程数
  4. 支持动态修改延迟时间
  5. 支持动态设置黑白名单
  6. 支持动态修改批量消费条数
  7. 支持消息发送令牌防止乱发
  8. 支持动态启停消费
  9. 支持自助创建topic,自助扩容
  10. 支持自助创建消费者组
  11. 支持自助添加和解除定于消息者组
  12. 支持一个应用订阅多个消费者组
  13. 失败消息重新消费
  14. 支持消息无缝迁移