server 2012 iis 添加网站,建设部网站 技术规范,wordpress 右拉,凡客app哪去了概述 M2M#xff08;即Machine-to-Machine#xff09;是一种端对端通信技术。本章节以Node JS SDK为例#xff0c;使用基于Topic消息路由的M2M设备间通信#xff0c;主要介绍如何基于物联网平台构建一个M2M设备间通信架构。 实验步骤 第一部分#xff1a;配置相关
1、产品…概述 M2M即Machine-to-Machine是一种端对端通信技术。本章节以Node JS SDK为例使用基于Topic消息路由的M2M设备间通信主要介绍如何基于物联网平台构建一个M2M设备间通信架构。 实验步骤 第一部分配置相关
1、产品、设备、Topic的创建参考链接
消息路由建立 本部分目前不支持门户直接配置需要基于管理API: CreateTopicRouteTable 来建立消息路由关系。 测试可以直接使用OpenAPI来快速实现相关功能本地集成相关功能直接基于SDK即可。 2、JAVA SDK Demo
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.exceptions.ServerException;
import com.aliyuncs.iot.model.v20170420.CreateTopicRouteTableRequest;
import com.aliyuncs.iot.model.v20170420.CreateTopicRouteTableResponse;
import com.aliyuncs.profile.DefaultProfile;
import com.google.gson.Gson;
import java.util.*;public class CreateTopicRouteTable {public static void main(String[] args) {DefaultProfile profile DefaultProfile.getProfile(cn-shanghai, LTAIOZZg********, v7CjUJCMk7j9aKduMAQLjy********);IAcsClient client new DefaultAcsClient(profile);CreateTopicRouteTableRequest request new CreateTopicRouteTableRequest();request.setRegionId(cn-shanghai);ListString dstTopicList new ArrayListString();dstTopicList.add(/a12OcQ4****/device2/user/RouteData);request.setDstTopics(dstTopicList);request.setSrcTopic(/a12OcQ4****/device1/user/RouteData);try {CreateTopicRouteTableResponse response client.getAcsResponse(request);System.out.println(new Gson().toJson(response));} catch (ServerException e) {e.printStackTrace();} catch (ClientException e) {System.out.println(ErrCode: e.getErrCode());System.out.println(ErrMsg: e.getErrMsg());System.out.println(RequestId: e.getRequestId());}}
} 注意SDK版本差异按照实际版本调整即可。 3、查询路由关系
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.exceptions.ServerException;
import com.aliyuncs.iot.model.v20170420.QueryTopicRouteTableRequest;
import com.aliyuncs.iot.model.v20170420.QueryTopicRouteTableResponse;
import com.aliyuncs.profile.DefaultProfile;
import com.google.gson.Gson;public class QueryTopicRouteTable {public static void main(String[] args) {DefaultProfile profile DefaultProfile.getProfile(cn-shanghai, LTAIOZZgY********, v7CjUJCMk7j9aKduMAQLjy********);IAcsClient client new DefaultAcsClient(profile);QueryTopicRouteTableRequest request new QueryTopicRouteTableRequest();request.setRegionId(cn-shanghai);request.setTopic(/a12OcQ4****/device1/user/RouteData);try {QueryTopicRouteTableResponse response client.getAcsResponse(request);System.out.println(new Gson().toJson(response));} catch (ServerException e) {e.printStackTrace();} catch (ClientException e) {System.out.println(ErrCode: e.getErrCode());System.out.println(ErrMsg: e.getErrMsg());System.out.println(RequestId: e.getRequestId());}}
} 运行结果 {requestId:9404FD71-7461-478E-B064-0AEB15C91111,success:true,dstTopics:[/a12OcQ4****/device2/user/RouteData]} 第二部分客户端代码相关
4、Node JS SDK安装参考链接
5、设备端业务代码 device1 // node引入包名
const iot require(alibabacloud-iot-device-sdk);
// 浏览器、微信小程序支付宝小程序引入./dist编译的js文件
// const iot require(./dist/alibabacloud-iot-device-sdk.js);
// js版本下载地址
// https://github.com/aliyun/alibabacloud-iot-device-sdk/tree/master/dist 或
// alibabacloud-iot-device-sdk.js 下载地址 https://unpkg.com/alibabacloud-iot-device-sdk1.2.4/dist/alibabacloud-iot-device-sdk.js 或
// alibabacloud-iot-device-sdk.min.js 下载地址 https://unpkg.com/alibabacloud-iot-device-sdk1.2.4/dist/alibabacloud-iot-device-sdk.min.js
// const device iot.device({productKey: a12OcQ4****,deviceName: device1,deviceSecret: 3yWqKtWxN7VPuWEEDEn4eKWN********// 支付宝小程序和微信小程序额外需要配置协议参数// protocol: alis://, protocol: wxs://,
});
device.on(connect, () {console.log(connect successfully!);// 发送消息到指定的Topic等待规则引擎转发到另外的一个设备的Topicdevice.publish(/a12OcQ4****/device1/user/RouteData, {ke1:value1 test});device.publish(/a12OcQ4****/device1/user/RouteData, This is my test job.);
}); device2 // node引入包名
const iot require(alibabacloud-iot-device-sdk);
// 浏览器、微信小程序支付宝小程序引入./dist编译的js文件
// const iot require(./dist/alibabacloud-iot-device-sdk.js);
// js版本下载地址
// https://github.com/aliyun/alibabacloud-iot-device-sdk/tree/master/dist 或
// alibabacloud-iot-device-sdk.js 下载地址 https://unpkg.com/alibabacloud-iot-device-sdk1.2.4/dist/alibabacloud-iot-device-sdk.js 或
// alibabacloud-iot-device-sdk.min.js 下载地址 https://unpkg.com/alibabacloud-iot-device-sdk1.2.4/dist/alibabacloud-iot-device-sdk.min.js
// const device iot.device({productKey: a12OcQ4****,deviceName: device2,deviceSecret: X9fzX9u0aIOORNghPyfYKq22********// 支付宝小程序和微信小程序额外需要配置协议参数// protocol: alis://, protocol: wxs://,
});
// 定于规则引擎转发过来的消息
device.subscribe(/a12OcQ4****/device2/user/RouteData);
device.on(connect, () {console.log(connect successfully!);
});
device.on(message, (topic, payload) {console.log(topic, payload.toString());
});
8、测试运行 原文链接 本文为云栖社区原创内容未经允许不得转载。
