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

35次阅读

共计 1175 个字符,预计需要花费 3 分钟才能阅读完成。

Release Notes

1、访问令牌(accessToken):为提升系统安全性,消息中心和客户端进行安全性校验,双方 AccessToken 匹配才允许通讯;
2、支持批量注册、摘除,提升注册发现性能;升级 xxl-rpc 至 v1.3.1;
3、升级 pom 依赖至较新版本;
4、表结构调整提升兼容性,表名转小写;
5、客户端取消 Consumer 非空的限制;

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

特性

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

5、三种消息模式:

并行消息:消息平均分配在该主题在线消费者,分片方式并行消费;适用于吞吐量较大的消息场景,如邮件发送、短信发送等业务逻辑
串行消息:消息固定分配给该主题在线消费者中其中一个,FIFO 方式串行消费;适用于严格限制并发的消息场景,如秒杀、抢单等排队业务逻辑;
广播消息:消息将会广播发送给该主题在线消费者分组,全部分组都会消费该消息,但是一个分组下只会消费一次;适用于广播场景,如广播更新缓存等

6、延时消息: 支持设置消息的延迟生效时间, 到达设置的生效时间时该消息才会被消费;适用于延时消费场景,如订单超时取消等;
7、事务性: 消费者开启事务开关后, 消息事务性保证只会成功执行一次;
8、失败重试: 支持设置消息的重试次数, 在消息执行失败后将会按照设置的值进行消息重试执行, 直至重试次数耗尽或者执行成功;
9、超时控制: 支持自定义消息超时时间,消息消费超时将会主动中断;
10、吞吐量: 依赖于部署的消费中心集群和 DB 性能;DB 可借助多表提升性能,不考虑 DB 的情况下,吞吐量可以无限横向扩展;可参考示例项目性能测试用例,单机 TPS 过万;
11、消息可见: 系统中每一条消息可通过 Web 界面在线查看, 甚至支持编辑消息内容和消息状态;
12、消息可追踪: 支持追踪每一条消息的执行路径, 便于排查业务问题;
13、消息失败告警:支持以 Topic 粒度监控消息,存在失败消息时主动推送告警邮件;默认提供邮件方式失败告警,同时预留扩展接口,可方面的扩展短信、钉钉等告警方式;
14、容器化:提供官方 docker 镜像,并实时更新推送 dockerhub,进一步实现产品开箱即用;
15、消息持久化:全部消息持久化存储,消息中心支持通过配置选择是否清理过期消息。
16、访问令牌(accessToken):为提升系统安全性,消息中心和客户端进行安全性校验,双方 AccessToken 匹配才允许通讯;

文档地址
中文文档
技术交流
社区交流

正文完
 0