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

调整

Browse Source
This commit is contained in:
shikong 2024-03-16 22:44:15 +08:00
parent 9a9db33e6f
commit d0803c6b62
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -134,9 +134,9 @@ public class DeviceProxyService {
.withStopStrategy(StopStrategies.stopAfterAttempt(10 * 1000))
.build();
zlmPublishHookService.getHandler(DEFAULT_ZLM_APP).put(callId,()->{
scheduledExecutorService.submit(()->{
executor.execute(()->{
try {
retryer.call(()->{
StartSendRtpResp sendRtpResp = retryer.call(() -> {
StartSendRtp startSendRtp = new StartSendRtp();
startSendRtp.setApp(DEFAULT_ZLM_APP);
startSendRtp.setStream(callId);
@ -149,6 +149,8 @@ public class DeviceProxyService {
// log.debug("startSendRtpResp {}",startSendRtpResp);
return startSendRtpResp;
});
log.info("sendRtp 推流成功 {} {}, {}", device.getDeviceCode(),device.getGbChannelId(), sendRtpResp);
} catch (Exception e) {
log.error("zlm rtp 推流失败, {} {} {}, {}", device.getDeviceCode(),device.getGbChannelId(), callId, e.getMessage());
Optional.ofNullable(zlmStreamChangeHookService.getUnregistHandler(DEFAULT_ZLM_APP).remove(callId))
@ -165,7 +167,7 @@ public class DeviceProxyService {
private void zlmStreamRegistHookEvent(String app, String callId, String ssrc){
zlmStreamChangeHookService.getUnregistHandler(app).put(callId,()->{
scheduledExecutorService.submit(()->{
executor.execute(()->{
ScheduledFuture<?> schedule = scheduledExecutorService.schedule(() -> {
StopSendRtp stopSendRtp = new StopSendRtp();
stopSendRtp.setApp(app);