socket.io 不工作 node.js

Question

我无法在 node.js 中运行 socket.io 代码，console.log() 在运行代码时也不显示。下面是代码。

app.js

var express = require('express');
var http = require('http');
var app = express();
app.set('port', process.env.PORT || 3000);
app.post('/testStream',test.testStream);
var server = http.createServer(app).listen(app.get('port'), function(){
  console.log('Express server listening on port ' + app.get('port'));
});

module.exports.appServer = server;

我已经创建了一个 test.js 文件，我在其中访问这个导出的变量 appServer。

var server = require('../app.js');

exports.testStream = function(req,res){        
    var io = require('socket.io').listen(server.appServer);
    io.on('connection',function(socket){
        console.log("in socket");
        fs.readFile('E:/temp/testimg.png',function(err,buf){
            socket.emit('image',{image: true,buffer: buf});
            console.log("test image");
        });
    })       
}

当代码运行时，它会卡住并且不显示 console.logs()。我在这里做错了什么。非常感谢任何帮助。

Answer 1

我建议遵循 socket.io 文档中建议的代码结构。

此外，您应该不在您的 testStream express 中间件中调用 io.listen 或 io.on('connection')。这些是你应该只做一次的事情，理想情况下它们应该在启动期间发生，在 app.js 内部，而不是响应 POST 请求。事实上，我不确定你的testStream 中间件的目的是什么，它甚至没有返回任何响应（例如res.end()）

如果您想在单独的模块中处理套接字连接，您可以，但不要像现在这样导出应用程序的 server，而是尝试将 io 实例作为变量传递给您的子模块。简而言之，试试这个：

app.js

var app = require('express')();
var server = require('http').Server(app);
var io = require('socket.io')(server);
var test = require('./test')(io);

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

server.listen(app.get('port'), function() {
    console.log('Express server listening on port ' + app.get('port'));
});

test.js

module.exports = function(io) {
    io.on('connection', function(socket) {
        console.log("in socket");
        fs.readFile('E:/temp/testimg.png', function(err, buf) {
            socket.emit('image', {
                image: true,
                buffer: buf
            });
            console.log("test image");
        });
    });
};