javascript - 如何使用 ngx-mqtt 库在 angular 6 中创建多个连接？

Question

我需要从同一个 Angular 6 应用程序连接到多个代理。

导入 MqttModule 时，我们将配置传递给它:

imports: [...
MqttModule.forRoot(MQTT_SERVICE_OPTIONS),
...]

我尝试在同一层级创建 2 个独立的模块并传递不同的配置并设置连接，但它不起作用。

我认为它在根级别创建服务，我们不能在不同模块中创建单独的连接。

我们甚至可以创建多个连接吗？如果是，怎么办？

Answer 1

我尝试了很多东西，但唯一对我有用的是低于(Angular 8)

在你的项目中安装以下命令

npm i buffer --save

npm i -S process

npm i mqtt --save

在 polyfills.js 末尾添加以下行

(window as any)['global'] = window;
global.Buffer = global.Buffer || require('buffer').Buffer;

import * as process from 'process';
window['process'] = process;

将以下代码添加到您的app.component.ts

import { Component } from '@angular/core';
import * as mqttt from "mqtt";

@Component({
  selector: 'app-root',
  templateUrl: './app.component.html',
  styleUrls: ['./app.component.css']
})
export class AppComponent {
  title = 'checkMqttFromWeb';
  constructor(){
    var client = mqttt.connect('mqtt://192.168.0.29:1884')
    client.on('connect', function () {
      client.subscribe('fooBar', function (err) {
        if (!err) {
          client.publish('fooBar', 'Hello mqtt')
        }
      })
    })

    client.on('message', function (topic, message) {
      // message is Buffer
      console.log(message.toString())
      client.end()
    })
  }
}

现在使用 ng serve 运行您的应用希望一切顺利