106 lines
2.4 KiB
JavaScript
106 lines
2.4 KiB
JavaScript
|
import mqtt from "mqtt/dist/mqtt"
|
|||
|
|
// import mqtt from "@/store/modules/mqtt.js"
|
|||
|
|
import store from "@/store"
|
|||
|
|
|
|||
|
|
//封装一个类（可直接cv）
|
|||
|
|
class MqttUtil {
|
|||
|
|
//创建公共变量
|
|||
|
|
static url //mqtt地址
|
|||
|
|
static userId //userId
|
|||
|
|
static clientId //clientId
|
|||
|
|
static options //clientId
|
|||
|
|
static client = null; //mqtt公共变量
|
|||
|
|
|
|||
|
|
//接收创建来的数据
|
|||
|
|
constructor() {
|
|||
|
|
this.url = import.meta.env.VITE_BASE_MQTT;
|
|||
|
|
// this.userId = store.state.user.user.userId;
|
|||
|
|
this.clientId = "mqtt_app_" + this.getUUID();
|
|||
|
|
|
|||
|
|
this.options = {
|
|||
|
|
qos: 1, //QoS 级别
|
|||
|
|
clean: false, // true: 清除会话, false: 保留会话
|
|||
|
|
connectTimeout: 3000, // 超时时间
|
|||
|
|
keepAlive: 60,
|
|||
|
|
username: "app_client",
|
|||
|
|
password: "app_client@2023",
|
|||
|
|
clientId: this.clientId
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//mqtt链接
|
|||
|
|
link() {
|
|||
|
|
if (this.client == null || this.client.connented == false) {
|
|||
|
|
let client = mqtt.connect(this.url, this.options);
|
|||
|
|
if (this.client == null) {
|
|||
|
|
this.client = client;
|
|||
|
|
|
|||
|
|
this.client.on("connect", error => {
|
|||
|
|
console.log("connect")
|
|||
|
|
})
|
|||
|
|
this.client.on("error", error => {
|
|||
|
|
console.log("error")
|
|||
|
|
})
|
|||
|
|
this.client.on("reconnect", error => {
|
|||
|
|
console.log("reconnect")
|
|||
|
|
})
|
|||
|
|
this.client.on("message", (topic, message) => {
|
|||
|
|
console.log("message：", message.toString())
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
//重新连接
|
|||
|
|
reconnect() {
|
|||
|
|
if (this.client.connected) {
|
|||
|
|
this.client.end(); // 关闭当前连接
|
|||
|
|
}
|
|||
|
|
this.client.connect(this.options); // 重新连接
|
|||
|
|
}
|
|||
|
|
//结束链接
|
|||
|
|
over() {
|
|||
|
|
this.client.end();
|
|||
|
|
this.client = null;
|
|||
|
|
}
|
|||
|
|
//订阅主题
|
|||
|
|
subscribes(topic) {
|
|||
|
|
this.client.subscribe(topic, error => {
|
|||
|
|
if (error) {
|
|||
|
|
console.error(`订阅主题失败:`, error)
|
|||
|
|
} else {
|
|||
|
|
console.log(`订阅主题成功`)
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
//取消订阅
|
|||
|
|
unsubscribes(topic) {
|
|||
|
|
this.client.unsubscribe(topic, error => {
|
|||
|
|
if (!error) {
|
|||
|
|
console.log("取消订阅成功")
|
|||
|
|
} else {
|
|||
|
|
console.log("取消订阅错误", topic)
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
//收到的消息
|
|||
|
|
get() {
|
|||
|
|
this.mqtt.client.on("message", (topic, message) => {
|
|||
|
|
console.log("接受消息")
|
|||
|
|
console.log("message：", message.toString())
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
//发送消息
|
|||
|
|
send(message) {
|
|||
|
|
this.client.publish("test", JSON.stringify(message), res => {
|
|||
|
|
console.log(res)
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
getUUID() {
|
|||
|
|
function S4() {
|
|||
|
|
return (((1 + Math.random()) * 0x10000) | 0).toString(16).substring(1);
|
|||
|
|
}
|
|||
|
|
return (S4() + S4() + "-" + S4() + "-" + S4() + "-" + S4() + "-" + S4() + S4() + S4());
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
export default MqttUtil
|