1

1

src/index.js

@@ -8,10 +8,16 @@ let client  = mqtt.connect({
 
 client.on('connect', function () {
     console.log("connect");
-    client.subscribe('TDL/#');
+    client.subscribe('GW/000000000006/#');
 });
 
 client.on('message', function (topic, message) {
-    console.log(topic);
-    console.log(message.toString())
-});
+    console.log(time()+":"+topic);
+    console.log(time()+"buffer:"+message)
+    console.log(time()+":"+message.toString())
\ No newline at end of file
+});
+
+function time(){
+    let t = new Date();
+    return t+" "+t.getTime();
+}
\ No newline at end of file

src/publish.js

+const mqtt = require('mqtt')
+let client  = mqtt.connect({
+    host: '120.27.235.39',
+    port: 1883,
+    username:'ugen',
+    password:'ugen'
+});
+
+client.on('connect', function () {
+    console.log("connect");
+    client.publish('GW/000000000006/Config',JSON.stringify({"action":"config","devList":["CC78AB004072"]}));
+});
\ No newline at end of file

test/test.js

@@ -10,7 +10,7 @@ describe('test', function () {
     });
 
     it("test1",(done)=>{
-        assert(51===51,"e");
+        assert(511===511,"e");
         done();
     });