转发websocket到websocket

npm install ws

const WebSocket = require('ws');

// 配置源WebSocket服务器和目标WebSocket服务器的URL
const sourceUrl = 'ws://source-server-url'; // 替换为源WebSocket服务器地址
const targetUrl = 'ws://target-server-url'; // 替换为目标WebSocket服务器地址

// 创建一个WebSocket连接到源服务器
const source = new WebSocket(sourceUrl);

// 当源连接打开时，创建一个监听客户端连接的WebSocket服务器
source.on('open', () => {
  console.log('Connected to source WebSocket server');

  const wss = new WebSocket.Server({ port: 8080 }); // 监听端口，例如8080

  wss.on('connection', (client) => {
    console.log('Client connected');

    // 将客户端消息转发到源服务器
    client.on('message', (message) => {
      console.log(`Received from client: ${message}`);
      source.send(message);
    });

    // 将源服务器消息转发到客户端
    source.on('message', (message) => {
      console.log(`Received from source: ${message}`);
      client.send(message);
    });

    // 处理客户端断开连接
    client.on('close', () => {
      console.log('Client disconnected');
      source.close();
    });
  });

  console.log(`WebSocket proxy server is listening on port 8080`);
});

// 处理源连接错误
source.on('error', (error) => {
  console.error(`Source connection error: ${error.message}`);
});

// 处理源连接关闭
source.on('close', () => {
  console.log('Disconnected from source WebSocket server');
});

node websocket-proxy.js

http {
    map $http_upgrade $connection_upgrade {
        default upgrade;
        ''      close;
    }

    server {
        listen 80;
        server_name your-domain.com;

        location /ws {
            proxy_pass http://target-server-url;
            proxy_http_version 1.1;
            proxy_set_header Upgrade $http_upgrade;
            proxy_set_header Connection $connection_upgrade;
            proxy_read_timeout 86400;
        }
    }
}

sudo nginx -s reload