Shikong/gb28181-docking-platform-proxy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

下载调整

Browse Source
This commit is contained in:
shikong 2023-09-18 17:05:47 +08:00
parent 704e9eb9a0
commit 7d71478baf
2 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/wvp/WvpService.java
View File

@ -275,6 +275,12 @@ public class WvpService {
JsonResponse<String> addDownloadTask2MediaServer = wvpProxyClient.addDownloadTask2MediaServer(token, mediaServerId, new AddDownloadTaskReq(app, stream));
String taskId = addDownloadTask2MediaServer.getData();
Retryer<JsonResponse<String>> mediaServerRetryer = RetryUtil.<String>getDefaultRetryerBuilder("从 mediaServer 获取视频")
// 重试间隔
.withWaitStrategy(WaitStrategies.fixedWait(RetryUtil.DEFAULT_RETRY_INTERVAL, TimeUnit.SECONDS))
// 重试次数
.withStopStrategy(StopStrategies.stopAfterAttempt(RetryUtil.DEFAULT_RETRY_TIME))
.retryIfResult(RetryUtil.defaultRetryIf())
.withRetryListener(RetryUtil.defaultRetryListener("从 mediaServer 获取视频"))
.withStopStrategy(StopStrategies.stopAfterAttempt(10))
.build();
return mediaServerRetryer.call(() -> {

15
gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/utils/RetryUtil.java
View File

@ -57,18 +57,19 @@ public class RetryUtil {
return RetryerBuilder.<JsonResponse<T>>newBuilder()
// 异常就重试
.retryIfException()
.retryIfRuntimeException()
.retryIfRuntimeException();
}
public static <T> Retryer<JsonResponse<T>> getDefaultRetryer(String name) {
return RetryUtil.<T>getDefaultRetryerBuilder(name)
// 重试间隔
.withWaitStrategy(WaitStrategies.fixedWait(DEFAULT_RETRY_INTERVAL, TimeUnit.SECONDS))
// 重试次数
.withStopStrategy(StopStrategies.stopAfterAttempt(DEFAULT_RETRY_TIME))
.retryIfResult(defaultRetryIf())
.withRetryListener(defaultRetryListener(name));
}
public static <T> Retryer<JsonResponse<T>> getDefaultRetryer(String name) {
return RetryUtil.<T>getDefaultRetryerBuilder(name).build();
.withRetryListener(defaultRetryListener(name))
.build();
}
public static RetryerBuilder<JsonResponse<?>> getDefaultGenericRetryerBuilder(String name, int retryTime, long retryInterval, TimeUnit retryTimeUnit,RetryListener retryListener) {