Wie kann ich Ereignisse aus Connected Sockets mit socket.io von meinen Express 4 Routen aus ausgeben?

Question

Dies ist eine Frage, die andere Leute gestellt haben, aber ich kann nicht von den Antworten profitieren, die sie bekommen haben, aufgrund der verschiedenen Express-Einstellungen, die ich habe.

Ich habe socket.io implementiert und funktioniert auf einfache Weise auf meinem Server. Dies ist, wie es funktioniert:

In bin/www:

#!/usr/bin/env node 
var debug = require('debug')('gokibitz'); 
var app = require('../../server'); 

app.set('port', process.env.PORT || 3000); 

var server = app.listen(app.get('port'), function() { 
    debug('Express server listening on port ' + server.address().port); 
}); 

var io = require('socket.io').listen(server); 

io.on('connection', require('../routes/socket.js')); 

Alle meine Routen und andere Express-Setup in ../../server.js ist.

var routes = require('./server/routes/index'); 
var user = require('./server/routes/user'); 
... 

app.use('/', routes); 
app.use('/api/user/', user); 
... 
app.use('*', routes); 

Dann in ../routes/socket.js, habe ich diese vorformulierten bekam:

module.exports = function (socket) { 
    socket.emit('send:news', { hello: 'world' }); 

    setInterval(function() { 
     socket.emit('send:time', { 
      time: (new Date()).toString() 
     }); 
    }, 1000); 

    return socket; 
}; 

Dies funktioniert schön, wie ich hinzufügen möchte. Aber jetzt möchte ich in der Lage sein, Ereignisse von den verschiedenen Routen in meiner recht gewöhnlichen Express-App auszugeben, und ich kann nicht für den Rest von mir den richtigen Weg finden, einen Verweis auf das Socket-Objekt zu bekommen, das ich brauche.

Beispiel: Wenn ein Benutzer einen Kommentar abgibt, möchte ich ein Ereignis an alle verbundenen Benutzer senden, um sie über den neuen Kommentar zu informieren. Wie kann ich aus meiner routes-Datei (./server/routes/user.js) Zugriff auf das Objekt erhalten, das ich zum Ausgeben von Ereignissen benötigen?

Hier ist ein Skelett der relevanten Bits aus einer Routendatei:

var express = require('express'); 
var router = express.Router(); 

router.post('/', function (req, res) { 
    ... 
}); 

module.exports = router; 

Der einzige Ort, kann ich auf sie in der ../routes/socket.js Datei ist, die nutzlos ist.

alle Routen sind in einem app.js gesetzt, bevor Objekt jede io oder Buchse gibt es in zu übergeben.

Soll ich require('socket.io') der Lage sein, und es verwenden, irgendwie an alle angeschlossenen Steckdosen zu emittieren?

Gibt es eine vernünftige Möglichkeit, die angeschlossenen Buchsen auf ../routes/socket.js zu speichern, so dass es von anderen Routen benötigt und ausgegeben werden kann?

Kann mich jemand in die richtige Richtung lenken?

Answer 1

konnte ich schließlich die Dinge bekommen mit diesem Beispiel arbeiten:

var io = require('socket.io')(); 

io.on('connection', function (socket) { 
    socket.emit('news', { hello: 'world' }); 
    socket.on('my other event', function (data) { 
    console.log(data); 
    }); 
}); 

module.exports = io; 

Dann aktualisiert ich server/bin/www dazu:

#!/usr/bin/env node 
var debug = require('debug')('gokibitz'); 
var app = require('../../server'); 
var io = require('../io'); 

app.set('port', process.env.PORT || 3000); 

var server = app.listen(app.get('port'), function() { 
    debug('Express server listening on port ' + server.address().port); 
}); 

io.attach(server); 

https://github.com/expressjs/generator/issues/45#issuecomment-53719435

ich eine neue Datei server/io.js genannt erstellt

Dann verwende ich auf meiner Route:

var io = require('../io'); 
... 
io.emit(...); 

Das fehlende Stück für mich, zumindest war die Fähigkeit, das io Objekt separat, senden Sie das richtige Objekt zu erstellen, dann io.attach(server) innerhalb bin/www verwendet es an der richtigen Stelle zu starten.

Hoffentlich hilft das jemand anderen in meine Fußstapfen treten.

var socketio = require('socket.io'); 
var io; 

module.exports = { 
socketServer: function (app) { 
    io = socketio.listen(app); 

    io.on('connection', function (socket) { 

     console.log(Object.keys(users)); 
     socket.on('message', function (data) { 
      io.emit('updateChat', 'Hello World!') 
     }); 
    }); 
    } 
} 

Und in meinem app.js:

Answer 2

Ich denke, Sie sind mit den Konzepten verwirrt. Die socket.io-Lib verwendet oder emuliert einen Websocket (bidirektionalen Socket) mit dem Client und hat keine Beziehung zu Routen.

Sie können eine Mitteilung an alle Sockets senden, um die io-Objekt:

io.emit('message_to_all', true); 

Sie auf io.sockets auf ein Array haben, mit allen Steckdosen.

Sie können verwendet Namespaces oder Zimmer, ich empfehle Sie lernen in der Dokumentation:

http://socket.io/docs/rooms-and-namespaces/#

hinzufügen etwas:

Wenn Sie eine Nachricht an alle Menschen in der gleichen senden möchten Route können Sie einem Kanal mit demselben Namen des Pfads beitreten.

Zum Beispiel in dem Client:

var socket = io(window.location.href); // Or route.. 

und den Server:

var nsp = io.of('/the/specific/route'); 
nsp.on('connection', function(socket){ 
    // ... 
}); 
nsp.emit('message_to_all_in_route', data); 

über die letzte Frage Bearbeitung:

Sie können das io-Objekt in Anfrage senden oder Antwortobjekt auf Routen mit der Express Middleware API:

Zum Beispiel:

#!/usr/bin/env node 
var debug = require('debug')('gokibitz'); 
var app = require('../../server'); 

app.set('port', process.env.PORT || 3000); 

var server = app.listen(app.get('port'), function() { 
    debug('Express server listening on port ' + server.address().port); 
}); 

var io = require('socket.io').listen(server); 

app.use(function (req, res, next) { 
    res.io = io; 
    next(); 
}); 

io.on('connection', require('../routes/socket.js')); 

Und in der Route:

route.post('/post/:id/comments', function (req, res) { 

    // Do your logic 

    var postio = res.io.of('/post/' + req.params.id); 
    postio.emit('new_comment', commentData); 

}); 

Answer 3

Wie ich in meinem Kommentar sagte, können Sie an alle angeschlossenen Clients mit senden:

io.emit(msg, data); 

Dies erfordert Zugriff auf das Objekt io, das Sie in Ihrem ersten Modul erstellt haben. Der übliche Weg, das mit Ihrem Modul mit Ihrem Routen-Modul zu teilen, wäre, eine Methode aus dem Modul routes zu exportieren, mit der Sie das io Objekt übergeben können und dann, nachdem Sie das Modul angefordert und das Objekt io erstellt haben Rufen Sie einfach diese Methode auf, um das Objekt io an das Routenmodul zu übergeben und es lokal für die zukünftige Verwendung zu speichern.

io ist nur ein gemeinsames Objekt wie das Objekt app ist. Wenn ein Modul in der Lage sein soll, ein gemeinsam genutztes Objekt zu verwenden, rufen Sie in der Regel eine Methode in diesem Modul auf, um einige Objekte mit ihm zu teilen, die dann verwendet werden können.

Answer 4

Ich habe eine neue Datei sockets.js in dieser Datei gemacht

var express = require('express'); 
var app = express(); 
var http = require('http').createServer(app); 
var port = process.env.PORT || 3000; 

var io = require('./sockets').socketServer(http); 
http.listen(port, function() { 
    console.log('SERVER RUNNING.. PORT: ' + port) 
}); 

Dies ist für mich arbeiten. Viel Glück!