云消息队列

介绍如何基于 Apache RocketMQ 的新特性构建异步化 Multi-Agent 系统，深入探讨 Agent 间的解耦通信、上下文隔离、状态恢复与任务编排机制，并通过实际案例展示如何利用 RocketMQ 实现 Multi-Agent 的任务调度。 讲师/嘉宾简介 周礼｜阿里云智能集团高级技术专家

掌握AI原生应用开发前沿趋势与核心技术！阿里云、快手专家齐聚一堂，带你全面了解典型应用场景及硬核实战经验！ 讲师/嘉宾简介 刘军

参与活动，有机会赢取斯T10扫地机器人、小米2K显示器27英寸Pro、阿里云社区xRocketMQ评测官奖杯、CHERRY机械键盘、罗技G502SE电竞鼠等多重好礼！立即参加：https://developer.aliyun.com/topic/rocketmq

AI 原生应用架构白皮书的背景 AI 原生应用架构的定义 AI 原生应用架构的难点 AI 原生应用架构的实践 讲师/嘉宾简介 肖京(亦盏)，阿里云智能高级技术专家，《AI 原生应用架构白皮书》主创

云端问道16期高弹性低成本的云消息队列 RabbitMQ 版方案教学

从「互联网+」到「云智一体」，从「云原生」到「AI 原生」，软件的定义正在被彻底改写。本场论坛将携手产业、企业、学术界代表，首次系统性阐述我们对 AI 原生应用架构新范式的理解、演进趋势、技术突破，及企业生产环境下 AI 平台建设现状和实践经验，并展示阿里云如何通过Serverless、AI中间件、可观测等产品和技术服务，为企业 AI 时代增长赋能。 讲师/嘉宾简介 释放 AI 研发效能，AI 原生驱动企业架构新范式演进——周琦，阿里云智能集团云原生应用平台负责人 《AI 原生应用架构白皮书》重磅发布——周琦，阿里云智能集团云原生应用平台负责人、穆飞，阿里云智能集团资深总监，阿里云研究院负责人、郑立，稳定性保障实验室负责人、魏峻，中国科学院软件研究所研究员，博士生导师，软件工程学科方向带头人，学术学位委员会委员、倪超，浙江大学软件学院副教授 《AI 原生应用架构白皮书》 解读：加速 AI 应用发生——李艳林，阿里云智能集团资深技术专家 云原生进化论：加速 AI 应用构建最佳范式——李国强，阿里云智能集团资深产品专家 生成式 AI 在实体店现场经营中的机会与实践——赵振宇，盒马资深技术专家 满帮 AI 基建建设现状与架构选型思考——杨兴华，满帮集团产研中心研发总经理 对话：AI 原生将如何重塑应用研发范式——杨兴华，满帮集团产研中心研发总经理、郑立，中国信通院云大所云计算部副主任、才振功，浙江大学软件学院副教授、李国强，阿里云智能集团资深产品专家

《AI 原生应用架构趋势与实践》——肖京｜阿里云智能云原生高级技术专家 《AI 应用云上运行时：函数计算到函数智能》——史明伟｜阿里云智能云原生高级技术专家 《MCP 网关的企业级最佳实践》——张添翼｜阿里云智能云原生技术专家 《可见、可管、可控：阿里云 AI 应用可观测能力建设》——曹炜怿｜阿里云智能云原生解决方案架构师 《Apache RocketMQ for AI：全面拥抱企业级 AI 应用，引领 AI MQ 新时代》——杨文婷｜阿里云智能云原生产品专家

《构建 AI 原生应用的 11 个关键要素》——王晨｜阿里云智能云原生高级技术运营专家 《从传统应用到 AI 应用的一站式托管》——赵庆杰｜阿里云智能云原生高级技术专家 《Higress AI 开放平台：构建企业私有化 MCP/Agent 市场的实践》——刘帅｜Higress Maintainer 《大模型驱动的可观测与 AIOps 新范式》——温希道｜阿里云智能云原生高级技术专家 《Apache RocketMQ x AI：面向异步化 Agent 的事件驱动架构》——周礼｜阿里云智能云原生高级技术专家

ApsaraMQ 全新升级，云消息队列 Confluent 版重磅发布讲师/嘉宾简介丁宇｜阿里云云原生应用平台总经理林清山｜阿里云消息负责人&Apache RocketMQ联合创始人

本论坛聚焦AI时代中间件技术演进，探讨消息队列、事件驱动架构及API网关等关键技术如何赋能AI应用，解析Java开发者构建AI应用的技术路径，重磅发布RocketMQ for AI、EventBridge for AI ETL、AI网关及Spring AI Alibaba Studio。特邀领先企业分享实践经验，助力企业与开发者解锁AI应用架构新范式，加速AI应用规模化落地，共同把握时代机遇。 讲师/嘉宾简介 未来已来：下一代 AI 中间件重磅发布，解锁 AI 应用架构新范式——林清山，阿里云智能集团资深技术专家 Multi Agent 探索与实践：AgentScope Java 版重磅发布——肖京，阿里云智能集团高级技术专家 Apache RocketMQ for AI：全面拥抱企业级 AI 应用，引领 AI MQ 新时代——杨文婷，阿里云智能集团产品专家 EventBridge for AI ETL 全新发布，事件驱动重塑 AI 应用数据全链路——陈涛，阿里云智能集团产品专家、徐志远，阿里云智能集团飞天实验室资深产品专家 AI 网关全新升级， HiMarket AI 开放平台重磅发布——张裕，阿里云智能集团高级产品专家 从 API 网关到 AI 网关：Higress 的演进之路——张添翼，阿里云智能集团技术专家 AI 时代的数据通道：云消息队列 Kafka 的演进与实践——刘尧，阿里云智能集团产品专家

AI Agent 架构趋势及演进 张海彬｜阿里云智能云原生技术专家 API 管理能力再升级：Higress 推出 AI 开放平台助力企业构建私有化 MCP/Agent 市场 泮圣伟｜阿里云智能云原生技术专家 Serverless 应用引擎 SAE： 让 AI 应用开发更简单 牛通｜阿里云智能云原生技术专家 RocketMQ for AI 的事件驱动架构实践 邹星宇｜阿里云智能云原生解决方案架构师 讲师/嘉宾简介 张海彬｜阿里云智能云原生技术专家 泮圣伟｜阿里云智能云原生技术专家 牛通｜阿里云智能云原生技术专家 邹星宇｜阿里云智能云原生解决方案架构师

通过 API 端点，用户可以轻松实现EventBridge与微服务、或SaaS服务进行集成；相比原HTTP方式，API 端点提供了更安全的鉴权方式，更灵活的参数传递，以及更友好的Target管理。讲师沈林(静罗)

B站UP主“IT楠老师”关于RocketMQ5.0的零基础教学课程高能来袭！带你从入门到精通，快来一起感受RocketMQ之美吧！

本次分享着眼于EDA 事件驱动架构的场景实践，从事件驱动架构设计、架构实施、触发配置等细节出发，帮助大家剥茧抽丝，介绍EDA（事件驱动）架构的应用价值与适用场景，为大家带来全方位的 EDA（事件驱动） 解读。讲师陈涛（肯梦）阿里云高级产品经理

本次课程主要介绍基于阿里云EventBridge的消息集成能力，结合目前消息产品的需求热点，从能力范围到场景实战，对EventBridge的消息集成解决方案进行了概要的介绍。 讲师/嘉宾简介 陈永明（昶风）｜阿里云开发工程师

在分布式系统调用场景中存在这样一个通用问题，即在执行一个核心业务逻辑的同时，还需要调用多个下游做业务处理，而且要求多个下游业务和当前核心业务必须同时成功或者同时失败，进而避免部分成功和失败的不一致情况出现。简单来说，消息队列中的“事务”，主要解决的是消息生产者和消费者的数据一致性问题。

消息堆积是指由于消费者的消费能力有限，未能在短时间内将所有消息正确消费掉，此时在服务端保存着未被消费的消息的状态。在 RocketMQ 中，消息堆积可以通过 Metrics 指标来衡量，这些指标可直接反映队列中消息的处理速率和堆积情况。

本期直播通过对阿里云消息队列Kafka Connect的介绍，帮助大家在功能、应用和开源对比层面更好的了解Kafka 生态集成及最佳实践。

RocketMQ 5.0 客户端正在开源社区火热迭代中，欢迎来自社区的开发者广泛参与，借助本次直播可以帮助你对 RocketMQ 5.0 的架构有更加深入的了解，熟悉客户端的基本原理以及贡献流程，从而可以从零开始实现一个健壮的，高性能的 RocketMQ 客户端。讲师凌楚

EventBridge 作为构建 EDA 架构的基础设施，通过一些核心概念和特性提供了灵活丰富的事件收集、处理和路由的能力，并支持通过 OpenAPI、terraform 等方式将这些能力方便快捷的带给用户。本期将介绍 EventBridge 和 IaC 的重点概念和特性，然后演示如何应用 IaC 理念自动化部署 EventBridge 来使用这些概念和特性。讲师王川（弗丁）阿里云技术专家

EventBridge 是事件驱动 EDA （Event-driven Architectures）架构的最佳落地产品，也是 Serverless 的最好搭档。通过本期介绍，带您一起深入了解 EDA 架构和 EventBridge 相关的产品内容，帮助您更好理解数据集成和事件集成的实际应用。讲师

讲师/嘉宾简介 王晨(望宸)｜阿里云智能云原生高级技术运营专家 战立飞(上昀)｜阿里云智能云原生产品专家 李颜良(孤弋)｜阿里云智能高级技术专家 宋明强(鸣溯)｜阿里云智能云原生可观测解决方案架构师 陈涛(肯梦)｜阿里云智能云原生产品专家

聚焦 LoongSuite 生态核心组件 LoongCollector，深度解析 LoongCollector 在智算服务中的技术突破，涵盖多租户观测隔离、GPU 集群性能追踪及事件驱动型数据管道设计，通过零侵入采集、智能预处理与自适应扩缩容机制，构建面向云原生AI场景的全栈可观测性基础设施，重新定义高并发、强异构环境下的可观测性能力边界。 讲师： 杨泽华｜阿里云研发工程师

云端问道16期高弹性低成本的云消息队列 RabbitMQ 版实践教学

结合使用RocketMQ开源自建集群的痛点，以及阿里云商业实例的优势，分析迁移上云的必要性； 对比常见的消息迁移方案，解析阿里云迁移上云方案如何保障用户以较低成本完成业务无缝迁移； 演示阿里云迁移上云方案的整体流程，上手完成从开源自建集群迁移到阿里云商业实例的完整过程。

消息队列Kafka版和Elasticsearch联合解决方案

阿里云消息队列MQ 2019年重磅升级发布会消息队列MQ 2019年重磅升级，开年特惠，限时折扣！普惠开发者，消息队列MQ 将有哪些重磅升级？发布会专属优惠：消息队列开年特惠6.8元起微消息队列 for IoT：新用户尝鲜低至 1 元AMQP子产品全新发布：更多详情点击点击了解“阿里云新品发布会频道”点击订阅：阿里云新品发布·周刊发布会主题主要介绍阿里云消息队列 MQ 产品系列在 2019开年新特性发布，主要包括以下几个方面的内容：消息队列 MQ 产品系列介绍、应用场景以及选型推荐，包括消息队列 RocketMQ、消息队列 Kafka、消息服务 MNS、消息队列 AMQP、微消息队列 MQTT；消息队列 AMQP子产品全新发布，全面兼容RabbitMQ 开源产品以及 AMQP 标准协议，开箱即用，提供更安全、更稳定可靠的云消息服务；消息队列 RocketMQ 全新开放 HTTP 协议，以及 7 种多语言客户端支持；消息队列 MQ实例化功能发布，用户接入流程体验优化等重磅嘉宾背景姓名：杨秋弟（曼红） 职位：阿里巴巴中间件产品专家阿里巴巴中间件产品专家，在分布式互联网领域核心研发多年，具有丰富的高可用、高可靠分布式系统构建以及调优经验。近年来一直从事中间件分布式消息产品相关的设计与研发工作，熟知分布式消息中间件系统架构，设计原理以及各类应用场景，当前负责阿里云消息队列MQ产品系列，包括消息队列 RocketMQ、消息队列 Kafka、微消息队列 for IoT、消息队列AMQP、消息服务 MNS等产品；姓名：张凤婷（娜米） 职位：阿里巴巴中间件高级产品经理阿里巴巴中间件高级产品经理，花名娜米，近年来一直从事阿里大数据产品研发相关工作。目前负责阿里云消息队列MQ、消息队列Kafka等的产品工作。扫描二维码加入中间件官方钉钉群，与专家沟通0距离。

《Apache RocketMQ Eventbridge｜您的 GenAI 为何需要 EDA？》 Lin Shen｜Apache RocketMQ PMC 《解密 Apache Kafka 的架构创新与多场景最佳实践》 Fujian Zhao｜Alibaba Senior Software Engineer 《使用 Apache RocketMQ 赋能无服务器消息架构》 Juntao Ji｜Alibaba Senior Development Engineer 《基于 Commitlog 和 RocksDB 的 RocketMQ 存储引擎》 Zhou Li｜Alibaba Cloud 《消息系统可观察性最佳实践｜Apache RocketMQ 和 OpenTelemetry 案例研究》 Minghui Zhang｜Alibaba Cloud 《弥合鸿沟｜在生产环境中协调 Apache SkyWalking 和 OpenTelemetry》 Cheng Chen｜Alibaba Senior Development Engineer 《全景可观测性｜LoongCollector 助力大规模 Apache Flink 和 Spark 集群》 Runqi Lin｜Alibaba Cloud Hongyi Zhou｜Alibaba Cloud

RocketMQ重试机制的概念与最佳实践 讲师/嘉宾简介： 李智敏（斜阳）：Apache RocketMQ Committer

RocketMQ功能解析：多样消费功能系列 消息队列 讲师/嘉宾简介： 丁双喜：阿里云云原生 消息技术专家

定时消息是生产者将一条消息发送到消息队列后并不期望这条消息马上会被消费者消费到，而是期望到了指定的时间，消费者才可以消费到。

为什么函数计算是最好的事件驱动服务，为什么我们如此需要事件总线服务？“Back to the essential of event-driven”，基于事件总线提供通用的事件通道和可定制化的事件推送能力，基于函数计算轻量化开发部署模式，提供快速扩展、细粒度、免运维的高性能事件处理引擎，基于云利用事件总线和函数计算构建最好的Serverless化事件驱动架构应用，极速上线提供服务，让事件驱动架构的优势真正为企业带来生产力的变革。讲师史明伟（世如)阿里云高级技术专家

事件总线EventBridge产品和Serverless函数计算产品全面深度集成，意味着函数计算和阿里云生态各产品及业务SaaS系统有了统一标准的接入方式；依托EventBridge统一标准的事件源接入能力，结合Serverless函数计算高效敏捷的开发特点，能够帮助客户基于丰富的事件，结合EDA架构快速构建云上业务系统。讲师史明伟（世如)阿里云高级技术专家

讲师：徐雷（点击关注专家，掌握一手干货）阿里云栖Java技术专场讲师2018阿里云大学讲师，与阿里P9叶翔主讲《阿里巴巴MongoDB高级实战课程》Java Spring Boot《阿里巴巴MongoDB认证》讲师阿里巴巴MongoDB大会讲师2017翻译《MongoDB实战》第2版吉林大学计算机学士，上海交通大学硕士直播内容：第(11)课：Java Spring Boot 2.0消息中间件 RabbitMQ 与APi源码解析(底层架构与Java面试题)直播地址：Java技术进阶群2000人大群进群方式：钉钉扫码入群

《AI 原生应用架构探索与实践 》、《开发更可控，部署更便捷：AgentScope 迈入1.0时代》、《AI网关：AI原生架构下的智能流量中枢》、《从可观测到RL：打造生产级可靠的长周期Agent》 讲师/嘉宾简介 肖京｜阿里云智能云原生高级技术专家 邝炜瑞｜阿里巴巴集团通义实验室 高级算法工程师 赵炳堃｜阿里云智能云原生高级开发工程师 马云雷｜阿里云智能云原生技术专家

RocketMQ 5.0 中的消费者类型与最佳实践 讲师/嘉宾简介： 艾阳坤：Apache RocketMQ PMC Member

本文章为创建专用网络VPC操作指引。

当消费者消费消息失败时， RocketMQ 会按照最大重试次数重新投递该消息进行故障恢复。在集群模式下，消费的业务逻辑代码会返回消费失败状态，或者抛出异常，如果一条消息消费失败，则会按照设置的最大重试次数重试，之后该消息会被丢弃。

对于一个指定的 Topic，同一 MessageGroup 的消息按照严格的先进先出（FIFO）原则进行发布和消费，即先发布的消息先消费，后发布的消息后消费，服务端严格按照发送顺序进行存储、消费。

结合使用RocketMQ开源自建集群的痛点，以及阿里云商业实例的优势，分析迁移上云的必要性；对比常见的消息迁移方案，解析阿里云迁移上云方案如何保障用户以较低成本完成业务无缝迁移；演示阿里云迁移上云方案的整体流程，上手完成从开源自建集群迁移到阿里云商业实例的完整过程。讲师/嘉宾简介徒钟

在分布式系统调用场景中存在这样一个通用问题，即一个核心业务逻辑的执行同时还需要调用多个下游做业务处理，要求多个下游业务和当前核心业务必须同时成功或者同时失败，避免部分成功和失败的不一致情况。本期主要介绍RocketMQ事务消息，通过功能场景、应用案例以及最佳实践等角度介绍RocketMQ事务消息类型的使用。讲师阮体洪(合伯)阿里云云原生研发专家

借助EventBridge的能力，我们可以快速的将多个云产品联动起来。本期将以几款云产品为示例，讲解如何利用EventBridge快速集成这些云服务，落地EDA架构。

作为一款无服务器事件总线服务，EventBridge 已经具备将阿里云产品、其他云厂商产品、SaaS 应用等整和到事件生态中的能力。本期将以 EventBridge Http Source 事件源为基础，讲解如何将 EventBridge 集成到 SaaS 应用中，帮助您更好实现业务事件上云。讲师陈永明（昶风）阿里云开发工程师

在多种消息类型中，普通消息是最简单也最为重要。普通消息是 RocketMQ 的基本消息类型，提供高吞吐、扩展、低延迟、异步的通信能力。

主要介绍如何利用RocketMQ可观测体系中的指标监控，对生产环境中典型场景：消息堆积、消息收发失败等场景配置合理的监控预警，快速发现问题，定位问题。讲师阮体洪(合伯)阿里云云原生研发专家

1）介绍消息过滤是什么，应用场景是怎么样的以及使用它能带来什么好处；2）介绍RocketMQ在实现消息过滤时的两种模式（Tag过滤和SQL过滤），包括这两个模式分别怎么使用以及技术原理是怎么样的，他们之间在能力上有什么差异；3）介绍消息过滤的最佳实践，包含主题如何划分、消息如何定义，以及订阅关系一致性的重要性；4）Demo演示，看下怎么在代码里面使用这两种过滤模式，以及效果是怎么样的。讲师丁双喜（徒钟）阿里云消息技术专家

讲师简介：鹿玄，阿里云智能解决方案架构师，经历过大型分布式系统的开发和维护，并在云计算、云原生等领域有多年从业经验。对系统架构选型、问题排查、性能调优有着丰富的实战经验。致力于通过云原生架构转型来帮助阿里云各行业客户实现业务价值。直播时间：2020/11/10（周二） 15:00议题简介：消息队列Kafka版是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。消息队列Kafka版广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的一部分。本次直播将为您深入分享消息队列Kafka的实战经验。议题大纲：1.阿里云消息队列Kafka的优势2.如何迁移阿里云Kafka3.客户端原理及实践4.典型应用场景观看方式：【加入钉钉群观看】阿里云专门成立了“互联网架构升级实战课”钉钉群，每周邀请一位阿里云专家在群内进行行业最佳实践直播，每天分享行业前沿干货，欢迎扫码或钉钉搜索群号加入：35712134。

高性能可靠传输机制系列RocketMQ客户端负载均衡机制 讲师/嘉宾简介： 张森泽（玄珏）

● 课题一：RocketMQ 存储弹性--冷热数据分级存储简介：本课程的核心内容是解析RocketMQ商业版储存空间按需使用、按量服务的底层设计，讲解阿里云在消息系统储存弹性的探索，包括如何低成本动态扩缩容、如何实现消息冷热分离与压缩归档等。● 课题二：RocketMQ 消息收发弹性--生产集群如何解决大促场景消息收发的弹性&降本诉求简介：本课程通过对消息收发弹性简介、产品使用和使用演示等方面的介绍，帮助大家更深入的了解阿里云RocketMQ5.0实例的消息弹性收发功能，以及通过该功能生产集群是如何解决大促场景消息收发的弹性和降本诉求。讲师玄珏阿里云消息技术专家宸罡阿里云消息技术专家

● 直播主题：RocketMQ 重试机制的概念与最佳实践直播讲师：李智敏（斜阳）直播简介：本文主要介绍在使用 RocketMQ 时为什么需要重试与兜底机制，介绍生产者与消费者触发重试的条件和具体行为，以及如何在 RocketMQ 中使用重试机制的最佳实践。● 直播主题：RocketMQ 客户端负载均衡机制直播讲师（含Title）： 玄珏直播简介：介绍 RocketMQ 负载均衡机制，主要涉及负载均衡发生的时机、客户端负载均衡对消费的影响（消息堆积/消费毛刺等）并且给出一些最佳实践的推荐● 直播主题：RocketMQ 5.0 中的消费者类型和最佳实践直播讲师：艾阳坤直播简介：介绍 RocketMQ 的多种消费类型，主要涉及PushConsumer、SimpleConsumer和PullConsumer三种不同消费者类型，同时给出一些最佳实践的推荐。