Usage no npm install needed!

<script type="module">
  import socketIoEmqx from 'https://cdn.skypack.dev/socket.io-emqx';
</script>

README

Socket.io-emqx

A adapter for socket.io support using Emqx broker.

Homepage:

https://www.emqx.io/
https://socket.io/

Work fine on version emqx/emqx:v3.0.0

Install

$ npm install --save socket.io-emqx

Usage

const adapter = require('socket.io-emqx');
const MQTT_CONNECT = 'mqtt://emqx-worker:1883';


var app = require('express')();
var server = require('http').Server(app);
var io = require('socket.io')(server);

io.adapter(adapter(MQTT_CONNECT, {key: 'chat.socket.io', keepalive: 1, reconnectPeriod: 5000}));

Work fine for Docker Swarm Cluster

alt text

That's it!