消息队列

消息队列(Message Queue,简称MQ)是阿里云商用的专业消息中间件,是企业级互联网架构的核心产品,基于高可用分布式集群技术,搭建了包括发布订阅、消息轨迹、资源统计、定时(延时)、监控报警等一套完整的消息云服务。MQ历史超过7年,帮您实现分布式计算场景中所有异步解耦功能,是阿里双11使用的核心产品。MQ由阿里巴巴集团中间件技术部自主研发,是原汁原味的阿里集团中间件技术精华之沉淀,是性价比最高、最可靠的企业级消息中间件产品。
  • MQ快速入门

  • MQ消息查询

  • MQ资源报表使用指南

MQ介绍

产品概述

消息队列优势

专业&验证

1、MQ是消息领域业内专业的消息中间件,多次在国内外获奖
2、经过双11阿里交易、商品、营销等核心链路真实场景验证
3、阿里集团内部1000+核心应用使用,每天流转几千亿条消息,稳定可靠
4、3种消息发送方式,消息场景全覆盖:可靠同步、可靠异步、oneway方式

技术体系

1、产品历史超过7年,消息保证不丢,技术体系丰富成熟
2、阿里内部产品名:MetaQ、Notify
3、开源社区产品名:RocketMQ,无技术绑定风险
4、应用灵活,无任何强制绑定其他产品

独立部署

1、支持专有云独立输出,支持物理机和虚拟机,最小部署仅几台机器
2、专有云配套运维系统,方便运维人员实时监控系统状态
3、专有云配套mqadmin命令集和管理类open API,方便集成及统一运维
4、支持混合云架构,包括VPC用户

高可靠

1、一份消息多份落盘存储,经过严格断电测试,消息依然保证不丢失
2、支持消息轨迹,消息从生产到消费轨迹,可清晰排查
3、海量消息堆积,单个Topic可堆积100亿+条消息,防止系统高流量崩溃
4、默认情况下消息落盘保留3天

高性能

1、同一网络内,消息传输RT在10毫秒之内,性能测试下,网卡可被打满
2、公有云默认单Topic 发送消息为每秒5000条,最高可申请扩展至10W以上
支持大量消息并发发送,超过5万个队列,性能依然卓越
3、支持消息海量堆积,单Topic可堆积100+亿条消息
4、单条消息默认最大支持256K,北京为4M

多协议

1、HTTP接入(简单、免费):HTTP公网接入支持跨网络调用,无短连接池,不会导致FULL GC,无CPU 100%占用风险
2、MQTT接入(物联、免费):支持主动推送模,多级Topic模型支持一次触达1000万+终端
可广泛应用于物联网\社交\娱乐互动场景,支持SSL加密、web socket、flash
3、TCP接入(专业) :区别于HTTP简单的接入方式,同时提供更为专业、可靠、稳定的TCP协议的SDK接入

产品功能

消息管理

Web控制台

1、Topic管理-创建、查询、删除、授权Topic
2、发布管理-创建、查询、删除ProducerID及示例代码
3、订阅管理-创建、查询、删除ConsumerID及示例代码
4、消息查询-按照Topic、消息key、消息ID查询
5、资源报表-消息消费、消息生产
6、监控报警
7、MQTT管理-GroupID管理、查询、收发统计
8、分布式事务TXC for MQ-事务总览、事务列表、活动事务

授权管理

支持两种授权模式:支持主-主账号授权;RAM主子账号授权

管理Open API

方便和自由管理系统集成,提供管理类API,创建Topic、Producer、Consumer等操作

管理mqadmin命令集

专有云同时提供一套丰富的mqadmin管理命令集,以命令方式管理您的MQ服务

消息模型

发布订阅模型

多线程发布、多线程订阅,一对多、多对多Topic模型,Topic个数无限水平扩展

定时消息(延迟消息)

在消息层面,实现消息延迟投递,满足应用需要定时、延迟发送消息的需求
最长定时(延时)40天

事务消息

实现类似X/Open XA的分布事务功能,达到事务最终一致性,保障业务可靠稳定。

大消息

目前默认最大消息为256K,支持最大4M消息(北京)

客户端接入

SDK接入

在TCP层,官方提供JAVA、C++、.NET、PHP四种高可靠SDK接入

PHP、Python、Nodejs即将支持

HTTP接入,可通过公网访问。

支持RESTful风格HTTP协议完成收发消息,可以解决跨语言使用MQ问题

MQTT接入,可通过公网访问。

真正的消息推送,可以满足物联网和社交设备与设备、设备与应用间的可靠高效的通信,适合大规模移动推送场景

特色功能

重置消费进度

如果您想重新消费一段时间(3天)内的消息,在Web控制台使用重置消费进度
将时间轴拉回指定时间即可,最大程度降低程序代码BUG的影响

消费者状态

在控制台-订阅管理,可以迅速查询消费端细节信息,包括: 在线情况、IP地址信息、消费TPS(成功、失败)、消费进程信息、消费线程数、消费堆积量、消费业务延迟时间、JAVA堆栈信息等

消息过滤

根据TAG可以进行消费过滤,增加消费灵活性

基本有序

MQ服务尽量保证消息有序,也可以通过消息Key来判断消息顺序,达到绝对有序的业务需求

轨迹跟踪

可以查看每条消息从生产到消费的整条链路的投递轨迹,是排查问题的利器

专有云

灵活部署

1、支持专有云独立输出,支持物理机和虚拟机,最小部署仅几台机器,可水平扩展至千台机器
2、部署验证效率高,一般情况下半天部署,半天验证
3、支持混合云架构

运维管控

1、专有云配套运维系统,方便运维人员实时监控系统状态
2、专有云配套mqadmin命令集和管理类open API,方便集成及统一运维。

专家定制

1、提供技术方案设计
2、按需高级定制化
3、专家级现场技术支持与培训
4、解决方案咨询:solution-middleware@service.aliyun.com

应用场景

消息队列Message Queue可应用在多个领域,包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等。

  • 消息发送
  • 事务场景
  • 通用场景
  • 行业应用

帮助与文档

开发者资源-TCP接入

开发者资源-HTTP接入