logo标签列表

Websocket - 浏览器websocket无法从服务器接收消息

javascriptnode.jshtmlwebsocket
3
我使用Node构建了一个WebSocket服务器和客户端，两者都运行良好。但是，我在单个HTML页面上构建了一个客户端，在那里，WebSocket只有在我从浏览器调用sendUTF时才会监听消息。由Node客户端发送的消息无法被浏览器客户端读取。这是安全问题/功能还是我的问题？
服务器代码：
var WebSocketServer = require('websocket').server;
var http = require('http');

var server = http.createServer( (req, res) => {
    console.log((new Date()) + ' Received request for ' + request.url);
    res.writeHead(404);
    res.end();
});

server.listen(8080, () => {
    console.log((new Date()) + ' Server is listening on port 8080');
});

wsServer = new WebSocketServer({
    httpServer: server,
    // You should not use autoAcceptConnections for production 
    // applications, as it defeats all standard cross-origin protection 
    // facilities built into the protocol and the browser.  You should 
    // *always* verify the connection's origin and decide whether or not 
    // to accept it. 
    autoAcceptConnections: false
});

function originIsAllowed(origin) {
  // put logic here to detect whether the specified origin is allowed. 
  return true;
}

wsServer.on('request', (request) => {
/*    if (!originIsAllowed(request.origin)) {
      // Make sure we only accept requests from an allowed origin 
      request.reject();
      console.log((new Date()) + ' Connection from origin ' + request.origin + ' rejected.');
      return;
    }*/

    var connection = {};
    try {
        connection = request.accept('echo-protocol', request.origin);
        console.log((new Date()) + ' Connection accepted.');
        connection.on('message', function(message) {
            if (message.type === 'utf8') {
                console.log('Received and send Message: ' + message.utf8Data);
                connection.sendUTF(message.utf8Data);
            }
            else if (message.type === 'binary') {
                console.log('Received Binary Message of ' + message.binaryData.length + ' bytes');
                connection.sendBytes(message.binaryData);
            }
            else {
                console.log('Received unknown format message: ' + message);
                connection.send(message);
            }
        });

        connection.on('close', function(reasonCode, description) {
            console.log((new Date()) + ' Peer ' + connection.remoteAddress + ' disconnected.');
        });        
    }
    catch(e) {
        console.error("Client fail trying to connect to websocket: " + e);
    }


});

Node客户端代码：

var express = require('express');
var app = express();
server = require('http').createServer(app);
var WebSocketClient = require('websocket').client;

var kinect = new Kinect2();

app.use(express.static(__dirname + 'js/View'));
//app.use(express.static(__dirname + 'js/Script'));

//instance of WebSocket object
var wsClient = new WebSocketClient();

//Websocket connection events
wsClient.on('connectFailed', function(error) {
    console.log('Connect Error: ' + error.toString());
    process.exit(0);
});

wsClient.on('connect',(connection) => {


    connection.on('error', (error) => {
      console.error("Connection Error: " + error.toString());
      process.exit(0);
    });

    connection.on('close',() => {
      console.log("Websocket connection is closed!");
    });

    // connection.on('message',(message) => {
    //   if (message.type === 'utf8') {
    //     console.log("Received: '" + message.utf8Data + "'");
    //   }
    // });
    console.log('Websocket connection OK!');

    setInterval(() => {
      console.log("sending message...");
      connection.send("This is a test!");
    },1000);
    //startKinect(connection);

});

wsClient.connect('ws://127.0.0.1:8080','echo-protocol');

最终我的浏览器客户端。
<!DOCTYPE html>
<html>
<head>
    <title>
        Websocket test
    </title>                                                     
</head>
<body>
    <h1>Websocket client test</h1>

    <script>
        console.log("Open Websocket...");
        var websocket = new WebSocket('ws://127.0.0.1:8080','echo-protocol');

        websocket.onopen = function () {
          console.log("websocket was open");
          //websocket.send('Websocket is working(I gess)');
        };

        websocket.onclose = () => {
          console.log("Websocket was closed!");
        }

        websocket.onerror = (error) =>{
          console.error("Websocket error: " + JSON.stringify(error));
        };

        websocket.onmessage = (message) => {
          // Web Socket message:

            console.log("MSG: " + message.data );


        };

        websocket.addEventListener('message',(e) => {
          websocket.onmessage(e);
        })

    </script>

</body>
</html>

欢迎提出任何问题！感谢您的支持！

如果我理解正确，您正在尝试通过WebSockets从Node客户端与浏览器客户端进行通信？这是不明确可能的，因为WebSockets使用服务器进行双工通信，而不是客户端和客户端之间。然而，似乎有一些在WebSockets中进行P2P通信的进展，这可能会对您有所帮助：https://dev59.com/K2855IYBdhLWcg3w1oE8 - Josh Weston
不是这样的！有一个websocket服务器和两个客户端。Nodejs客户端是“生产者”，可以写入websocket。浏览器客户端是“消费者”，应该能够从websocket中读取，除非我的概念有误。 - Andre Carneiro
2个回答
1

看起来我错过了“广播”部分。幸运的是，“ws”模块使我可以非常容易地做到这一点！

const WebSocket = require('ws');
var port = 8080;
const wss = new WebSocket.Server({ "port": port });

// Broadcast to all.
wss.broadcast = function broadcast(data) {
  wss.clients.forEach(function each(client) {
    if ( client.readyState == WebSocket.OPEN && data != undefined ) 
      client.send(data);
  });
};

wss.on('connection', function connection(ws) {
  console.log("CONNECTION OK...");
  ws.on('message', function incoming(data) {
    // Broadcast to everyone else.
    wss.broadcast(data);
  });
});
1
你的服务器正作为回声（客户端 -> 服务器 -> 客户端）工作，但你所描述的是广播（客户端 -> 服务器 -> 客户端s）。你应该保留客户端的参考并将信息发送给所有客户端。
在request事件处理程序之外添加：
var connections = [];

在接受请求后，将连接添加到数组中：
connections.push( connection );

当您想要向所有人发送数据时，请循环遍历连接：

for ( var i = 0; i < connections.length; i++ )
    connections[ i ].sendUTF( message.utf8Data );
谢谢您的回答！但是我不明白如果这个对象只存在于“请求”对象中，那么我如何在“请求”事件之外使用“连接”对象呢？您能解释一下吗？ - Andre Carneiro
网页内容由stack overflow 提供, 点击上面的
可以查看英文原文，
原文链接