AngularJS and Autobahn.js WAMP Implementation

Question

创建使用Autobahn.js 0.8.1实现WAMP v1（WebSocket应用程序消息协议）的AngularJS服务的最佳方式是什么？理想情况下，我希望即使在路由更改时也可以访问websocket，而无需重新初始化连接。

这是一个无法与互联网通信的内部应用程序，因此PubNub不是一个选项。如果可能的话，避免重写《高速公路》也是有帮助的。

似乎没有AngularJS WAMP库可用，但这将是一个受欢迎的替代方案。

这个问题围绕着到Websocket的初始连接大约需要150毫秒。如果我编写了一个连接到websocket的服务，那么当我调用控制器中的pubsub套接字时，我必须使用超时函数，这样我就不会在套接字连接之前进行调用。

当前实施：

services.factory('socket', ['$rootScope',
  function($rootScope) {
    var pubsub = new ab.Session(
      'ws://1.1.1.1:8080',
      function(session) {
        console.log('New Session Established');
        return session;
      },
      function(code, reason) {
        console.log('Websocket connection closed. Code: '+code+'; reason: '+reason);
      }
    );
    return {
      pubsub: pubsub
    };
  }]);
controllers.controller('PageCtrl', ['$scope', 'socket', '$timeout',
  function($scope, socket, $timeout) {
    $timeout(function() {
      $scope.data = socket.pubsub.call('somecall', []).then(
        function(res) {
        }
      );
    }, 300);
  }]);

由于controller需要等待service，这似乎是$q.dedefer的一个很好的用途。当我尝试实现以下内容时，尽管更改了ab._Deferred方法，但它没有延迟：

services.factory('socket',['$rootScope', '$q',
  function($rootScope, $q) {
    // Change AutoBahn to use Angular Deferred:
    ab._Deferred = $q.defer;
    var service = {};
    service.address = 'ws://box:8080';
    service.name = 'socket';
    service.defer = $q.defer();
    service.connection = new ab.connect(
      // Address:
      service.address,
      // WAMP successful:
      function(session) {
        service.defer.promise.then(function() {
          service.session = session;
          console.log('connected!');
          return service;
        });
        // @todo: make another request now that we're connected
      },
      // WAMP unsuccessful:
      function(code, reason, detail) {
        // @todo: reject $q/defer here?
        //service.defer.reject(error);
      }
    );
    service.getDefer = function() {
      return service.defer;
    };
    service.subscribe = function(name, callback) {
      service.defer.promise.then(function() {
        service.session.subscribe(name, callback);
      });
      service.defer.resolve();
    };
    service.remoteCall = function(remote, msg) {
      service.session.call(remote, msg);
    };
    return service;
  }]);

controllers.controller('AppCtrl', ['$q', '$scope', 'socket') {
  var myDef = $q.defer();
  myDef.promise.then(function() {
    var ws = socket;
    var defer = ws.getDefer();
    defer.resolve();
    console.log('1');
    return ws;
  }).
  then(function(ws) {
    console.log('2');
    ws.remoteCall('somecall', function(res) {
      console.log('Call Successful: ' + res);
    });
    return ws;
  });
  $scope.ws = myDef.resolve();
  ws.remoteCall('anothercall', function(data) {
    console.log(data);
  });
}

我还需要包括when.js吗，就像在这个问题中一样？在requirejs（autobahn和whenjs）中正确加载依赖项

有一个非常相似的问题没有解决方案：https://stackoverflow.com/questions/17798504/angularjs-and-websocket-application-messaging-protocol

Answer 1

有AngularWAMP我试过了，效果很好。请注意，这是针对AngularJS（不是Angular2）的。关于不连接互联网的问题：你所做的是在本地局域网上设置一个路由器（使用Crossbar），你的整个企业都可以访问（而不是互联网）。您的所有客户端/服务器都将连接到您的本地路由器。