我需要实现以下行为:
- 进行 REST post 请求
- 如果响应返回状态码
429 Too many requests
,则重试3次并延迟1秒 - 如果第三次重试失败或出现其他任何错误,则记录并写入数据库
- 如果请求成功(HTTP状态码200),则记录一些信息
Mono<ClientResponse> response = webClient.post()
.uri(URI.create("/myuri"))
.body(BodyInserters.fromObject(request))
.retrieve()
.onStatus(httpStatus -> httpStatus.equals(HttpStatus.TOO_MANY_REQUESTS),
response -> Mono.error(new TooManyRequestsException("System is overloaded")))
.bodyToMono(ClientResponse.class)
.retryWhen(Retry.anyOf(TooManyRequestsException.class)
.fixedBackoff(Duration.ofSeconds(1)).retryMax(3))
.doOnError(throwable -> saveToDB(some_id, throwable))
.subscribe(response -> logResponse(some_id, response));
现在我想测试一下重试机制和错误处理是否按照我的期望工作。也许我可以使用StepVerifier来达到这个目的,但是我无法弄清楚如何在我的情况下使用它。有什么有用的提示吗?