aunix/wvp-GB28181-pro
1
0
Fork 0
mirror of https://gitee.com/pan648540858/wvp-GB28181-pro.git synced 2026-05-25 22:47:49 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化ZLM推流鉴权日志，调整日志信息格式

Browse Source
This commit is contained in:
lin 2026-05-21 14:50:35 +08:00
parent 667a85c2a1
commit 920ad76eb6
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java
View File

@ -119,11 +119,11 @@ public class ZLMHttpHookListener {
ResultForOnPublish resultForOnPublish = mediaService.authenticatePublish(mediaServer, param.getApp(), param.getStream(), param.getParams()); ResultForOnPublish resultForOnPublish = mediaService.authenticatePublish(mediaServer, param.getApp(), param.getStream(), param.getParams());
if (resultForOnPublish != null) { if (resultForOnPublish != null) {
HookResultForOnPublish successResult = HookResultForOnPublish.getInstance(resultForOnPublish); HookResultForOnPublish successResult = HookResultForOnPublish.getInstance(resultForOnPublish);
log.info("[ZLM HOOK]推流鉴权 响应：{}->{}->>>>{}", param.getMediaServerId(), param, successResult); log.info("[ZLM HOOK]推流鉴权-允许-响应：{}->{}->>>>{}", param.getMediaServerId(), param, successResult);
return successResult; return successResult;
}else { }else {
HookResultForOnPublish fail = HookResultForOnPublish.Fail(); HookResultForOnPublish fail = HookResultForOnPublish.Fail();
log.info("[ZLM HOOK]推流鉴权 响应：{}->{}->>>>{}", param.getMediaServerId(), param, fail); log.info("[ZLM HOOK]推流鉴权-拒绝-参数：{}->{}", param.getMediaServerId(), param);
return fail; return fail;
} }
} }

3
src/main/java/com/genersoft/iot/vmp/service/impl/RtpServerServiceImpl.java
View File

@ -28,7 +28,6 @@ import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.Objects;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@Slf4j @Slf4j
@ -140,7 +139,7 @@ public class RtpServerServiceImpl implements IReceiveRtpServerService {
ssrc = ssrcFactory.getPlaySsrc(mediaServer); ssrc = ssrcFactory.getPlaySsrc(mediaServer);
} }
String streamId = String.format("%08x", Long.parseLong(ssrc)).toUpperCase(); String streamId = String.format("%08x", Long.parseLong(ssrc)).toLowerCase();
String streamReplace = String.format("%s_%s", device.getDeviceId(), channel.getDeviceId()); String streamReplace = String.format("%s_%s", device.getDeviceId(), channel.getDeviceId());
int tcpMode = device.getStreamMode().equals("TCP-ACTIVE")? 2: (device.getStreamMode().equals("TCP-PASSIVE")? 1:0); int tcpMode = device.getStreamMode().equals("TCP-ACTIVE")? 2: (device.getStreamMode().equals("TCP-PASSIVE")? 1:0);