From 06d78575cc08170d09e089f40cd271acbbb4661f Mon Sep 17 00:00:00 2001
From: 64850858 <648540858@qq.com>
Date: 星期三, 14 七月 2021 16:59:55 +0800
Subject: [PATCH] 修改声音处理逻辑

---
 src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMRTPServerFactory.java |   17 +++++++++--------
 1 files changed, 9 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMRTPServerFactory.java b/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMRTPServerFactory.java
index 63102b1..ed069f8 100644
--- a/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMRTPServerFactory.java
+++ b/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMRTPServerFactory.java
@@ -8,7 +8,6 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 
 import java.util.HashMap;
@@ -35,11 +34,13 @@
         if (currentStreams == null) {
             currentStreams = new HashMap<>();
             JSONObject jsonObject = zlmresTfulUtils.listRtpServer();
-            JSONArray data = jsonObject.getJSONArray("data");
-            if (data != null) {
-                for (int i = 0; i < data.size(); i++) {
-                    JSONObject dataItem = data.getJSONObject(i);
-                    currentStreams.put(dataItem.getString("stream_id"), dataItem.getInteger("port"));
+            if (jsonObject != null) {
+                JSONArray data = jsonObject.getJSONArray("data");
+                if (data != null) {
+                    for (int i = 0; i < data.size(); i++) {
+                        JSONObject dataItem = data.getJSONObject(i);
+                        currentStreams.put(dataItem.getString("stream_id"), dataItem.getInteger("port"));
+                    }
                 }
             }
         }
@@ -74,12 +75,12 @@
                     result= createRTPServer(streamId);
                     break;
                 default:
-                    logger.error("鍒涘缓RTP Server 澶辫触: " + jsonObject.getString("msg"));
+                    logger.error("鍒涘缓RTP Server 澶辫触 {}: " + jsonObject.getString("msg"), newPort);
                     break;
             }
         }else {
             //  妫�鏌LM鐘舵��
-            logger.error("鍒涘缓RTP Server 澶辫触: 璇锋鏌LM鏈嶅姟");
+            logger.error("鍒涘缓RTP Server 澶辫触 {}: 璇锋鏌LM鏈嶅姟", newPort);
         }
         return result;
     }

--
Gitblit v1.8.0