云消息队列

RocketMQ x OpenTelemetry 分布式全链路追踪最佳实践

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三种不同消费者类型，同时给出一些最佳实践的推荐。