示例代码
创建的Producer和Consumer对象为线程安全的，可以在多线程间进行共享，避免每个线程创建一个实例。thread和anotherThread共享Producer对象，并发地发送消息至消息队列RocketMQ版。Thread thread=new Thread(new Runnable(){@Override ...
消费者（Consumer）
因此，为了保证分组内消息的正常负载和消费，云消息队列 RocketMQ 版 要求同一分组下的所有消费者以下消费行为保持一致：投递顺序 消费重试策略 版本兼容性 如行为约束中所述，同一分组内所有消费者的投递顺序和消费重试策略需要保持一致。...
SmsUp
将messageType和queueName替换成您需要的消息类型名称和对应的队列名称*云通信产品下所有的回执消息类型:*1:短信回执：SmsReport，*2:短信上行：SmsUp*3:国际短信回执：GlobeSmsReport*4:语音呼叫：VoiceReport*5:流量直冲：FlowReport*/...
建立gRPC连接
强类型接口定义：使用Protocol Buffers来定义服务接口和消息结构，提供严格的类型检查，有助于减少错误并简化版本管理。流式处理：支持单向和双向流式RPC，非常适合大数据流和实时消息交互场景。安全：可以与TLS加密集成，确保通信安全，...
设置消息通知
JSON：消息体为JSON格式，包含消息正文和消息属性。XML：消息体为XML格式，包含消息正文和消息属性。单击 确定，完成创建。创建队列 在MNS控制台左侧导航栏，单击 队列列表。在队列列表页面，单击 创建队列，并配置如下参数。参数 描述 ...
在ECS实例内访问网站提示“Nginx 502 bad gateway”...
本文介绍在ECS实例上使用浏览器访问网站时，提示“Nginx 502 Bad Gateway”错误的问题原因和解决方案。问题原因“Nginx 502 Bad Gateway”错误表示访问请求的php-cgi进程已经开始执行，但是由于读取资源失败等原因没有执行完毕，导致...
添加待流转的数据源
消息转发Topic和数据格式的详情说明，请参见 开源MQTT协议的消息通信说明、JT/T 808协议的消息转发说明、GB/T 32960协议的消息转发说明、SL 651协议概述。可选：重复上一步操作，可在当前数据源下，添加多个消息Topic。添加Topic后，若有...
一键诊断
您可以使用 PAI灵骏智算服务 提供的一键诊断功能，检查灵骏节点的网络和硬件状态，基于多种通信库和通信模型进行网络测试。本文为您介绍灵骏的一键诊断功能。自助诊断 网络诊断 网络诊断功能分为 静态配置类检查 和 动态运行类检查，支持...
云产品流转概述
支持流转的数据目的如下：数据目的 说明 相关文档 Topic 将数据转发到另一个设备的Topic中，实现设备间的M2M通信 数据转发到其他Topic AMQP消费组 通过AMQP服务端订阅消费组，将设备消息流转到您的业务服务器上。AMQP客户端接入说明 数据...
云产品流转概述
数据目的 说明 相关文档 Topic 将数据转发到另一个设备的Topic中，实现设备间的M2M通信 数据转发到另一Topic AMQP消费组 通过AMQP服务端订阅消费组，将设备消息流转到您的业务服务器上。AMQP客户端接入说明 数据转发到AMQP服务端订阅消费组...
运行 Windows Demo
环境要求 类型 说明 终端设备 如果使用不自带摄像头和麦克风的设备，需要插入外置摄像头和麦克风。系统版本 Windows 7、Windows 8.X、Windows 10，Windows 11 操作步骤 下载并解压SDK及示例代码，下载地址，请参见 SDK下载 SDK变更公告。...
什么是云消息队列 MQTT 版
在该模型中消息的生产者和消费者都是分布在终端设备，通过MQTT协议连接到 云消息队列 MQTT 版 产品。根据以上两种消息收发模型，可以将使用 云消息队列 MQTT 版 的开发人员分为终端和云端两大类。两类开发人员所需的二次开发内容请分别参见...
产品优势
服务网格作为应用与基础设施的桥梁，突破传统的 SDK 接入方式，以对应用透明的方式处理服务之间、服务与基础设施间的通信，实现应用研发和基础设施最大程度地解耦，让应用研发只需专注于业务开发。技术业务分离 在之前，微服务体系都是由...
使用云数据库Redis版实现即时通信场景中的多端同步
随着即时通信（Instant Messaging）场景和客户端种类的不断丰富，多端通信已经成为普遍趋势。本文为您介绍一种使用云数据库Redis版在IM场景中实现多端同步的方案。消息存储模型 通常，IM系统的核心架构分为三个部分：消息管理模块、消息...
查看消费者状态
查看 Group ID 下单个消费者信息 如该 Group ID 的在线状态为 在线，则在 连接信息 页面您可以查看此时在线的每个消费者实例的具体信息，包括客户端 ID、宿主机 IP/公网 IP、当前进程 ID 和消息堆积量等。单击目标消费者右侧的 连接详情，...
顺序消息
如上图所示，消息组1和消息组4的消息混合存储在队列1中，云消息队列 RocketMQ 版 保证消息组1中的消息G1-M1、G1-M2、G1-M3是按发送顺序存储，且消息组4的消息G4-M1、G4-M2也是按顺序存储，但消息组1和消息组4中的消息不涉及顺序关系。...
pg_stat_activity视图
pg_stat_activity是 云原生数据仓库AnalyticDB PostgreSQL版 用来定位实例当前执行查询的系统视图，每行显示一个服务器进程同时详细描述与之关联的用户会话和查询，可以有效帮助用户分析排查当前运行的SQL任务以及异常问题。注意事项 只有...
查询云电脑指定用户的应用和进程信息
查询云电脑指定授权用户的应用和进程信息。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 当前API暂无授权信息透出。请求参数 名称 类型 必...
应用视图
为帮助您更容易找到目标进程，AHAS将进程分为以下4种：虚拟进程：所有服务间的虚拟进程。系统进程：所有应用的进程。进程的已防护和未防护标签反映了应用是否已开启流控降级。云服务：AHAS识别出的云服务，并列出了调用该云服务的所有进程...
基于NVMe共享盘部署集群文件系统
NVMe专为SSD设计，它利用高速接口进行CPU和SDD间的数据通信，相比SCSI、virtio-blk等传统驱动协议速度更快、传输带宽更高。使用场景 适用于一般企业的日常业务需求，特别是当预算有限或对性能要求不是非常高的业务场景。适用于高性能计算...
HTTPS连接通信
数据内容的格式说明如下：消息通信Topic的数据格式说明，请参见 Topic分类和通信说明。设备定位Topic的数据格式说明，请参见 HTTP定位。返回结果示例：body:{"code":0,"message":"success","info":{"messageId":892687*47040 } } 表 5.错误...
数据压缩
通过对消息的压缩，达到节约设备流量和提高传输速度的效果。本文介绍数据压缩功能的使用。使用限制 仅尊享型企业版实例和标准型企业版实例支持数据压缩。仅MQTT协议接入支持数据压缩。每个设备支持压缩或解压缩数据的Topic不超过20个，且...
应用场景
下文先以用户注册为场景说明 云消息队列 RocketMQ 版 如何实现以下功能：异步解耦 分布式事务的数据一致性 消息的顺序收发 最后，再以电商的秒杀场景和价格同步场景分别说明 云消息队列 RocketMQ 版 所实现的削峰填谷和大规模机器的缓存...
生产者（Producer）
预绑定主题列表 定义：云消息队列 RocketMQ 版 的生产者需要将消息发送到的目标主题列表，主要作用如下：事务消息（必须设置）：事务消息场景下，生产者在故障、重启恢复时，需要检查事务消息的主题中是否有未提交的事务消息。避免生产者...
应用调研
在上云实施阶段，应用调研的目标，是为...采用无侵入式采集技术，不影响在线业务的性能前提下从主机和进程两个维度构建架构拓扑，自动分析识别主机和进程信息、资源使用水位以及各应用和组件之间的依赖关系。更多详情，请参见 应用发现服务。
使用限制
网关设备及其子设备的消息限流，请参见 连接通信 中的《消息通信限流》。设备管理 限制项 描述 限制 物模型功能定义 一个产品最多可包含物模型模块（默认模块和自定义模块）总数。200 一个物模型模块最多可添加的功能总数。300 struct类的...
无影云桌面客户端无法连接Windows云桌面的排查方法
问题原因 客户端无法连接云桌面，说明云桌面和后端组件无法正常通信，可能原因如下：云桌面的IP地址被修改 云桌面的网卡被禁用 云桌面的路由表损坏 云桌面的80端口被System之外的其他进程占用 解决方案 请参见以下操作排查无法连接无影云...
名词解释
分别可在消息发送端和消息消费端设置。发送端的QoS设置：影响发送端发送消息到 云消息队列 MQTT 版 的传输质量。消费端的QoS设置：影响 云消息队列 MQTT 版 服务端投递消息到消费端的传输质量。QoS包括以下级别：QoS0：代表最多分发一次。...
产品简介
API 网关是金融分布式架构 SOFAStack 下的一个 API 管理平台，提供 API 托管服务，帮助企业开发者将内部系统的接口封装成 API 开放出去，供外部应用调用，为网络隔离的系统间提供高性能、高安全、高可靠的通信，同时保障内部系统的安全性。...
设备使用物模型通信
本文介绍设备与物联网平台之间，如何通过物模型实现多场景消息通信。背景信息 物联网平台提供的物模型功能定义和使用说明，请参见 什么是物模型。物联网平台物模型通信Topic定义和通信说明，请参见 什么是Topic 和 使用Topic通信。设备与物...
消息队列
消息队列使用环形缓冲池（ring buffer）来管理消息的队列缓冲区，并使用类似信号量的机制进行任务间的同步。任务通过消息队列可以发送消息，也可以通过它接收消息，从而实现数据的同步及通信。任务发送的消息会暂存在消息队列中，当接收...
批量消费
功能优势及场景示例 批量消费的功能优势和场景示例说明如下：优势一：提高消息的吞吐能力和处理效率 场景示例：上游订单系统和下游Elasticsearch系统间通过 云消息队列 RocketMQ 版 解耦，Elasticsearch消费订单系统的10条日志消息，每一条...
Linux系统木马查杀
pstree 以树状图的形式显示进程间的关系。lsof 查看进程打开的文件、文件或目录被哪个进程占用、打开某个端口的进程、系统所有打开的端口等信息。netstat 查看系统监听的所有端口、网络连接情况，查找连接数过多的IP地址等信息。iftop 监控...
启动方式与环境变量说明
PERSEUS_ALLREDUCE_MODE 选择节点间的AllReduce通信模式，分为以下两种：0：所有节点采用一层AllReduce进行通信。1：若存在多个节点，每个节点多卡，会做两级通信，节点内部先reduce到一张卡上，然后每个节点一张卡参与第二级通信。默认为...
消息通信商业化公告
为更好保障客户的消息通信服务，同时控制设备日均消息通信成本，平台对消息通信服务进行全面商业化升级，针对本次升级内容做以下说明。消息通信商业化介绍 激活码消息 购买普通设备（非视频类设备）激活码，包含每台设备每天100条上报消息...
错误码表
本文从通用错误、作业错误、管道错误和消息发送错误为您介绍媒体处理时常见的错误代码。通用错误 错误代码 描述 详细信息 Throttling 接口限流 Request was denied due to request throttling.InvalidIdentity.ServiceDisabled 服务未开通...
CreateDataSourceItem
自定义的消息Topic说明，请参见消息通信说明。若输入自定义的消息Topic，需同时传入 ScopeType和 ProductKey。若 ScopeType为 DEVICE，还需传入 DeviceName。IotInstanceId String 否 iot-0pp1n8t*实例ID。您可在物联网平台控制台的 实例...
Workers
SAE将提供弹性和可扩展的数据管道，通过CPU或者Memory水位阈值判断并在指定范围内自动进行弹性扩缩，满足Workers的弹性诉求。Workers配置总览 Workers配置参数与开源Kafka Connect的配置参数兼容，配置全集请参见 Confluent Kafka Connect...
查看会话监控信息
选择一个或者多个用户，单击会话列表底部的 发送消息，并输入 主题 和 消息，然后单击 确定。消息发送后，您会在控制台收到 消息已成功发送 的通知；接收消息的云电脑会收到并展示您发送的消息内容。应用列表 查看和管理终端用户的应用和...
计费常见问题
若您使用 云消息队列 MQTT 版 的数据流入、数据流出规则和 云消息队列 RocketMQ 版 进行通信，云消息队列 RocketMQ 版 会根据调用的 云消息队列 RocketMQ 版 的消息收发API或Topic资源等进行计费。客户端上线下事件流出到消息队列RocketMQ...
- 产品推荐
- 这些文档可能帮助您