express.js 4 और एक्सप्रेस राउटर

Question

के साथ सॉकेट्स मैं express.js 4 का उपयोग करके वास्तव में एक साधारण नोड एपीआई बनाने की कोशिश कर रहा हूं लेकिन मुझे कुछ 'रीयलटाइम' ईवेंट की आवश्यकता है जिसके लिए मैंने socket.io जोड़ा है। मैं दोनों के लिए काफी नया हूं इसलिए मुझे कुछ मूलभूत याद आ रही है लेकिन मुझे इस पर अच्छे दस्तावेज़/टट्स नहीं मिल रहे हैं।

एक्सप्रेस ऐप (एक्सप्रेस जनरेटर के साथ बनाया गया) में मेरे पास कुछ सरल उदाहरण और प्रोजेक्ट दस्तावेज़ों के आधार पर ऐसा कुछ है जो मैंने पढ़ा है। यह ठीक काम करता है और ग्राहक क्षुधा से, मैं भेज/सॉकेट ईवेंट प्राप्त कर सकते हैं:

var express = require('express'); 
var path = require('path'); 
var logger = require('morgan'); 
var api = require('./routes/api'); 
var app = express(); 
var io = require('socket.io').listen(app.listen(3000)); 

app.use(logger('dev')); 
app.use(express.static(path.join(__dirname, 'public'))); 
app.use('/api', api); 

io.sockets.on('connection', function (socket) { 
    console.log('client connect'); 
    socket.on('echo', function (data) { 
     io.sockets.emit('message', data); 
    }); 
}); 


// error handlers omitted 

module.exports = app; 

लेकिन मैं अपने एपीआई मार्गों से सॉकेट (./routes/api.js फ़ाइल में है कि मैं की आवश्यकता का उपयोग करना चाहते ' ऊपर)। उदाहरण के लिए, कोई व्यक्ति संसाधन को PUT/POST करने के लिए API का उपयोग कर सकता है और मैं चाहता हूं कि वह socket.io क्लाइंट से कनेक्ट हो।

मैं नहीं देख सकता कि 'io' चर का उपयोग कैसे करें या वर्तमान में io.sockets.on('connection' ... एक्सप्रेस मार्गों के भीतर कोड को व्यवस्थित करें। आप जाँच कर सकते हैं अगर यह काम करता है

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

router.put('/foo', function(req, res) { 
    /* 
     do stuff to update the foo resource 
     ... 
    */ 

    // now broadcast the updated foo.. 
    io.sockets.emit('update', foo); // how? 
}); 

module.exports = router; 

Answer 1

मैं अपनी फ़ाइलें एक छोटा सा संशोधन किया है,: यहाँ ./routes/api.js फ़ाइल है?

आप अपने मार्गों को नीचे दिए गए io को पारित कर सकते हैं;

require('./routes/api')(app,io); 

मैंने सॉकेट.आईओ भागों का परीक्षण नहीं किया लेकिन कोई वाक्यविन्यास त्रुटि नहीं है और मार्ग भी काम कर रहे हैं।

server.js फ़ाइल:

var express = require('express'); 
var app = express(); 
var path = require('path'); 
var logger = require('morgan'); 

var io = require('socket.io').listen(app.listen(3000)); 

app.use(logger('dev')); 
app.use(express.static(path.join(__dirname, 'public'))); 

io.sockets.on('connection', function (socket) { 
    console.log('client connect'); 
    socket.on('echo', function (data) { 
    io.sockets.emit('message', data); 
}); 
}); 

require('./routes/api')(app,io); 

console.log("Server listening at port 3000"); 

api.js:

module.exports = function(app,io) { 
app.put('/foo', function(req, res) { 

    /* 

     do stuff to update the foo resource 

     ... 

    */ 


    // now broadcast the updated foo.. 

    console.log("PUT OK!"); 

    io.sockets.emit('update'); // how? 
    res.json({result: "update sent over IO"}); 

}); 
} 

Answer 2

एक विकल्प अनुरोध वस्तु में इसे पारित करने के लिए है।

app.js:

var express = require('express'); 
var path = require('path'); 
var logger = require('morgan'); 
var api = require('./routes/api'); 
var app = express(); 
var io = require('socket.io').listen(app.listen(3000)); 

app.use(logger('dev')); 
app.use(express.static(path.join(__dirname, 'public'))); 

io.sockets.on('connection', function (socket) { 
    console.log('client connect'); 
    socket.on('echo', function (data) { 
     io.sockets.emit('message', data); 
    }); 
}); 

// Make io accessible to our router 
app.use(function(req,res,next){ 
    req.io = io; 
    next(); 
}); 

app.use('/api', api); 

// error handlers omitted 

module.exports = app; 

./routes/api.js:

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

router.put('/foo', function(req, res) { 
    /* 
     do stuff to update the foo resource 
     ... 
    */ 

    // now broadcast the updated foo.. 
    req.io.sockets.emit('update', foo); 
}); 

module.exports = router;