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

zlm rtp 推流失败 日志

Browse Source
This commit is contained in:
shikong 2024-03-14 09:14:19 +08:00
parent d9376eebf7
commit 0fd058e1c5
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/device/DeviceProxyService.java
View File

@ -126,7 +126,7 @@ public class DeviceProxyService {
// 重试间隔 // 重试间隔
.withWaitStrategy(WaitStrategies.fixedWait(1, TimeUnit.MILLISECONDS)) .withWaitStrategy(WaitStrategies.fixedWait(1, TimeUnit.MILLISECONDS))
// 重试次数 // 重试次数
.withStopStrategy(StopStrategies.stopAfterAttempt(5 * 1000)) .withStopStrategy(StopStrategies.stopAfterAttempt(10 * 1000))
.build(); .build();
zlmPublishHookService.getHandler(DEFAULT_ZLM_APP).put(callId,()->{ zlmPublishHookService.getHandler(DEFAULT_ZLM_APP).put(callId,()->{
scheduledExecutorService.submit(()->{ scheduledExecutorService.submit(()->{
@ -145,7 +145,7 @@ public class DeviceProxyService {
return startSendRtpResp; return startSendRtpResp;
}); });
} catch (Exception e) { } catch (Exception e) {
log.error("zlm rtp 推流失败",e); log.error("zlm rtp 推流失败, {} {}, {}", device.getGbChannelId(), callId, e.getMessage());
Optional.ofNullable(zlmStreamChangeHookService.getUnregistHandler(DEFAULT_ZLM_APP).remove(callId)) Optional.ofNullable(zlmStreamChangeHookService.getUnregistHandler(DEFAULT_ZLM_APP).remove(callId))
.ifPresent(ZlmStreamChangeHookService.ZlmStreamChangeHookHandler::handler); .ifPresent(ZlmStreamChangeHookService.ZlmStreamChangeHookHandler::handler);
throw new RuntimeException(e); throw new RuntimeException(e);
@ -573,7 +573,7 @@ public class DeviceProxyService {
return startSendRtpResp; return startSendRtpResp;
}); });
} catch (Exception e){ } catch (Exception e){
log.error("zlm rtp 推流失败",e); log.error("zlm rtp 推流失败, {} {}, {}", device.getGbChannelId(), callId, e.getMessage());
sendBye(request, device, ""); sendBye(request, device, "");
} }
}); });