自定义消息发送和接收
ARTC SDK提供自定义消息的发送和接收能力，实现在传输音视频数据的同时再发送自定义的实时消息数据。本文介绍自定义消息发送和接收的实现原理和示例代码。实现原理 主播角色可以发送和接收消息，观众角色仅支持接收消息。示例代码 开启...
关于WhatsApp营销模板调控的通知
重要 模板调控会在消息发出后根据用户的反馈改变发送的状态，如果调控期间收到的客户反馈为负面反馈，会导致消息发送失败。内容 从2023年09月12日起，适用于巴西、哥伦比亚和新加坡境内的企业。从2023年10月12日起，适用于所有企业。新建的...
概述
消息队列可提供强大的抗积压能力，实现削峰填谷，生产方生产消息后，消费方可以按照系统自身的承受能力进行消息的消费。顺序收发指的是消息消费者按照消息发送的顺序进行消费，保证 FIFO。金融场景里需要保证顺序的应用场景非常多，例如...
HTTPS接入概述
如果您希望设备能被动接收物联网平台的消息，可以使用MQTT协议接入设备。更多信息，请参见 概述。设备认证：设备认证请求HTTPS Header中的Content-Type必须为 application/json。设备认证返回的Token仅7天内有效，Token失效后，需重新获取...
消息轨迹
在分布式应用中，云消息队列 RocketMQ 版 作为全链路中异步解耦的关键服务，提供的消息轨迹数据可有效将业务上下游信息串联起来，帮助您更好地排查异常信息，定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版 定义的轨迹参数...
概述
如果您希望设备能被动接收物联网平台的消息，可以使用MQTT协议接入设备。更多信息，请参见 概述。设备认证：设备认证请求HTTPS Header中的Content-Type必须为 application/json。设备认证返回的Token仅7天内有效，Token失效后，需重新获取...
查看云电脑监控信息
接收消息的云电脑会收到并展示您发送的消息内容。查看云电脑运行时长排行榜 您可以查看云电脑的运行时长排行榜，并根据需要管理相应的云电脑资源，或者查看终端用户的操作记录。说明 此排行榜仅包含自2024年03月26日开始的统计数据。在左侧...
消息路由设置示例
下图中的示例表示，lightSensorDataFilter边缘应用过滤出符合/productkey/devicename/user/的消息主题，并将该消息主题中的消息发送给云端，当网络故障后，Link IoT Edge将lightSensorDataFilter边缘应用无法上报的消息存储到本地，并在...
Filebeat发送失败问题
由于发送消息的请求无法找到订阅的Topic，所以出现 Request was for a topic or partition that does not exist on this broker.的错误提示。解决方案 在 云消息队列 Kafka 版 控制台 的 Topic 管理 页面创建Topic，请使用全小写字母给...
云端SDK常见问题
暂不支持查询云端SDK发送的消息。云端SDK无法运行，返回连接超时错误。可能原因：检查实例接入点是否填写正确。云端SDK需要单独使用云端SDK接入点，和终端使用的SDK接入点不一样。云端SDK接入点获取方式，请参见 接入点说明。云端SDK支持...
直播互动解决方案
system为自定义二级Topic，无需在 云消息队列 MQTT 版 控制台创建，本示例中表示系统发送的消息。具体消息流向如下图所示。流程说明如下：后端应用更新消息发送至 云消息队列 RocketMQ 版 的Topic。云消息队列 RocketMQ 版 根据创建的数据...
消息过滤
预期结果：示例中发送的消息Tag和自定义属性符合订阅的过滤条件，消息被投递到消费端。同时根据多个自定义属性订阅消息。Consumer consumer=ONSFactory.createConsumer(properties);只订阅region为hangzhou且属性price小于20的消息。...
SendMessage-向云消息队列 MQTT 版发送单条消息
调用 SendMessage 接口发送的消息不支持流转至云消息队列 RocketMQ 版。若需要通过 MQTT 服务端将消息流转至云消息队列 RocketMQ 版，请使用 SDK 发送消息。SendMessage 接口的 QPS 限制为 1000。更多信息，请参见 QPS 限制。每成功调用...
Java客户端设置回调是否会影响消息发送的速度？
Java客户端设置回调是否会影响消息发送的速度取决于：回调里的处理耗时：为减少回调里的处理耗时，不要过于频繁地在回调里面做耗时的处理。您可以积累一定量Ack后再做批量的回调处理，或者在另一个异步的线程去处理，从而不阻塞回调的完成...
发送消息（多线程）
Thread thread=new Thread(new Runnable(){@Override public void run(){ try { Message msg=new Message(/普通消息所属的Topic，切勿使用普通消息的Topic来收发其他类型的消息。TopicTestMQ",/Message Tag可理解为Gmail中的标签，对消息...
如何处理消息堆积
可能原因 云消息队列 RocketMQ 版 的消息发送至Broker节点后，配置了Group ID的客户端根据当前的消费位点，从Broker节点拉取部分消息到本地进行消费。一般情况下，客户端从Broker节点拉取消息的过程不会导致消息堆积，主要是客户端本地消费...
基于MQTT Topic通信
本文介绍设备如何直接基于MQTT Topic向物联网平台发送消息，以及接收物联网平台云端下发的消息。背景信息 Topic是设备与物联网平台之间通信的管道，设备可通过Topic实现消息的发送和接收。Topic格式必须以/进行分层，区分每个类目。自定义...
收发定时消息和延时消息
设置发送的消息内容和消息Tag。res=await producer.publishMessage("hello mq.timer msg!TagA",msgProps);console.log("Publish message:MessageID:%s,BodyMD5:%s",res.body.MessageId,res.body.MessageBodyMD5);} } catch(e){/消息发送...
MQTT与RocketMQ的消息结构映射
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景，提供交互...clientId clientId 具体的Client ID字符串 不可设置，云消息队列 MQTT 版 发给 云消息队列 RocketMQ 版 消息时，用于追踪该消息的发送源的Client ID。
QueryMqttTraceMessageOfClient-查询消息轨迹
查询指定设备在一定时间段内的消息列表。当消息的收发不符合预期时，您可以通过该接口查看消息的收发状态等轨迹信息，帮助您快速定位异常原因。接口说明 每成功调用一次 QueryMqttTraceMessageOfClient 接口，都会计算为一次消息 TPS，从而...
使用函数计算实现消息数据清洗
消息数据清洗功能提供常见的消息处理模板，如消息分割、动态路由和消息富化等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。本文介绍 云消息队列 RocketMQ 版 消息数据清洗模板的类型和使用方式。背景信息 消息...
使用函数计算实现消息数据清洗
消息数据清洗功能提供常见的消息处理模板，如消息分割、动态路由和消息富化等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。本文介绍 云消息队列 RocketMQ 版 消息数据清洗模板的类型和使用方式。背景信息 消息...
基本概念
Producer 向 云消息队列 Kafka 版 发送消息的应用。Consumer 从 云消息队列 Kafka 版 接收消息的应用。Group 一组具有相同Group ID的Consumer。当一个Topic被同一个 Group 的多个Consumer消费时，每一条消息都只会被投递到一个Consumer，...
接口和参数说明
消息发送接口 消息发送参数 参数名 参数说明 SendMsgTimeoutMillis 设置消息发送的超时时间，单位：毫秒。CheckImmunityTimeInSeconds（事务消息）设置事务消息第一次回查的最快时间，单位：秒。shardingKey（顺序消息）顺序消息中用来计算...
如何配置客户端参数？
buffer.memory 发送的内存池大小。如果内存池设置过小，则有可能导致申请内存耗时过长，从而影响发送性能，甚至导致发送超时。建议 buffer.memory ≧ batch.size*分区数*2。单位：字节。表 2.消费者客户端参数 参数 说明 fetch.min.bytes ...
SOFAMQ 常见问题
如果是存在时间较长的 Topic，则会忽略历史消息，从启动之后发送的消息开始消费。如果这个 Group ID 是第二次启动，那么从上次消费的位置开始消费。如果想从特定位置开始消费，可以通过消息队列控制台的消费位点重置功能，指定到具体的时间...
RRpc
RequestBase64Byte String 是 dGhpcyBpcyBhbiBleGFtcGxl 要发送的消息内容。您需要将消息原文转换成二进制数据，并进行Base64编码，从而生成消息内容。说明 物联网平台会先对消息内容进行Base64解码，再将解码后的对应消息发送给设备。设备...
仪表盘
消息堆积场景 如下图所示，表示指定主题的某一队列中各消息的状态：上图表示指定主题的某一队列中各消息的状态，云消息队列 RocketMQ 版 将处于不同处理阶段的消息数量和耗时进行统计，这些指标可直接反映队列中消息的处理速率和堆积情况，...
订阅消息API
订阅者可通过调用订阅消息API来消费 云消息队列 RocketMQ 版 服务端中的消息。请求构造 请求行 GET/topics/TopicName/messages?ns=INSTANCE_ID&consumer=GID&tag=taga&numOfMessages=3&waitseconds=3 HTTP/1.1 重要 请求行总长度不能超过...
MQTT接入
IOT_MQTT_Publish_Simple：带更多配置选项的消息发送。的普通消息发送，该接口可以带更多配置选项发送消息。参数说明 参数 数据类型 方向 说明 handle void*输入 MQTT句柄，可为NULL。topic_name const char*输入 接收此推送消息的目标...
如何使用消息服务？
消息下发 消息下发页面导航：CMNS-下行消息 进入下行消息页面，点击消息发送按钮，在弹出的消息发送对话框中设置发送参数进行消息发送。2.消息上行 消息上行是指应用客户端将数据通过cmns长连通道上行并通过阿里云mns消息队列转交给应用...
消息渠道概述
Dataphin支持对接不同的消息发送渠道，包括系统内置的电话、短信、邮件和钉钉群机器人，同时支持用户自定义消息渠道。功能介绍 Dataphin中您可通过钉钉群或邮件发送告警消息。在成员管理中配置好成员的钉钉群机器人的webhook（如何配置钉钉...
Queue管理
Queue是指消息队列，云消息队列 RabbitMQ 版 的消息都会被投入到一个或多个Queue中。本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息的存储资源Queue、查看Dashboard大盘、被Exchange绑定、向指定Queue发送消息、查看Consumer Tag、...
物联网平台通信方式概述
背景信息 设备通过消息Topic实现消息的发送和接收，消息通信Topic的定义、使用和分类说明，请参见 什么是Topic。设备上报的原始数据格式，需您在设备端完成开发。阿里云物联网平台提供的设备端Link SDK，可实现设备快速接入物联网平台并...
Serverless版实例计费
消息收发量 使用 云消息队列 MQTT 版 支持的协议，进行上行数据发送和下行数据接收的消息总条数。计费周期为天，即每天账单中统计的是前一天0点开始的24小时内接收消息和发送消息的总数。消息收发仅涉及通过 云消息队列 MQTT 版 进行收发的...
FindVersionMessageSendRecords
调用FindVersionMessageSendRecords查询版本下的群发消息记录，只针对按照机型群发的消息记录的查询。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求...
使用须知
例如您的 云消息队列 RocketMQ 版 实例在华东1（杭州）地域，则只能使用华东1（杭州）地域的接入点来访问该地域的实例。...您可以自行采用Base64编码对发送的消息进行编（解）码，以适用于此类不符合XML规范的消息收发场景。
基于AppFlow实现钉钉群聊定时通知
SECf73952b2dea753d6ceade3348ed3cxxxxxxxxxxx 文本内容 是 钉钉机器人需要发送的文本内容。定时提醒：定时消息文本 是否@所有人 否 机器人发送的消息是否@所有人，仅在 内部群 有效。True;False 被@人的用户userID 否 机器人发送的消息@...
设置消息路由
消息路由即通过路由规则动态规划消息的传输路径，使消息按照过滤条件，从消息源路由到目标节点。前提条件 消息路由需在边缘实例中设置。您需在设置消息路由之前，先创建边缘实例，并为该实例分配网关、驱动、设备和边缘应用。操作步骤 登录...
媒体扩展信息（SEI）的使用
sendMediaExtensionMsg 函数中 repeatCount 参数为自定义消息冗余度，若大于1，则会发送多次，防止网络丢包导致的消息丢失，此时房间里的其他人也会收到多次相同的消息，需要去重。发送的自定义消息，在旁路直播时，房间里的订阅者也一样会...
- 产品推荐
- 这些文档可能帮助您