消费者分类
如何实现同步、异步消息处理：对于不同的集成场景，消费者获取消息后可能会将消息异步分发到业务逻辑中处理，此时，消息异步化处理如何实现？如何实现消息可靠处理：消费者处理消息时如何返回响应结果？如何在消息异常情况进行重试，保证...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
消息堆积和延迟问题
通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或在运维过程中及时调整业务逻辑，避免因消息堆积和延迟影响业务运行。背景信息 消息处理流程中，如果客户端的消费...
定时/延时消息
因此，下文统一用定时消息描述。在分布式定时调度触发、任务超时处理等场景，需要实现精准、可靠的定时事件触发。使用 云消息队列 RocketMQ 版 的定时消息可以简化定时调度任务的开发逻辑，实现高性能、可扩展、高可靠的定时触发能力。典型...
共享订阅
使用场景 服务端负载均衡 当大量设备接入物联网平台并向物联网平台发送消息时，需要有多个业务服务端来处理这些消息，物联网平台的共享订阅特性可以帮助客户将消息分发到多个业务服务端，实现负载均衡。在下图中，业务服务端A、B使用相同的...
中兴通讯的Landing Zone：“一站式”云上管理及治理
提升效率：公网业务开通到结算由技术部统一管理，开通后信息安全部跟进落实防护情况，让用户专注于业务，让安全更简单。总结 中兴通讯在集团信息安全部和技术部的联合努力下完成了云上统管IT治理，对存量业务进行了更好的管理及治理，未来...
应用场景
通过 云消息队列 Kafka 版 的发布/订阅模型，您可以实时收集网站活动数据（例如注册、登录、充值、支付、购买），根据业务数据类型将消息发布到不同的Topic，然后利用订阅消息的实时投递，将消息流用于实时处理、实时监控或者加载到Hadoop...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
什么是云原生应用组装平台BizWorks
云原生应用组装平台BizWorks是基于组装式理念和阿里巴巴中台实践构建的一体化云原生应用开发和组装平台，提供了业务建模、微服务开发、轻应用组装、能力开放等平台功能，致力于帮助企业快速设计、构建、组装和运营可复用的业务能力组件和...
鉴权概述
本文主要介绍 云消息队列 MQTT 版 客户端鉴权的原理和分类，以便您使用相应的鉴权功能。鉴权原理 使用 云消息队列 MQTT 版 的客户端收发消息时，服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景，...
鉴权概述
本文主要介绍 云消息队列 MQTT 版 客户端鉴权的原理和分类，以便您使用相应的鉴权功能。鉴权原理 使用 云消息队列 MQTT 版 的客户端收发消息时，服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景，...
顺序消息
如需保证消息生产的顺序性，则必须满足以下条件：同一消息组（MessageGroup）消息生产顺序性的范围为消息组，生产者发送消息时可以为每条消息设置消息组，只有同一消息组内的消息可以保证顺序性，不同消息组或未设置消息组的消息之间不保证...
直播互动解决方案
订阅了 云消息队列 RocketMQ 版 Topic的后端应用消费该消息以实现业务处理，例如内容审核。后端应用将处理后的消息再次发送至 云消息队列 RocketMQ 版 的Topic。云消息队列 RocketMQ 版 根据创建的数据流入规则将该消息转发至 云消息队列 ...
全景监控
全景监控支持业务链路配置监控场景，通过自定义监控链路和告警消息配置，可快速实现从数据生产到业务应用的全链路编排及溯源，实现全局监控和问题快速锁定。全景监控提供丰富的告警信息输出方式，包括：钉钉消息、标准协议等方式，出现问题...
功能简介
全景监控支持业务链路配置监控场景，通过自定义监控链路和告警消息配置，可快速实现从数据生产到业务应用的全链路编排及溯源，实现全局监控和问题快速锁定。全景监控提供丰富的告警信息输出方式，包括：钉钉消息、标准协议等方式，出现问题...
功能简介
全景监控支持业务链路配置监控场景，通过自定义监控链路和告警消息配置，可快速实现从数据生产到业务应用的全链路编排及溯源，实现全局监控和问题快速锁定。全景监控提供丰富的告警信息输出方式，包括：钉钉消息、标准协议等方式，出现问题...
消息推送简介
消息推送服务（Message Push Service，简称 MPS）是移动开发平台 mPaaS 提供的专业的移动消息推送方案，针对不同的场景推出多种推送类型，满足您的个性化推送需求。为了提升推送的到达率，mPaaS 在 MPS 中集成了华为、小米等厂商的推送功能...
产品优势
多种客户端接入支持 同一个 API 发布后，既...灵活的插件自定义能力 支持多种插件能力，包括参数映射、数据模型、外部授权 API 等多种自定义参数配置模型，满足不同业务场景的统一网关需求，可用于多部门协同时可通过网关实现统一规范场景。
版本管理
云消息队列 RocketMQ 版 为您提供全托管的版本管理服务，服务端版本更新后，系统会在后台自动完成升级，不影响消息收发，业务侧无感知。您可以根据波峰谷时间修改后台升级的执行时间和可维护时间段。使用限制 仅铂金版实例支持版本管理功能...
更新记录
本文为您介绍ChatApp消息服务文档更新的最新动态，基于此您可以及时了解ChatApp消息服务的新增特性及功能变更。2023年11月更新记录 时间 特性 内容描述 2023.11.21 新增 控制台-目录管理，增加商品目录授权按钮用于授权Meta商品目录。控制...
使用Exactly-Once投递语义收发消息
此示例演示了消费并记录消息到数据库系统的场景，实际的业务处理按照：接收消息->业务处理->结果持久化的过程。Exactly-Once投递语义保证消息处理的持久化过程有且仅有一次。connection=dataSource.getConnection();statement=connection....
基于Flink的资讯场景实时数仓
本文介绍如何针对资讯聚合类业务场景搭建基于 云消息队列 Kafka 版 和实时计算Flink的实时数仓。场景描述 本文首先介绍什么是实时数仓以及相关技术架构，接着介绍资讯聚合类业务的典型场景及其业务目标，并据此设计了相应的技术架构。然后...
配额与限制
PushConsumer消费超时时长由 云消息队列 RocketMQ 版 服务端统一控制。超过消费超时时长消息还未处理完成，将被系统强制判定为消费失败并进行重试，因此可能会导致少量消息重复。PushConsumer本地缓存 默认值：最大缓存数量：1024条。最大...
云存储网关利用MQTT服务实现统一管控
通过 云消息队列 MQTT 版 所提供的服务，可采用统一的框架，即云控制台，来管理不同部署模式的云存储网关CSG（Cloud Storage Gateway），并实现安全合规的公网和私网穿透，以此提供一致的用户体验。名词解释 MQTT 一种物联网和移动互联网...
权限策略
mq:DeleteMqttInstance 删除实例 无 mq:UpdateMqttInstance 变更实例的信息 无 mq:BindMqttInstance 绑定实例 如果业务需要绑定实例，需要具备操作指定的 云消息队列 MQTT 版 实例以及绑定的持久化实例的权限，持久化实例的权限设置，请...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
应用场景
本文为您介绍 SOFAStack 消息队列的适用场景，以便您更好地判断如何在业务中使用消息队列。在互联网金融场景里，其业务涉及广泛，如支付交易、收费计息、商户结算、业务营销、会员积分、风险核查等；同时，也会涉及许多业务峰值时刻，如双 ...
消息过滤
场景示例 以下图电商交易场景为例，从客户下单到收到商品这一过程会生产一系列消息，按照类型将消息分为订单消息和物流消息，其中给物流消息定义地域属性，按照地域分为杭州和上海：订单消息 物流消息 物流消息且地域为杭州 物流消息且地域...
典型客户案例
方案优势 无侵入平滑上云：无需修改业务代码，无需考虑依赖关系，低成本平滑上云 异构服务治理：服务限流、消息限流、服务路由 提升可观测性：全链路跟踪、立体化监控 架构灵活演进：扩展 SOFARPC 框架，兼容 ESB 服务，新老应用互联互通 ...
新金融行业
但硬件设备数量有限，“一机一微”成本过高 员工行为不可控，为提升运营效率，部分业务员采用外挂方式推送消息 同个IP出口无序高频并发发送消息的太多会导致微信IP封禁 人员变更离职带来数据安全风险；证监会定期抽查封禁及聊天信息，作为...
畅捷通
高效消息采集和传输 畅捷通利用日志服务的强大数据接入能力，将其混合云架构中网络、服务器、移动端、容器的各类访问类、系统类、应用类、消息类等各类日志统一汇入日志服务，实现每天TB级数据的快速处理。灵活的数据处理和存储 针对内部...
仪表盘
业务背景 云消息队列 RocketMQ 版 的消息收发流程中，队列的堆积情况、缓冲情况以及消息处理各关节的耗时等，会直接反映当前业务处理的性能和服务端运行的状态。因此，云消息队列 RocketMQ 版 的重点指标主要涉及以下业务场景。消息堆积...
基础版/铂金版实例计费
请确保您购买的消息TPS上限的规格大于业务实际的消息收发TPS峰值，避免超过规格上限值触发限流，导致部分消息收发失败。计算规则 消息TPS仅涉及通过 云消息队列 MQTT 版 收发的消息，不涉及 云消息队列 RocketMQ 版 收发的消息。对于QoS=1...
核心能力
数据资源平台提供了一站式数据资产定义、生产、管理与服务平台，提供企业级数据资产构建能力和一致性使用体验，助力客户快速构建数据智能平台，实现数据资源统一管理，挖掘潜在规律，优化业务决策，让大数据真正的驱动客户业务。...
OSS事件通知概述
通过创建事件通知规则，消息服务MNS 可以将对象存储OSS指定资源上产生的事件以消息的方式主动推送到指定的接收端。本文介绍对象存储OSS事件通知的背景信息、适用场景、事件类型以及消息格式。背景信息 如下图所示，如果您创建了事件通知...
API 统一网关
API 网关是金融分布式架构 SOFAStack 下的一个 API 管理平台，旨在帮助企业统一管理对内外开放的 API，为网络隔离的系统间提供高性能、高安全、高可靠的通信，同时保障内部系统的安全性。不仅用于企业对外部合作伙伴开放业务，同时保证企业...
步骤三：调用SDK收发消息
本文以Java SDK为例，说明如何将开源SDK客户端接入 云消息队列 RabbitMQ 版 服务端，并完成消息收发。前提条件 创建资源 安装IDEA 您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA Ultimate为例。安装JDK 安装Maven 安装Java依赖...
消息过滤
功能描述 消息过滤功能指消息生产者向Topic中发送消息时，设置消息属性对消息进行分类，消费者订阅Topic时，根据消息属性设置过滤条件对消息进行过滤，只有符合过滤条件的消息才会被投递到消费端进行消费。消费者订阅Topic时若未设置过滤...
数仓规划概述
业务分类 当企业业务比较复杂，不同类型业务彼此间需要共享数据域，但是又希望能在模型设计和应用过程中快速定位本业务的数据时，您可结合真实业务情况，规划不同的业务分类，在后续建模的维度表和明细表中，将其关联到对应的业务分类中。...
- 产品推荐
- 这些文档可能帮助您