aedes-server-factory

import Aedes from 'aedes'; import { createServer } from 'aedes-server-factory'; import { createServer as createHttpServer } from 'http'; const aedes = Aedes(); // Create a basic TCP MQTT server const tcpServer = createServer(aedes); tcpServer.listen(1883, () => { console.log('Aedes TCP server listening on port 1883'); }); // Create an HTTP server and bind it for WebSockets const httpServer = createHttpServer(); const wsServer = createServer(aedes, { ws: true, http: httpServer }); httpServer.listen(8080, () => { console.log('Aedes HTTP/WS server listening on port 8080'); }); // Handle cleanup on process exit process.on('SIGTERM', () => { console.log('Shutting down Aedes servers...'); tcpServer.close(() => console.log('TCP server closed.')); wsServer.close(() => console.log('HTTP/WS server closed.')); aedes.close(() => console.log('Aedes broker closed.')); });