广播拉取消息模型
本文介绍如何高效利用该模型实现多消费者并行拉取与处理消息。说明 本文以Java SDK为例介绍广播拉取消息流程，其他语言SDK请参见 新版SDK参考（推荐）。前提条件 安装IDEA 您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。...
基本概念
每个 Topic 对应队列数与消息类型以及实例所处地域（Region）相关，具体的队列数可咨询技术支持。定时消息 Scheduled message，Producer 将消息发送到消息队列服务端，但并不期望这条消息立马投递，而是推迟到在当前时间点之后的某一个时间...
消息发送重试和流控机制
消息重复问题：因远程调用的不确定性，当 云消息队列 RocketMQ 版 客户端因请求超时触发消息发送重试流程，此时客户端无法感知服务端的处理结果，客户端进行的消息发送重试可能会产生消息重复问题，业务逻辑需要自行处理消息重复问题。消息...
通过可观测性能力进行故障处理最佳实践
设计思路 核心问题 运维场景下，故障处理的核心问题如下：服务出现异常如何预警并上报 出现异常问题如何快速定位 解决方案 云消息队列 RocketMQ 版 定义的Metrics、Tracing指标覆盖消息收发各阶段的状态信息、云消息队列 RocketMQ 版 服务...
专家成长计划服务内容说明
8 基于海量云上的诊断排查实战经验，针对使用ECS产品场景，提供针对阿里云产品功能特性、架构设计、性能调优、疑难诊断等方面技术赋能，包括但不限于如下场景的综合技术项：1、ECS和磁盘使用基本介绍、Linux启动问题处理、Linux登录问题...
消息保序递交解决方案
本文介绍消息传递中的乱序问题及其解决方案。
应用场景
分布式事务可应用在多个涉及数据库操作的领域，尤其在金融领域可以做到全场景的覆盖与落地验证，包括：支付与转账、账务：对于吞吐量有很高的要求 金融与理财：往往涉及的金额较大，所以对于产品的稳定性要求非常高 保险与监管报送：参与方...
功能特性
这允许系统根据消息本身的特性、现有的业务需求或其他动态因素实时调整路由决策，从而提高了消息传递的灵活性和效率。元数据导入 安全合规 功能集 功能 功能描述 参考文档 数据加密 支持SASL、SSL接入点 SASL和SSL提供了两个关键的安全特性...
基本概念
消息堆积量=处理中消息量+已就绪消息量，具体的指标含义，可参考以下说明：上图表示指定主题的某一队列中各消息的状态，云消息队列 RocketMQ 版 将处于不同处理阶段的消息数量和耗时进行统计，这些指标可直接反映队列中消息的处理速率和...
现代IM系统中的消息系统—架构
消息同步系统最重要的衡量指标就是消息传递的实时性、完整性以及能支撑的消息规模。在功能上，至少要支持在线和离线推送，有些IM系统还支持多端同步。消息存储：指消息的持久化保存。传统消息系统通常只能支持消息在接收端的本地存储，数据...
AMQP客户端接入说明
如果需要将设备消息转发至AMQP客户端进行消费，您需在业务服务器中使用AMQP SDK开启客户端连接物联网平台。AMQP客户端接入成功并在业务服务器运行，才能接收物联网平台的设备消息。本文介绍AMQP客户端接入物联网平台的方法。前提条件 已...
使用Topic通信
定义Topic后，设备可以通过Topic与物联网平台通信，从而实现设备、物联网平台、业务服务器、其他云产品之间的通信。前提条件 使用物模型Topic通信，需要先 添加物模型。...常见问题 物模型相关问题 消息通信相关问题 Link SDK运行相关问题
应用场景
远程协助 在智联车的使用过程中，我们提供了远程协助的功能，当车辆出现软件问题时，维修人员可通过远程指令的下发，例如远程截屏等，诊断车辆设备问题原因。除此之外，还可通过远程控制功能，在得到车机端用户授权的情况下，维修人员可...
消息 Mesh
Service Mesh 不仅负责在微服务架构的复杂拓扑中可靠地传递请求，也将限流、熔断、监控、链路追踪、服务发现、负载均衡、异常处理等与业务逻辑无关的流量控制或服务治理行为下沉，让应用程序能更好地关注自身业务逻辑。微服务架构中的通信...
Upsert Kafka
参数取值如下：csv json avro debezium-json canal-json maxwell-json avro-confluent raw key.fields-prefix 为所有Kafka消息key部分指定自定义前缀，以避免与消息value部分格式字段重名。String 否 无 该配置项仅用于源表和结果表的列名...
什么是云消息队列 Confluent 版？
业务监控与告警：每个Consumer Group都可以针对消息的堆积量情况设置监控与告警，帮助您及时发现问题。OpenAPI：提供了一整套完备的管控类OpenAPI，用于实现一系列的资源管理和运维功能。开箱即用：提供的是完全托管的Confluent Platform...
通用WebSocket接入指南
同理，服务端发送消息给客户端，客户端收到消息之后也需要立即发送一条回执消息（该回执消息需要在处理消息之前立即发送，避免服务端误判客户端没有收到消息而导致重复发送该条消息）。回执消息格式：业务消息协议：消息内容：6{"messageId...
错误响应
当您使用文件处理功能出现错误时，会返回相应的错误码和错误信息，帮助您定位与处理问题。错误响应 文件处理功能错误响应的消息体示例如下：<Error><Code>Imm Client</Code><Message>InvalidArgument,The parameter OctreeOption is ...
错误响应
当您使用文档处理功能出现错误时，会返回相应的错误码和错误信息，帮助您定位与处理问题。错误响应 文档处理功能错误响应的消息体示例如下：<Error><Code>Imm Client</Code><Message>InvalidArgument,[target]:is required.9D31D05E-FC1C-...
错误响应
当您使用媒体处理功能出现错误时，会返回相应的错误码和错误信息，帮助您定位与处理问题。错误响应 媒体处理功能错误响应的消息体示例如下：<Error><Code>Imm Client</Code><Message>InvalidArgument,[target]:is required.9D31D05E-FC1C-...
支持计划
4.9.3 订阅支持 阿里云针对购买云产品的客户，将免费提供消息订阅企业级支持，目前提供的消息种类主要包含产品消息、故障消息、服务消息、活动消息几大类，客户可根据需要登录阿里云官网进入 消息中心 设置订阅或查看消息。5.阿里云支持...
音视频通信解决方案（MQTT）
音视频管控服务还需要根据用户A邀请的信息找到用户B信息，同样封装一条邀请入会的消息，传递流程同 步骤2。会议参与者用户B收到参数后加入会议，本次通信初始化完成。基于上述设计思路，可以使用 云消息队列 MQTT 版 消息实现其他自定义...
错误响应
当用户访问图片处理服务出现错误的时候，图片处理服务会返回给用户相应的错误码和错误信息，以帮助用户定位与处理问题。错误响应 图片处理服务错误响应的消息体示例如下：<Error><Code>BadRequest</Code><Message>Input is not base64 ...
蓝图编辑器精选案例实战
按照同样的方法配置接收端的 WebSocket 节点，节点内所配置 接受消息 的 消息名 与 发送消息 的 消息名 需要保持一致，设为test。设置完成后，在蓝图编辑器配置页面右上角，单击预览 图标，查看分屏联动效果。如果您想查看 如何实现跨屏...
应用场景
表格存储 数据湖架构能有效的解决大数据领域面临的数据存储与数据分析问题，典型应用场景包括推荐系统和舆情&风控分析场景。推荐系统 推荐系统作为当前所有业务精细化运营的主要手段，广泛应用在电商、短视频、新闻等场景，具有数据量大、...
如何通过ChatOps处理告警
并且可以让告警处理与企业已经搭建在这些IM上的其他系统进行有机融合。多端一体 ARMS开发一个H5应用，通过与钉钉、企业微信、飞书打通SSO登录流程，在不同的IM软件提供的Web容器内实现了告警处理流程的统一。可以在不同的操作系统和设备上...
数据处理
数据处理类节点包括页面导航节点、并行数据处理节点、串行数据处理节点、序列执行节点和WebSocket节点。本文介绍在蓝图编辑器中，配置数据处理类节点的方法。页面导航节点 页面导航 节点，可用于实现页面跳转的功能，支持新开浏览器标签页...
基础术语
每个 Topic 对应队列数与消息类型以及实例所处地域（Region）相关，具体的队列数可咨询技术支持。集群消费 Clustering consumption 一个 Group ID 所标识的所有 Consumer 平均分摊消费消息。例如某个 Topic 有 9 条消息，一个 Group ID 有 ...
快速入门
常见问题处理 如下方案仅为建议的通用解决方案，不同的应用场景请根据实际分析和处理问题。常见问题 解决方案 iframe内部预览界面被遮挡问题 禁止iframe滚动，设置iframe属性scrolling="no"（预览界面实现了局部滚动，可以放心把该属性设置...
消费者负载均衡
背景信息 了解消费者负载均衡策略，可以帮助您解决以下问题：消息消费处理的容灾策略：您可以根据消费者负载均衡策略，明确当局部节点出现故障时，消息如何进行消费重试和容灾切换。消息消费的顺序性机制：通过消费者负载均衡策略，您可以...
什么是消息服务MNS
在创建订阅时指定消息过滤标签，然后PublishMessage时指定消息标签，消息服务MNS 在推送消息时会根据标签进行过滤，仅推送消息标签与订阅中指定的过滤标签匹配的消息到指定队列上。更多信息，请参见 主题接口规范。消息投递 消息服务MNS ...
通用软件漏洞收集及奖励计划第四期
通用软件漏洞情报收集及奖励标准 为了更好地保障云上用户的安全，提升安全防御能力，阿里云先知专门制定了《通用软件漏洞验收及奖励计划》，以提供奖励的方式鼓励白帽子遵循负责任的漏洞披露机制，向我们提供供应链软件的安全漏洞情报信息...
Kafka触发器
常见问题 为什么Kafka触发器触发函数的次数与消息的条数不一致？事件总线EventBridge会根据您的攒批配置将消息推送给函数处理，不能通过函数调用次数判断消息是否全部被消费。您可以在函数中打印日志来确认消费的消息情况。更多关于攒批...
厂商消息分类
华为分类 厂商针对消息分类的说明 根据消息内容，华为推送将通知分类为 服务与通讯、资讯营销 两大类别，并对不同类别消息的提醒方式、消息样式进行差异化管理，具体如下：消息类型 服务与通讯 资讯营销 推送内容 包括社交通讯类消息和服务...
实践教程概览
业务应用 实践教程 主要内容 使用LAMMPS软件进行工业仿真 LAMMPS是一款经典分子动力学软件，其包含的势函数可用于固体材料（金属、半导体）、软物质（生物大分子，聚合物）、粗粒化或介观尺度模型体系。本教程介绍如何使用E-HPC集群运行...
错误响应
当您访问图片处理服务出现错误时，图片处理服务会将相应的错误码和错误信息返回给您，以帮助您定位与处理问题。图片处理服务错误的响应格式 错误响应的消息体例子：<Error><Code>BadRequest</Code><Message>Input is not base64 decoding....
常见问题
本文主要介绍在操作分布式事务过程中的常见问题。SOFAStack 是否可以部署在虚拟机、物理机上？可以，SOFAStack 部署支持物理机、虚机机 VM。SOFAStack 当前是否只支持阿里云飞天 ACK？SOFAStack 部署支持多云异构、目前支持华为云、开源 ...
接口说明
通用错误码 状态码 状态消息 原因 解决方案 40000000 默认的客户端错误码，对应了多个错误消息。用户使用了不合理的参数或者调用逻辑。请参考官网文档示例代码进行对比测试验证。40000001 The token 'xxx' has expired；The token 'xxx' is...
错误码查询
您可以通过返回结果中的错误码快速地定位问题，并根据对应的解决方案尝试修改代码或者反馈给终端用户加以解决。错误码分类 错误码表示 服务端错误码 服务端报错 8位错误码，例如：50000000 客户操作错误导致的服务端报错 8位错误码，例如：...
服务协议
阿里云产品服务协议 提示条款 欢迎您与阿里云计算有限公司（以下简称“阿里云”）共同签署本《阿里云产品服务协议》（下称“本协议”）并使用阿里云服务！协议中条款前所列索引关键词仅为帮助您理解该条款表达的主旨之用，不影响或限制本...
- 产品推荐
- 这些文档可能帮助您