1.添加mqtt服务。2.修改coap插件

CoAP/client.js

+// coap_client.js
+const coap = require('coap'); // 引入 coap 模块
+const req = coap.request('coap://localhost');
+
+req.on('response', (res) => {
+  res.pipe(process.stdout); // 输出响应内容
+  res.on('end', () => process.exit(0));
+});
+
+req.end(); // 发送请求
+
+
+

CoAP/server.js

+// coap_server.js
+const coap = require('coap');
+const server = coap.createServer();
+
+server.on('request', (req, res) => {
+  console.log(`Received ${req.method} request on ${req.url}`);
+
+  console.log("method:",req.method);
+
+ if (req.method === 'POST') {
+    let payload = {data:"123"};
+    req.on('data', chunk => {
+      payload += chunk;
+    });
+    req.on('end', () => {
+      console.log('Payload:', payload);
+      res.end('POST received with payload: ' + payload);
+    });
+  } else {
+    res.end('Only POST is supported in this example.');
+  }
+});
+
+server.listen(() => {
+  console.log('CoAP server listening on port 5683...');
+});
+

main.js

@@ -150,7 +150,13 @@ const nodeRedProcess = spawn('node', ['main.js', '-c=config.js'], {
   stdio: 'inherit' // 可选：继承父进程的输入输出
 });
 
+//启动mqtt服务
+const mqttTargetDir = path.join(__dirname, 'mqtt');
 
+const mqttNodeRedProcess = spawn('node', ['mqtt.js'], {
+  cwd: mqttTargetDir, // 关键参数
+  stdio: 'inherit' // 可选：继承父进程的输入输出
+});
 /*
 nodeRedProcess.stdout.on('data', (data) => {
   console.log(`Node-RED输出: ${data}`);

mqtt/mqtt.js

+const aedes = require('aedes')();
+const server = require('net').createServer(aedes.handle);
+const PORT = 10883;
+
+server.listen(PORT, function () {
+  console.log(`MQTT server is running on port ${PORT}`);
+});
+
+aedes.on('client', (client) => {
+  console.log(`Client Connected: ${client.id}`);
+});
+
+aedes.on('clientDisconnect', (client) => {
+  console.log(`Client Disconnected: ${client.id}`);
+});
+
+aedes.on('publish', (packet, client) => {
+  console.log(`Message Published: ${packet.payload.toString()}`);
+});

nr/database/entity/5a7e757d-14e6-4e52-98fb-029d30fe6e35/.config.users.json

@@ -25,6 +25,16 @@
         "menu-menu-item-sidebar": true,
         "menu-deploymenu-item-flow": false,
         "menu-deploymenu-item-full": true,
-        "menu-deploymenu-item-node": false
+        "menu-deploymenu-item-node": false,
+        "debug": {
+            "filter": "filterAll",
+            "filteredNodes": [
+                "c24cc8c42d8363c8",
+                "ebf4104ff1d325fd",
+                "b1cc61ff14b43511",
+                "63bac2c98fb58711",
+                "91e4e21768b60e69"
+            ]
+        }
     }
 }
\ No newline at end of file

nr/database/entity/5a7e757d-14e6-4e52-98fb-029d30fe6e35/.config.users.json.backup

@@ -25,6 +25,16 @@
         "menu-menu-item-sidebar": false,
         "menu-deploymenu-item-flow": false,
         "menu-deploymenu-item-full": true,
-        "menu-deploymenu-item-node": false
+        "menu-deploymenu-item-node": false,
+        "debug": {
+            "filter": "filterAll",
+            "filteredNodes": [
+                "c24cc8c42d8363c8",
+                "ebf4104ff1d325fd",
+                "b1cc61ff14b43511",
+                "63bac2c98fb58711",
+                "91e4e21768b60e69"
+            ]
+        }
     }
 }
\ No newline at end of file

nr/database/entity/5a7e757d-14e6-4e52-98fb-029d30fe6e35/.flows_cred.json.backup

 {
-    "$": "cde32bc9c067e7a0f724a3ba7baea3b8xmgVKHFMKkoyF1s3k98bgj54SiYLTNc="
+    "$": "12ee322ac6282cf7980513eba07951e8Rc40ePOG+3odVSGAjKHviiNBfSXB3EIkDIqLm71E3oOfHkwVoSNI2I+eq2vgaXx+PNHKJT6ooQg="
 }
\ No newline at end of file

nr/database/entity/5a7e757d-14e6-4e52-98fb-029d30fe6e35/flows_cred.json

 {
-    "$": "305dfbb3c73cfb86307e63aa77392295K3xgBrlhAHrz1FLLJ8M3KSV9JI4xMHDMTCj3VtTFNIlXnxXRbicJ3+co4ieU"
+    "$": "efce33599da4441dbcdde6320ec1e1eftUA="
 }
\ No newline at end of file

nr/node-red/packages/node_modules/@node-red/editor-client/public/red/red.min.js

@@ -105,7 +105,7 @@ jQuery.propHooks.disabled = {
 * limitations under the License.
 **/
 
-const HOST_IP = "http://192.168.0.168:8082";
+const HOST_IP = "http://192.168.0.82:8082";
 
 var RED = (function() {
 

nr/token.json

-{"testTaskId":"1923190422843166720","host":"http://192.168.0.82:8085","token":"Bearer eyJhbGciOiJIUzI1NiJ9.eyJzZXNzaW9uSWQiOiJhZG1pbl80XzY0NDk2YjQwNDAwOTRlOGU4M2I5MWUxNTQwNWJiYWZlIiwiQ3JlYXRlZFRpbWUiOjE3NDczNjEzMDU1ODcsImV4cCI6MTc0Nzk2NjEwNX0.MdCPmr8t3zk4lGSi51OLEfpY_W1-xnlZ72C1OT1OFOI"}
+{"testTaskId":"1929900489378369536","host":"http://192.168.0.82:8082","token":"Bearer eyJhbGciOiJIUzI1NiJ9.eyJzZXNzaW9uSWQiOiJhZG1pbl80XzU0YmMwN2U0N2NkZTQwNzJhZWQyNWRiOTM1MmEyYzg1IiwiQ3JlYXRlZFRpbWUiOjE3NDg5NTkwNTEzNzIsImV4cCI6MTc0OTU2Mzg1MX0.bU1jeVrCs0kpMNgWvtpSeHuajiKKUlBvrJ9srLxTRGk"}

package.json

@@ -62,15 +62,18 @@
   },
   "dependencies": {
     "@gulpjs/to-absolute-glob": "^4.0.0",
+    "aedes": "^0.51.3",
     "anymatch": "^3.1.3",
     "async": "^3.2.4",
     "child_process": "^1.0.2",
+    "coap": "^1.4.1",
     "core-js": "^3.32.0",
     "electron-prompt": "^1.7.0",
     "electron-squirrel-startup": "^1.0.0",
     "electron-store": "^8.1.0",
     "glob-stream": "^8.0.0",
     "is-negated-glob": "^1.0.0",
+    "mqtt": "^5.13.0",
     "node-record-lpcm16": "^1.0.1",
     "normalize-path": "^3.0.0",
     "ps-tree": "^1.2.0",