guoshilong
2023-09-11 11433d0f47eae3403e883fc26d72269b930235f2
src/mqtt/index.ts
@@ -34,10 +34,13 @@
      ...OPTIONS,
      ...this._options,
    })
    console.log(this._client, 'client')
    this._hasInit = true
    if (this._client) {
      this._client.on('reconnect', this._onReconnect)
      this._client.on('connect', () => {
        console.log('connect')
      })
      // 消息监听
      this._client.on('message', this._onMessage)