🚑 !HOTFIX: redis pub/sub은 다른 클라이언트 사용하도록 변경

Author: sieunie

BE/src/common/redis/redis.domain-service.ts

@@ -4,8 +4,9 @@ import Redis from 'ioredis';
 @Injectable()
 export class RedisDomainService {
   constructor(
-    @Inject('REDIS_CLIENT')
-    private readonly redis: Redis,
+    @Inject('REDIS_CLIENT') private readonly redis: Redis,
+    @Inject('REDIS_PUBLISHER') private readonly publisher: Redis,
+    @Inject('REDIS_SUBSCRIBER') private readonly subscriber: Redis,
   ) {}
 
   async exists(key: string): Promise<number> {
@@ -64,11 +65,11 @@ export class RedisDomainService {
   }
 
   async publish(channel: string, message: string) {
-    return this.redis.publish(channel, message);
+    return this.publisher.publish(channel, message);
   }
 
   async subscribe(channel: string) {
-    await this.redis.subscribe(channel);
+    await this.subscriber.subscribe(channel);
   }
 
   on(callback: (message: string) => void) {

BE/src/common/redis/redis.module.ts

@@ -15,6 +15,24 @@ import { RedisDomainService } from './redis.domain-service';
         });
       },
     },
+    {
+      provide: 'REDIS_PUBLISHER',
+      useFactory: () => {
+        return new Redis({
+          host: process.env.REDIS_HOST || 'redis',
+          port: Number(process.env.REDIS_PORT || 6379),
+        });
+      },
+    },
+    {
+      provide: 'REDIS_SUBSCRIBER',
+      useFactory: () => {
+        return new Redis({
+          host: process.env.REDIS_HOST || 'redis',
+          port: Number(process.env.REDIS_PORT || 6379),
+        });
+      },
+    },
     RedisDomainService,
   ],
   exports: [RedisDomainService, 'REDIS_CLIENT'],