XXL-MQ v1.2.2 发布，分布式消息队列

Release Notes

• 一、访问令牌（accessToken）：为提高系统安全性，消息中心和客户端进行安全性校验，双方AccessToken匹配才容许通信；
• 二、支持批量注册、摘除，提高注册发现性能；升级 xxl-rpc 至 v1.3.1;
• 三、升级 pom 依赖至较新版本；
• 四、表结构调整提高兼容性，表名转小写；
• 五、客户端取消Consumer非空的限制；

简介

XXL-MQ是一款轻量级分布式消息队列，支持 "并发消息、串行消息、广播消息、延迟消息、事务消息、失败重试、超时控制" 等消息特性。现已开放源代码，开箱即用。

特性

• 一、简单易用: 一行代码便可发布一条消息; 一行注解便可订阅一个消息主题;
• 二、轻量级: 部署简单，不依赖第三方服务，一分钟上手；
• 三、消息中心HA：消息中心支持集群部署,可大大提升系统可用性,以及消息吞吐能力;
• 四、消费者HA：消费者支持集群部署，保证消费者可用性；

• 五、三种消息模式:

  • 并行消息：消息平均分配在该主题在线消费者，分片方式并行消费；适用于吞吐量较大的消息场景，如邮件发送、短信发送等业务逻辑
  • 串行消息：消息固定分配给该主题在线消费者中其中一个，FIFO方式串行消费；适用于严格限制并发的消息场景，如秒杀、抢单等排队业务逻辑；
  • 广播消息：消息将会广播发送给该主题在线消费者分组，所有分组都会消费该消息，可是一个分组下只会消费一次；适用于广播场景，如广播更新缓存等
• 六、延时消息: 支持设置消息的延迟生效时间, 到达设置的生效时间时该消息才会被消费；适用于延时消费场景，如订单超时取消等;
• 七、事务性: 消费者开启事务开关后,消息事务性保证只会成功执行一次;
• 八、失败重试: 支持设置消息的重试次数, 在消息执行失败后将会按照设置的值进行消息重试执行,直至重试次数耗尽或者执行成功;
• 九、超时控制: 支持自定义消息超时时间，消息消费超时将会主动中断；
• 十、吞吐量: 依赖于部署的消费中心集群和DB性能;DB可借助多表提高性能，不考虑DB的状况下，吞吐量能够无限横向扩展；可参考示例项目性能测试用例，单机TPS过万；
• 十一、消息可见: 系统中每一条消息可经过Web界面在线查看,甚至支持编辑消息内容和消息状态;
• 十二、消息可追踪: 支持追踪每一条消息的执行路径, 便于排查业务问题;
• 1三、消息失败告警：支持以Topic粒度监控消息，存在失败消息时主动推送告警邮件；默认提供邮件方式失败告警，同时预留扩展接口，可方面的扩展短信、钉钉等告警方式；
• 1四、容器化：提供官方docker镜像，并实时更新推送dockerhub，进一步实现产品开箱即用；
• 1五、消息持久化：所有消息持久化存储，消息中心支持经过配置选择是否清理过时消息。
• 1六、访问令牌（accessToken）：为提高系统安全性，消息中心和客户端进行安全性校验，双方AccessToken匹配才容许通信；

文档地址

• 中文文档

技术交流

• 社区交流