私の Spring Boot アプリケーションでは、インポート サービスを実装する必要があります。ユーザーは一連の JSON ファイルを送信でき、アプリケーションはこれらのファイルからデータをインポートしようとします。JSON ファイルのデータ量によっては、1 回のインポート プロセスに 1 ~ 2 時間かかる場合があります。
インポート プロセス中にユーザーをブロックしたくないので、インポートのタスクを受け入れ、このデータの処理がスケジュールされていることをユーザーに通知する予定です。データをキューに入れると、反対側の空いているキュー コンシューマーがインポート プロセスを開始します。また、キュー内のジョブを監視し、必要に応じて終了できるようにする必要があります。
現在、メッセージのプロデューサとコンシューマのロジックを導入するために Embedded を使用することを考えていますApache ActiveMQ
が、その前に、アーキテクチャの観点から、説明されているタスクに適しているのか、それとも実装できるのかを尋ねたいと思います。より適切なツール..たとえば、単純なSpring@Async
などですか?