From 763b436981c512fd1d222e3450c994ff121ff822 Mon Sep 17 00:00:00 2001
From: Alexander Tim Hobelsberger
<alexander_tim.hobelsberger@student.reutlingen-university.de>
Date: Wed, 14 Dec 2022 14:09:16 +0100
Subject: [PATCH] redisDapater
---
index.js | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
diff --git a/index.js b/index.js
index 18a0ef9..e765e9a 100644
--- a/index.js
+++ b/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', {
--
GitLab