金額並列処理Simple Queue Service（SQS）

Question

Spring Cloudを使用してSimple Queue Service（SQS）を使用しています。 Iは、並列処理のために、以下の構成を有する：

@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; 
} 

Iは

（maxNumberOfMessagesはSQSから返された）50件のスレッド（豆SimpleAsyncTaskExecutorで構成）50件のメッセージを処理する必要はなく、並列にわずか10のメッセージを処理しています

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を参照してください。 （それは第1段落にあります）。