jersey-clientでのリトライ処理の実装方法

初めて質問させて頂きます。
現在、jersey-clientを使い、RESTリクエストを送信するプログラムを作成しています。

この際、タイムアウト等の発生時に規定回数リトライを行いたのですが、タイムアウト時間の設定方法までは分かったのですが(分かったつもりかもしれませんが)、リトライ処理の実装方法が分かりませんでした。

jersey-clientでのリトライ実装方法についてご教示いただけないでしょうか。
(「そもそもjersey-clientではなく、このライブラリを使用したほうが良い」等あれば、ぜひご教示いただきたいです。)

使用しているライブラリ
org.glassfish.jersey.media:jersey-client:2.22.1

lang
1ClientConfig config = new ClientConfig()
2    .property(ClientProperties.CONNECT_TIMEOUT, "5000");
3
4Response response = ClientBuilder.newClient(config)
5    .target("http://localhost:8080")
6    .path("/sample")
7    .queryParam("code", "dummyCode")
8    .request(MediaType.APPLICATION_FORM_URLENCODED_TYPE)
9    .accept(MediaType.APPLICATION_JSON_TYPE)
10    .get();
11
12System.out.println(response.readEntity(String.class));

行動規範の内容に同意します

回答1件

ベストアンサー

Jerseyそのものにはリトライの仕組みは無さそうです。

実プロジェクトで使ったことはないのですが、
How to implement a retry mechanism in jersey-client java - Stack Overflow
で紹介されている、Recurrentは使いやすそうです。

それから、CONNECT_TIMEOUTは接続のタイムアウトで、
処理のタイムアウトはREAD_TIMEOUTを使って、ミリ秒単位で指定する様です。

以下、タイムアウトするか、200応答以外が返った際に、
1秒おいてリトライを3回行う様に記述してみたコードです。
タイムアウトはCONNECT_TIMEOUTを5秒、READ_TIMEOUTが3秒にしました。
試しに処理が10秒かかるようにしたところ、正しくタイムアウトしてリトライされたようです。

lang
1RetryPolicy retryPolicy = new RetryPolicy()
2        .retryWhen((Response response) -> response.getStatus() != 200)
3        .retryOn((ProcessingException ex) -> ex.getCause() instanceof SocketTimeoutException)
4        .withDelay(1, TimeUnit.SECONDS)
5        .withMaxRetries(3);
6
7ClientConfig config = new ClientConfig()
8        .property(ClientProperties.CONNECT_TIMEOUT, "5000")
9        .property(ClientProperties.READ_TIMEOUT, "3000");
10
11Builder builder = ClientBuilder.newClient(config)
12        .target("http://localhost:8080")
13        .path("/sample")
14        .queryParam("code", "dummyCode")
15        .request(MediaType.APPLICATION_FORM_URLENCODED_TYPE)
16        .accept(MediaType.APPLICATION_JSON_TYPE);
17
18Recurrent.get(() -> builder.get(), retryPolicy);
19System.out.println(response.getStatus());