Socket.IO服务器未收到来自客户端的消息 [英] Socket.IO server not receiving message from client

问题描述

我正在通过创建聊天应用程序来处理Node、Socket.IO和BDD。在其中一个测试期间，我收到一个超时错误，指出：

错误：已超过2000ms的超时时间。确保在此测试中调用了Done()回调。

受影响的测试

it('#must be able to receive a message', function(done)
{
    chatterServer.on('chatterMessage', function(data)
    {
        console.log('Incoming message!');
        expect(data).to.have.property('message');
        expect(data.message).to.be('Hello, world!');
        done();
    });

    console.log('Sending message!');
    chatterClient.send('chatterMessage', { message: 'Hello, world!' });
    console.log('Sent!');
});

我发现此问题的原因是chatterMessage事件未被服务器捕获。而我确实指定了它。

控制台的输出为：

发送消息！
已发送！
错误：已超过2000ms的超时。确保在此测试中调用了Done()回调。

我可能做错了什么。我对Node和Socket.IO不太熟悉，如果这个问题很明显，我很抱歉。

我在Google上搜索了搜索词"Socket.IO服务器未从客户端接收"，但从我发现的情况来看，到目前为止没有任何帮助我解决问题的方法。

但是，我确实尝试了this question中的解决方案，但这不能解决我的问题。

完整测试如下：

var util = require('util');
var Chatter = require('../src/index');
var ChatterServer = Chatter.Server;
var ChatterClient = Chatter.Client;
var express = require('express');
var expect = require('expect.js');
var socketIO = require('socket.io');
var socketIOClient = require('socket.io-client');

var host = 'http://localhost';
var port = 8080;

describe('Chatter', function()
{
    'use strict';

    var chatterServer;
    var chatterClient;
    var server;

    before(function()
    {
        var app = express();

        server = app.listen(port);
    });

    beforeEach(function()
    {
        chatterServer = new ChatterServer(socketIO(server));
        chatterClient = new ChatterClient(socketIOClient, util.format('%s:%s', host, port.toString()));
    });

    ...

    it('#must be able to receive a message', function(done)
    {
        chatterServer.on('chatterMessage', function(data)
        {
            console.log('Incoming message!');
            expect(data).to.have.property('message');
            expect(data.message).to.be('Hello, world!');
            done();
        });

        console.log('Sending message!');
        chatterClient.send('chatterMessage', { message: 'Hello, world!' });
        console.log('Sent!');
    });
});

我的客户端(ChatterClient)是：

(function()
{
    'use strict';

    function Client(socketIO, url)
    {
        this.socketIO = socketIO(url);
    }

    Client.prototype.send = function(event, data)
    {
        this.socketIO.emit(event, data);
    };

    Client.prototype.on = function(event, callback)
    {
        this.socketIO.on(event, callback);
    };

    if (module !== undefined && module.hasOwnProperty('exports')) {
        module.exports = Client;
    } else {
        window.Chatter = {
            Client: Client,
        };
    }
}());

(function()
{
    'use strict';

    function Server(socketIO)
    {
        this.socketIO = socketIO;
        this.connectedUsers = {};

        this.on('connection', (function(user)
        {
            var userID = user.client.id;

            this.connectedUsers[userID] = user;

            user.emit('chatterConnectionAcknowledged', { id: userID });
        }).bind(this));
    }

    Server.prototype.on = function(event, handler)
    {
        this.socketIO.on(event, handler);
    };

    module.exports = Server;

}());

推荐答案

您需要在两面更改代码。

第一面，您将需要侦听socketIO对象上的传入套接字连接。(请参阅下面强调的代码)

    //.. some code

    function Server(socketIO)
    {
        this.socketIO = socketIO;
        this.connectedUsers = {};

        this.socketIO.on('connection', (function(user)
        {
            var userID = user.client.id;

            this.connectedUsers[userID] = user;

            user.emit('chatterConnectionAcknowledged', { id: userID });
        }).bind(this));
    }

    //.. some code

第二方面当您在服务器上添加要侦听的新事件时，需要将这些事件绑定到套接字，因为它们将在事件从套接字客户端发出时进行侦听。

Server.prototype.on = function (event, handler) {
  Object.keys(this.connectedUsers).map(function (key) {
    this.connectedUsers[key].on(event, handler);
  }.bind(this));
};

这篇关于Socket.IO服务器未收到来自客户端的消息的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！