Erstellen Sie eine Liste der Verbundenen Clients über socket.io

Hier sind 2 Fragen. Buchen Sie zusammen, macht mehr Sinn.

Frage 1

Habe ich eine node.js app, die sendet ein Ereignis an alle clients und alle aktuellen Kunden reagieren mit einem ready emittieren. Wie kann ich erstellen Sie eine Liste aller clients, antwortete der erste emittieren, und welche Art von Kennzeichnung verwendet werden können, unterscheiden sich die Kunden?

Question2:

Was ich versuche zu tun, nach dem sammeln eine Liste der verbundenen clients, um dann den Zugriff auf eine MySQL-Datenbank-Tabelle N Anzahl der Zeilen und weisen Sie jeden client X Zeilen jeweils. Diese Zeilen ausgestoßen werden, zurück zu Ihren jeweiligen Kunden. Wie kann das getan werden?

Aktuellen Code für Qn 1

Knoten Code

setInterval(function() {
    util.log('Checking for new jobs...');
    dbCheckQueue(function(results) {  //checks if there are new rows to "distribute" to clients
        if (results.length) {
            util.log(results.length + ' new jobs found.');
            io.sockets.emit('job_available');
        }
    });
}, 10*1000);

Client-Seite JS-Code

socket.on('job_available', function() {
                console.log('Job Available.. Responding with Ready!');
                socket.emit('ready');
            });

io.sockets.on('connection', function(socket) {
    socket.on('ready', function() {
        //UPDATE N rows with client_id in column checkout.
        //Then SELECTS * from table where checkout = client_id
        getListings(client_id, function(listings) {
            socket.emit('job', listings);   //send jobs
        });
    });
});

Aktuellen Code für Qn 2
Der code funktioniert für einen einzelnen client, aber wie mache ich eine Schleife durch alle angeschlossenen clients, und führen Sie die gleiche Aktualisierung der Spalte und die Auswahl der Zeilen?

io.sockets.on('connection', function(socket) {
    socket.on('ready', function() {
        //UPDATE N rows with client_id in column checkout.
        //Then SELECTS * from table where checkout = client_id
        getListings(client_id, function(listings) {
            socket.emit('job', listings);   //send jobs
        });
    });
});
InformationsquelleAutor Nyxynyx | 2011-11-27
  1. 16

    Müssen Sie zu verfolgen die angeschlossenen clients selbst. Der einfache Weg zu tun wäre, um ein array zu verwenden:

    var clients = [];

io.sockets.on('connect', function(client) {
    clients.push(client); 

    client.on('disconnect', function() {
        clients.splice(clients.indexOf(client), 1);
    });
});

    Dann können Sie Referenzen, die clients array auf dem server, wohin Sie müssen, in Ihre ready event-handler oder was auch immer. So etwas wie:

    io.sockets.on('connection', function(socket) {
    socket.on('ready', function() {
        //UPDATE N rows with client_id in column checkout.
        //Then SELECTS * from table where checkout = client_id
        clients.forEach(function(client, index) {
            var client_id = index; //Just use the index in the clients array for now
            getListings(client_id, function(listings) {
                socket.emit('job', listings);   //send jobs
            });
        });
    });
});
    • könnten Sie proevide die Logik einer getListings () - Funktion, da ich die Anwendung smiliar Lösung, aber ich sehe auf dem Bildschirm auf den Namen einer der ersten angemeldeten user.
    • Die getListings nennen, ist nur Beispielcode, zog ich aus der ursprünglichen Frage. Ich habe keine Ahnung, was es enthält, oder wie es implementiert ist.
    • Ich sehe, weil ich bin die Speicherung von clients im array und wenn ich versuche, rufen Sie mit der hepl von foreach oder for Schleifen ich einfach nur die ersten angemeldeten client den Benutzernamen im browser.
    InformationsquelleAutor rossipedia
  2. 20

    Buchse.io bietet Ihnen eine öffentliche api, so dass statt des Hackens etwas wie Bryan schlage vor, Sie verwenden können:

    io.sockets.clients()

    Wird, gibt ein array zurück, der alle verbundenen clients.

    Wenn Sie möchten, dass alle angeschlossenen clients zu einem bestimmten Namensraum:

    io.of('/namespace').clients()

    Aber Sie können auch filter es sogar noch mehr.. wenn Sie wollen, um alle Steckdosen in einem Raum:

    io.sockets.clients('room name here as first argument')

    Zurückkehren wird eine Reihe von verbundenen buchsen für den Raum room name here as first argument

    • Dank 3rdEden, die ich verwendet, Bryan Lösung mit geringfügigen änderungen, weil ich will nur die angeschlossenen clients, antwortete mit einem ready Nachricht geschoben werden, in ein array. Können die API verwenden, tun etwas, das in einer anderen Art und Weise?
    • Eigentlich etwas hacken, mit der api besser sein würde, alles, was Sie zu tun hatte, war irgendwas mit socket.isReady = true;, wenn Sie bereit ist, empfangen wird, und dadurch würden Sie sich gerettet aus mantaining eine andere Liste 😛
    • Dies ist der Weg zu gehen! Vielen Dank 🙂
    • Sie sind der Autor von node-memcached? Ich benutze es auch 🙂
    • Ja, ich bin auch der Autor des Moduls 🙂
    • Ich glaube, dass die Funktionalität in dieser Antwort ist veraltet 1.0
    • was ist die aktuelle Lösung für diesen Anwendungsfall in v1.0+?

    InformationsquelleAutor 3rdEden
Schreibe einen Kommentar