基本概念
处理中消息量＋已就绪消息量 消息耗时指标 已就绪消息的就绪时间（ready time）普通消息、顺序消息：消息存储到服务端的时间。定时/延时消息：消息定时或延时结束的时间。事务消息：事务提交的时间。不涉及 已就绪消息的排队时间（ready ...
数据流转方案对比
另外，消息类产品存在延迟的可能，业务场景一定要做好消息丢失或者延迟送达的影响防护。数据流转到消息服务（MNS）功能说明 使用限制 注意事项 可以通过云产品流转功能，将指定Topic的消息流转到MNS的主题中，然后通过MNS的SDK接收相应的...
收发事务消息
当步骤1半事务消息发送完成，但本地事务返回状态为 TransactionStatus.Unknow 时，亦或是应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条半状态的消息的状态是未知的，因此Broker会定期向消息发送方即消息生产者集群中的...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容Java ONS 1.x SDK客户端接入，您可以使用ONS 1.x SDK的接入5.x实例进行消息收发。本文为您介绍Java ONS 1.x SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力...
调用TCP协议的SDK收发普通消息
调用TCP协议的SDK订阅普通消息 消息发送成功后，需要启动消费者来订阅普通消息。请按需运行对应语言的示例代码来启动消费者，并测试订阅消息的功能。请按照说明正确设置相关参数。Java import com.aliyun.openservices.ons.api.Action;...
应用场景
灵活接入，API定制 提供标准对接API和开箱即用的SaaS软件服务两种服务方式，快速完成企业积分兑换业务搭建。员工福利内购电商业务 提供海量福利商品，包括实物商品、虚拟商品、阿里商家及自营权益等，一站式满足企业员工福利场景的供应链和...
获取MQTT客户端在线状态
应用场景 云消息队列 MQTT 版 需结合后端存储消息队列产品，如 云消息队列 RocketMQ 版 等使用，来和部署在云端服务器上的应用（下文简称为业务应用）完成业务流程。获取客户端在线状态主要的应用场景如下：主业务流程中需要根据客户端是否...
应用容灾
消息：业务流量在机房内部和跨机房的异步调用方式，基于消息削峰填谷，一般有 Producer、Consumer、Broker 等角色。数据层涵盖业务应用数据读写、数据存储和数据同步，其具备流量路由、数据一致性保护、数据同步三个核心能力。云平台是支撑...
示例代码
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time，单位：ms。指定一个...
什么是Topic
消息内容（Payload）：消息的具体内容。MQTT协议消息的传输过程，以业务服务器向设备下发消息为例 设备订阅相应的主题（Topic）。服务器发送消息给物联网平台。物联网平台接收消息，根据消息的主题（Topic）确定设备并发送消息。业务服务器...
MQTT客户端上下线事件数据流出
云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。...
实例规格族
本文介绍云数据库MongoDB版的通用型、独享型和专属型实例规格族。规格族 规格族 说明 适用场景 通用型 独享被分配的内存和存储空间，共享CPU和I/O，存在资源争抢的风险。通过资源复用换取利用率最大化，性价比较高，享受规模红利。对价格...
概览
IO密集型业务和计算密集型任务会导致不同ECS实例的CPU或负载（load.1m、load.5m 和 load.15m）出现不同负载水位。由于单指标报警规则设置了固定的报警阈值，所以无法应对以上复杂场景，导致经常出现部分高负载实例持续报警，而低水位负载...
Spring集成
RabbitListener(queues="myQueue")public void receiveFromMyQueue(Message message,Channel channel){/进入消息消费业务逻辑。须在Ack有效期（消息重试间隔时间）内返回Ack，否则为无效确认，消息还会被重复投递。channel.basicAck...
NVMe协议介绍
而计算节点则经常受断电、宕机、硬件故障等影响，所以业务通常搭建主备模式解决计算的高可用问题。例如数据库场景，当主库故障时迅速切换到备库对外提供服务，实例切换后，可以通过NVMe PR命令释放旧实例的写入权限，从而确保旧实例不再...
HLS标准加密
解密流程 播放端解密播放HLS加密视频的流程如下：业务方搭建令牌服务，用于颁发令牌MtsHlsUriToken。重要 令牌服务指用于派发MtsHlsUriToken的服务。业务方调用KMS解密接口搭建解密服务，用于解密视频，同时提供数据密钥（DK）给播放终端。...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
互联网金融
互联网金融方案 适合初创互联网金融公司快速搭建平台，满足在开业筹备期间快速完成各类监管验收所需系统搭建和业务功能。业务架构 架构说明：初创互金公司关键系统是风控系统和网申系统，阿里云上有大量的部署参考案例。通过合理的网络和...
快速入门
依靠阿里巴巴核心电商业务多年技术沉淀与商家商品供应链能力，LinkedMall在多渠道销货和多渠道找货两个环节沉淀了丰富的产品能力，帮助企业快速搭建多业务场景的S2B2C电商平台。如果您是品牌商 品牌商城：我想快速拥有支付宝、私域社交电商...
功能介绍
本文介绍通过Lindorm Streams实现数据订阅功能，数据订阅功能将云数据库HBase增强版（云原生多模数据库Lindorm）表格的增量数据推送至下游消息队列Kafka，您可以根据自身业务需求自由消费增量数据，搭建或实现多种业务场景。推送流程 数据...
规格及选型
8C64G ESSD云盘 PL1 适合计算密集型场景，支持大量高复杂度数据分析，高并发等场景。16C128G ESSD云盘 PL2 适合企业级平台建设，适用于高并发场景，大规模企业核心数据平台推荐选择。高性能（基础版）2C8G ESSD云盘 PL0 POC测试。个人学习...
定向服务简介
使用场景 当前物联网行业不少客户出于网络安全考虑，在设备使用物联网卡联网时，希望通过专用网络访问指定的目标地址（比如自行搭建的业务服务器地址）。但和运营商搭建专用网络的开发成本较高。针对上述场景，物联网无线连接服务提供了物...
连接公网概述
此时，您可创建一个公网负载均衡实例，配置四层（TCP/UDP）监听，并在后端挂载多台ECS来搭建整个业务架构。对外提供带有负载均衡的七层服务 除了基本的流量分发，当您希望将不同的业务流量分发到不同的后端服务器时，可以使用七层负载均衡...
常见问题
当前不少物联网行业用户出于网络安全考虑，在物联网终端使用物联网卡上网时，不希望通过公共网络，而是通过专网访问指定目标地址（比如自己搭建的业务系统等）。通过运营商搭建专用网络周期长、成本高，且需要网络第三方支持。针对以上场景...
Demo工程
针对初次接触 云消息队列 RocketMQ 版 的工程师，本文以TCP协议下的Java SDK为例，提供操作示例帮助您从零开始搭建 云消息队列 RocketMQ 版 测试工程。Demo工程包含普通消息、顺序消息、事务消息、定时和延时消息的测试代码，以及相关...
查询业务事件消息推送的间隔
调用该接口查询业务事件消息推送间隔的配置信息。路径/vision/customer/bizevent/config/get 版本号 1.0.3 协议 HTTPS 请求方法 POST 是否需要用户身份鉴权 可选 超时时间 3000 请求参数 名称 类型 是否必选 示例值 描述 iotId String 是 ...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
购买企业版实例
物联网平台提供标准型和尊享型的企业版实例，帮助您针对不同业务需求管理产品、设备、消息转发、数据服务和监控运维等资源，进而实现对物联网设备业务的提效目的。背景信息 物联网平台实例的使用说明，请参见 实例概述。企业版实例分为标准...
消息管理
项目下的“消息管理”，是平台为项目提供的消息通知能力的管理入口，其功能包括“消息规则”的管理和“消息模板”的管理。当然，为了让消息能够触达用户，需要具体的消息服务。目前支持的消息服务包括“短信”和邮件。消息服务 短信“短信...
消费者分类
SimpleConsumer SimpleConsumer是一种接口原子型的消费者类型，消息的获取、消费状态提交以及消费重试都是通过消费者业务逻辑主动发起调用完成。使用方式 SimpleConsumer的使用涉及多个接口调用，由业务逻辑按需调用接口获取消息，然后分发...
主题（Topic）
云消息队列 RocketMQ 版 支持的主题类型如下：Normal：普通消息，消息本身无特殊语义，消息之间也没有任何关联。FIFO：顺序消息，云消息队列 RocketMQ 版 通过消息分组MessageGroup标记一组特定消息的先后顺序，可以保证消息的投递顺序严格...
通过增强型公网 NAT 实现云上统一公网出入口 IP
本文介绍如何借助云速搭 CADT 搭建验证环境，并联动增强型公网 NAT 网关和传统型负载均衡 CLB（Classic Load Balancer）实现互联网业务的高可用性，且通过增强型公网 NAT 网关绑定弹性公网 IP（Elastic IP Address，简称 EIP）实现统一云上...
功能特性
极速型NAS CPFS 100MB/s基线 CPFS的细分存储类型，适用HPC高性能计算、AI训练、自动驾驶、基因计算、影视渲染、EDA仿真、油气勘探、气象分析等高吞吐、高IOPS、海量文件的IO密集型业务。CPFS存储规格 200MB/s基线 CPFS的细分存储类型，适用...
新零售电子价签解决方案（MQTT）
注意事项 上述流程简要描述了如何使用 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 来搭建电子价签系统，具体的SDK说明，请参见 云消息队列 MQTT 版 以及 云消息队列 RocketMQ 版 文档。其中使用 云消息队列 MQTT 版 和 云消息队列 ...
收发顺序消息
说明 对于新手用户，建议在正式收发消息前，阅读 Demo工程 来了解搭建 云消息队列 RocketMQ 版 工程的具体步骤。发送顺序消息 重要 云消息队列 RocketMQ 版 服务端判定消息产生的顺序性是参照单一生产者、单一线程并发下消息发送的时序。...
收发定时消息
说明 对于新手用户，建议在正式收发消息前，阅读 Demo工程 来了解搭建 云消息队列 RocketMQ 版 工程的具体步骤。前提条件 您已完成以下操作：安装Java SDK。更多信息，请参见 准备环境。创建资源。代码中涉及的资源信息，例如实例、Topic和...
收发延时消息
说明 对于新手用户，建议在正式收发消息前，阅读 Demo 工程 来了解搭建 云消息队列 RocketMQ 版 工程的具体步骤。发送延时消息 具体的示例代码，请以 云消息队列 RocketMQ 版 代码库 为准。发送延时消息的示例代码如下：import ...
步骤一：架构规划
前提条件 了解 单元化架构 架构介绍 如上图所示，该业务系统搭建在同城双活单元化架构上。业务架构覆盖的业务场景如下：转账 存款送积分 支撑业务的应用如下：交易中心（txnflow）：交易服务中心，提供转账服务，依次调用转出账户的取款...
- 产品推荐
- 这些文档可能帮助您