NodeJS：如何使用訂閱websocket的多個響應來更新視圖？

Question

我是websockets的新手。

我想在一個MeanJS應用程序中實現一個websocket來訂閱另一個網站提供的一些實時數據，當數據得到返回時我想更新我的視圖中的表與結果。

我遇到了一個邏輯問題。

throw new Error('Cant set headers after they are sent.'); 

我明白爲什麼這個錯誤是發生，但作爲新的WebSockets和相當新：我的執行失敗，因爲它試圖在一個TCP連接（我相信）發送多個響應，它與錯誤死亡到NodeJS我不知道如何以有意義的方式重構此代碼。

在我的客戶方控制器：

// Get Orderbook 
    $scope.getOrderbook = function() { 
     $http.get('exchanges/' + $stateParams.exchangeId + '/get_orderbook') 
      .success(function(data) { 
       console.log("ORDERBOOK DATA: " + data); // DEBUGGING 
       $scope.orderBook = data; 
      }); 
    }; 

在我的服務器端控制器：

exports.getOrderbook = function(req, res, next) { 
     var exchange = req.exchange; 

     if(exchange.slug === 'somesite') { 
      var ws = new WebSocket('wss://www.somesite.com/realtimews'); 

      ws.on('open', function open() { 
       ws.send('{"op": "subscribe", "args": "orderBook"}'); 
      }); 

      ws.on('message', function(message) { 
       var response = JSON.parse(message); 

       if(response.table) { 
        res.jsonp(response.data); 
       } 
      }); 
     } 
    }; 

什麼是重構這個代碼，這樣我可以訂閱的WebSocket的最佳方式，接收來自它的消息，以及何時收到消息，用數據更新視圖？

Answer 1

在每個新的傳入http請求上，您都試圖打開一個新的websocket到某個站點，然後每次您收到一條消息時您都試圖發送響應。同時，你永遠不會關閉你的websocket。

當第一個響應已發送時，當您嘗試向同一http請求發送第二個http響應時，會發生特定錯誤。當你在websocket上得到第二條消息時，這將發生在你的代碼中。

另外，你每次打開一個新的websocket時，你只會讓這些打開的websocket累積起來。

如果您確實需要使用websocket來獲取您的數據，那麼只要您收到第一條消息或刪除與特定請求關聯的事件處理程序，就需要關閉websocket。

下面是做這件事：

exports.getOrderbook = function(req, res, next) { 
    var exchange = req.exchange; 

    if(exchange.slug === 'somesite') { 
     var ws = new WebSocket('wss://www.somesite.com/realtimews'); 

     ws.on('open', function open() { 
      ws.send('{"op": "subscribe", "args": "orderBook"}'); 
     }); 

     ws.on('message', function(message) { 
      var response = JSON.parse(message); 

      if(response.table) { 
       res.jsonp(response.data); 
      } else { 
       res.jsonp(/* some error response here */) 
      } 
      // close the websocket so we don't associate any more responses 
      // with this particular http request 
      ws.close();     
     }); 
    } else { 
     // need to send some response here 
    } 
};