https://ahmetimamoglu.com.tr/nginx-ve-node-js-ile-ssl-web-socket-uygulamasi-nasil-yapilir

01-node-app.js

const fs = require('fs');
const https = require('https');
const WebSocket = require('ws');

const server = https.createServer({
    cert: fs.readFileSync('/home/user/certificates/test.com.crt'), // Domain SSL Certificate
    key:  fs.readFileSync('/home/user/certificates/test.com.key'), // Domain SSL Private Key
});

const wss = new WebSocket.Server({ server });

const port = 9443; // Burada tanımladığımız port numarasını Nginx sunucumuzda da aynı şekilde tanımlayacağız.

wss.on('connection', function connection(ws) {
    
    ws.on('message', function incoming(message) {
        console.log('Alınan Mesaj: %s', message);
    });
    
    // Bağlanan kullanıcıya ilk mesajımızı gönderiyoruz...
    let data = JSON.stringify({message: 'Hoşgeldiniz...'});
    ws.send(data);

});

// Test için her 5 saniyede aktif kullanıcılara mesaj gönder...
setInterval(function () {
    sendMessageActiveUsers('Test');
}, 5000);

function sendMessageActiveUsers(message)
{
    let data = JSON.stringify({message: message});
    
    wss.clients.forEach(function each(client) {
        if (client.readyState === WebSocket.OPEN) {
            client.send(data);
        }
    });
}

server.listen(port);

02-nginx.sh

server {
    listen 443;

    root /home/user/test.com;
    index index.php;
    server_name test.com;

    ssl                         on;
    ssl_certificate             /home/user/certificates/test.com.crt;
    ssl_certificate_key         /home/user/certificates/test.com.key;

    location / {
        try_files $uri $uri/ /index.php?$query_string;
    }

    location /websocket/ {
        # Aşağıdaki port numarası node js sunucumuzun çalıştığı port numarası olmalıdır!
        proxy_pass https://localhost:9443;
        proxy_http_version 1.1;
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection "upgrade";
        proxy_set_header Host $host;

    }

    location ~ \.php$ {
        include snippets/fastcgi-php.conf;
        fastcgi_pass unix:/run/php7.2-fpm-test.sock;
    }
}

03-client.js

let socket = new WebSocket("wss://test.com/websocket/");

socket.onopen = function()
{
    console.log("Socket bağlandı...");
};

socket.onclose = function()
{
    console.log("Socket bağlantısı kesildi.");
};

socket.onmessage = function(event)
{
    try {
        
        let data = JSON.parse(event.data);
        
        console.log('Socket mesajı alındı.');
        console.log(data);
        
    } catch (e) {
        
        console.log('Socket mesajı JSON formatında değil');
        
    }
};