금액 병렬 처리 단순 대기열 서비스 (SQS)

Question

Spring Cloud를 사용하여 SQS (Simple Queue Service)를 사용하고 있습니다.

@Bean 
public SimpleAsyncTaskExecutor simpleAsyncTaskExecutor() { 
    SimpleAsyncTaskExecutor simpleAsyncTaskExecutor = new SimpleAsyncTaskExecutor(); 
    simpleAsyncTaskExecutor.setConcurrencyLimit(50); 
    return simpleAsyncTaskExecutor; 
} 

@Bean 
public SimpleMessageListenerContainerFactory simpleMessageListenerContainerFactory(
     SimpleAsyncTaskExecutor simpleAsyncTaskExecutor) { 

    SimpleMessageListenerContainerFactory factory = new SimpleMessageListenerContainerFactory(); 
    factory.setAutoStartup(true); 
    factory.setTaskExecutor(simpleAsyncTaskExecutor); 
    factory.setWaitTimeOut(20); 
    factory.setMaxNumberOfMessages(10); 

    return factory; 
} 

내가 50 개 스레드 (50) 메시지 (빈 SimpleAsyncTaskExecutor의 구성을) 처리해야하지만, 병렬에만 10 개의 메시지를 처리 ​​

이 (maxNumberOfMessages는 SQS에서 반환)

: 나는 병렬 처리를 위해 다음과 같은 구성을 가지고

대신 10 개 대신 50 개의 메시지를 처리 ​​할 수 ​​있습니까?

Answer 1

해결책을 찾았습니다.

@Async으로 주석을 달고 deletionPolicy을 NEVER으로 변경하고 실행을 완료 할 때 메시지를 삭제해야합니다.

이렇게하면 대기열 소비는 구성된 스레드 수를 따릅니다. 예를 들어, 50 개의 스레드가있는 경우 SQS 큐에서 5 개의 요청 (요청 당 10 개의 메시지)을 수행하여 총 50 개의 메시지를 병렬로 처리합니다.

코드는 다음과 같습니다

@Async 
@SqsListener(value = "sqsName", deletionPolicy = SqsMessageDeletionPolicy.NEVER) 
public void consume(String message, Acknowledgment acknowledgment) throws InterruptedException, ExecutionException { 

    //your code 

    acknowledgment.acknowledge().get(); //To delete message from queue 
} 

Answer 2

너무 많은 특정 메시지 (예 : 50 개의 메시지 50 개)가 너무 많습니다. 대신 성능 테스트를 해보십시오 (피크 시간대에 예상되는 메시지 수를 대기열로 보내고 서비스가 병목 현상을 일으키는 지 확인하기 위해 무언가를 작성하십시오).

실제 질문과 같이 할 수 없습니다. AWS SQS는 단순히 10 개 이상의 메시지를 가져 오는 것을 지원하지 않습니다. 의뢰. 참조 용으로 http://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ReceiveMessage.html을 참조하십시오. (첫 번째 문단에 있음).