websockets

hnasr · hnasr · commit d3e989a541c6 · 2021-09-17T11:38:55.000-07:00
diff --git a/nginx-websockets-practice/index.html b/nginx-websockets-practice/index.html
@@ -0,0 +1,28 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <meta http-equiv="X-UA-Compatible" content="IE=edge">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>Document</title>
+</head>
+<body>
+    <h1>Hello, WebSockets</h1>
+    <input type = 'text' id = 'txt'>
+    <div id = 'divOut'></div>
+    <script>
+    const txtBox = document.getElementById("txt");
+    const divOut = document.getElementById("divOut");
+    const ws = new WebSocket("ws://localhost/wschat/")
+    ws.onmessage = e=> divOut.innerHTML += e.data + "<br/>";
+    txtBox.addEventListener("keypress", e=> {
+        if (e.keyCode === 13){
+
+          ws.send(txtBox.value);
+        txtBox.value ="";
+        }
+    })
+    </script>
+
+</body>
+</html>
diff --git a/nginx-websockets-practice/index.js b/nginx-websockets-practice/index.js
@@ -0,0 +1,17 @@
+const http = require("http");
+const WebSocketServer = require("websocket").server;
+const httpServer = http.createServer();
+const websocketServer = new WebSocketServer( 
+        {"httpServer": httpServer})
+const PORT = process.argv[2] || 8080;
+let connection = null;
+httpServer.listen(PORT, () => console.log(`Listening on port ${PORT}`))
+
+websocketServer.on("request", request => {
+
+    connection = request.accept(null, request.origin);
+    connection.on("message", data => {
+        console.log(`Hey I received a message ${data.utf8Data}`);
+        connection.send(`Hey Client! Received your message  ${data.utf8Data} on ${PORT}`)
+    })
+})
diff --git a/nginx-websockets-practice/package.json b/nginx-websockets-practice/package.json
@@ -0,0 +1,11 @@
+{
+  "name": "nginx-websockets-practice",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "",
+  "license": "ISC"
+}
diff --git a/nginx-websockets-practice/tcp.cfg b/nginx-websockets-practice/tcp.cfg
@@ -0,0 +1,20 @@
+stream {
+
+    upstream wsbackends {
+
+        server 127.0.0.1:2222;
+        server 127.0.0.1:3333;
+        server 127.0.0.1:4444;
+        server 127.0.0.1:5555;
+    }
+
+    server {
+        listen 80;
+        proxy_pass wsbackends;
+    }
+
+
+}
+
+
+events { }
diff --git a/nginx-websockets-practice/useful.txt b/nginx-websockets-practice/useful.txt
@@ -0,0 +1,10 @@
+#kill all node processes
+sudo killall node
+#stop nginx
+nginx -s stop
+#kill any dead nginx processes
+sudo killall nginx 
+#run node 
+node index.js 2222 & node index.js 3333 & node index.js 4444 & node index.js 5555  
+#run nginx with a config
+nginx -c /Users/HusseinNasser/javascript/javascript_playground/nginx-websockets/tcp.cfg 
diff --git a/nginx-websockets-practice/ws.cfg b/nginx-websockets-practice/ws.cfg
@@ -0,0 +1,46 @@
+http {
+
+    upstream wsapp {
+
+        server 127.0.0.1:2222;
+        server 127.0.0.1:3333;
+    }
+    
+    upstream wschat {
+
+        server 127.0.0.1:4444;
+        server 127.0.0.1:5555;
+
+    }
+    server {
+        listen 80;
+
+        location / {
+            root /Users/HusseinNasser/javascript/javascript_playground/nginx-websockets-practice/;
+        }
+
+        location /wsapp {
+                proxy_pass http://wsapp;
+                proxy_http_version 1.1;
+                proxy_set_header Upgrade $http_upgrade;
+                proxy_set_header Connection "Upgrade";
+                proxy_set_header Host $host;
+
+        }
+
+        location /wschat {
+
+                proxy_pass http://wschat;
+                
+                proxy_http_version 1.1;
+                proxy_set_header Upgrade $http_upgrade;
+                proxy_set_header Connection "Upgrade";
+                proxy_set_header Host $host;
+        }
+    }
+
+
+}
+
+
+events { }
