AngularJS + WebSockets

Question

我有几个控制器。在其中一种情况下，我需要打开web socket连接。在另一种情况下，我需要监听消息，如果需要，还需要更新$scope。请在下面的示例中帮助我完成此操作：

app.controller('MainCtrl', ['$scope', function($scope) {
    $scope.testProp = {};
    $scope.testProp2 = '';
    // listen messages here
    // and update $scope.testProp && $scope.testProp2
}]);

app.controller('SearchCtrl', ['$scope', function($scope) {
    // open connection here
}]);

附言:我知道这个问题是微不足道的，但我是AngularJS和WebSockets的新手，我需要帮助，现在我没有时间学习文档(我以后要做什么)

Answer 1

我找到了一个简单的工厂解决方案：

app.factory('socket', [function() {
    var stack = [];
    var onmessageDefer;
    var socket = {
        ws: new WebSocket(websocket_url),
        send: function(data) {
            data = JSON.stringify(data);
            if (socket.ws.readyState == 1) {
                socket.ws.send(data);
            } else {
                stack.push(data);
            }
        },
        onmessage: function(callback) {
            if (socket.ws.readyState == 1) {
                socket.ws.onmessage = callback;
            } else {
                onmessageDefer = callback;
            }
        }
    };
    socket.ws.onopen = function(event) {
        for (i in stack) {
            socket.ws.send(stack[i]);
        }
        stack = [];
        if (onmessageDefer) {
            socket.ws.onmessage = onmessageDefer;
            onmessageDefer = null;
        }
    };
    return socket;
}]);

什么时候

app.controller('MainCtrl', ['$scope', 'socket', function($scope, socket) {
    socket.onmessage(function(event) {
        //var data = JSON.parse(event.data);
        //$scope.testVar = 
    });
}]);

app.controller('SearchCtrl', ['$scope', 'socket', function($scope, socket) {
    socket.send({
        //somedata
    });
}]);

Answer 2

请看这个答案：AngularJS and WebSockets beyond

基本上，它是一个关于在AngularJS中创建可用于请求/响应和发布/订阅的WebSocket服务的示例。