Angular中的WebSocket服务更新作用域(使用ngWebSocket)

Question

我正在尝试从websocket获取数据以自动更新控制器范围内的值。

我的服务:

mimosaApp.service("Device", function ($websocket) {
    var self = this;
    var ws = $websocket.$new({
        url: "ws://" + window.location.host + ":81",
        //mock: true,
        reconnect: true
    });
    this.data = {};
    ws.$on("$open", function() {
        ws.$emit("get", "device");
    });
    ws.$on("$message", function (message) {
        console.log("WS Received", message);
        for(var key in message) {
            self.data[key] = message[key];
        }
        console.log(self.data); // At this point, self.data contains the proper data.
    });
    this.send = function (obj) {
        ws.$emit("set", obj);
    };
});

和我的简单控制器:

angular.module("MimosaApp").controller("PageController", ["Device", "$scope", "$http", function(Device, $scope, $http) {
    $scope.device = Device;
}]);

当建立套接字连接时，浏览器发送请求数据的消息($open事件)。当它得到响应时，它更新Device。

但我没有看到这反映在我的控制器范围/视图。如果在控制器中，我设置了Device.data.name ='blah';之类的东西，我可以在控制器作用域/视图中看到name属性。

我对Angular有点陌生，所以如果我的问题不太有意义，很抱歉。:)

我的视图正试图这样使用它:

<div class="container-fluid">
    location
    <ul>
        <li ng-repeat="(key, value) in device.data">
            {{key}}: {{ value }}
        </li>
    </ul>
    <p>{{device.data.face}}</p>
</div>

Answer 1

查看源代码，它似乎没有在$on处理程序中使用scope.$apply调用摘要循环。这意味着angular并不知道视图绑定的任何更新，所以不会在视图中反映任何更改。因此，您需要在您的服务中手动执行此操作，您可以注入$rootScope或$timeout来触发消化循环。

: -

注射$timeout

 ws.$on("$message", function (message) {
        console.log("WS Received", message);
        for(var key in message) {
            self.data[key] = message[key];
        }
        console.log(self.data); // At this point, self.data contains the proper data.
       $timeout(angular.noop); //<-- just invoke a dummy digest
    });

注射$rootScope

 ws.$on("$message", function (message) {
        console.log("WS Received", message);
        for(var key in message) {
            self.data[key] = message[key];
        }
        console.log(self.data); // At this point, self.data contains the proper data.
      $rootScope.$apply(); //invoke digest
    });

或者甚至在你的服务中使用$q创建一个虚拟的承诺。

mimosaApp.service("Device", function ($websocket, $q) {
    var self = this;
    var _dummyPromise = $q.when(); //<-- here
    var ws = $websocket.$new({
        url: "ws://" + window.location.host + ":81",
        //mock: true,
        reconnect: true
    });
    //...

    ws.$on("$message", function (message) {
        console.log("WS Received", message);
        for(var key in message) {
            self.data[key] = message[key];
        }
       _dummyPromise.then(angular.noop); //<-- here
    });
    this.send = function (obj) {
        ws.$emit("set", obj);
    };
});

Answer 2

最可能的原因是$on回调没有触发$digest周期来通知应用程序的其他部分任何更改。

你可以手动注入$rootScope

mimosaApp.service("Device", function ($rootScope, $websocket)

，然后在更新数据

后触发$digest。

ws.$on("$message", function (message) {
    console.log("WS Received", message);
    for(var key in message) {
        self.data[key] = message[key];
    }
    if(!$rootScope.$$phase) { // prevents triggering a $digest if there's already one in progress
        $rootScope.$digest()
    }
    console.log(self.data); // At this point, self.data contains the proper data.
});