개요

현재는 클라이언트와 서버의 연동을 확인하기 위해 작업한 CRDT 문서들을 서버에 인스턴스로 저장하고 있다

이제 우리는 워크스페이스와 페이지들을 MongoDB에 직접 저장해야 한다

데이터 저장 형식

• 데이터는 우리가 직접 개발한 CRDT 구조를 따른다
  • [CRDT] 몰아보기

Workspace 데이터

• 데이터 문자열로 뽑는 방법

  • 우리가 구현한 CRDT 라이브러리는 객체를 JSON으로 변환하는 serialize() 메서드가 있다
  • 따라서 WorkSpace 객체를 serialize()한 결과를 JSON.stringify()로 출력하면 된다

  console.log(JSON.stringify(workspace.serialize(), null, 2));
  

• 실제 출력값 (주의! 797줄임 (노션은 코드 블럭이 500줄이 넘어가면 syntax highlighting이 적용되지 않는다..))

CRDT가 적용되는 데이터 구조

• workspace → Workspace

DB 저장에 있어 고려해야 할 점

DB를 언제 어떻게 업데이트해야 할까?

• 페이지가 수정될 때마다 이를 DB에 적용하는 것은 굉장히 비효율적이다
  • 수정될 때마다 저장한다면 글자 하나하나 바뀔 때마다 DB에 저장하게 되니까
• 작업 내용을 일시적으로 서버에 저장하고 있다가 주기적으로 이를 DB에 반영하는 것이 좋아보인다
  • 현재 로직에서는 인메모리에 Map으로 저장하고 있으니 이걸 그대로 쓰면 되겠다
• 그렇다면 주기를 어떻게 잡을 것인가?
  • 인메모리로 저장하고 있다면 자주 저장할 필요가 없을 것 같다(서버만 안전하다면…)
  • 메인 데이터는 DB에 저장하고 인메모리는 임시로 저장하는 것이니 인메모리 데이터를 영구히 유지할 필요가 없다
  • 그렇다면 서버 자원 최적화를 위해 인메모리 데이터를 주기적으로 비워줘야 한다
    • 비우는 조건을 어떻게 설정할 수 있지?
      • 해당 워크스페이스에서 작업중인 사람이 없을 때(소켓 룸에 아무도 없을 때)
  • 인메모리 데이터를 정리할 때 그 상태를 DB에 저장하면 DB 연산을 최소화하면서도 내용을 유지할 수 있지 않을까?
  • 그렇다면 가비지 컬렉터를 구현할 때 DB에다 저장하는 로직도 추가해보자

구현해보기

인메모리 DB 가비지 컬렉터

초기 구현

• 인메모리 DB에서 작업 중인 클라이언트가 없는 워크스페이스를 비울 때, DB에 해당 워크스페이스를 업데이트하고 인메모리 DB에서 제거한다

@Injectable()
export class workSpaceService implements OnModuleInit {
  private workspaces: Map<string, CRDTWorkSpace>;
  private server: Server;
  constructor(@InjectModel(Workspace.name) private workspaceModel: Model<WorkspaceDocument>) {}

  // Socket.IO 서버 인스턴스 설정
  setServer(server: Server) {
    this.server = server;
  }

  async onModuleInit() {
    this.workspaces = new Map();
    // 게스트 워크스페이스 초기화
    const guestWorkspace = new CRDTWorkSpace("guest", []);
    this.workspaces.set("guest", guestWorkspace);

    // 주기적으로 인메모리 DB 정리 작업 실행
    setInterval(
      () => {
        this.cleanupWorkspaces();
      },
      process.env.NODE_ENV === "production" ? 1 * 60 * 60 * 1000 : 30 * 1000,
    );
  }

	private async cleanupWorkspaces() {
	  try {
	    for (const [roomId, workspace] of this.workspaces.entries()) {
	      // guest workspace는 제외
	      if (roomId === "guest") continue;
	
	      // room의 연결된 클라이언트 수 확인
	      const room = this.server.sockets.adapter.rooms.get(roomId);
	      const clientCount = room ? room.size : 0;
	
	      if (clientCount === 0) {
	        // DB에 workspace 상태 저장
	        await this.updateWorkspaceInDB(roomId, workspace);
	
	        // Map에서 제거
	        this.workspaces.delete(roomId);
	
	        console.log(`Workspace ${roomId} has been saved to DB and removed from memory`);
	      }
	    }
	
	    console.log("Workspace cleanup completed, current workspaces: ", this.workspaces.keys());
	  } catch (error) {
	    console.error("Error during workspace cleanup: ", error);
	  }
	}