通过Knative事件驱动实现消息发送

本文通过一个Demo示例介绍如何通过Knative部署消息处理、事件驱动和Homepage,实现消息发送。前提条件 创建ACK Serverless集群 部署Knative 部署Eventing Demo介绍 Demo主要包含以下三部分:HomePage:用于发送和接收弹幕,通过Knative ...

版本说明

本文介绍RocketMQ ONS 1.x系列Java SDK的版本...新增顺序消息、BatchConsumer与Spring集成的Demo。功能优化 针对分区有序消息,将Sharding Key放入到消息结构中。消息属性设置支持Int型的Value值。ons-client-1.6.0.Final 后续步骤 准备环境

版本说明

本文介绍Java SDK的版本信息,包含使用限制、...新增顺序消息、BatchConsumer与Spring集成的Demo。功能优化 针对分区有序消息,将Sharding Key放入到消息结构中。消息属性设置支持Int型的Value值。ons-client-1.6.0.Final 后续步骤 准备环境

概述

Demo简介 Demo 功能 device_basic_demo 演示设备基础建连,发送接收消息,包含自定义消息的使用。device_bootstrap_demo 演示设备就近接入功能的使用。device_dynamic_register_demo 演示设备就近接入功能的使用。ota_basic_demo 演示设备...

Go Demo

通过本文,您可以了解短信服务Go语言的消息回执示例,同时下载相应的SDK安装包拉取MNS消息。下载地址:Go SDK。Demo如下:说明 调用接口前需配置环境变量,通过环境变量读取访问凭证。AccessKey ID和AccessKey Secret的环境变量名:SMS_...

Go Demo

通过本文,您可以了解短信服务Go语言的消息回执示例,同时下载相应的SDK安装包拉取MNS消息。下载地址:Go SDK。Demo如下:说明 调用接口前需配置环境变量,通过环境变量读取访问凭证。AccessKey ID和AccessKey Secret的环境变量名:SECRET_...

使用示例

本文以C Link SDK中的Demo文件./demos/coap_basic_demo.c 为例,介绍如何调用Link SDK的API,使用对称加密的方式,将CoAP协议的设备接入物联网平台并进行消息收发。背景信息 CoAP接入的更多信息,请参见 概述。步骤一:初始化 添加头文件。...

快速使用MQTT的Java SDK收发消息(终端和云端消息收发...

更多消息收发示例代码,请参见 终端Demo工程 或 云端Demo工程。接入点说明 终端和云端服务与 云消息队列 MQTT 版 通信时,需要在各自的SDK代码中设置 云消息队列 MQTT 版 实例的接入点信息,通过接入点和 云消息队列 MQTT 版 服务端连接。...

快速使用MQTT的Java SDK收发消息(终端和终端消息收发...

下载阿里云 云消息队列 MQTT 版 的Java SDK的Demo示例作为您代码开发的参考。下载地址为 mqtt-java-demo。解压该Demo工程包至您指定的文件夹。在IntelliJ IDEA中,导入解压后的文件以创建相应的工程,并确认 pom.xml 中已包含以下依赖。...

MQTT和RocketMQ进行数据互通(客户端上下线通知)

MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息,云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品,并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...

MQTT和RocketMQ进行数据互通(跨产品数据流入)

如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能,例如顺序消息特性、事务消息特性等,您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...

MQTT和RocketMQ进行数据互通(跨产品数据流出)

如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能,例如顺序消息特性、事务消息特性等,您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...

获取代码示例

组件 CocoaPods mPaaS 插件 Extension 插件 合集(包含所有组件)ios-portal-pod-demo-10.1.32-201904020020.zip 无 无 消息推送 ios-push-pod-demo-10.1.32-201904021854.zip ios-push-plugin-demo-10.1.32-201904031034.zip 无 移动同步 ...

物模型开发

参考示例,更多使用可参考demo LinkKit.getInstance().getDeviceThing().thingPropertyPost(reportData,new IPublishResourceListener(){ public void onSuccess(String alinkId,Object o){/消息从设备发出成功/alinkId表示该消息的...

使用示例

本文以C Link SDK中的Demo文件./demos/shadow_basic_demo.c 为例,介绍如何调用Link SDK的API,展示设备影子功能。背景信息 设备影子功能的更多信息,请参见 概述。设备影子 功能基于MQTT接入,开发过程中涉及MQTT接入的代码说明,请参见 ...

云上迁移Group

本文介绍如何使用 云消息队列 Kafka 版 提供的迁移工具将某个 云消息队列 Kafka 版 实例的 Group 迁移到另一个 云消息队列 Kafka 版 实例。前提条件 您已完成以下操作:下载JDK 8 下载迁移工具JAR文件 重要 迁移不会删除源 云消息队列 ...

RocketMQ全链路追踪解决方案

Demo示例:RocketMQ Trace指标大盘Demo:展示利用Trace数据转化得到的消息发送延时、发送成功率、消费成功率、端到端时延等指标。RocketMQ Trace分析Demo:可以根据Trace指标大盘得到的Message ID或Trace ID,对异常调用进行进一步分析。...

.NET/C# Demo

阿里云SDK核心库 dybaseapi Demo如下:说明 调用接口前需配置环境变量,通过环境变量读取访问凭证。AccessKey ID和AccessKey Secret的环境变量名:SMS_ACCESS_KEY_ENV、SMS_ACCESS_KEY_SECRET_ENV。配置详情请参见 配置访问凭证。using ...

使用示例

本文以C Link SDK中的Demo文件./demos/http_basic_demo 为例,介绍如何调用Link SDK的API,将HTTPS协议的设备接入物联网平台并进行消息收发。背景信息 HTTPS接入的更多信息,请参见 概述。步骤一:初始化 配置底层依赖和日志输出。aiot_...

HTTPS接入使用示例

本文以C Link SDK中的Demo文件./demos/http_basic_demo 为例,介绍如何调用Link SDK的API,将HTTPS 协议的设备接入物联网平台并进行消息收发。背景信息 HTTPS接入的更多信息,请参见 概述。步骤一:初始化 配置底层依赖和日志输出。aiot_...

物模型透传开发

物模型消息的回调函数*/static void demo_dm_msg_callback(void*device,const aiot_dm_msg_t*dm_msg,void*userdata){ if(dm_msg=NULL){ return;} printf("[thing-message]recv msg type%d\r",dm_msg->type);switch(dm_msg->type){ case ...

名词解释

在使用 云消息队列 MQTT 版 前,需理解该产品和MQTT协议所涉及的基本概念和术语。基本概念 实例(Instance)创建购买 云消息队列 MQTT 版 服务的实体单元,每个 云消息队列 MQTT 版 实例都对应一个全局唯一的服务接入点URL。使用 云消息...

直播互动解决方案

本文以单直播间、一名老师、两名学生的场景为例,说明如何使用 云消息队列 MQTT 版 实现直播互动消息、禁言、成员上下线通知以及系统消息通知,其中,老师和学生的客户端以HTML网页为例,后端应用以Java为例。背景信息 在直播互动的场景下...

客户端连接常见问题

本文介绍 云消息队列 MQTT 版 客户端连接服务端时的常见问题。使用安卓的Demo,返回连接失败报错。问题描述 资源填写正确,且网络可以连通。AK(AccessKey ID)、SK(AccessKey Secret)填写正确且已授权。可能原因 接入点格式不正确,正确...

基于 LinkSDK 集成安全 Agent 最佳实践

接入IoT安全运营中心消息回调*/ipc_error_t demo_security_message_handler(void*context,pid_t pid,char*message,uint16_t length){ channel_session_t*session=(channel_session_t*)context;void*mqtt_handle=NULL;char topic[MAX_TOPIC_...

日志上报

demo_logpost_msg_callback 日志模块的消息回调函数。NULL 回调函数的上下文。(可选)设置日志上报是否需要回复。设置日志上报是否需要回复 0:默认值,不需要回复 1.需要回复*/aiot_device_logpost_set_post_reply(device,1);参数说明 ...

基于 LinkSDK 集成安全 Agent 最佳实践

接入IoT安全运营中心消息回调*/ipc_error_t demo_security_message_handler(void*context,pid_t pid,char*message,uint16_t length){ channel_session_t*session=(channel_session_t*)context;void*mqtt_handle=NULL;char topic[MAX_TOPIC_...

使用示例

本文以C Link SDK中的Demo文件./demos/logpost_basic_demo.c 为例,介绍如何调用Link SDK的API,以支持设备向物联网平台上报本地日志。背景信息 使用日志上报功能前,请确保 已在物联网平台控制的 设备详情 页,打开 设备本地日志上报 开关...

CreateVirtualHost

VirtualHost String 是 Demo 待创建Vhost的名称。取值说明如下:Vhost名称只能包含字母、数字、短划线(-)、下划线(_)、半角句号(.)、井号(#)、正斜线(/)、at符号(@)。Vhost名称长度限制1~255字符。Vhost创建后,Vhost名称不可...

使用示例

TODO:回调中,将设备分发消息内容存储指定位置,这些空间就会被SDK释放*/memcpy(demo_info->host,packet->data.connection_info.host,strlen(packet->data.connection_info.host));demo_info->port=packet->data.connection_info.port;} } ...

基于 libmosquitto 集成安全 Agent 最佳实践

接入IoT安全运营中心消息回调*/ipc_error_t demo_security_message_handler(void*context,pid_t pid,char*message,uint16_t length){ int rc=0;channel_session_t*session=(channel_session_t*)context;struct mosquitto*mosq=NULL;char ...

远程登录进程说明

demo_tunnel_listen_task Listen 监听到消息,并添加进隧道服务,完成隧道建连。msg recv data len 644,[1644819889.299][LK-1C80]remote proxy thread start![1644819889.344][LK-1C80]start to create cloud channel[1644819889.344][LK-...

设备数据订阅指引

参考SDK链接:https://help.aliyun.com/document_detail/143601.html?spm=a2c4g.11186623.4.5.367d4f38ycUoZZ 此处提供了SDK Demo,您可以参考此Demo,开发SDK,进行订阅设备端的消息。AMQP(Advanced Message Queuing Protocol)即高级...

通过RocketMQ客户端消费设备消息

output/data-basic-demo 返回如下日志,设备接入并发布消息成功:[1698060995.066][LK-0313]MQTT user calls aiot_mqtt_connect api,connect[1698060995.066][LK-032A]mqtt host:iot-*.mqtt.iothub.aliyuncs.com [1698060995.066][LK-0317]...

使用示例

本文以C Link SDK中的Demo文件./demos/mqtt_v5_basic_demo.c 为例,介绍如何调用C Link SDK的API,将MQTT 5.0协议的设备接入物联网平台并进行消息收发。背景信息 MQTT 5.0接入的更多信息,请参见 概述。步骤一:初始化 添加头文件。include...

MQTT接入使用示例

本文以C Link SDK中的Demo文件./mqtt_basic_demo.c 为例,介绍如何调用Link SDK的API,将MQTT 协议的设备接入物联网平台并进行消息收发。背景信息 MQTT接入的更多信息,请参见 概述。步骤一:初始化 添加头文件。include"aiot_state_api.h...

使用示例

本文以C Link SDK中的Demo文件为例,介绍如何调用Link SDK的API,将MQTT协议的设备接入物联网平台并进行消息收发。背景信息 MQTT接入的更多信息,请参见 MQTT接入概述。物联网平台提供的C Link SDK中,非云网关设备接入的Demo文件为./mqtt_...

AUI Kits

您可以基于Demo源码进行二次开发,可有效节约您的开发时间和成本。互动直播 Demo体验 场景 样式 平台 角色 开发参考 体验入口 互动直播 竖屏样式 Android 主播端 观众端 Android端竖屏样式接入 iOS 主播端 观众端 iOS端竖屏样式接入 Web ...

使用示例

本文以C Link SDK中的Demo文件./demos/devinfo_posix_demo.c 为例,介绍如何调用Link SDK的API,向物联网平台,上报或删除设备标签。背景信息 设备标签功能的更多信息,请参见 概述。设备标签功能基于MQTT接入,开发过程中涉及MQTT接入的...

开源MQTT托管设备接入示例

订阅消息*/MQTTClient_subscribe(client,"/user/aiot_mqtt_demo_downraw",1);生成消息并循环发布消息*/MQTTClient_message pubmsg=MQTTClient_message_initializer;const char*topic="/user/aiot_mqtt_demo_upraw;pubmsg.payload="Hello ...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
消息服务 云消息队列 Kafka 版 云消息队列 RocketMQ 版 智能对话机器人 表格存储 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用