From 5874d4d1fa2b61de4ca983e294b5be237fc0b699 Mon Sep 17 00:00:00 2001
From: lin <648540858@qq.com>
Date: Tue, 15 Jul 2025 18:37:53 +0800
Subject: [PATCH] =?UTF-8?q?[1078]=20=E4=BF=AE=E5=A4=8Dwebrtc=E5=9C=B0?=
 =?UTF-8?q?=E5=9D=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/genersoft/iot/vmp/common/StreamInfo.java     | 3 ++-
 .../genersoft/iot/vmp/jt1078/codec/decode/Jt808Decoder.java    | 1 +
 .../java/com/genersoft/iot/vmp/jt1078/proc/request/Re.java     | 1 -
 3 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/common/StreamInfo.java b/src/main/java/com/genersoft/iot/vmp/common/StreamInfo.java
index 9c186ad33..941bdebee 100644
--- a/src/main/java/com/genersoft/iot/vmp/common/StreamInfo.java
+++ b/src/main/java/com/genersoft/iot/vmp/common/StreamInfo.java
@@ -182,7 +182,8 @@ public class StreamInfo implements Serializable, Cloneable{
         if (callIdParam != null) {
             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) {
             this.rtc = new StreamURL("http", host, port, file);
         }
diff --git a/src/main/java/com/genersoft/iot/vmp/jt1078/codec/decode/Jt808Decoder.java b/src/main/java/com/genersoft/iot/vmp/jt1078/codec/decode/Jt808Decoder.java
index cf03aaa41..1c5f6108e 100644
--- a/src/main/java/com/genersoft/iot/vmp/jt1078/codec/decode/Jt808Decoder.java
+++ b/src/main/java/com/genersoft/iot/vmp/jt1078/codec/decode/Jt808Decoder.java
@@ -88,6 +88,7 @@ public class Jt808Decoder extends ByteToMessageDecoder {
             if (decode != null) {
                 out.add(decode);
             }
+            buf.release();
         } finally {
             in.skipBytes(in.readableBytes());
         }
diff --git a/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/Re.java b/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/Re.java
index 03a66f497..1609caa64 100644
--- a/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/Re.java
+++ b/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/Re.java
@@ -28,7 +28,6 @@ public abstract class Re {
             session.register(header.getPhoneNumber(), (int) header.getVersion(), header);
         }
         Rs rs = decode0(buf, header, session);
-        buf.release();
         Rs rsHand = handler(header, session, service);
         if (rs == null && rsHand != null) {
             rs = rsHand;