【ITニュース解説】Background Services in ASP.Net core

ASP.NET Coreで開発するアプリケーションには、ユーザーからの直接的なリクエストに応じて処理を行う部分とは別に、アプリケーションの裏側で継続的に動き続ける必要がある処理が存在する。例えば、大量のデータメッセージが順番待ちをしているキューからそれらを一つずつ取り出して処理したり、特定の時間になったら自動的に何らかのタスクを実行したり、あるいは外部のシステムやサービスが正常に稼働しているかを監視し続けたりといった作業だ。これらの処理は、ユーザーがWebサイトを操作している間も途切れることなく、独立して実行されることが求められる。このような裏方の役割を担う処理を効率的かつ安定して実行するために提供されるのが、「BackgroundService」という機能である。

BackgroundServiceは、.NETという開発プラットフォームで利用できる「抽象基底クラス」と呼ばれる種類のクラスだ。これは、具体的な機能は持たないが、それらを実装するクラスが従うべき基本的な骨組みやルールを定義した設計図のようなものだと考えればよい。開発者はこのBackgroundServiceを継承し、自分のバックグラウンド処理に特化した独自のサービスを構築する。この機能は「Microsoft.Extensions.Hosting」という名前空間に属しており、これはアプリケーションの起動・停止、設定の読み込み、依存関係の管理といった、アプリケーション全体のライフサイクルを管理するための重要なコンポーネント群の一部である。主にASP.NET Coreで構築されたWebアプリケーションや、Webサーバーを持たずにバックグラウンド処理に特化した「Worker Services」と呼ばれるアプリケーションで広く利用されている。

BackgroundServiceの核心的な役割の一つは、「IHostedService」というインターフェースを実装している点にある。インターフェースとは、特定の機能を持つべきだと約束された契約書のようなもので、これを実装することで、BackgroundServiceはアプリケーション全体の「ホスト」によってその生存期間（ライフサイクル）が管理される対象となる。ホストとは、アプリケーションの起動から終了までを統括し、アプリケーションが利用するさまざまなサービス（部品）を管理する、アプリケーションの「心臓部」と呼べる存在だ。ホストはIHostedServiceを実装するサービスを検知すると、アプリケーションの起動と同時にそのサービスを開始させ、アプリケーションが停止する際にはそのサービスも優雅に停止させるという一連の処理を自動的に行ってくれる。

BackgroundServiceを使ってバックグラウンド処理を実装する際には、「ExecuteAsync(CancellationToken stoppingToken)」という非同期メソッドをオーバーライド（上書き）して、その中に具体的な処理ロジックを記述する。このメソッドに書かれたコードは、Webアプリケーションがユーザーからのリクエストを処理するメインのスレッドとは別の、独立した「スレッド」で実行される。これにより、時間のかかるバックグラウンド処理が実行されていても、Webサイトの応答が遅くなったり、アプリケーションがフリーズしたりする心配がない。また、ExecuteAsyncメソッドには「CancellationToken」という特殊な引数がホストから自動的に渡される。これは、アプリケーションがシャットダウンしようとしていることをバックグラウンド処理に知らせるための「停止信号」のようなものだ。この信号を受け取ったバックグラウンド処理は、作業を途中で無理やり中断されるのではなく、きりの良いところで安全に終了する準備を整えることができるため、データの整合性を保ちながら優雅なシャットダウンが可能となる。

BackgroundServiceの主な用途は多岐にわたる。前述したような、Kafka、RabbitMQ、Azure Service Busといったメッセージキューから送られてくるメッセージを継続的に処理するタスクや、WindowsのタスクスケジューラやLinuxのcronジョブのように、一定間隔で自動的に実行される定期的なバックグラウンドタスク、さらには外部のデータベースやAPIサービスなどが正常に稼働しているかを定期的に監視するようなタスクで活用されることが多い。

基本的な実装手順は非常に直感的だ。まず、BackgroundServiceを継承する新しいクラスを作成する。例えば「MyBackgroundService」という名前のクラスだ。このクラスのコンストラクタでは、「ILogger」というログ出力のためのサービスを受け取って初期化することが一般的だ。そして、BackgroundServiceのExecuteAsyncメソッドをオーバーライドし、その中に実行したいバックグラウンドロジックを記述する。このロジックは通常、while (!stoppingToken.IsCancellationRequested)という条件でループし続ける形になる。これは、停止信号がまだ来ていない間は処理を継続するという意味だ。ループの中で、実際の作業をシミュレートする「Task.Delay(5000, stoppingToken)」のようなコードを記述し、5秒ごとにログを出力するといった処理を実装できる。

次に、作成したMyBackgroundServiceをアプリケーションの起動時にホストに「登録」する必要がある。これは、通常アプリケーションのエントリポイントとなる「Program.cs」ファイルで行う。Webアプリケーションの構築設定を行う部分で、「builder.Services.AddHostedService<MyBackgroundService>();」という一行を追加するだけで完了だ。これにより、ホストはMyBackgroundServiceの存在を認識し、アプリケーションの起動プロセスの一部としてこのサービスを開始する準備が整う。

アプリケーションが実際に動作する際、まずアプリケーションが起動すると、ホストは設定に従ってMyBackgroundServiceのインスタンスを作成し、そのExecuteAsyncメソッドを独立したスレッドで実行し始める。ExecuteAsyncメソッド内のループは、アプリケーションが実行されている間、中断されることなく継続的に処理を行う。そして、アプリケーションがシャットダウンされる事態が発生した場合、例えばコマンドラインでCtrl+Cが押されたり、クラウド環境でアプリケーションが停止されたりすると、ホストはBackgroundServiceに渡したstoppingTokenをトリガーする。この信号を受け取ったExecuteAsyncメソッドは、ループの条件（!stoppingToken.IsCancellationRequested）が偽となるため、実行中の作業をきりの良いところで終了させ、適切にリソースを解放してから安全に停止する。このようにして、BackgroundServiceはアプリケーションの起動からシャットダウンまで、一貫して信頼性の高いバックグラウンド処理を提供し、アプリケーション全体の安定性と応答性を高める重要な役割を果たす。システムエンジニアを目指す初心者にとって、このBackgroundServiceの概念と基本的な使い方を理解することは、より実用的で堅牢なアプリケーションを構築する上で非常に価値のあるスキルとなるだろう。