Skip to content
Snippets Groups Projects
Select Git revision
  • 7e8a93f764a744f524c5330200133585cb83c8ef
  • main default protected
  • minikube-fresh-start
3 results

App.vue

Blame
  • 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());
    })});