最新消息:雨落星辰是一个专注网站SEO优化、网站SEO诊断、搜索引擎研究、网络营销推广、网站策划运营及站长类的自媒体原创博客

javascript - MQTT.js - How to handle connection errors? - Stack Overflow

programmeradmin2浏览0评论

I have difficulties detecting connection errors with MQTT.js.

I'm trying to use it in an Angular service and connecting and municating with the server seems to work fine when the server is running but client.on('error', ...) never fires.

I managed to detect errors when connecting by attaching the error callback to client.stream instead, but stream seems to be a private property since it isn't exposed in the official TypeScript definitions, so not sure if this really is the correct way to go.

But what I still don't get to work are errors when the connection is lost, none of the error handlers fire. Instead the browser console logs unhandled websocket errors.

Sample code:

import { Injectable } from '@angular/core';
import { connect, MqttClient } from 'mqtt';
import * as msgpack5 from 'msgpack5';
import { environment } from '../../environments/environment';

@Injectable()
export class MqttService {

  private client: MqttClient;
  private msgpack: msgpack5.MessagePack;

  constructor() {
    this.msgpack = msgpack5();

    this.client = connect(`ws://${environment.host}:8001/mqtt`);

    this.client.on('connect', () => {
      console.log('connected');
      this.client.subscribe('foo');
    });

    this.client['stream'].on('error', (error) => {
      // fires when connection can't be established
      // but not when an established connection is lost
      console.log('stream', error);
      this.client.end();
    });

    this.client.on('error', (error) => {
      console.log('client', error); // never fires
    });

    this.client.on('message', (topic, payload) => {
      console.log(topic, this.msgpack.decode(payload));
    });
  }
}

I have difficulties detecting connection errors with MQTT.js.

I'm trying to use it in an Angular service and connecting and municating with the server seems to work fine when the server is running but client.on('error', ...) never fires.

I managed to detect errors when connecting by attaching the error callback to client.stream instead, but stream seems to be a private property since it isn't exposed in the official TypeScript definitions, so not sure if this really is the correct way to go.

But what I still don't get to work are errors when the connection is lost, none of the error handlers fire. Instead the browser console logs unhandled websocket errors.

Sample code:

import { Injectable } from '@angular/core';
import { connect, MqttClient } from 'mqtt';
import * as msgpack5 from 'msgpack5';
import { environment } from '../../environments/environment';

@Injectable()
export class MqttService {

  private client: MqttClient;
  private msgpack: msgpack5.MessagePack;

  constructor() {
    this.msgpack = msgpack5();

    this.client = connect(`ws://${environment.host}:8001/mqtt`);

    this.client.on('connect', () => {
      console.log('connected');
      this.client.subscribe('foo');
    });

    this.client['stream'].on('error', (error) => {
      // fires when connection can't be established
      // but not when an established connection is lost
      console.log('stream', error);
      this.client.end();
    });

    this.client.on('error', (error) => {
      console.log('client', error); // never fires
    });

    this.client.on('message', (topic, payload) => {
      console.log(topic, this.msgpack.decode(payload));
    });
  }
}
Share Improve this question edited Mar 21, 2018 at 18:04 Tao asked Mar 21, 2018 at 17:59 TaoTao 2,24016 silver badges15 bronze badges
Add a ment  | 

1 Answer 1

Reset to default 7

I had a very similar issue with client.on('error'.. didnt trigger on WebSocket connection error, the solution was:

client.stream.on('error', (err) => { console.log('error', err); client.end() });

发布评论

评论列表(0)

  1. 暂无评论