MicroProfile Fault Tolerance(MP Fault Tolerance)を紹介する最後は設定によるフォールトトレランス機能の指定です。今回も前回同様、MP Fault Toleranceから提供される機能とその設定を「こんなことをしたい」的な利用シーンごとに説明していきます。なお、MP Fault Toleranceの機能は豊富なため説明は前々回の基本機能編、前回の非同期編、そして今回の設定編と3回に分けて行っています。

記事はコードの抜粋を記載します。全体を見たい場合や動作を確認したい場合は以下のGitHubリポジトリを参照ください。

• https://github.com/extact-io/contrarian-microprofile-sample/tree/main/08-fault_tolerance

MP Fault Toleranceに対する指定は前回まで見てきたとおり、すべてアノテーションで行うことができますが、全体に対する指定やアノテーションで指定した属性値の上書きなどはMicroProfile Config^[1]の設定ファイルで行うことができます。今回はこのMP Fault Toleranceの設定機能を設定例を交えながら説明していきます。

次の3つのレベルでアノテーションで指定した属性値を上書きできます。

• メソッドに指定されている個々のアノテーションに対する属性値の上書き
• クラスに指定されているアノテーションに対する属性値の上書き
• アプリケーション全体のアノテーションに対する属性値の上書き

上書きする際の設定キーの書式は以下になります。
<classname>/<methodname>/<annotation>/<parameter>

上記は一番細かいレベルのメソッドに指定されているアノテーション設定を上書きする書式となります。クラスに指定されているものを上書きする場合は<classname>が、アプリケーション全体の場合は<classname>と<methodname>の指定が不要となります。

それでは、以下のコードを題材にそれに対する設定例をみていきましょう。

package io.extact.sample;
...
@ApplicationScoped
@Timeout(500)
public class FtClient {
    @Retry(maxRetries = 3, delay = 1000)
    public void execA(String param) {
        workA(param);
    }
    @Retry(maxRetries = 2, maxDuration = 100)
    public String execB() {
        return workB();
    }
    @Retry(maxRetries = 5)
    @Fallback(fallbackMethod = "fallback")
    public int execC(int count) {
        return workC();
    }
    ...
}

このコードに対し以下の設定をした場合、実行時にexecBのmaxDuration属性の値が10000(msec)で上書きされます。なお、ここでの設定はすべてMicroProfile Config標準のmicroprofile-config.propertiesに対する例となります。

io.extact.sample.FtClient/execB/Retry/maxDuration=10000

次に以下の設定をした場合はクラスに指定されている@Timeoutのvalue属性の値が10000(msec)で上書きされ、結果、実行時にexecA, execB, execCのタイムアウト値が10000(msec)になります。

io.extact.sample.FtClient/Timeout/value=10000

最後にアプリケーション全体に対する指定は次のとおりになります。この場合はすべての@Retryに対するmaxRetries属性の値が1で上書きされ、結果、アプリケーション全体でリトライ回数が1回に統一されます。

Retry/maxRetries=1

package io.extact.sample;
...
@ApplicationScoped
@Timeout(500)
public class FtClient {
    @Retry(maxRetries = 3, delay = 1000)
    public void execA(String param) {
        workA(param);
    }
}

io.extact.sample.FtClient/execA/Retry/maxDuration=10000

Bulkhead/value=3

アプリケーションの稼働環境などによりタイムアウトやリトライなどのフォールトトレランス機能を無効化したい場合があります。このような場合は設定で個別に機能を無効化することができます。

この無効化する設定キーの書式は以下になります。
<classname>/<methodname>/<annotation>/enabled=false

設定方法は先ほどのアノテーションを上書きする場合と同じです。

# 1. メソッド単位で無効化
io.extact.sample.FtClient/execC/Retry/enabled=false
# 2. クラス単位で無効化
io.extact.sample.FtClient/Retry/enabled=false
# 3. アプリケーション単位で無効化
Retry/enabled=false

1.はメソッド個別に無効化する例で、2.はクラス、3.はアプリケーション全体で機能を無効化する例となります。

なお、無効化されている機能を環境変数などで有効化する場合はtrueを指定します。

サービスメッシュなどアプリケーション外部の仕組みでフォールトトレランス機能を代替することを想定し、機能個別ではなくフォールバック以外の機能を一括して無効化する設定が用意されています。無効化対象からフォールバック機能が除かれるのはフォールバック処理はアプリケーションロジックであるため、アプリケーション外部の機能では代替できないことを想定してのためです。

この指定を行う場合は以下を設定します。
MP_Fault_Tolerance_NonFallback_Enabled=false

先ほどの個別の無効化機能で明示的にtrueで有効化されている機能がある場合は、そちらが優先されます。つまり、次のような設定がされている場合、フォールバック機能に加えバルクヘッド機能も有効となります。

MP_Fault_Tolerance_NonFallback_Enabled=false
Bulkhead/enabled=true

MicroProfile Configの設定（機能）を使っているため、リトライ回数やタイムアウトなどの条件を環境変数を使って上書きすることができます。この辺りの値は最初から一発で決まるものではなく、また環境によっても調整が必要になることからリビルドせずに条件を変更できるのはとても便利です。また、このようなことを簡単にできるのがマイクロサービスに必要な仕様を一貫して提供するMicroProfileの利点といえます。