Разделение файлового сервера и логики socket.io в node.js
Я новичок в node.js, и я нашел довольно сложное разделение проекта на несколько файлов по мере роста размера проекта. У меня был один большой файл, перед которым работал как файловый сервер, так и сервер Socket.IO для многопользовательской игры HTML5. Я в идеале хочу отделить файловый сервер, логику socket.IO(чтение информации из сети и запись ее в буфер с меткой времени, затем ее передачу всем другим игрокам) и логику игры.
Используя первый пример из socket.io, чтобы продемонстрировать свою проблему, обычно два файла. app.js - сервер, а index.html - клиенту.
app.js:
var app = require('http').createServer(handler)
, io = require('socket.io').listen(app)
, fs = require('fs')
app.listen(80);
function handler (req, res) {
fs.readFile(__dirname + '/index.html',
function (err, data) {
if (err) {
res.writeHead(500);
return res.end('Error loading index.html');
}
res.writeHead(200);
res.end(data);
});
}
io.sockets.on('connection', function (socket) {
socket.emit('news', { hello: 'world' });
socket.on('my other event', function (data) {
console.log(data);
});
});
index.html
<script src="/socket.io/socket.io.js"></script>
<script>
var socket = io.connect('http://localhost');
socket.on('news', function (data) {
console.log(data);
socket.emit('my other event', { my: 'data' });
});
</script>
Чтобы отделить логику файлового сервера и игрового сервера, мне понадобится функция "обработчик", определенная в одном файле, мне понадобится анонимная функция, использующая обратный вызов для io.sockets.on(), чтобы быть в другом файле, и я бы нужен еще третий файл для успешного включения обоих этих файлов. На данный момент я пробовал следующее:
start.js:
var fileserver = require('./fileserver.js').start()
, gameserver = require('./gameserver.js').start(fileserver);
fileserver.js:
var app = require('http').createServer(handler),
fs = require('fs');
function handler (req, res) {
fs.readFile(__dirname + '/index.html',
function (err, data) {
if (err) {
res.writeHead(500);
return res.end('Error loading index.html');
}
res.writeHead(200);
res.end(data);
});
}
module.exports = {
start: function() {
app.listen(80);
return app;
}
}
Gameserver:
var io = require('socket.io');
function handler(socket) {
socket.emit('news', { hello: 'world' });
socket.on('my other event', function (data) {
console.log(data);
});
}
module.exports = {
start: function(fileserver) {
io.listen(fileserver).on('connection', handler);
}
}
Кажется, что это работает (статический контент должным образом обслуживается, и на консоли четко отображается рукопожатие с Socket.IO при подключении клиента), хотя данные никогда не отправляются. Как будто socket.emit() и socket.on() никогда не вызываются. Я даже изменил обработчик() в gameserver.js, чтобы добавить console.log('User connected');, однако это никогда не отображается.
Как я могу использовать Socket.IO в одном файле, файловый сервер в другом и все еще ожидать, что оба будут работать правильно?
Ответы
Ответ 1
В socket.io 0.8 вы должны присоединять события, используя io.sockets.on('...'), если вы не используете пространства имен, вам кажется, что отсутствует часть sockets:
io.listen(fileserver).sockets.on('connection', handler)
Вероятно, лучше избегать цепочки таким образом (возможно, вы захотите использовать объект io позже). То, как я это делаю прямо сейчас:
// sockets.js
var socketio = require('socket.io')
module.exports.listen = function(app){
io = socketio.listen(app)
users = io.of('/users')
users.on('connection', function(socket){
socket.on ...
})
return io
}
Затем после создания сервера app:
// main.js
var io = require('./lib/sockets').listen(app)
Ответ 2
я сделал бы что-то вроде этого.
app.js
var app = require('http').createServer(handler),
sockets = require('./sockets'),
fs = require('fs');
function handler (req, res) {
fs.readFile(__dirname + '/index.html',
function (err, data) {
if (err) {
res.writeHead(500);
return res.end('Error loading index.html');
}
res.writeHead(200);
res.end(data);
});
}
sockets.startSocketServer(app);
app.listen(80);
и sockets.js
var socketio = require('socket.io'),
io, clients = {};
module.exports = {
startSocketServer: function (app) {
io = socketio.listen(app);
// configure
io.configure('development', function () {
//io.set('transports', ['websocket', 'xhr-polling']);
//io.enable('log');
});
io.configure('production', function () {
io.enable('browser client minification'); // send minified client
io.enable('browser client etag'); // apply etag caching logic based on version number
io.set('log level', 1); // reduce logging
io.set('transports', [ // enable all transports (optional if you want flashsocket)
'websocket'
, 'flashsocket'
, 'htmlfile'
, 'xhr-polling'
, 'jsonp-polling'
]);
});
//
io.sockets.on('connection', function (socket) {
console.log("new connection: " + socket.id);
socket.on('disconnect', function () {
console.log("device disconnected");
});
socket.on('connect_device', function (data, fn) {
console.log("data from connected device: " + data);
for (var col in data) {
console.log(col + " => " + data[col]);
}
});
});
}
};
Я просто скопировал и наклеил некоторый мой старый код - не знаю, что изменилось в последних версиях socket.io, но это больше о структуре, чем о самом коде.
и я бы использовал только 2 файла для ваших целей, а не 3.
когда вы думаете о его расщеплении, возможно, еще один файл для разных маршрутов...
надеюсь, что это поможет.
Ответ 3
У меня тоже была трещина, и я вполне доволен результатом. Проверьте https://github.com/hackify/hackify-server для исходного кода.
Ответ 4
У меня есть другое решение. Вы можете использовать require.js, создавая модуль и передавая "приложение" в качестве аргумента. Внутри модуля вы можете запустить socket.io и организовать свои сокеты.
app.js
var requirejs = require('requirejs');
requirejs.config({
baseUrl: './',
nodeRequire: require
});
requirejs(['sockets'], function(sockets) {
var app = require('http').createServer()
, fs = require('fs')
, io = sockets(app);
// do something
// add more sockets here using "io" resource
});
В вашем модуле socket.js вы можете сделать что-то вроде этого:
define(['socket.io'], function(socket){
return function(app){
var server = app.listen(3000)
, io = socket.listen(server);
io.sockets.on('connection', function (socket) {
console.log('connected to socket');
socket.emit('news', { hello: 'world' });
socket.on('my other event', function (data) {
console.log(data);
});
// more more more
});
return io;
}
});
Я надеюсь помочь вам с моим вкладом.
