Skalierbarkeit

index.js

@@ -14,6 +14,7 @@ const server = http.createServer(app);
   cert: fs.readFileSync(__dirname + '/tls/cert.pem'),
   }, app);
    */
+
 const { Server } = require("socket.io");
 const io = new Server(server);
 const bodyParser = require('body-parser');
@@ -27,9 +28,13 @@ const User = require('./models/user');
 var port = process.env.PORT || 3000;
 const redis = require('socket.io-redis');
 const { createAdapter } = require('@socket.io/redis-adapter');
+const { createClient } = require('redis');
+
+const pubClient = createClient({ host: 'localhost', port: 6379 });
+const subClient = pubClient.duplicate();
+
+io.adapter(createAdapter(pubClient, subClient));
 
-//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");
@@ -283,7 +288,7 @@ io.on('connection', (socket) => {
       var msg = response.msg;
       var name = response.name;
       var dateTime = new Date().toTimeString();
-
+      console.log("Received Message: " + msg);
       messageCounterOut.inc(activeUsers.size);
 
       io.emit('chat message', {