xxl-mq 正在参加 2020 年度 OSC 中国开源项目评选,请投票支持!
xxl-mq 在 2020 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
投票让它出道
已投票
授权协议 GPL
开发语言 Java 查看源码 »
操作系统 跨平台
软件类型 开源软件
开发厂商
地区 国产
提 交 者 许雪里
适用人群 未知
收录时间 2015-11-29

软件简介

《分布式消息队列XXL-MQ》

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,进一步实现产品开箱即用;

官方文档

技术交流

展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论 (4)

加载中
2019/12/27 14:11
回复
举报
吞吐量是多少
2019/02/19 10:32
回复
举报
许雪里软件作者

引用来自“小99”的评论

您好!目前这个支持消息确认机制吗?
你好,支持的。每条消息事务保证消费且消费一次。
2018/11/28 09:57
回复
举报
许雪里软件作者
XXL携#xxl-job##xxl-mq##xxl-api##xxl-conf##xxl-excel##xxl-crawler#……等十余个项目前来祝贺。并表示xxl-job原生提供的nutz版本执行器简洁实用 :)
2018/01/29 22:00
回复
举报
您好!目前这个支持消息确认机制吗?
2017/03/23 23:31
回复
举报
更多评论
发表于运维专区
2018/12/21 15:57

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

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

27
23
发表于服务端专区
2018/12/03 09:14

分布式消息队列 XXL-MQ v1.2.1 发布,单机 TPS 过万

Release Notes 1、单机TPS过万:示例项目中新增功能测试、性能测试用例,以及消息生产、消费、成功率等方便的数据分析;可参考示例项目性能测试用例(章节 “2.6 功能测试 & 性能测试”),单机TPS过万; 2、底层long polling监控keys非法去重问题修复; 3、注册逻辑优化,批量注册,提高注册性能,降低注册中...

11
29
发表于软件架构专区
2018/11/28 09:48

分布式消息队列 XXL-MQ v1.2.0,集群时移除 ZK 依赖更轻量级

Release Notes 1、client端与Broker长链初始化优化,防止重复创建连接。 2、POM多项依赖升级; 3、UI组件升级; 4、规范项目目录结构; 6、超时控制; 5、通讯迁移至 xxl-rpc; 6、除了springboot类型示例;新增无框架示例项目 "xxl-mq-samples-frameless"。不依赖第三方框架,只需main方法即可启动运行; 7、消息生产,...

19
20
发表了资讯
2016/11/16 11:27

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

分布式消息队列 XXL-MQ v1.1.1 发布了。版本 V1.1.1 特性: 项目groupId改为com.xuxueli,为推送maven中央仓库做准备; 项目推送Maven中央仓库; 底层系统优化,CleanCode等; 修复confirm和alert弹框冲突导致消息列表错乱的问题; 优化ZK注册逻辑,ZK注册基础路径提前初始化; broadcast 广播消息时ZK 发送方不进行watch...

9
31
发表了资讯
2016/09/12 00:00

分布式消息队列 xxl-mq V1.1 ,新特性速览

版本V1.1新特性 1、简单易用: 一行代码即可发布一条消息; 一行注解即可订阅一个消息主题; 2、部署简单: 除ZK之外不依赖第三方服务; 3、三种消息模式: TOPIC(广播消息)模型、QUEUE(并发队列)模型 和 SERIAL_QUEUE(串行队列)模型,下文将会详细讲解: 4、Broker集群、HA: Broker支持集群部署, 可大大提高系统可用性,以及消息...

7
55
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
发表于开发技能专区
2016/08/28 14:44

分布式消息队列XXL-MQ

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

16
52
发表了博客
2019/02/20 13:31

springboot整合xxl-mq学习笔记

首先xxl-mq是大神xuxueli开发的一个消息中间件框架: 与springboot整合过程: <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http:...

0
0
发表了博客
2019/05/28 16:30

MQ:MQ(IBM MQ)

ylbtech-MQ:MQ(IBM MQ) MQ传递主干,在世界屡获殊荣。 它帮您搭建企业服务总线(ESB)的基础传输层。IBM WebSphere MQ为SOA提供可靠的消息传递。它为经过验证的消息传递主干, 全方位、 多用途的数据传输, 并帮助您搭建企业服务总线的传输基础设施。 消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过写...

0
0
08/13 11:29

XXL-job

调度器 执行器 任务管理 调度日志 文档 https://www.xuxueli.com/xxl-job/#%E3%80%8A%E5%88%86%E5%B8%83%E5%BC%8F%E4%BB%BB%E5%8A%A1%E8%B0%83%E5%BA%A6%E5%B9%B3%E5%8F%B0XXL-JOB%E3%80%8B......

0
0
发表于服务端专区
2019/06/27 11:48

MQ

为什么使用MQ? 解耦 异步 削峰 消息队列有什么优缺点? 优点 解耦 异步 削峰 缺点 系统可用性降低 系统复杂度提高 一致性问题 Kafka、ActiveMQ、RabbitMQ、RocketMQ 有什么优缺点? 特性 ActiveMQ RabbitMQ Rock...

0
1
发表了博客
2018/06/25 23:04

MQ

mq MQ安装---linux MQ_V9.0.3_TRIAL_CDR_LNX_ON_X86_64.tar.gz 创建mqm用户 tar -xf MQ_V9.0.3_TRIAL_CDR_LNX_ON_X86_64.tar.gz 切换至解压后的目录: cd MQServer 授权: ./mqlicense.sh -text_only 再选择1接受授权。 安装: rpm -ivh MQSeriesRuntime-6.0.0-0.i386.rpm rpm -ivh MQSeriesSDK-6.0.0-0.i386.rpm rpm -i...

0
0
发表了博客
2019/06/06 15:25

四大MQ比较及MQ详解

消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能,成为异步RPC的主要手段之 一。当今市面上有很多主流的消息中间件,如老牌的ActiveMQ、RabbitMQ,炙手可热的Kafka,阿里巴巴自主开发RocketMQ等。 消息中间件的组成 Broker 消息服务器,作为server提...

0
0
发表了博客
2019/07/03 11:03

MQ详解及四大MQ比较

一、消息中间件相关知识 1、概述 消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能,成为异步RPC的主要手段之一。当今市面上有很多主流的消息中间件,如老牌的ActiveMQ、RabbitMQ,炙手可热的Kafka,阿里巴巴自主开发RocketMQ等。 2、消息中间件的组...

0
0
04/21 18:39

XXL-Job

简书

0
0
发表了博客
07/10 11:11

POSIX 消息队列函数(mq_open、mq_getattr、mq_send、mq_receive)示例

概述 消息队列是Linux IPC中很常用的一种通信方式,它通常用来在不同进程间发送特定格式的消息数据。 消息队列和之前讨论过的管道和FIFO有很大的区别,主要有以下两点: 一个进程向消息队列写入消息之前,并不需要某个进程在该队列上等待该消息的到达,而管道和FIFO是相反的,进程向其中写消息时,管道和FIFO必需已经打开...

0
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
暂无内容
4 评论
66 收藏
分享
返回顶部
顶部