|
@@ -1488,12 +1488,14 @@
|
|
|
}
|
|
|
let url = mqttInfo.connectInfo.brokerHostNameWSS
|
|
|
let client = this.$mqtt.connect(url, options)
|
|
|
+ let thetopic = localStorage.getItem('deveceId') + mqttInfo.subscribeTopic.receiveDirectMethod
|
|
|
+ console.log(thetopic,'教师端订阅的主题')
|
|
|
that.client = client
|
|
|
client.on('connect', function () {
|
|
|
console.log('连接服务器成功111')
|
|
|
// 订阅主题,替换productKey和deviceName
|
|
|
that.info = '连接服务器成功'
|
|
|
- client.subscribe(mqttInfo.subscribeTopic.receiveDirectMethod, function (err) {
|
|
|
+ client.subscribe(thetopic, function (err) {
|
|
|
if (!err) {
|
|
|
console.log('主题订阅成功2222')
|
|
|
that.$Message.success('通讯连接成功!')
|
|
@@ -1503,7 +1505,6 @@
|
|
|
}
|
|
|
})
|
|
|
client.on('message', function (topic, message) {
|
|
|
-
|
|
|
// message is Buffer
|
|
|
console.log('收到消息 主题:' + topic + ' 消息:' + message.toString() + '内容是:' + message)
|
|
|
// localStorage.setItem('irsBack',message);
|