Nginx实现websocket代理


server.js

console.log("Server started");
var Msg = '';
var WebSocketServer = require('ws').Server
        ,wss = new WebSocketServer({port:8011});
wss.on("connection",function(ws){
        ws.on("message",function(message){
        console.log("Receuved from client:%s ",message);
        ws.send("server received from client:",message)
     })
})

测试

wscat --connect ws ://127.0.0.1:8020

test2026-06-12 13:15


map $http_upgrade $connection_upgrade {
    default upgrade;
    '' close;
}
upstream websocket {
    server 127.0.0.1:8011;
}
server
{
    listen 8020;
    access_log /var/log/nginx/test_websocket.log main;
    location /ws/ {
        proxy_pass http://websocket;
        proxy_http_version 1.1;
        proxy_set_header Upgrade $http_upgrade;
        proxy_set header Connection $connection_upgrade;
    }
}

test2026-06-12 13:24