对于我的RESTapi,我为每个路由创建了一个文件。
app.get('/api/user', routes.user.index);
app.get('/api/user/login', routes.user.login);
等等。
现在我将socket.io引入后端,似乎我只能为所有套接字事件调用一个函数。
var socket = require('./socket/stuff.js');
io.sockets.on('connection', function(sock){
socket.stuff(sock, io);
});
我应该如何分解./socket/stuff.js
文件(它导出stuff
)。放入单独的文件中。我希望最终用套接字替换RESTapi,但我不希望所有内容都在一个文件中。
我想我会有:
./socket/chat.js
./socket/user.js
等等。等等
要在不同的文件中组织事件处理程序,可以使用这样的结构:
/main.js
var io = require('socket.io');
var Chat = require('./EventHandlers/Chat');
var User = require('./EventHandlers/User');
var app = {
allSockets: []
};
io.sockets.on('connection', function (socket) {
// Create event handlers for this socket
var eventHandlers = {
chat: new Chat(app, socket),
user: new User(app, socket)
};
// Bind events to handlers
for (var category in eventHandlers) {
var handler = eventHandlers[category].handler;
for (var event in handler) {
socket.on(event, handler[event]);
}
}
// Keep track of the socket
app.allSockets.push(socket);
});
/EventHandlers/Chat.js
var Chat = function (app, socket) {
this.app = app;
this.socket = socket;
// Expose handler methods for events
this.handler = {
message: message.bind(this) // use the bind function to access this.app
ping: ping.bind(this) // and this.socket in events
};
}
// Events
function message(text) {
// Broadcast message to all sockets
this.app.allSockets.emit('message', text);
});
function ping() {
// Reply to sender
this.socket.emit('message', 'PONG!');
});
module.exports = Chat;
index.js
const httpServer = require("http").createServer();
const io = require("socket.io")(httpServer);
const registerOrderHandlers = require("./orderHandler");
const registerUserHandlers = require("./userHandler");
const onConnection = (socket) => {
registerOrderHandlers(io, socket);
registerUserHandlers(io, socket);
}
io.on("connection", onConnection);
orderHandler.js
module.exports = (io, socket) => { const createOrder = (payload) => { // ... }
const readOrder = (orderId, callback) => { // ... }
socket.on("order:create", createOrder); socket.on("order:read", readOrder);}
我是从文件中得到的。https://socket.io/docs/v4/server-application-structure/