怎样让Consumer不立即消费消息并使消息重入队列？
您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...
设备影子
pcontext void*输入 用户Context，当收到消息应答时通过回调函数送回给用户。返回值说明 值 说明 0 成功失败 IOT_Shadow_Pull 接口原型 iotx_err_t IOT_Shadow_Pull(void*handle);接口说明 该接口用于从云端获取设备影子。参数说明 参数 ...
存证服务API
one_way_message_timeout 单向消息发送超时时间（毫秒为单位），超过该时间就认为发送失败 否 默认15000 biz.sdk.wait_response_timeout 双向消息应答超时时间（毫秒为单位），超过该时间就认为应答失败 否 默认30000 biz.sdk.socket_send_...
CoAP接入
参数说明 参数 数据类型 方向 说明 p_message void*输入 CoAP应答消息句柄，在应答消息的回调函数中可获得。pp_payload unsigned char*输出 用于存放从 p_message 中获取的消息Payload。p_len int*输出 pp_payload 的长度。返回值说明 值 ...
怎样让Consumer不立即消费消息并使消息重入队列？
您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...
SDK FAQ
使用basicReject方法否定应答消息并使消息重入队列 参数 说明 deliveryTag Channel的消息投递的唯一标识符。requeue 被否定应答的消息是否重入队列。如果设置为true，则消息重入队列；如果设置为false，则消息被丢弃或发送到死信Exchange。...
消费失败是否支持重试？
如果您开启了Consumer客户端消费消息，消费失败，即Consumer客户端一分钟内没有应答消息，则触发消息重试：重试期间，任何一次消费成功，即Consumer客户端应答消息，则立即停止消息重试。重试间隔时间：专业版实例：60秒 企业版实例：5分钟...
消息超时和重试机制
如果您开启了Consumer客户端消费消息，当消费失败时，即Consumer客户端在重试间隔时间内没有应答消息，则触发消息重试：重试间隔时间：Serverless版实例：5分钟 专业版实例：1分钟 企业版实例：5分钟 铂金版实例：30分钟 重试期间，任何...
HTTP接入
timeout_ms 设置等待应答消息的超时时间。返回值说明 值 说明 NULL 初始化失败 非NULL HTTP Context IOT_HTTP_DeInit 接口原型 void IOT_HTTP_DeInit(void*handle);接口说明 HTTP反初始化函数，断开与云端的连接并释放所有指定Context中...
API详解
IOTX_IOCTL_SEND_PROP_SET_REPLY 控制当SDK收到云端的设置属性的消息时，是否需要向云端发送应答消息，data 的数据类型为 int*。当data的值为1时，SDK需要向云端发送设置属性的应答消息。当data的值为0时，SDK不需要向云端发送设置属性的...
使用示例
步骤五：接收应答 消息发送后，物联网平台返回应答报文。设备端调用 aiot_coap_recv 接收CoAP应答数据，根据事件回调函数，执行对应处理。res=aiot_coap_recv(handle);if(res=0){/*成功接收到服务器应答,且业务应答码为=0,说明数据上报成功...
使用示例
} 透传/自定义格式 应答报文消息在 recv->data.raw_data 中，消息收发前，您需在物联网平台上传解析脚本，更多信息请参见 物模型消息解析。static void demo_dm_recv_raw_data_reply(void*dm_handle,const aiot_dm_recv_t*recv,void*...
使用示例
示例代码中回调函数的处理逻辑：打印了RRPC消息，并同步向物联网平台返回了一条 payload 的值为 pong 的应答消息。void demo_mqtt_default_recv_handler(void*handle,const aiot_mqtt_recv_t*packet,void*userdata){ switch(packet->type){...
使用示例
步骤五：接收应答 消息发送后，物联网平台返回应答报文。设备端调用 aiot_http_recv 接收HTTPS应答数据，根据事件回调函数，执行对应处理。res=aiot_http_recv(handle);if(res>=0){/*成功接收到服务器应答,且业务应答码为0,说明数据上报...
HTTPS接入使用示例
步骤五：接收应答 消息发送后，物联网平台返回应答报文。设备端调用 aiot_http_recv 接收HTTPS 应答数据，根据事件回调函数，执行对应处理。res=aiot_http_recv(handle);if(res>=0){/*成功接收到服务器应答,且业务应答码为0,说明数据上报...
服务调用
播报标识 需与输入参数中的播报标识保持一致，用于返回本次播报调用相匹配的应答消息。开始处理时间戳 设备开始处理播报请求的UTC时间戳，用于云端统计播报的指标。处理完成时间戳 设备完成处理播报请求的UTC时间戳，用于云端统计播报的...
使用示例
设备端调用 aiot_bootstrap_recv，接收应答消息，根据消息回调函数的处理逻辑，执行对应处理。res=aiot_bootstrap_recv(bootstrap_handle);if(res){ printf("aiot_bootstrap_recv failed,res:0x%04X",-res);return-1;} 编写回调函数的处理...
HTTPS动态注册使用示例
设备端调用 aiot_dynreg_recv，接收应答消息，根据消息回调函数，执行对应处理。res=aiot_dynreg_recv(dynreg_handle);if(res){ printf("aiot_dynreg_recv failed:0x%04X",-res);return-1;} 例程仅做打印操作，但在实际业务环境中，您还需...
边缘应用 Link IoT Edge对接
3.2 选择分组代理网关 应用程序需要访问边缘分组的信息时，需要有一台网关（分组代理网关）负责查询、收集、汇总分组中所有的网关信息，并返回一条应答消息给应用程序。这时涉及如何选择分组中代理网关的问题，有两个策略：用户在页面选择...
消息轨迹
按消息处理耗时：指消息投递开始到接收后的应答耗时，适用于需要查询处理消息所花费的时间在某个时长的模糊查询场景。使用限制 使用 云消息队列 RabbitMQ 版 消息轨迹功能时，限制如下：仅当实例支持消息轨迹时，才可以查询该实例中消息...
错误码映射插件
位置名称 适用范围 说明 StatusCode 应答 后端的HTTP应答码，如：200,400 ErrorCode 应答 API网关系统错误码 ErrorMessage 应答 API网关系统错误消息 Header 应答 使用 Header:{Name} 获取名字为 {Name} 的HTTP头的第一个值 BodyJsonField ...
使用示例
void demo_devinfo_recv_handler(void*handle,const aiot_devinfo_recv_t*packet,void*userdata){ switch(packet->type){/*物联网平台对devinfo消息的应答*/case AIOT_DEVINFORECV_GENERIC_REPLY:{ printf("pk:%s,dn:%s,code:%d,msg id:%d,...
死信Exchange
消费者消费失败后消息重试次数超过16次依然没有成功，或者消费者没有消费消息而直接否定应答，消息变成死信消息。Queue根据 x-dead-letter-exchange 将死信消息发送到死信Exchange，并根据 x-dead-letter-routing-key 为死信消息设置死信...
产品优势
死信Exchange 增强型死信Exchange，不仅支持被否定应答的消息，还支持重试失败的消息自动进入死信Exchange，确保消息不丢失。超强性能 平台性能上限 支持百万级队列，横向扩容带来性能的线性增长，性能上无并发限制。单队列扩容 解决...
蓝牙BLE基础规范
Bit序 说明 备注 0~3 消息ID，Msg ID 每发送一条消息ID加1 如果消息有应答时，应答的消息ID需要和请求的消息ID匹配 ID超过15，自动循环到1 4 数据加密指示 置0 5~7 版本信息 置0 Header Byte 1：指令类型，蓝牙设备应用层和手机App交互的...
使用示例
应答报文 消息的类型为 AIOT_SHADOWRECV_GENERIC_REPLY。以下是应答报文示例及其Alink数据格式：示例 Alink格式 说明 {"status":"success","version":0 } {"method":"reply","payload":{"status":"success","version":0 },"timestamp":...
新零售电子价签解决方案（MQTT）
目标电子价签节点改价成功后，智能AP节点回发一条应答MQTT消息，通知电子价签管控服务当前任务已完成。电子价签管控服务将当前任务的执行记录写入SLS日志，方便后续溯源查询。注意事项 上述流程简要描述了如何使用 云消息队列 MQTT 版 和 ...
消息轨迹
取值如下：成功 失败 消息基础信息 消息类型 普通消息 顺序消息 定时/延时消息 事务消息 消息ID 消息的全局唯一标识，由 云消息队列 RocketMQ 版 系统自动生成。Topic 消息所属的主题名称。消息Keys MessageKey，消息的业务标识，由消息...
运行日志
应答日志：设备端接收到RRPC消息后，做出应答响应，并打印如下日志：[1578054379.700][LK-0309]pub:/ext/rrpc/1213074107617*/a18wP*/LightSwitch/user/get[LK-030A]>70 6F 6E 67|pong 物联网平台日志 您可以登录 物联网平台控制台，在左侧...
JT/T 808协议云网关概述
消息 消息类型 终端通用应答 0x0001 平台通用应答 0x8001 终端心跳 0x0002 终端注册 0x0100 终端注册应答 0x8100 终端注销 0x0003 终端鉴权 0x0102 数据透传下行 0x8900 数据上行透传 0x0900 位置信息汇报 0x0200 定位数据批量上传 0x0704 ...
发送普通消息（三种方式）
由于在oneway方式发送消息时没有请求应答处理，如果出现消息发送失败，则会因为没有重试而导致数据丢失。若数据不可丢，建议选用可靠同步或可靠异步发送方式。producer.sendOneway(msg);}/在应用退出前，销毁Producer对象。注意：销毁...
名词解释
消息变成死信消息的可能原因如下：requeue 参数被设置为 false，消费者使用 basic.reject 或 basic.nack 否定应答（NACK）消息。消息重试次数超过16次，消息重试失败。具体信息，请参见 消息重试。消息过期，即消息在Queue中存在的时间超过...
顺序消息
如需保证消息消费的顺序性，则必须满足以下条件：投递顺序 云消息队列 RocketMQ 版 通过客户端SDK和服务端通信协议保障消息按照服务端存储顺序投递，但业务方消费消息时需要严格按照接收—处理—应答的语义处理消息，避免因异步处理导致...
示例代码
由于在oneway方式发送消息时没有请求应答处理，如果出现消息发送失败，则会因为没有重试而导致数据丢失。若数据不可丢，建议选用可靠同步或可靠异步发送方式。producer.sendOneway(msg);}/在应用退出前，销毁Producer对象。注意：销毁...
概述
本文介绍通过配置C Link SDK，实现设备端接收同步消息，并处理和应答下发对设备的控制指令。前提条件 已准备开发环境。已获取C Link SDK。定制SDK时，在 SDK定制 页面的 连接物联网平台协议 区域，选中 MQTT 3.1.1。已获取设备认证信息。...
基于MQTT Topic通信
返回应答 适用于用户将设备上行的消息流转到自己的业务服务器，业务服务器再发送下行消息给设备的场景。适用于用户使用Alink协议的Topic，并且协议规定服务端会回复reply报文的场景。发布 MqttPublishRequest request=new ...
基于MQTT Topic通信
返回应答 适用于用户将设备上行的消息流转到自己的业务服务器，业务服务器再发送下行消息给设备的场景。适用于用户使用Alink协议的Topic，并且协议规定服务端会回复reply报文的场景。发布 MqttPublishRequest request=new ...
收发普通消息（三种方式）
} } 单向（Oneway）发送 原理 发送方只负责发送消息，不等待服务端返回响应且没有回调函数触发，即只发送请求不等待应答。此方式发送消息的过程耗时非常短，一般在微秒级别。应用场景 适用于某些耗时非常短，但对可靠性要求并不高的场景，...
概述
功能原理 应用程序通过调用C Link SDK的API，基于 MQTT协议的连接，接收并应答物联网平台下发的广播消息。如下功能时序图，以设备的应用程序 demos/mqtt_broadcast_demo.c 为例，介绍应用程序实现该功能的流程。广播通信 功能基于MQTT接入...
消息幂等
投递时消息重复 消息消费的场景下，消息已投递到Consumer并完成业务处理，当客户端给服务端反馈应答的时候网络闪断。为了保证消息至少被消费一次，云消息队列 RabbitMQ 版 的服务端将在网络恢复后再次尝试投递之前已被处理过的消息，...
- 产品推荐
- 这些文档可能帮助您