nginxConfig

docker-compose.yaml

@@ -11,46 +11,48 @@ services:
       - server-ringo
     ports:
       - "3600:80"
+    logging:
+      driver: none
 
   server-john:
     build: ./
     links:
       - redis
     expose:
-      - "3600"
+      - "3601"
     environment:
       - NAME=john
-      - PORT=3600
+      - PORT=3601
 
   server-paul:
     build: ./
     links:
       - redis
     expose:
-      - "3600"
+      - "3602"
     environment:
       - NAME=paul
-      - PORT=3600
+      - PORT=3602
 
   server-george:
     build: ./
     links:
       - redis
     expose:
-      - "3600"
+      - "3603"
     environment:
       - NAME=george
-      - PORT=3600
+      - PORT=3603
 
   server-ringo:
     build: ./
     links:
       - redis
     expose:
-      - "3600"
+      - "3604"
     environment:
       - NAME=ringo
-      - PORT=3600
+      - PORT=3604
 
   redis:
     image: redis

index.js

@@ -26,11 +26,11 @@ const { resolve } = require('path');
 const User = require('./models/user');
 var port = process.env.PORT || 3000;
 const redis = require('socket.io-redis');
+const { createAdapter } = require('@socket.io/redis-adapter');
 
 //Redis Adapter so every packet is sent to all matching clients connected to the current Server
 io.adapter(redis({ host: 'redis', port: 6379 }));
 
-
 //DB Connection
 //mongoose.connect("mongodb://mongodb:27017/cloudComputing");
 
@@ -190,6 +190,7 @@ app.get('/login', (req, res) => {
 io.on('connection', (socket) => {
   
   socket.on('userLogin', async function(response) {
+    console.log("userLogin event on: " + port);
     await addUserToActiveUsers(response, socket);
     clientActiveUsers.set(activeUsers.size);
   });
@@ -223,7 +224,7 @@ async function addUserToActiveUsers(response, socket) {
     clientActiveUsers.set(activeUsers.size);
     
     var userArr = Array.from(activeUsers.values());
-    console.log(userArr);
+    //console.log(userArr);
     io.emit('updateUserlist', {
       userList : userArr
     });
@@ -487,8 +488,6 @@ function serverListen() {
   server.listen(process.env.PORT, function () {
 
     console.log('Server listening at port %d', port);
-    console.log('Server listening at port', process.env.PORT);
-
     console.log('Hello, I\'m ', process.env.NAME, ' how can I help?');
 
   });

nginx/nginx.conf

@@ -26,15 +26,15 @@ http {
   upstream nodes {
     # enable sticky session with either "hash" (uses the complete IP address)
     #hash $remote_addr consistent;
-    least_conn;
+    # least_conn;
     # or "ip_hash" (uses the first three octets of the client IPv4 address, or the entire IPv6 address)
-    # ip_hash;
+    ip_hash;
     # or "sticky" (needs commercial subscription)
     # sticky cookie srv_id expires=1h domain=.example.com path=/;
 
-    server server-john:3600;
-    server server-paul:3600;
-    server server-george:3600;
-    server server-ringo:3600;
+    server server-john:3601;
+    server server-paul:3602;
+    server server-george:3603;
+    server server-ringo:3604;
   }
 }
\ No newline at end of file