消息队列

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

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

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

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

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

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

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

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

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

在有序事件处理、交易撮合、CDC增量同步等场景，异构系统之间需要维持强一致的状态同步，上游的变更事件需要按序传递到下游正确处理。在这类场景中使用RocketMQ顺序消息可以保证数据传输的顺序性。本期主要介绍RocketMQ顺序消息，通过功能场景、应用案例以及最佳实践等角度介绍RocketMQ顺序消息类型的使用。讲师詹洲翔（绍舒）阿里云云原生研发专家

RocketMQ作为金融级可靠的业务消息方案，一直专注于业务集成领域的异步通信能力构建。本期将从业务集成场景的诉求开始，介绍RocketMQ作为业务消息集成方案的核心能力和优势，通过功能场景、应用案例以及最佳实践等角度介绍RocketMQ普通消息类型的使用。讲师陈仲良（明锻）阿里云云原生产品专家

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

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

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

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

阿里云消息队列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距离。

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

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

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

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

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

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

迅速蜕变| 架构师成长系列直播正式上线！》》》 【直播介绍】 分享阿里云消息队列 Kafka 版相对于自建开源 Kafka 的产品优势，介绍研发团队在这背后遇到的挑战，以及如何应对这些挑战。着重从原理层面介绍了消息队列 Kafka 版产品的易用性、稳定性以及内核的差异化特性。 【讲师介绍】 叶茂伟，阿里云高级开发工程师 具有多年分布式系统、中间件工程经验，对消息队列等分布式系统有深刻理解，目前主要负责阿里云消息队列Kafka版内核研发工作。

本次技术沙龙，天谋科技将联手 RocketMQ 社区，进行技术开发集成，与落地实践分享，以期为各位提供时序数据高稳定、高吞吐、“端边云”一体化传输的可行方案。 讲师/嘉宾简介 蔡宗翰、王帆、张金瑞、侯昊男

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

本讲将从基础概念、API使用以及实操等方面展开，为大家介绍如何使用EventBridge创建RocketMQ 4.0、5.0 以及自建实例相关任务，同时也为大家介绍实现 RocketMQ 端到端能力的消息路由，帮助开发者轻松构建云上数据管道服务。讲师陈永明（昶风）阿里云云产品研发专家

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

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

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

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

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

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

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

直播主题：消息队列之延时消息应用解析及实践直播时间：1月20日（周三）15：00直播简介：消息队列常用于实现业务需要的异步、解耦以及削峰功能。但在某些特殊的业务场景中，还需要消息队列服务本身支持一些特殊的消息类型，比如常见的延时消息。本次直播为您深入剖析延时消息的特性、应用场景，对比各类消息队列对延时消息的支持情况，并向大家介绍阿里云商业版RocketMQ消息队列服务。讲师：鹿玄，阿里云智能解决方案架构师，经历过大型分布式系统的开发和维护，并在云计算、云原生等领域有多年从业经验。对系统架构选型、问题排查、性能调优有着丰富的实战经验。致力于通过云原生架构转型来帮助阿里云各行业客户实现业务价值。观看方式：【加入钉钉群观看】阿里云专门成立了“互联网架构升级实战课”钉钉群，每周邀请一位阿里云专家在群内进行行业最佳实践直播，每天分享行业前沿干货，欢迎扫码或钉钉搜索群号加入：35712134。

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

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

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

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

EventBridge在近期上线了open API target，open API target可以驱动所有云产品的open API，使得用户能够基于 EventBridge 来触发云产品接口以管理自己的云上资源。本讲将从基础概念、如何使用以及实践场景等方面为大家介绍 EventBridge open API target，便于大家快速熟悉这项EventBridge产品的新能力。讲师陈永明（昶风）阿里云云产品研发专家

讲师陈仲良（明锻）阿里云云原生产品专家尘央（周新宇）阿里云云原生高级技术专家洛浩（卢萌凯）阿里云云原生高级解决方案框架师

在分布式定时调度触发、任务超时处理等场景，需要实现精准、可靠的定时事件触发。本期主要介绍RocketMQ定时消息，通过功能场景、应用案例以及最佳实践等角度介绍RocketMQ定时消息类型的使用。讲师李凯阿里云云原生研发专家

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

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

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