feat: redis service에 lock 적용

Author: ezcolin2

apps/backend/src/page/page.service.ts

@@ -64,7 +64,7 @@ export class PageService {
 
   async deletePage(id: number): Promise<void> {
     // 락을 획득할 때까지 기다린다.
-    const lock = await this.redisLock.acquire([id.toString()], 1000);
+    const lock = await this.redisLock.acquire([`user:${id.toString()}`], 1000);
     try {
       // 페이지를 삭제한다.
       const deleteResult = await this.pageRepository.delete(id);
@@ -81,7 +81,7 @@ export class PageService {
 
   async updatePage(id: number, dto: UpdatePageDto): Promise<Page> {
     // 락을 획득할 때까지 기다린다.
-    const lock = await this.redisLock.acquire(['user:' + id.toString()], 1000);
+    const lock = await this.redisLock.acquire([`user:${id.toString()}`], 1000);
     try {
       // 갱신할 페이지를 조회한다.
       // 페이지를 조회한다.

apps/backend/src/red-lock/red-lock.module.ts

@@ -1,12 +1,12 @@
-import { Module } from '@nestjs/common';
+import { Module, forwardRef } from '@nestjs/common';
 import Redis from 'ioredis';
 import Redlock from 'redlock';
 import { RedisModule } from '../redis/redis.module';
 const RED_LOCK_TOKEN = 'RED_LOCK';
 const REDIS_CLIENT_TOKEN = 'REDIS_CLIENT';
 
 @Module({
-  imports: [RedisModule],
+  imports: [forwardRef(()=>RedisModule)],
   providers: [
     {
       provide: RED_LOCK_TOKEN,

apps/backend/src/redis/redis.module.ts

@@ -1,13 +1,14 @@
-import { Module } from '@nestjs/common';
+import { Module, forwardRef } from '@nestjs/common';
 import { ConfigModule, ConfigService } from '@nestjs/config';
 import { RedisService } from './redis.service';
 import Redis from 'ioredis';
+import { RedLockModule } from '../red-lock/red-lock.module';
 
 // 의존성 주입할 때 redis client를 식별할 토큰
 const REDIS_CLIENT_TOKEN = 'REDIS_CLIENT';
 
 @Module({
-  imports: [ConfigModule], // ConfigModule 추가
+  imports: [ConfigModule, forwardRef(() => RedLockModule)], // ConfigModule 추가
   providers: [
     RedisService,
     {

apps/backend/src/redis/redis.service.ts

@@ -1,18 +1,21 @@
 import { Injectable } from '@nestjs/common';
 import { Inject } from '@nestjs/common';
 import Redis from 'ioredis';
+import Redlock from 'redlock';
 const REDIS_CLIENT_TOKEN = 'REDIS_CLIENT';
+const RED_LOCK_TOKEN = 'RED_LOCK';
 
 type RedisPage = {
   title?: string;
-  content?: string
+  content?: string;
 };
 @Injectable()
 export class RedisService {
   // private readonly redisClient: Redis;
 
   constructor(
     @Inject(REDIS_CLIENT_TOKEN) private readonly redisClient: Redis,
+    @Inject(RED_LOCK_TOKEN) private readonly redisLock: Redlock,
   ) {}
 
   async getAllKeys(pattern) {
@@ -31,14 +34,32 @@ export class RedisService {
   }
 
   async set(key: string, value: object) {
-    return await this.redisClient.hset(key, Object.entries(value));
+    // 락을 획득할 때까지 기다린다.
+    const lock = await this.redisLock.acquire([`user:${key}`], 1000);
+    try {
+      await this.redisClient.hset(key, Object.entries(value));
+    } finally {
+      lock.release();
+    }
   }
 
   async setField(key: string, field: string, value: string) {
-    return await this.redisClient.hset(key, field, value);
+    // 락을 획득할 때까지 기다린다.
+    const lock = await this.redisLock.acquire([`user:${key}`], 1000);
+    try {
+      return await this.redisClient.hset(key, field, value);
+    } finally {
+      lock.release();
+    }
   }
 
   async delete(key: string) {
-    return await this.redisClient.del(key);
+    // 락을 획득할 때까지 기다린다.
+    const lock = await this.redisLock.acquire([`user:${key}`], 1000);
+    try {
+      return await this.redisClient.del(key);
+    } finally {
+      lock.release();
+    }
   }
 }