javascript - 如何使用 node.js 使 Websocket 服务器安全
问题描述
我的基于 node.js 的 websocket 服务器适用于 ws:// 但不适用于 wss://
服务器在我的 Raspberry Pi B 3+ 上运行。现在我已经在我的 JavaScript 文件中将 ws:// 更改为 wss://,它不再起作用了。
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' 是一个子域,它通过 dns 引用 Raspberry Pi 的 IP。我收到以下错误:
WebSocket 连接到“wss://myDomain:4445/”失败:连接建立错误:net::ERR_CONNECTION_CLOSED
解决方案
也许它会帮助你
例子:
节点服务器.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}`));
React 中的客户端
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;
推荐阅读
- android - 附近的连接 - Kindle 上显示的移动热点图标,尽管在设置中没有选项
- vba - 在 Outlook 365 中插入指向附加文档的链接
- java - 如何即时删除菜单项?
- amazon-web-services - Route 53 + AWS Lambda 的 URL
- php - 从关系函数访问模型属性
- javascript - 使用 php 和 sweet alert 2 删除文件
- c - realloc 上的错误:损坏的大小与 prev_size
- algorithm - Space complexity for recursive calls
- c++ - Visual Studio Code“未定义对‘WinMain@16’的引用”
- r - 按组将值替换为同一列中的另一个值