增加模拟器

simulator/scripts/demo-device.js

@@ -0,0 +1,63 @@
+/**
+ * 烟感设备模拟器
+ */
+var _logger = logger;
+//设备实例id前缀
+var devicePrefix = "demo-";
+
+var eventId = Math.ceil(Math.random() * 1000);
+//事件类型
+var events = {
+    reportProperty: function (index, session) {
+        var deviceId = devicePrefix + index;
+        var topic = "/report-property";
+        var json =    JSON.stringify({
+            "deviceId": deviceId,
+            "success": true,
+            "timestamp":new Date().getTime(),
+            properties: {"temperature": java.util.concurrent.ThreadLocalRandom.current().nextInt(20, 30)},
+        });
+        session.sendMessage(topic, json)
+    },
+    fireAlarm: function (index, session) {
+        var deviceId = devicePrefix + index;
+        var topic = "/fire_alarm/department/1/area/1/dev/" + deviceId;
+        var json =    JSON.stringify({
+            "deviceId": deviceId, // 设备编号 "pid": "TBS-110", // 设备编号
+            "a_name": "商务大厦", // 区域名称 "bid": 2, // 建筑 ID
+            "b_name": "C2 栋", // 建筑名称
+            "l_name": "12-05-201", // 位置名称
+            "timestamp": new Date().getTime() // 消息时间
+        });
+
+        session.sendMessage(topic,json )
+    }
+};
+
+//事件上报
+simulator.onEvent(function (index, session) {
+    events.reportProperty(index, session);
+    events.fireAlarm(index,session);
+});
+
+simulator.bindHandler("/read-property", function (message, session) {
+    session.sendMessage("/read-property-reply", JSON.stringify({
+        messageId: message.messageId,
+        deviceId: message.deviceId,
+        timestamp: new Date().getTime(),
+        properties: {"temperature": java.util.concurrent.ThreadLocalRandom.current().nextInt(20, 30)},
+        success: true
+    }));
+});
+
+
+simulator.onConnect(function (session) {
+    _logger.info("[{}]:连接成功", session.auth.clientId);
+});
+
+simulator.onAuth(function (index, auth) {
+
+    auth.setClientId(devicePrefix + index);
+    auth.setUsername("admin");
+    auth.setPassword("admin");
+});

simulator/start.sh

@@ -0,0 +1,11 @@
+#!/usr/bin/env bash
+
+java -jar device-simulator.jar \
+  mqtt.limit=1 \
+  mqtt.start=0 \
+  mqtt.enableEvent=true \
+  mqtt.eventLimit=1 \
+  mqtt.eventRate=1000 \
+  mqtt.scriptFile=./scripts/demo-device.js \
+  mqtt.address=127.0.0.1 \
+  mqtt.port=1889