0

我有一个 Node/Vue 应用程序。我正在使用来自 Binance 的 WebSocket，这是一个加密交换。当我记录它们时，我可以在服务器控制台上看到引号，我可以在客户端停止记录它们之前将它们发送到浏览器一小段时间。

浏览器仅使用WebSocketAPI 节点使用ws库

节点代码，我正在运行它作为它自己的服务，就像它一样。

'use strict';
const WebSocket = require('ws');
const binanceWS = new WebSocket('wss://stream.binance.com:9443/ws/btcusdt@trade')

const server = new WebSocket.Server({ port: 5002 });


//websocket connection event will return a socket you can later use

binanceWS.on("open", function() {
 console.log("connected to Binance");

});

binanceWS.on('message', function(data){
  console.log(data);
  server.on('connection', function connection(ws){
    console.log("Connected a new client");
    ws.send(data);

  });

  server.on('closed', function (id){
    console.log("connection closed");
    console.log(id);
  });

  server.on('error', function (err){
    console.log(err)
  })

})

在客户端，我使用的是 Vue，在 app.js 文件中我有这个问题created。

let socket = new WebSocket("ws://localhost:5002")
    socket.addEventListener('message', function(event){
      let quotes = JSON.parse(event.data);
      console.log(quotes.p)
    });

    socket.addEventListener('error', function(event){
      console.log("closing because " + event);
    })

现在我只听上面app.vue文件中的控制台。

我在浏览器控制台中看到的是很多引号，然后它们在一两秒后停止。有时可能有超过一千个引号。然后有时我console.log('created')会在 的子组件中看到一个app.vue。在许多情况下，这是在数百次引用之后控制台中的最后一件事。

在服务器的 console.log 中，我看到通过一页刷新创建了很多会话。如此之多，以至于它填满了我的控制台。

所以我不确定我是否正确地创建了连接，我不确定 Vue 是否以某种方式停止了 console.log 的？

我在任何地方都看不到任何错误，并且在我的服务器控制台中，Binance API 一直在继续流式传输。

4

1 回答 1

1

您必须在消息处理程序上的 binance 之外编写服务器事件侦听器；

然后您可以通过向服务器发送新事件来将消息从币安传递到服务器

从币安接收消息后，您可以将数据发送到服务器上的所有连接

或者试试这个代码，我认为它会起作用：

'use strict';
const WebSocket = require('ws');
const binanceWS = new WebSocket('wss://stream.binance.com:9443/ws/btcusdt@trade')

const server = new WebSocket.Server({ port: 5002 });

server.on('connection', function connection(ws){
    console.log("Connected a new client");

  });

  server.on('closed', function (id){
    console.log("connection closed");
    console.log(id);
  });

  server.on('error', function (err){
    console.log(err)
  })

//websocket connection event will return a socket you can later use

binanceWS.on("open", function() {
 console.log("connected to Binance");

});


binanceWS.on('message', function(data){
  console.log(data);
 server.clients.forEach(function each(client) {
  if (client.readyState === WebSocket.OPEN) {
    client.send(data);
  }
 });   

})
于 2019-08-23T00:26:41.467 回答