云消息队列

springmvc+redis实现简单消息队列

阿里云消息队列 Kafka 生态集成的实践与探索

本文将从业务架构和 API 使用等方面讲解如何使用 EventBridge 创建阿里云 RocketMQ 4.0、5.0 版本，开源自建版本以及消息路由的相关任务。

本文主要向大家介绍如何利用 RocketMQ 可观测体系中的指标监控，对生产环境中典型场景：消息堆积、消息收发失败等场景配置合理的监控预警，快速发现问题，定位问题。

以“深入数字经济·洞见技术价值”为主题的【InfoQ 2022 中国技术力量年终榜单】正式公布获奖名单。其中，Apache RocketMQ以其卓越的易用性、社区活跃性、成熟度、产品优越性、代码健康度等荣获【2022 年度十大开源新锐项目】。

我们欢迎任何形式的贡献，包括且不限于新 feature、bugfix、代码优化、生态集成、测试工作、文档撰写。更加欢迎能够认领一个完整的特定语言实现的同学！不要犹豫，欢迎大家以 issue/pull request 的形式将你的想法反馈到社区，一起来建设更好的 RocketMQ！

今天来给大家分享下阿里云 RocketMQ5.0 实例的消息弹性收发功能，并且通过该功能生产集群是如果解决大促场景消息收发的弹性以及降本诉求的。

今天的主题围绕事件总线+函数计算，构建云上最佳事件驱动架构应用。

本次新增集成中心（Integration Center）是负责 EventBridge 与外界系统对接的模块，通过抽象与配置快速获取第三方事件并将事件集成到第三方系统。并且优化现有 HTTP Sink 集成方案，为用户下游集成创造更多适配场景。

在 RocketMQ 5.0 中，更加强调了客户端类型的概念，尤其是消费者类型。为了满足多样的 RocketMQ 中一共有三种不同的消费者类型，分别是 PushConsumer、SimpleConsumer 和 PullConsumer。不同的消费者类型对应着不同的业务场景。

本文介绍 RocketMQ 负载均衡机制，主要涉及负载均衡发生的时机、客户端负载均衡对消费的影响（消息堆积/消费毛刺等）并且给出一些最佳实践的推荐。

11 月 5 日，2022 杭州 · 云栖大会上，阿里云智能高级产品专家杨秋弟在云原生峰会上发表主题演讲，发布消息队列 RocketMQ 5.0：从消息服务到云原生事件流处理平台。

本文主要介绍在使用 RocketMQ 时为什么需要重试与兜底机制，生产者与消费者触发重试的条件和具体行为，如何在 RocketMQ 中合理使用重试机制，帮助构建弹性，高可用系统的最佳实践。

本文将从 SLS 在 EventBridge上 的使用以及若干最佳实践场景等方面，为大家介绍如何基于 EventBridge 构建 SLS 相关应用。

在消息中间件的使用过程中，一个主题对应的消费者想要通过规则只消费这个主题下具备某些特征的消息，过滤掉自己不关心的消息，这个功能就叫消息过滤。

RocketMQ 5.0 SDK 采用了全新的 API，使用 gRPC 作为通信层的实现，并在可观测性上做了很大幅度的提升。

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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