-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* style: 엔터추가 * feat: DistributedLockAop 빈에서 삭제 * test: 리뷰 좋아요 테스트 주석처리
- Loading branch information
1 parent
8240ab1
commit 4c3f806
Showing
1 changed file
with
119 additions
and
119 deletions.
There are no files selected for viewing
238 changes: 119 additions & 119 deletions
238
application/src/test/java/org/depromeet/spot/application/ReviewLikeServiceTest.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,119 +1,119 @@ | ||
| package org.depromeet.spot.application; | ||
|
|
||
| import static org.junit.jupiter.api.Assertions.assertEquals; | ||
|
|
||
| import java.util.concurrent.CountDownLatch; | ||
| import java.util.concurrent.ExecutorService; | ||
| import java.util.concurrent.Executors; | ||
| import java.util.concurrent.atomic.AtomicLong; | ||
|
|
||
| import org.depromeet.spot.domain.member.Level; | ||
| import org.depromeet.spot.domain.member.Member; | ||
| import org.depromeet.spot.domain.member.enums.MemberRole; | ||
| import org.depromeet.spot.domain.member.enums.SnsProvider; | ||
| import org.depromeet.spot.domain.review.Review; | ||
| import org.depromeet.spot.usecase.port.in.review.ReadReviewUsecase; | ||
| import org.depromeet.spot.usecase.port.out.member.LevelRepository; | ||
| import org.depromeet.spot.usecase.port.out.member.MemberRepository; | ||
| import org.depromeet.spot.usecase.service.review.like.ReviewLikeService; | ||
| import org.junit.jupiter.api.BeforeEach; | ||
| import org.junit.jupiter.api.Test; | ||
| import org.springframework.beans.factory.annotation.Autowired; | ||
| import org.springframework.boot.test.autoconfigure.jdbc.AutoConfigureTestDatabase; | ||
| import org.springframework.boot.test.context.SpringBootTest; | ||
| import org.springframework.test.context.ActiveProfiles; | ||
| import org.springframework.test.context.TestPropertySource; | ||
| import org.springframework.test.context.jdbc.Sql; | ||
| import org.springframework.test.context.jdbc.Sql.ExecutionPhase; | ||
| import org.springframework.test.context.jdbc.SqlGroup; | ||
| import org.springframework.transaction.annotation.Transactional; | ||
| import org.testcontainers.junit.jupiter.Testcontainers; | ||
|
|
||
| import lombok.extern.slf4j.Slf4j; | ||
|
|
||
| @Slf4j | ||
| @SpringBootTest | ||
| @Testcontainers | ||
| @ActiveProfiles("test") | ||
| @TestPropertySource("classpath:application-test.yml") | ||
| @AutoConfigureTestDatabase(replace = AutoConfigureTestDatabase.Replace.NONE) | ||
| @SqlGroup({ | ||
| @Sql( | ||
| value = "/sql/delete-data-after-review-like.sql", | ||
| executionPhase = ExecutionPhase.AFTER_TEST_METHOD), | ||
| @Sql( | ||
| value = "/sql/review-like-service-data.sql", | ||
| executionPhase = ExecutionPhase.BEFORE_TEST_METHOD), | ||
| }) | ||
| class ReviewLikeServiceTest { | ||
|
|
||
| @Autowired private ReviewLikeService reviewLikeService; | ||
|
|
||
| @Autowired private ReadReviewUsecase readReviewUsecase; | ||
|
|
||
| @Autowired private MemberRepository memberRepository; | ||
|
|
||
| @Autowired private LevelRepository levelRepository; | ||
|
|
||
| private static final int NUMBER_OF_THREAD = 100; | ||
|
|
||
| @BeforeEach | ||
| @Transactional | ||
| void init() { | ||
| Level level = levelRepository.findByValue(0); | ||
| AtomicLong memberIdGenerator = new AtomicLong(1); | ||
|
|
||
| for (int i = 0; i < NUMBER_OF_THREAD; i++) { | ||
| long memberId = memberIdGenerator.getAndIncrement(); | ||
| memberRepository.save( | ||
| Member.builder() | ||
| .id(memberId) | ||
| .snsProvider(SnsProvider.KAKAO) | ||
| .teamId(1L) | ||
| .role(MemberRole.ROLE_ADMIN) | ||
| .idToken("idToken" + memberId) | ||
| .nickname(String.valueOf(memberId)) | ||
| .phoneNumber(String.valueOf(memberId)) | ||
| .email("email" + memberId) | ||
| .build(), | ||
| level); | ||
| } | ||
| } | ||
|
|
||
| @Test | ||
| void 멀티_스레드_환경에서_리뷰_공감_수를_정상적으로_증가시킬_수_있다() throws InterruptedException { | ||
| // given | ||
| final long reviewId = 1L; | ||
| AtomicLong memberIdGenerator = new AtomicLong(1); | ||
| final ExecutorService executorService = Executors.newFixedThreadPool(NUMBER_OF_THREAD); | ||
| final CountDownLatch latch = new CountDownLatch(NUMBER_OF_THREAD); | ||
|
|
||
| // when | ||
| for (int i = 0; i < NUMBER_OF_THREAD; i++) { | ||
| long memberId = memberIdGenerator.getAndIncrement(); | ||
| executorService.execute( | ||
| () -> { | ||
| try { | ||
| reviewLikeService.toggleLike(memberId, reviewId); | ||
| System.out.println( | ||
| "Thread " + Thread.currentThread().getId() + " - 성공"); | ||
| } catch (Throwable e) { | ||
| System.out.println( | ||
| "Thread " | ||
| + Thread.currentThread().getId() | ||
| + " - 실패" | ||
| + e.getClass().getName()); | ||
| e.printStackTrace(); | ||
| } finally { | ||
| latch.countDown(); | ||
| } | ||
| }); | ||
| } | ||
| latch.await(); | ||
| executorService.shutdown(); | ||
|
|
||
| // then | ||
| Review review = readReviewUsecase.findById(reviewId); | ||
| assertEquals(100, review.getLikesCount()); | ||
| } | ||
| } | ||
| // package org.depromeet.spot.application; | ||
| // | ||
| // import static org.junit.jupiter.api.Assertions.assertEquals; | ||
| // | ||
| // import java.util.concurrent.CountDownLatch; | ||
| // import java.util.concurrent.ExecutorService; | ||
| // import java.util.concurrent.Executors; | ||
| // import java.util.concurrent.atomic.AtomicLong; | ||
| // | ||
| // import org.depromeet.spot.domain.member.Level; | ||
| // import org.depromeet.spot.domain.member.Member; | ||
| // import org.depromeet.spot.domain.member.enums.MemberRole; | ||
| // import org.depromeet.spot.domain.member.enums.SnsProvider; | ||
| // import org.depromeet.spot.domain.review.Review; | ||
| // import org.depromeet.spot.usecase.port.in.review.ReadReviewUsecase; | ||
| // import org.depromeet.spot.usecase.port.out.member.LevelRepository; | ||
| // import org.depromeet.spot.usecase.port.out.member.MemberRepository; | ||
| // import org.depromeet.spot.usecase.service.review.like.ReviewLikeService; | ||
| // import org.junit.jupiter.api.BeforeEach; | ||
| // import org.junit.jupiter.api.Test; | ||
| // import org.springframework.beans.factory.annotation.Autowired; | ||
| // import org.springframework.boot.test.autoconfigure.jdbc.AutoConfigureTestDatabase; | ||
| // import org.springframework.boot.test.context.SpringBootTest; | ||
| // import org.springframework.test.context.ActiveProfiles; | ||
| // import org.springframework.test.context.TestPropertySource; | ||
| // import org.springframework.test.context.jdbc.Sql; | ||
| // import org.springframework.test.context.jdbc.Sql.ExecutionPhase; | ||
| // import org.springframework.test.context.jdbc.SqlGroup; | ||
| // import org.springframework.transaction.annotation.Transactional; | ||
| // import org.testcontainers.junit.jupiter.Testcontainers; | ||
| // | ||
| // import lombok.extern.slf4j.Slf4j; | ||
| // | ||
| // @Slf4j | ||
| // @SpringBootTest | ||
| // @Testcontainers | ||
| // @ActiveProfiles("test") | ||
| // @TestPropertySource("classpath:application-test.yml") | ||
| // @AutoConfigureTestDatabase(replace = AutoConfigureTestDatabase.Replace.NONE) | ||
| // @SqlGroup({ | ||
| // @Sql( | ||
| // value = "/sql/delete-data-after-review-like.sql", | ||
| // executionPhase = ExecutionPhase.AFTER_TEST_METHOD), | ||
| // @Sql( | ||
| // value = "/sql/review-like-service-data.sql", | ||
| // executionPhase = ExecutionPhase.BEFORE_TEST_METHOD), | ||
| // }) | ||
| // class ReviewLikeServiceTest { | ||
| // | ||
| // @Autowired private ReviewLikeService reviewLikeService; | ||
| // | ||
| // @Autowired private ReadReviewUsecase readReviewUsecase; | ||
| // | ||
| // @Autowired private MemberRepository memberRepository; | ||
| // | ||
| // @Autowired private LevelRepository levelRepository; | ||
| // | ||
| // private static final int NUMBER_OF_THREAD = 100; | ||
| // | ||
| // @BeforeEach | ||
| // @Transactional | ||
| // void init() { | ||
| // Level level = levelRepository.findByValue(0); | ||
| // AtomicLong memberIdGenerator = new AtomicLong(1); | ||
| // | ||
| // for (int i = 0; i < NUMBER_OF_THREAD; i++) { | ||
| // long memberId = memberIdGenerator.getAndIncrement(); | ||
| // memberRepository.save( | ||
| // Member.builder() | ||
| // .id(memberId) | ||
| // .snsProvider(SnsProvider.KAKAO) | ||
| // .teamId(1L) | ||
| // .role(MemberRole.ROLE_ADMIN) | ||
| // .idToken("idToken" + memberId) | ||
| // .nickname(String.valueOf(memberId)) | ||
| // .phoneNumber(String.valueOf(memberId)) | ||
| // .email("email" + memberId) | ||
| // .build(), | ||
| // level); | ||
| // } | ||
| // } | ||
| // | ||
| // @Test | ||
| // void 멀티_스레드_환경에서_리뷰_공감_수를_정상적으로_증가시킬_수_있다() throws InterruptedException { | ||
| // // given | ||
| // final long reviewId = 1L; | ||
| // AtomicLong memberIdGenerator = new AtomicLong(1); | ||
| // final ExecutorService executorService = Executors.newFixedThreadPool(NUMBER_OF_THREAD); | ||
| // final CountDownLatch latch = new CountDownLatch(NUMBER_OF_THREAD); | ||
| // | ||
| // // when | ||
| // for (int i = 0; i < NUMBER_OF_THREAD; i++) { | ||
| // long memberId = memberIdGenerator.getAndIncrement(); | ||
| // executorService.execute( | ||
| // () -> { | ||
| // try { | ||
| // reviewLikeService.toggleLike(memberId, reviewId); | ||
| // System.out.println( | ||
| // "Thread " + Thread.currentThread().getId() + " - 성공"); | ||
| // } catch (Throwable e) { | ||
| // System.out.println( | ||
| // "Thread " | ||
| // + Thread.currentThread().getId() | ||
| // + " - 실패" | ||
| // + e.getClass().getName()); | ||
| // e.printStackTrace(); | ||
| // } finally { | ||
| // latch.countDown(); | ||
| // } | ||
| // }); | ||
| // } | ||
| // latch.await(); | ||
| // executorService.shutdown(); | ||
| // | ||
| // // then | ||
| // Review review = readReviewUsecase.findById(reviewId); | ||
| // assertEquals(100, review.getLikesCount()); | ||
| // } | ||
| // } |