WebOTX Manual V10.4 (第4版) 目次を表示

---

14.3. MicroProfile Fault Tolerance

14.3.1. 概要

14.3.2. 設定情報

MicroProfile Fault Tolerance の設定項目は、[ リファレンス > 設定 > マイクロサービスアプリケーション > MicroProfile Fault Tolerance ] を参照してください。

14.3.3. 提供機能

14.3.3.1. Timeout

• スレッドがブロッキングI/O（DBやファイルの読み書き）でブロックされている場合や、NIOチャネルの例外発生のみを待ち受けている場合
• スレッドが待ち合わせを行っていない場合
• スレッドがInterruptedExceptionをキャッチし、割込みを無視している場合

14.3.3.2. Retry

14.3.3.3. Fallback

14.3.3.4. Bulkhead

14.3.3.5. CircuitBreaker

図14.3.3.5-1

14.3.3.6. Asynchronous

14.3.3.7. ChronoUnit

14.3.3.8. メトリクス情報

14.3.4. 記述例

package sample;

import java.util.Map;

import javax.enterprise.context.ApplicationScoped;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

import org.eclipse.microprofile.faulttolerance.Timeout;

import sample.resource.Customer;
import sample.util.Util;

@ApplicationScoped
@Path("/timeout")
public class CustomerResource1 {

    @Path("{id}")
    @GET
    @Produces(MediaType.APPLICATION_JSON)
    @Timeout(500)
    public Customer getCustomerList(@PathParam("id") String id) throws Exception {
        // load data
        Map<String, Customer> map = Util.loadData("/sample/data/customerlist.txt");
        Customer customer = map.get(id);
        return customer;
    }

    public Customer fallbackService(@PathParam("id") String id) {
        // load sorry data
        Map<String, Customer> map = Util.loadData("/sample/data/sorrylist.txt");
        Customer customer = map.get("0001");
        return customer;
    }
}      

  上記メソッド（getCustomerList()）を呼び出した際、処理が500ミリ秒で終了しない場合はTimeoutExceptionをスローします。
  

package sample;

import java.util.Map;

import javax.enterprise.context.ApplicationScoped;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

import org.eclipse.microprofile.faulttolerance.Retry;
import org.eclipse.microprofile.faulttolerance.Timeout;

import sample.resource.Customer;
import sample.util.Util;

@ApplicationScoped
@Path("/retry")
public class CustomerResource2 {

    @Path("{id}")
    @GET
    @Produces(MediaType.APPLICATION_JSON)
    @Timeout(500)
    @Retry(maxRetries=1)
    public Customer getCustomerList(@PathParam("id") String id) throws Exception {
    	// load data
        Map<String, Customer> map = Util.loadData("/sample/data/customerlist.txt");
        Customer customer = map.get(id);
        return customer;
    }

    public Customer fallbackService(@PathParam("id") String id) {
        // load sorry data
        Map<String, Customer> map = Util.loadData("/sample/data/sorrylist.txt");
        Customer customer = map.get("0001");
        return customer;
    }
}

  上記メソッド（getCustomerList()）の呼び出しにおいて、最大１回まで処理をリトライします。
  

package sample;

import java.util.Map;

import javax.enterprise.context.RequestScoped;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

import org.eclipse.microprofile.faulttolerance.Fallback;
import org.eclipse.microprofile.faulttolerance.Timeout;

import sample.resource.Customer;
import sample.util.Util;

@RequestScoped
@Path("/fallback")
public class CustomerResource3 {

    @Path("{id}")
    @GET
    @Produces(MediaType.APPLICATION_JSON)
    @Timeout(500)
    @Fallback(fallbackMethod="fallbackService")
    public Customer getCustomerList(@PathParam("id") String id) throws Exception {
        // load data
    	throw new Exception("test!");
    }

    public Customer fallbackService(@PathParam("id") String id) {
        // load sorry data
        Map<String, Customer> map = Util.loadData("/sample/data/sorrylist.txt");
        Customer customer = map.get("0001");
        return customer;
    }
}

  上記メソッド（getCustomerList()）の呼び出しにおいて例外が検知された場合、指定された代替メソッド（fallbackService()）が実行され、代替メソッドの結果が返されます。

  

package sample;

import java.util.Map;
import java.util.logging.Logger;

import javax.enterprise.context.ApplicationScoped;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

import org.eclipse.microprofile.faulttolerance.Bulkhead;

import com.nec.webotx.webservice.xml.ws.util.Log;

import sample.resource.Customer;
import sample.util.Util;

@ApplicationScoped
@Path("/bulkhead")
public class CustomerResource5 {

	Logger log = Log.getOTXLogger();

    @Path("{id}")
    @GET
    @Produces(MediaType.APPLICATION_JSON)
    @Bulkhead(value=1)
    public Customer getCustomerList(@PathParam("id") String id) throws Exception {
        // load data
        Map<String, Customer> map = Util.loadData("/sample/data/customerlist.txt");
        Customer customer = map.get(id);
        return customer;
    }

    public Customer fallbackService(@PathParam("id") String id) {
        // load sorry data
        Map<String, Customer> map = Util.loadData("/sample/data/sorrylist.txt");
        Customer customer = map.get("0001");
        return customer;
    }
}

  上記メソッド（getCustomerList()）の呼び出しにおいて、同時呼び出し数が1件に制限されます。

  1件を超える呼び出しを行った場合BulkheadExceptionをスローします。
  

 
package sample;

import java.util.Map;

import javax.enterprise.context.ApplicationScoped;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

import org.eclipse.microprofile.faulttolerance.CircuitBreaker;
import org.eclipse.microprofile.faulttolerance.Timeout;

import sample.resource.Customer;
import sample.util.Util;

@ApplicationScoped
@Path("/circuitbreaker")
public class CustomerResource4 {

    @Path("{id}")
    @GET
    @Produces(MediaType.APPLICATION_JSON)
    @Timeout(500)
    @CircuitBreaker(requestVolumeThreshold=2, failureRatio=0.5)
    public Customer getCustomerList(@PathParam("id") String id) throws Exception {
        // load data
        Map<String, Customer> map = Util.loadData("/sample/data/customerlist.txt");
        Customer customer = map.get(id);
        return customer;
    }

    public Customer fallbackService(@PathParam("id") String id) {
        // load sorry data
        Map<String, Customer> map = Util.loadData("/sample/data/sorrylist.txt");
        Customer customer = map.get("0001");
        return customer;
    }
}

  上記メソッド（getCustomerList()）の呼び出しにおいて、呼び出し回数2回中、1回以上失敗した場合はサーキットブレーカーを開きます。

  サーキットブレーカーが開いている状態で呼び出しを行った場合はCircuitBreakerOpenExceptionをスローします。
  

package sample;

import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Future;

import javax.enterprise.context.ApplicationScoped;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

import org.eclipse.microprofile.faulttolerance.Asynchronous;

import sample.resource.Customer;
import sample.util.Util;

@ApplicationScoped

@Path("/async")
public class CustomerResource6 {

    @Path("{id}")
    @GET
    @Produces(MediaType.APPLICATION_JSON)
    @Asynchronous
    public Future<Customer> getCustomerList(@PathParam("id") String id) throws Exception {
        // load data
        Map<String, Customer> map = Util.loadData("/sample/data/customerlist.txt");
        Customer customer = map.get(id);
        return CompletableFuture.completedFuture(customer);
    }

    public Future<Customer> fallbackService(@PathParam("id") String id) {
        // load sorry data
        Map<String, Customer> map = Util.loadData("/sample/data/sorrylist.txt");
        Customer customer = map.get("0001");
        return CompletableFuture.completedFuture(customer);
    }
}

  上記メソッド（getCustomerList()）を呼び出した際、処理は呼び出し元とは別スレッドで非同期に実行されます。