消息幂等
如果消息重复消费会影响您的业务处理，请对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 在数学与计算机学中，幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。在消息领域，幂等是...
迁移上云概述
您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验，本文为您介绍开源RocketMQ集群迁移上云的方案及原理。产品差异对比 和开源RocketMQ相比，阿里云 云消息队列 RocketMQ 版 在技术架构、弹性效率、运维复杂...
基本概念
主题（Topic）云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题通过TopicName来做唯一标识和区分。更多信息，请参见 主题（Topic）。消息类型（MessageType）云消息队列 RocketMQ 版 中按照消息...
典型场景迁移说明
场景三 业务场景 设备使用一型一密预认证方式，采用公共实例域名，接入物联网平台。设备采用自定义Topic上报数据，通过AMQP服务端订阅发送给业务服务器。服务端调用 Pub 接口，给设备发送消息。迁移说明 设备端无需改造。采用灰度迁移方式...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
概述
SOFAStack 消息队列（SOFAStack MQ，简称 SOFAMQ）是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息...
消息堆积和延迟问题
通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或在运维过程中及时调整业务逻辑，避免因消息堆积和延迟影响业务运行。背景信息 消息处理流程中，如果客户端的消费...
直播互动解决方案
订阅了 云消息队列 RocketMQ 版 Topic的后端应用消费该消息以实现业务处理，例如内容审核。后端应用将处理后的消息再次发送至 云消息队列 RocketMQ 版 的Topic。云消息队列 RocketMQ 版 根据创建的数据流入规则将该消息转发至 云消息队列 ...
消费者（Consumer）
消费者通常被集成在业务系统中，从 云消息队列 RocketMQ 版 服务端获取消息，并将消息转化成业务可理解的信息，供业务逻辑处理。在消息消费端，可以定义如下传输行为：消费者身份：消费者必须关联一个指定的消费者分组，以获取分组内统一...
版本管理
云消息队列 RocketMQ 版 为您提供全托管的版本管理服务，服务端版本更新后，系统会在后台自动完成升级，不影响消息收发，业务侧无感知。您可以根据波峰谷时间修改后台升级的执行时间和可维护时间段。使用限制 仅铂金版实例支持版本管理功能...
消息推送简介
消息推送服务（Message Push Service，简称 MPS）是移动开发平台 mPaaS 提供的专业的移动消息推送方案，针对不同的场景推出多种推送类型，满足您的个性化推送需求。为了提升推送的到达率，mPaaS 在 MPS 中集成了华为、小米等厂商的推送功能...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
使用Exactly-Once投递语义收发消息
本文主要介绍如何使用 云消息队列 RocketMQ 版 的Exactly-Once投递语义收发消息，以保证消息的最终处理结果写入到数据库有且仅有一次。背景信息 重要 目前Exactly-Once投递语义仅在Java SDK中支持。相关SDK下载，请参见 版本说明。云消息...
更新记录
本文为您介绍ChatApp消息服务文档更新的最新动态，基于此您可以及时了解ChatApp消息服务的新增特性及功能变更。2023年11月更新记录 时间 特性 内容描述 2023.11.21 新增 控制台-目录管理，增加商品目录授权按钮用于授权Meta商品目录。控制...
什么是弹性伸缩ESS
弹性伸缩（Elastic Scaling Service，简称ESS），也称为Auto Scaling，其能根据您设定的策略自动调整计算资源数量（即业务所需的实例数量），帮助您应对业务流量波动的同时，提高资源利用率，有效降低成本。本视频以ECS实例为例介绍弹性...
功能特性
TCC 模式提供自定义补偿型事务、自定义资源预留型事务、消息事务等场景，用户可以介入两阶段提交的过程，以达到特殊场景下的自定义优化及特殊功能的实现。FMT 模式 为了解决 TCC 模式的易用性问题，分布式事务推出了框架管理事务模式...
消息存储和清理机制
了解消息存储和过期清理机制，可以从以下方面帮助您更好的进行运维管理：提供消息存储时间SLA，为业务提供安全冗余空间：消息存储时间的承诺本质上代表业务侧可以自由获取消息的时间范围。对于消费时间长、消息堆积、故障恢复等场景非常...
顺序消息
如需保证消息生产的顺序性，则必须满足以下条件：同一消息组（MessageGroup）消息生产顺序性的范围为消息组，生产者发送消息时可以为每条消息设置消息组，只有同一消息组内的消息可以保证顺序性，不同消息组或未设置消息组的消息之间不保证...
收发顺序消息
顺序消息（FIFO消息）是阿里云 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的社区版C++ SDK收发顺序消息的示例代码供您参考。顺序消息分为两类：全局顺序：对于指定的一个Topic，所有...
消息过滤
功能描述 消息过滤功能指消息生产者向Topic中发送消息时，设置消息属性对消息进行分类，消费者订阅Topic时，根据消息属性设置过滤条件对消息进行过滤，只有符合过滤条件的消息才会被投递到消费端进行消费。消费者订阅Topic时若未设置过滤...
负载均衡SLB产品家族介绍
NLB 面向海量终端连接、高并发消息服务、音视频传输等业务场景针对性地推出了TCPSSL卸载、新建连接限速、全端口监听等高级特性，在物联网MQTTS加密卸载等场景为用户提供多种辅助手段，是适合IoT业务的新一代负载均衡。更多信息，请参见 ...
消息过滤
场景示例 以下图电商交易场景为例，从客户下单到收到商品这一过程会生产一系列消息，按照类型将消息分为订单消息和物流消息，其中给物流消息定义地域属性，按照地域分为杭州和上海：订单消息 物流消息 物流消息且地域为杭州 物流消息且地域...
概述
消息流入能够在多种数据源（消息、Log日志、关系型数据和非关系型数据等）之间进行灵活、快速、无侵入式的数据集成。可以实现跨机房、跨数据中心、跨云的数据集成方案，并能自助实施、运维、监控集成数据。主要能力是将各类数据流入至消息...
什么是云数据库Redis版
云数据库Redis版（ApsaraDB for Redis）是兼容开源Redis协议标准的数据库服务，基于双机热备架构及集群架构，可满足高吞吐、低延迟及弹性变配等业务需求。为什么选择云数据库Redis版 硬件部署在云端，提供完善的基础设施规划、网络安全保障...
概述
消息流入能够在多种数据源（消息、Log日志、关系型数据和非关系型数据等）之间进行灵活、快速、无侵入式的数据集成。可以实现跨机房、跨数据中心、跨云的数据集成方案，并能自助实施、运维、监控集成数据。主要能力是将各类数据流入至消息...
概述
消息流入能够在多种数据源（消息、Log日志、关系型数据和非关系型数据等）之间进行灵活、快速、无侵入式的数据集成。可以实现跨机房、跨数据中心、跨云的数据集成方案，并能自助实施、运维、监控集成数据。主要能力是将各类数据流入至消息...
附录：SOFAStack 产品目录
引入消息队列后，利用消息队列的抗堆积能力，这些业务系统作为消息的消费方，可以根据自身应用的能力进行消息的消费，不受大流量的影响。API 网关 API 网关（API Gateway）是一个 API 管理平台，帮助企业统一管理对内外开放的 API，为网络...
资源模型相关
分析型数据库MySQL版扩容/缩容是否需要停业务？分析型数据库MySQL版支持弹性扩缩容和升降配，可以做到用户无感知和业务无影响。可否只对内存进行扩容 分析型数据库MySQL版的实例规格有多种，C4、C8、S2n和S8n，不同的资源规格对应的实例在...
产品优势
死信Exchange 增强型死信Exchange，不仅支持被否定应答的消息，还支持重试失败的消息自动进入死信Exchange，确保消息不丢失。超强性能 平台性能上限 支持百万级队列，横向扩容带来性能的线性增长，性能上无并发限制。单队列扩容 解决...
仪表盘
业务背景 云消息队列 RocketMQ 版 的消息收发流程中，队列的堆积情况、缓冲情况以及消息处理各关节的耗时等，会直接反映当前业务处理的性能和服务端运行的状态。因此，云消息队列 RocketMQ 版 的重点指标主要涉及以下业务场景。消息堆积...
步骤三：调用SDK收发消息
false,"ConsumerTag",new DefaultConsumer(channel){@Override public void handleDelivery(String consumerTag,Envelope envelope,AMQP.BasicProperties properties,byte[]body)throws IOException {/接收到的消息，进行业务逻辑处理。...
企业版实例不同类型和功能区别
物联网平台企业版实例类型包含标准型、尊享型 和MQTT型，您可根据实际业务需求，参考本文实例说明，购买需要的企业版实例。本文介绍各类型企业版实例的使用说明。背景信息 物联网平台实例的使用说明，请参见 实例概述。物联网平台支持的...
应用场景
本文为您介绍 SOFAStack 消息队列的适用场景，以便您更好地判断如何在业务中使用消息队列。在互联网金融场景里，其业务涉及广泛，如支付交易、收费计息、商户结算、业务营销、会员积分、风险核查等；同时，也会涉及许多业务峰值时刻，如双 ...
视频型企业版实例
实例服务 赠送的视频型企业版实例，为已激活的边缘一体机提供如下服务：云端消息通道 云端消息规则引擎 云端远程订阅报警消息 云端API调用 视频直播点播播放 视频或图片的云端存储服务 实例资源 赠送的视频型企业版实例，包含如下资源：...
基于Flink的资讯场景实时数仓
本文介绍如何针对资讯聚合类业务场景搭建基于 云消息队列 Kafka 版 和实时计算Flink的实时数仓。场景描述 本文首先介绍什么是实时数仓以及相关技术架构，接着介绍资讯聚合类业务的典型场景及其业务目标，并据此设计了相应的技术架构。然后...
集成概述
消息流入能够在多种数据源（消息、Log日志、关系型数据和非关系型数据等）之间进行灵活、快速、无侵入式的数据集成。可以实现跨机房、跨数据中心、跨云的数据集成方案，并能自助实施、运维、监控集成数据。主要能力是将各类数据流入至 云...
引擎简介
云原生多模数据库 Lindorm 消息引擎是Lindorm面向IoT、车联网、日志等流式数据提供的数据接入服务，支持业务原始数据高吞吐写入，并基于流引擎的实时处理能力，业务只需做简单开发，即可快速实现数据的ETL并入库到Lindorm宽表引擎。...
基础版/铂金版实例计费
请确保您购买的消息TPS上限的规格大于业务实际的消息收发TPS峰值，避免超过规格上限值触发限流，导致部分消息收发失败。计算规则 消息TPS仅涉及通过 云消息队列 MQTT 版 收发的消息，不涉及 云消息队列 RocketMQ 版 收发的消息。对于QoS=1...
示例代码
public MessageQueueSelector { public:MQMessageQueue select(const std:vector<MQMessageQueue>&mqs,const MQMessage&msg,void*arg){/实现自定义分区逻辑，根据业务传入arg参数即分区键，计算路由到哪个队列，这里以arg为int型参数为例。...
- 产品推荐
- 这些文档可能帮助您