复用原有 /status/ask 与 /status/reply 两个topic,并改为加密传输 /status/ask 内容格式如下: { messageId: string, timestamp: string, functionKey: string, data: string // 格式根据functionKey决定 } /status/reply 内容格式如下: { messageId: string, // 对应ask的id timestamp: string, functionKey: string, // 对应ask code: int, // 执行结果,0为成功,若为非0时,data直接为失败描述,例如 { ..., code: -1, data: "未知异常" } data: string // 根据code与functionKey决定 } data为json格式的字符串,需进行解析 onMessage (topic, message) { const result = topic.match(/^(\d+)\/(\d+)\/status\/reply$/) if (result) { const { productId, id } = this.device if (productId === result[1] && id === result[2]) { debugger message = JSON.parse(message) // 处理回调 // todo } } }, 得到的message为"{"status":1,"programUrl":"","lastCommand":"1647860970304884737\/1654313899182313473\/multifunctionCard\/invoke"}" 使用mqtt协议,后续处理的代码怎么写,请具体写出
时间: 2024-03-01 19:52:52 浏览: 53
DS26900:JTAG复用器/开关
在处理回调数据时,需要将收到的加密消息进行解密,并根据消息中的字段进行相应的处理。以下是一个示例代码:
```
const { encrypt, decrypt } = require('crypto-js'); // 引入加密库
onMessage(topic, message) {
const result = topic.match(/^(\d+)\/(\d+)\/status\/reply$/);
if (result) {
const { productId, id } = this.device;
if (productId === result[1] && id === result[2]) {
const decryptedMessage = decrypt(message, 'secret-key').toString(enc.Utf8); // 解密消息
const { messageId, timestamp, functionKey, code, data } = JSON.parse(decryptedMessage); // 解析消息
// 处理回调数据
if (code === 0) {
// 执行成功
switch (functionKey) {
case 'function1':
// 处理 function1 的结果
// ...
break;
case 'function2':
// 处理 function2 的结果
// ...
break;
// 处理其他功能键的结果
default:
// ...
}
} else {
// 执行失败,根据 code 和 data 进行相应的处理
// ...
}
}
}
}
```
在这个示例中,首先使用加密库进行解密,得到原始的 JSON 格式的消息。然后,通过解析消息中的字段,获取消息的相关信息,例如消息 ID、时间戳、功能键、执行结果和数据等。在处理回调数据时,根据执行结果的 code 值,判断执行成功还是失败,并根据功能键进行相应的处理。如果执行失败,可以根据 code 和 data 进行相应的处理。注意,这个示例代码中的密钥为 "secret-key",需要根据实际情况进行修改。
阅读全文