// mqtt module import mqtt from 'mqtt'const CONNECT_MQTT = 'CONNECT_MQTT'const SERVER_IP = '' const SERVER_PORT = '' const SERVER_PATH = 'mqtt' // 连接地址 const SERVICE = `${SERVER_IP}:${SERVER_PORT}/${SERVER_PATH}`// 连接配置项 const options = {wsOptions: {},protocolVersion: 4, //MQTT连接协议版本keepalive: 60,clean: true,clientId: CLIENT_ID,reconnectPeriod: 1000, //1000毫秒，两次重新连接之间的间隔connectTimeout: 30 * 1000,resubscribe: true ,//如果连接断开并重新连接，则会再次自动订阅已订阅的主题（默认true） }const state = () => ({ mqttClient: null })const actions = {[CONNECT_MQTT]({ commit, state }) {// 连接mqtt 监听常用事件let client = mqtt.connect('wx://' + service + options)client.on('connect', () => {}).on('error', () => {}).on('reconnect', () => {}).on('message', () => {}).on('close', () => {})commit(CONNECT_MQTT, client)} }const mutations = {[CONNECT_MQTT](state, client) {state.mqttClient = client } }