const cloud = require('wx-server-sdk')
var utils=require(('mqtt.min.js'))
cloud.init({ env: cloud.DYNAMIC_CURRENT_ENV }) // 使用当前云环境
let client=null
// 云函数入口函数
exports.main = async (event, context) => {
const options = {
clean: true, // true: 清除会话, false: 保留会话
connectTimeout: 4000, // 超时时间
// 认证信息
clientId: 'emqx_test',
}
const connectUrl = 'wxs://broker.emqx.io:8084/mqtt'
const client = await utils.connect(connectUrl, options)
// client.subscribe('testtg');
// console.log(client)
// client.on('message', (topic, message) => {
// console.log('收到消息:', topic, message.toString())
// })
return utils
}
请问那位大哥能帮帮
相似问题