AngularJS发布/订阅者套接字连接

Question

我无法订阅与服务器的套接字连接内的主题。

app.factory('socket', [function() { 
 
    var stack = []; 
 
    var onmessageDefer; 
 
    var socket = { 
 
     ws: new WebSocket('wss://site.com:61015/'), 
 
     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; 
 
}]);

我如何能实现对服务器的话题发布/订阅，我怎么能在控制器获取套接字的消息？

Answer 1

请找到一个代码示例：AngularJS and WebSockets beyond

请注意，你必须自己实现该订阅机制，因为WebSockets的只是是运输，没有基本的pub/sub。