Как сделать Сервер для Websocket безопасным с помощью node.js

Question

Мой сервер веб-сокетов, основанный на node.js, работает для ws: //, но не для wss: //

Сервер работает на моем Raspberry Pi B 3+.Теперь, когда я изменил ws: // на wss: // в моем файле JavaScript, он больше не работает.

Сервер node.js:

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

wss.on('connection', function connection(ws) {
    console.log("New client connected.");

    ws.on('message', function incoming(data) {
        console.log(data);
        ws.close();
    });

    ws.on('close', function close() {
        console.log("Client disconnected.");
    });

});

Клиент JavaScript:

var connection = new Websocket('wss://myDomain:4445');

connection.onopen = function () {
    connection.send("Hello");
    connection.close();
}

connection.onerror = function (error) {
    console.log(error);
    connection.lose();
}

'myDomain' - это поддомен, который ссылается на IP Raspberry Pi через dns.Я получаю следующую ошибку:

Сбой соединения WebSocket с 'wss: // myDomain: 4445 /': Ошибка при установлении соединения: net :: ERR_CONNECTION_CLOSED

Answer 1

Может быть, это поможет вам

Пример:

Узел server.js

const express = require("express");
const http = require("http");
const socketIo = require("socket.io");
const axios = require("axios");
const port = process.env.PORT || 4445;
const index = require("./routes/index");
const app = express();
app.use(index);
const server = http.createServer(app);
const io = socketIo(server); 

let interval;
io.on("connection", socket => {
  console.log("New client connected");
  if (interval) {
    clearInterval(interval);
  }
  interval = setInterval(() => getApiAndEmit(socket), 10000);
  socket.on("disconnect", () => {
    console.log("Client disconnected");
  });
});

const getApiAndEmit = async socket => {
    try {
      const res = await axios.get(
        "https://b.application.com/api/v1/scores?expand=createdBy"
      );
      socket.emit("FromAPI", res.data); // Emitting a new message. It will be consumed by the client
    } catch (error) {
      console.error(`Error: ${error.code}`);
    }
  };

server.listen(port, () => console.log(`Listening on port ${port}`));

Реагирующий клиент

import socketIOClient from "socket.io-client";

class App extends Component {
  constructor (props) {
    super(props);
    this.state = {
      scores: []
      endpoint: "http://127.0.0.1:4445" 
    }
  }

componentDidMount() {
  const { endpoint } = this.state;

  const socket = socketIOClient(endpoint);

  socket.on("FromAPI", data => this.setState({ scores: data }));
}


  render () {
      <div>
      </div>
    )
  }
}

export default App;