8

我有一个 JavaScript Websockets 实现，我想使用一个单例模型，该模型使用一个 Websocket 连接对服务器进行多次调用，但具有不同的回调事件处理程序。我的实现工作得很好，但注意到一些奇怪的行为，消息被定向到错误的回调处理程序。这是一些代码：

Connection.js 文件

var connection = function(){
    var _socket = null;
    return {
        socket : function(){
            if (_socket == null){
                _socket = new WebSocket("ws://localhost:8081/index.ashx");
                _socket.onclose = function(evt){alert('Closed');}
                _socket.extraParameter = null;
            }
            return _socket;
        },
        send : function(data, callback){
            var localSocket = connection.socket();
            localSocket.extraParameter = new Date().toString();
            localSocket.onmessage = callback;
            localSocket.originalDataSent = data;
            localSocket.send(data);
        }
    }
}();

应用程序.js 文件

var App = function(){
    return {
        cpuUtilization : function(evt){
            var localSocket = this;
            var dateTimeOfRequest = localSocket.extraParameter;
            var originalDataSent = localSocket.originalDataSent
            var jsonData = $.parseJSON(evt.data);
            if ($.parseJSON(originalDataSent).type == "cpu"){
                $("#dateTimeContainer").html();
                $("#cpuContainer").html(jsonData.value);
            }
        }
    }
}();

第三方 Signal.js 文件

var Signal = function(){
    return {
        handlerProcess : function(evt){
            //  Does some third party stuff...
        }
    }
}();

用法

connection.send("{type:'process'}", Signal.handlerProcess);
connection.send("{type:'cpu'}", App.cpuUtilization);
connection.send("{type:'memory'}", Signal.handlerMemory);
connection.send("{type:'harddrive'}", Signal.handlerHardDrive);

现在我认为我看到的问题是当通过同一个 websocket 发出多个请求并且消息返回时。由于这是异步的，我无法将请求与事件回调联系起来。我的解决方案使用处理程序中的选项作为参考，但根据 websocket 请求运行所需的时间，错误的回调处理程序被调用并且进程失败。我认为它失败了，因为我正在从 websocket 实例访问可能在调用之间发生变化的属性。

有没有办法将引用或附加参数与 evt 参数一起传递？也许以某种方式包装这个？

4

1 回答 1

9

我认为它失败了，因为我正在从 websocket 实例访问可能在调用之间发生变化的属性。

是的。

由于这是异步的，我无法将请求与事件回调联系起来。

不，您可以为回调函数创建一个闭包，而不是callback直接调用 using：

... send: function(data, callback){
    var localSocket = connection.socket();
    var extraParameter = new Date().toString();
    localSocket.onmessage = function(evt) {
        callback(evt.data, /* original- */ data, extraParameter);
    };
    localSocket.send(data);
}

但是，您仍然有一个不断变化的onmessage回调处理程序。这意味着，一个事件可能被发送到一个不值得它的处理程序。拥有一个异步系统，您需要向服务器响应添加一条信息，指示数据属于哪个进程。然后，一个通用消息处理程序可以解决该问题并调用正确的回调。

于 2012-06-20T20:18:20.950 回答