XW-AIOT/wvp-platform
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[1078] 修复webrtc地址

Browse Source
This commit is contained in:
lin
2025-07-15 18:37:53 +08:00
parent d40bc5a034
commit 5874d4d1fa
3 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/genersoft/iot/vmp/common/StreamInfo.java
View File

@@ -182,7 +182,8 @@ public class StreamInfo implements Serializable, Cloneable{
if (callIdParam != null) { if (callIdParam != null) {
callIdParam = Objects.equals(callIdParam, "") ? callIdParam : callIdParam.replace("?", "&"); callIdParam = Objects.equals(callIdParam, "") ? callIdParam : callIdParam.replace("?", "&");
} }
String file = String.format("%s/%s?type=%s%s", app, stream, isPlay?"play":"push", callIdParam); // String file = String.format("%s/%s?type=%s%s", app, stream, isPlay?"play":"push", callIdParam);
String file = String.format("index/api/webrtc?app=%s&stream=%s&type=%s%s", app, stream, isPlay?"play":"push", callIdParam);
if (port > 0) { if (port > 0) {
this.rtc = new StreamURL("http", host, port, file); this.rtc = new StreamURL("http", host, port, file);
} }

1
src/main/java/com/genersoft/iot/vmp/jt1078/codec/decode/Jt808Decoder.java
View File

@@ -88,6 +88,7 @@ public class Jt808Decoder extends ByteToMessageDecoder {
if (decode != null) { if (decode != null) {
out.add(decode); out.add(decode);
} }
buf.release();
} finally { } finally {
in.skipBytes(in.readableBytes()); in.skipBytes(in.readableBytes());
} }

1
src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/Re.java
View File

@@ -28,7 +28,6 @@ public abstract class Re {
session.register(header.getPhoneNumber(), (int) header.getVersion(), header); session.register(header.getPhoneNumber(), (int) header.getVersion(), header);
} }
Rs rs = decode0(buf, header, session); Rs rs = decode0(buf, header, session);
buf.release();
Rs rsHand = handler(header, session, service); Rs rsHand = handler(header, session, service);
if (rs == null && rsHand != null) { if (rs == null && rsHand != null) {
rs = rsHand; rs = rsHand;