동시성+데드락 제어를 위한 비관적 락 잠금 질문

안녕하세요 글쓰기 커뮤니티 프로젝트를 개발하는 중입니다 회원이 소설을 찜하는 기능(좋아요)을 구현 중에 있는데요 찜 객체는 아래 첨부한 코드와 같이 memberId와 novelId를 외래키로 갖습니다 동시성 이슈를 다뤄보고자 500명의 사용자가 동시에 novelId가 1인 소설을 찜하는 요청을 보낸다는 가정 하에 jmeter로 테스트를 돌려보니 동시성 이슈가 아니라 데드락 문제가 발생해서요 favoriteJDBCRepository.save(memberId, novelId); 시 novelId가 외래키라 외래키 정합성 검사 때문에 db 내부적으로 novelId가 1인 레코드에 read lock이 걸리는 것 같습니다 favorite 객체 save 시 트랜잭션 A가 novelId가 1인 레코드에 대해 read lock을 얻고, novelId가 3인 novel의 favoriteCount(찜 개수)를 +1하고자 write lock 요청 -> favorite 객체 save 시 다른 트랜잭션 B도 novelId가 1인 레코드에 대해 readlock을 얻고, novelId가 1인 novel의 favoriteCount(찜 개수)를 +1하고자 write lock 요청 -> write lock은 read lock이 전부 해제되어야 얻을 수 있음. 트랜잭션 A는 B가 read lock을 release하기를 대기하고 B도 A가 read lock을 release하기를 대기하면서 데드락 발생 일단 novelId로 novel을 비관적 락을 사용해 조회해서 favorite 객체를 생성한 뒤에 저장하는 방식으로 데드락+동시성 이슈 둘 다 해결이 되는데요(chooseFavoriteV2) 이 방법 말고도 더 좋은 대안은 없을까요??

1/ **
2찜 엔티티
3**/
4
5
6@Entity
7public class Favorite {
8
9  @Id
10  @GeneratedValue(strategy = GenerationType.IDENTITY)
11  private Long favoriteId;
12
13  @ManyToOne(fetch = FetchType.LAZY)
14  @JoinColumn(name = "member_id")
15  @NotNull
16  private Member member;
17
18  @ManyToOne(fetch = FetchType.LAZY)
19  @JoinColumn(name = "novel_id")
20  @NotNull
21  private Novel novel;
22}
23
24/////////////////////////////////////////////////////////////////////////////////////////////////////////
25
26/ **
27FavoriteService 에 찜 기능 구현
28**/
29
30@Transactional
31  public FavoriteResponseDTO chooseFavorite(Long novelId, Long memberId) {
32    favoriteJDBCRepository.save(memberId, novelId);
33    novelRepository.updateFavoriteCount(novelId, +1L);
34
35    return FavoriteResponseDTO
36            .builder()
37    ....
38
39  }
40
41/////////////////////////////////////////////////////////////////////////////////////////////////////////
42
43/ **
44favoriteJDBCRepository.save(memberId, novelId)
45**/
46
47public int save(Long memberId, Long novelId) {
48    String query = "INSERT INTO favorite (member_id, novelId) VALUES (?, ?)";
49    return jdbcTemplate.update(query, memberId, novelId);
50  }
51
52
53/////////////////////////////////////////////////////////////////////////////////////////////////////////
54
55/ **
56chooseFavoriteV2
57**/
58
59@Transactional
60  public FavoriteResponseDTO chooseFavoriteV2(Long novelId, Long memberId) {
61    Novel foundNovel = novelRepository.findByIdWithPessimisticLock(novelId).orElseThrow(...);
62    Member foundMember = memberRepository.findById(memberId).orElseThrow(...);
63    
64    Favorite favorite = Favorite.builder()
65            .member(foundMember)
66            .novel(foundNovel)
67            .build();
68
69    favoriteRepository.save(favorite);
70    novelRepository.updateFavoriteCount(novelId, +1L);
71
72    return FavoriteResponseDTO
73            .builder()
74    ....
75
76  }

이 질문이 도움이 되었나요?

'추천해요' 버튼을 누르면 좋은 질문이 더 많은 사람에게 노출될 수 있어요. '보충이 필요해요' 버튼을 누르면 질문자에게 질문 내용 보충을 요청하는 알림이 가요.

추천해요 1

보충이 필요해요 0

익명님의 질문