Skip to content
This repository was archived by the owner on Oct 24, 2024. It is now read-only.

[#46] 비동기적인 Push 알람 서비스 구현 #48

Open
wants to merge 14 commits into
base: develop
Choose a base branch
from
Open

[#46] 비동기적인 Push 알람 서비스 구현 #48

Changes from 1 commit
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
8108c9c
푸쉬 알람 서비스 초기 환결설정
tjdrnr0557 Oct 28, 2020
f91e91e
라이더 토큰 추가
tjdrnr0557 Oct 28, 2020
6252939
Async를 위한 스레드 풀 초기 설정
tjdrnr0557 Nov 2, 2020
63e9b35
주문 승인 시 대기중인 라이더들에게 푸쉬 알람 전송 기능 추가
tjdrnr0557 Nov 2, 2020
4451c96
git ignore 추가
tjdrnr0557 Nov 2, 2020
dd0fcde
캐시 삭제
tjdrnr0557 Nov 2, 2020
f45050a
[#47] 리뷰 반영
tjdrnr0557 Nov 2, 2020
631569a
[#47] 리뷰 반영
tjdrnr0557 Nov 3, 2020
6e14c40
[#47] 리뷰 반영
tjdrnr0557 Nov 3, 2020
c6280de
[#47] 리뷰 반영
tjdrnr0557 Nov 3, 2020
1c5b247
[#47] 리뷰 반영
tjdrnr0557 Nov 4, 2020
3ece9d5
[#47] 리뷰 반영
tjdrnr0557 Nov 5, 2020
a1d3104
[#47] 리뷰 반영
tjdrnr0557 Nov 5, 2020
71c41a2
어플리케이션 레벨에서 비동기를 구현하여 푸쉬메세지 전송
tjdrnr0557 Nov 6, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions src/main/java/com/flab/makedel/config/SpringAsyncConfig.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,10 @@
@EnableAsync
public class SpringAsyncConfig {

private static final int CORE_POOL_SIZE = 3;
private static final int MAX_POOL_SIZE = 100;
private static final int QUEUE_CAPACITY = 3;
private static final int KEEP_ALIVE_SECONDS = 30;
private static final int CORE_POOL_SIZE = 5;
private static final int MAX_POOL_SIZE = 500;
Copy link
Member

@f-lab-dev f-lab-dev Nov 3, 2020

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

이거는 이렇게 높혀주신 이유가 있으실까요?

Copy link
Collaborator Author

@tjdrnr0557 tjdrnr0557 Nov 4, 2020

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

라이더들에게 지역별로 푸쉬 알람을 보내긴 하지만 갑자기 푸쉬 알람이 폭증할 가능성이 있기 때문에 max_pool_size를 늘려서 푸쉬 알람 보내는 기능에 병목이 일어날 확률이 적어지도록 만들었습니다.

Copy link
Member

@f-lab-dev f-lab-dev Nov 5, 2020

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

이런 값은 성능테스트하면서 조절하는게 일반적인데요~ 추후에 한번 테스트해보시면서 조절해봐도 좋을 것 같네요

private static final int QUEUE_CAPACITY = 0;
Copy link
Collaborator Author

@tjdrnr0557 tjdrnr0557 Nov 3, 2020

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

queue capacity가 양수이면 LinkedBlockingQueue로 지정되고

0이하라면 SynchronousQueue를 이용합니다.

LinkedBlockingQueue는 큐의 크기가 제한되지 않는 큐입니다. 크기를 수동으로 설정을 할 수도 있습니다. 하지만 큐에 작업이 계속 쌓이게 되면 푸쉬 알람에 병목이 생길 수 있습니다.

SynchronousQueue는 큐라기보다는 작업이 들어오면 그것을 스레드에 넘겨주는 역할을 합니다. 큐에 쌓지 않고 바로 프로듀서에서 생성한 작업을 컨슈머인 스레드에게 직접 전달합니다. 쉬고 있는 스레드에게 처리할 작업을 직접 넘겨주므로 효율적입니다. 또한 대기중인 스레드가 없는 상태에서 스레드의 개수가 max pool size보다 작다면 새로운 스레드를 생성해 동작시킵니다. 따라서 푸쉬알람이 폭증해도 대비할 수 있습니다. 하지만 정해둔 max pool size보다 커진다면 abort policy를 이용해 푸쉬 알람 보내는 것을 거부하고 exception을 던집니다.

private static final int KEEP_ALIVE_SECONDS = 60;
private static final String NAME_PREFIX = "springAsyncTask-";

@Bean(name = "springAsyncTask")
Expand Down