在node.js上使用socket-io的Http服务器没有运行

Http server with socket-io on node.js doens't running

本文关键字:服务器 Http 运行 socket-io js node      更新时间:2023-09-26

我在node.js上使用socket-io的http服务器没有运行。我使用npm install socket-io和运行服务器。

服务器的代码

    var static = require('node-static');
var http = require('http');
// Create a node-static server instance
var file = new(static.Server)();
// We use the http moduleÕs createServer function and
// rely on our instance of node-static to serve the files
var app = http.createServer(function (req, res) {
  file.serve(req, res);
}).listen(8181);
// Use socket.io JavaScript library for real-time web applications
var io = require('socket.io').listen(app);
// Let's start managing connections...
io.sockets.on('connection', function (socket){
        // Handle 'message' messages
        socket.on('message', function (message) {
                log('S --> got message: ', message);
                // channel-only broadcast...
                socket.broadcast.emit('message', message);
        });
        // Handle 'create or join' messages
        socket.on('create or join', function (room) {
                /*var namespace = '/';
                for (var numClients in io.nsps[namespace].adapter.rooms[room]) {
                    console.log(numClients);
                }*/
                //var numClients = io.sockets.clients(room).length;
                var numClients = io.sockets.adapter.rooms[room]!=undefined ? Object.keys(io.sockets.adapter.rooms[room]).length:0;
                log('SERVER: CLIENTS ' + room + ' has ' + numClients + ' client(s)');
                log('S --> Room ' + room + ' has ' + numClients + ' client(s)');
                log('S --> Request to create or join room', room);
                // First client joining...
                if (numClients == 0){
                        socket.join(room);
                        socket.emit('created', room);
                } else if (numClients == 1) {
                // Second client joining...                 
                        io.sockets.in(room).emit('join', room);
                        socket.join(room);
                        socket.emit('joined', room);
                        log('S: sent JOIN message');
                } else { // max two clients
                        socket.emit('full', room);
                }
        });
        function log(){
            var array = [">>> "];
            for (var i = 0; i < arguments.length; i++) {
                array.push(arguments[i]);
            }
            socket.emit('log', array);
        }
});

当这是客户端连接到套接字的代码:

   var room = getParameterByName('room_name'); 
alert ("room_name: "+room);
// Connect to signalling server
var socket = io.connect();
// Send 'Create or join' message to singnalling server
if (room !== '') {
  console.log('Create or join room', room);
  socket.emit('create or join', room);
}

使用netstat -a命令,我看到了服务器的端口是活动的。但是它不发送消息。

我有另一个问题:服务器如何发送消息不广播,但指定的对等连接?我的意思是:而不是

socket.on('message', function (message) {
            log('S --> got message: ', message);
            // channel-only broadcast...
            socket.broadcast.emit('message', message);
    });

我该怎么办?谢谢!

我有另一个问题:服务器如何发送消息而不是广播,但是要连接到指定的对等体?

你的问题的第二部分是,你只是做socket.emit()发送到一个套接字,像这样发送回同一个套接字,刚刚发送给你一个消息:

socket.on('message', function (message) {
     log('S --> got message: ', message);
     // channel-only broadcast...
     socket.emit('message', "got your message");
});

或者,如果您有其他连接的客户端的套接字id值,您可以在服务器上获取该套接字,如下所示:

io.sockets.connected[id].emit(...)