Redis와 Pub,Sub 패턴을 이용한 Look Aside & Write Back 구현

Scenario

1. 게시글과 게시글에 달린 댓글 기능을 지원함
2. 게시글의 수정 사항은 사용자에게 바로 노출되어야 함
3. 게시글은 읽기 작업이 많고 댓글은 읽기/쓰기 작업이 많은 상황을 가정함
4. 댓글은 사용자에게 실시간 응답을 보장하지 않아도 됨
5. 댓글이 작성된 순서는 보장되어야 함

Domain definition

• feed - 게시글
• comment - 게시글에 달린 댓글

Feature Implement

• Feed 읽기 - 많은 읽기 작업이 필요하므로 Look Aside 사용
• Feed 쓰기 - 사용자에게 변경 사항이 즉시 노출되어야 하므로 Write Through 사용
• Comment 읽기 - 많은 읽기 작업이 필요하므로 Look Aside 사용
• Comment 쓰기 - 실시간 응답을 보장하지 않아도 되고 쓰기 작업이 많기 때문에 Write Back 사용

Details

Implement Write Back

• Comment는 쓰기 작업이 많기 때문에 buffer를 적용하여 특정 조건을 만족하면 트랜잭션으로 일괄 저장하도록 구현
• Redis를 buffer와 Message Queue로 사용, 댓글 쓰기 시도 시 buffer에 저장 후 key를 publish
• subsciber는 해당 key를 array에 저장함. array가 가득 차거나 특정 시간이 지나면 array에 있는 모든 key를 buffer에서 조회하여 DB에 트랜잭션으로 일괄 저장
• 새롭게 추가된 Comment들은 기존 Comment cache 만료 시 사용자에게 노출됨

Infra Architecture

Result

Build

# Only UNIX environment
make init-dotenv    # Set env
make up    # Init application

Test

아래 URL을 이용해 테스트 가능

• 게시글 작성
• 게시글 조회
• 댓글 작성
• 댓글 조회

API Spec

Feed

• GET /api/user/{user_id}/feeds

  • 게시글 목록 조회

• POST /api/user/{user_id}/feed

  • 게시글 작성
  • Request Body

  {   
      "title" : "string",
      "content": "string",
      "image_urls": "string"
  }

• PUT /api/user/{user_id}/feed/{feed_id}

  • 게시글 수정
  • Request Body

  {   
      "title" : "string",
      "content": "string",
      "image_urls": "string"
  }

• DELETE /api/user/{user_id}/feed/{feed_id}

  • 게시글 삭제

• GET /api/feed/test

  • 테스트 게시글 작성

Comment

• GET /api/feed/{feed_id}/comments
  • 댓글 목록 조회
• POST /api/feed/{feed_id}/comment
  • 댓글 작성
  • Request Body

    {   
        "user_id" : "string",
        "content": "string"
    }

• PUT /api/feed/{feed_id}/comment/{comment_id}
  • 댓글 수정
  • Request Body

    {   
        "user_id" : "string",
        "content": "string"
    }

• DELETE /api/feed/{feed_id}/comment/{comment_id}
  • 댓글 삭제
  • Request Body

    {   
        "user_id" : "string"
    }

• GET /api/comment/test
  • 테스트 댓글 작성