fscarmen2
commented
3 months ago 问 ai
nodejs如何做到像 nginx 一样的websocket ，通过 /a 或者 /b 或者 /c ，location 到 8080端口
ChatGPT
ChatGPT ChatGPT
Poe
要在 Node.js 中实现类似 Nginx 的 WebSocket 代理功能，让不同的路径（例如 /a、/b、/c）转发到不同的后端 WebSocket 服务器（例如 8080 端口），可以使用以下代码示例：
javascript 复制
const http = require('http');
const httpProxy = require('http-proxy');
const WebSocket = require('ws');
// 创建一个 HTTP 代理服务器
const proxy = httpProxy.createProxyServer({});
// 创建一个 HTTP 服务器
const server = http.createServer((req, res) => {
const { url } = req;
// 根据请求路径进行分流
if (url.startsWith('/a')) {
proxy.web(req, res, { target: 'ws://localhost:8080' });
} else if (url.startsWith('/b')) {
proxy.web(req, res, { target: 'ws://localhost:8081' });
} else if (url.startsWith('/c')) {
proxy.web(req, res, { target: 'ws://localhost:8082' });
} else {
res.statusCode = 404;
res.end('Not Found');
}
});
// 创建 WebSocket 服务器
const wss1 = new WebSocket.Server({ noServer: true });
const wss2 = new WebSocket.Server({ noServer: true });
const wss3 = new WebSocket.Server({ noServer: true });
// 将 WebSocket 服务器附加到 HTTP 服务器上
server.on('upgrade', (req, socket, head) => {
const { url } = req;
// 根据请求路径进行 WebSocket 升级
if (url.startsWith('/a')) {
wss1.handleUpgrade(req, socket, head, (ws) => {
wss1.emit('connection', ws, req);
});
} else if (url.startsWith('/b')) {
wss2.handleUpgrade(req, socket, head, (ws) => {
wss2.emit('connection', ws, req);
});
} else if (url.startsWith('/c')) {
wss3.handleUpgrade(req, socket, head, (ws) => {
wss3.emit('connection', ws, req);
});
} else {
socket.destroy();
}
});
// 启动服务器
server.listen(80, () => {
console.log('Server is running on port 80');
});以上代码使用了 http-proxy 模块来创建一个 HTTP 代理服务器，并使用 http 模块创建一个 HTTP 服务器。根据请求的路径进行分流，将不同的路径转发到不同的后端 WebSocket 服务器。
同时，使用 ws 模块创建了三个 WebSocket 服务器，并通过 handleUpgrade 方法将它们附加到 HTTP 服务器上，以便处理 WebSocket 升级请求。
你可以根据需要修改示例中的路径、后端 WebSocket 服务器的地址和端口，以及服务器的监听端口。启动该 Node.js 代码后，它将监听指定的端口（例如 80），并根据请求路径将 WebSocket 请求转发到相应的后端 WebSocket 服务器。
Gemini
只使用 Node.js 实现类似 Nginx 的 WebSocket 功能，可以通过以下步骤进行：
- 安装依赖库
首先，需要安装 Node.js 的 WebSocket 库，例如 ws 或 socket.io。
npm install ws- 创建 WebSocket 服务器
使用 ws 库创建 WebSocket 服务器，并监听指定的端口。
JavaScript
const WebSocket = require('ws');
const server = new WebSocket.Server({ port: 8080 });
server.on('connection', (socket) => {
// 处理 WebSocket 连接
});请谨慎使用代码。
- 处理不同路径
根据不同的路径，使用不同的处理逻辑。例如，可以根据路径的不同，发送不同的消息或执行不同的操作。
JavaScript
const WebSocket = require('ws');
const server = new WebSocket.Server({ port: 8080 });
server.on('connection', (socket, request) => {
const pathname = request.url.pathname;
switch (pathname) {
case '/a':
// 处理 `/a` 路径
break;
case '/b':
// 处理 `/b` 路径
break;
case '/c':
// 处理 `/c` 路径
break;
}
});请谨慎使用代码。
示例代码： JavaScript
// server.js
const WebSocket = require('ws');
const server = new WebSocket.Server({ port: 8080 });
server.on('connection', (socket, request) => {
const pathname = request.url.pathname;
switch (pathname) {
case '/a':
socket.send('This is /a');
break;
case '/b':
socket.send('This is /b');
break;
case '/c':
socket.send('This is /c');
break;
}
});请谨慎使用代码。
运行示例：
node server.js测试：
使用浏览器或 WebSocket 客户端连接到 http://localhost:8080/a、http://localhost:8080/b 或 http://localhost:8080/c，即可建立 WebSocket 连接，并收到相应的消息。
Ropgrc
fscarmen
没有其他办法了吗？ 如果把临时隧道配置修改成8080，跟Xray一样，访问临时隧道的时候直接显示bad req。那么我用NodeJS搞的Web网页不就是摆设吗？ 临时隧道的配置修改成NodeJS的监听端口3000就正常了，访问临时隧道显示web网页，也能访问list节点信息，同时打入ws的路径也能访问Xray的bad req。只不过容器给的域名没了，访问容器域名直接给的是中间件代理到Xray的bad req。 我的意思是能不能让临时隧道的流量经过web，走nodejs的中间件代理到Xray？而不是把nodejs的端口占了。