华南 1(深圳) 物联网平台实例化开发实战
明天，阿里云 IoT 物联网平台在 华南 1(深圳)节点正式上线！对于华南地区的设施接入延时能够做到 <10ms，比跨地区接入延时缩小了 3 倍以上，同时反对通过规定引擎接入其余阿里云产品。
10 毫秒是什么概念？这么说吧，咱们每次实现眨眼的动作须要 … 100 毫秒的工夫 …
根本业务链路
按需开明实例
咱们登录 IoT 物联网控制台，在左上角，切换到华南 1(深圳)节点，即可在华南创立 IoT 物联网平台实例，如下图：
在实例规格页面的地区和可用区，抉择华南 1(深圳)节点，其余规格能够依据理论业务状况抉择，如下图：
在线领取后，稍等几分钟，实例初始化实现。
在实例设置页面，咱们能够切换实例，查看实例 MQTT，CoAP，HTTP，AMQP，云端 API 的接入点信息，以及 VPC 内网接入点信息。
设施接入实战
咱们以冷链运输追踪器为例，实现 IoT 设施接入华南 1 节点的开发实战。
1.创立产品和设施
在实例中，咱们创立产品，抉择直连设施，以设施秘钥形式认证身份。
在产品详情的 Topic 类列表创立用于业务通信的 Topic，具体如下图：
而后，咱们注册一个设施。在设施详情，能够看到设施处于未激活，区域为华南 1（深圳）。
2.配置业务数据流转规定
首先，咱们创立服务端订阅生产组，用来生产设施产生的业务数据，如下图：
而后，咱们配置规定引擎，把数据流转到刚刚创立的生产组，如下图：
开发编码
3. 设施端开发
咱们以 Nodejs 为例，设施接入代码残缺过程，如下：
const mqtt = require('aliyun-iot-mqtt');
var options = {
productKey: "xxxxx",
deviceName: "xxxx",
deviceSecret: "xxxxxxxx",
host: "iot-cn-xxxxx.mqtt.iothub.aliyuncs.com"
};
// 1. 建设连贯
const client = mqtt.getAliyunIotMqttClient(options);
// 2. 监听云端指令
client.subscribe(`/${options.productKey}/${options.deviceName}/user/config`)
client.on('message', function(topic, message) {console.log("topic" + topic)
console.log("message" + message)
})
setInterval(function() {
// 3. 上报车厢数据
client.publish(`/${options.productKey}/${options.deviceName}/user/data/post`, getPostData(), { qos: 0});
}, 1000);
function getPostData() {
const payloadJson = {temperature: Math.floor((Math.random() * 20) + 10),
humidity: Math.floor((Math.random() * 20) + 10),
speed: Math.floor((Math.random() * 20) + 30),
}
console.log("payloadJson" + JSON.stringify(payloadJson))
return JSON.stringify(payloadJson);
}4.服务端 AMQP 订阅
实例化下 AMQP 的接入域名：
业务服务器与 IoT 物联网平台建设 AMQP 长连贯：
public static void main(String[] args) throws Exception {
// 参数阐明
long timeStamp = System.currentTimeMillis();
// 签名办法：反对 hmacmd5，hmacsha1 和 hmacsha256
String signMethod = "hmacsha1";
// 控制台服务端订阅中生产组状态页客户端 ID 一栏将显示 clientId 参数。// 倡议应用机器 UUID、MAC 地址、IP 等惟一标识等作为 clientId。便于您辨别辨认不同的客户端。String clientId = "ecs_"+System.currentTimeMillis();
//UserName 组装办法，请参见上一篇文档：AMQP 客户端接入阐明。String userName = clientId + "|authMode=aksign"
+ ",signMethod=" + signMethod
+ ",timestamp=" + timeStamp
+ ",authId=" + accessKey
+ ",iotInstanceId=" + iotInstanceId
+ ",consumerGroupId=" + consumerGroupId
+ "|";
//password 组装办法，请参见上一篇文档：AMQP 客户端接入阐明。String signContent = "authId=" + accessKey + "×tamp=" + timeStamp;
String password = doSign(signContent,accessSecret, signMethod);
// 依照 qpid-jms 的标准，组装连贯 URL。String connectionUrl = "failover:(amqps://"+iotInstanceId+".amqp.iothub.aliyuncs.com:5671?amqp.idleTimeout=80000)"
+ "?failover.reconnectDelay=30";
Hashtable<String, String> hashtable = new Hashtable<>();
hashtable.put("connectionfactory.SBCF",connectionUrl);
hashtable.put("queue.QUEUE", "default");
hashtable.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.qpid.jms.jndi.JmsInitialContextFactory");
Context context = new InitialContext(hashtable);
ConnectionFactory cf = (ConnectionFactory)context.lookup("SBCF");
Destination queue = (Destination)context.lookup("QUEUE");
// Create Connection
Connection connection = cf.createConnection(userName, password);
((JmsConnection) connection).addConnectionListener(myJmsConnectionListener);
// Create Session
// Session.CLIENT_ACKNOWLEDGE: 收到音讯后，须要手动调用 message.acknowledge()
// Session.AUTO_ACKNOWLEDGE: SDK 主动 ACK（举荐）Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
connection.start();
// Create Receiver Link
MessageConsumer consumer = session.createConsumer(queue);
consumer.setMessageListener(messageListener);
}回调中解决接管的数据
private static MessageListener messageListener = new MessageListener() {
@Override
public void onMessage(Message message) {
try {byte[] body = message.getBody(byte[].class);
String content = new String(body);
String topic = message.getStringProperty("topic");
String messageId = message.getStringProperty("messageId");
String tag = message.getStringProperty("tag");
logger.info("receive message"
+ ",\n topic =" + topic
+ ",\n messageId =" + messageId
+ ",\n tag =" + tag
+ ",\n content =" + content
+"\n");
System.out.println();
// 如果创立 Session 抉择的是 Session.CLIENT_ACKNOWLEDGE，这里须要手动 ACK。message.acknowledge();
// 如果要对收到的音讯做耗时的解决，请异步解决，确保这里不要有耗时逻辑。} catch (Exception e) {e.printStackTrace();
}
}
};调用云端 API 上行指令：
实例化下的云端 API 接入域名：
调用代码参考：
public static void main(String[] args) {IClientProfile profile = DefaultProfile.getProfile("cn-shenzhen", accessKey, accessKeySecret);
IAcsClient client = new DefaultAcsClient(profile);
PubRequest request = new PubRequest();
request.setSysEndpoint("iot.cn-shenzhen.aliyuncs.com");
request.setTopicFullName("/xxxxx/xxxxxx/user/config");
request.setMessageContent("Q01ELDgyOTIzLGFkMzIyCiA=");// 原始报文 : CMD,82923,ad322
request.setProductKey("xxxxx");
request.setIotInstanceId(iotInstanceId);
request.setQos(1);
try {PubResponse response = client.getAcsResponse(request);
System.out.println(new Gson().toJson(response));
} catch (ClientException e) {System.out.println("ErrCode:" + e.getErrCode());
System.out.println("ErrMsg:" + e.getErrMsg());
System.out.println("RequestId:" + e.getRequestId());
}
}设施联机运行
5. 设施上报业务数据
启动 Nodejs 设施模仿脚本后，IoT 物联网平台的控制台，设施状态变成在线。
业务服务器 AMQP 回调，打印出设施上报数据信息，如下图：
日志服务能看到残缺的上行数据流转链路，如下图：
服务端订阅生产组详情，如下图：
6.云端上行控制指令
业务服务器调用 Pub 接口，上行控制指令，如下图：
设施端打印进去，接管到的云端指令：
日志服务能看到残缺的上行数据链路，如下图：
至此，咱们通过一个冷链运输追踪器的案例，体验了华南 1（深圳）节点的 IoT 设施接入，数据上行，云端指令上行的全过程。
【往期回顾】
1. 自建 MQTT 集群迁徙阿里云 IoT 平台
2.IoT 时代：WiFi 配网技术分析
3. 微信小程序和 IoT 智能家居实际
4.IoT 云端通用数据解析脚本实际
物联网平台产品介绍详情：https://www.aliyun.com/produc…
阿里云物联网平台客户交换群