网页套库 - 从网页套筒服务器获取消息并将其发送到客户端

Question

我正在尝试学习websocket是如何工作的。我能够从websocket服务器获取交易数据并将其打印在html" target="_blank">控制台上。然而，我正在尝试了解如何将该消息传递到我的websocket服务器，以便我可以将其发送到我的websocket客户端。基本上，我想在浏览器上打印每条消息。

"use strict";

const WebSocket = require("ws");

const binanceWS = new WebSocket("wss://stream.binance.com:9443/ws/stratbtc@trade");

binanceWS.on("open", function open() {
    console.log("open action");
});

binanceWS.on("message", function incoming(data) {
    console.log(data);
});

现在，这个币安WS将在收到数据时打印数据。我正在尝试做的是如何传递给我的 WebSocket.Server 对象的发送事件侦听器。正如你从 https://github.com/websockets/ws wss本身的例子中看到的，当存在连接时，它会占用一个 websocket 对象。

const wss = new WebSocket.Server({ port: 8080 });

wss.on('connection', function connection(ws) {
  ws.on('message', function incoming(message) {
    console.log('received: %s', message);
  });

  ws.send('something');
});

谢谢！

注意:我说的结构是这样的。基本上，我会让websocket消费者获取交易数据。在同一个主机(目前是localhost)中，将有一个websocket服务器。此websocket服务器将向每个客户端web socket发送数据。

成功：好的，我通过在网络平台服务器连接中定义消费者网络密码（binanceWS）消息侦听器来实现它。我不确定这是否是一个好方法

"use strict";

const WebSocket = require("ws");

const binanceWS = new WebSocket("wss://stream.binance.com:9443/ws/stratbtc@trade");

binanceWS.on("open", function open() {
    console.log("open action");
});

const wss = new WebSocket.Server({ port: 8080 });

wss.on('connection', function connection(ws) {
  ws.on('message', function incoming(message) {
    console.log('received: %s', message);
  });

  binanceWS.on("message", function incoming(data) {
      ws.send(data);
  });
});

Answer 1

单websocket

//websocket connection event will return a socket you can later use
binanceWS.on("connection", function(socket) {
    socket.on("message", function incoming(data) {
    console.log(data);
    // if you want to send that message back to the client who sent it, 
    // you can use send method on the socket
     socket.send(data)
    });
});

嵌套Web套接字

//websocket connection event will return a socket you can later use
binanceWS.on("connection", function(socket) {
    // create another websocket here
    const wss = new WebSocket.Server({ port: 8080 });

    // connect the second websocket
     wss.on("connection", function(ws) {
      // start listening to first websocket incoming messages 
      // if second communication has successully been instantiated 
      socket.on("message", function incoming(data) {
      // send the data using the second websocket
      ws.send(data)
      })
    });
});

然后，您需要在客户机中使用最少的代码，您将看到服务器和客户机之间的交互

客户

const socket = new WebSocket('server_url'); // Connection opened 
socket.addEventListener('message', function (event) { socket.send('send message'); });

注意:由于您将使用一个websocket的传入数据到另一个websocket中，所以只有在第一个web socket已经成功打开的情况下，才最好打开第二个web socket

Answer 2

我通过保存websocket客户端的全局列表实现了这一点。当消费者websocket消息事件被触发时，它通过遍历列表发送给每个客户端。

"use strict";

const WebSocket = require("ws");

const binanceWS = new WebSocket("wss://stream.binance.com:9443/ws/eosbtc@trade");

var websocketList = [];

binanceWS.on("open", function open() {
    console.log("open action");
});

binanceWS.on("message", function incoming(data) {
    console.log(data);

    // send data to every websocket client
    websocketList.forEach(ws => {
        ws.send(data);
    });
});

const wss = new WebSocket.Server({ port: 8080 });

wss.on("connection", function connection(ws) {

    // add ws handle to websocket list.
    websocketList.push(ws);

    ws.on("close", function close() {
        console.log("Disconnected");
    });
});