Select Git revision
Code owners
Assign users and groups as approvers for specific file changes. Learn more.
server.js 650 B
const mqtt = require("mqtt");
const ws = require ("ws");
let socketserver = new ws.WebSocketServer({
port: 443
});
let client = mqtt.connect("mqtt://localhost:1883",{
username: "standardUser",
password: "GreatHHZ4Ever!"
});
client.on("connect", function() {
let topicID = "Topic1";
client.subscribe(topicID);
});
socketserver.on('connection', ws => {
console.log("new client connected");
});
socketserver.on('close', () => console.log('Client has disconnected!'));
client.on("message", function(topic, message){
socketserver.clients.forEach(client => {
client.send(message.toString());
})});