From ef6693aabbbf12e83d09ad8749f6e60faacc012d Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期二, 29 十一月 2022 15:18:56 +0800
Subject: [PATCH] Merge branch 'wvp-28181-2.0' into Zafu-Dev-1127

---
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/MobilePositionNotifyMessageHandler.java |   32 -
 src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamStatusMsgListener.java                                         |   51 +-
 src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamResponseListener.java                                          |   30 
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/AlarmNotifyMessageHandler.java          |  209 +++++-----
 src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisGpsMsgListener.java                                                      |   17 
 src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisStreamMsgListener.java                                                   |   74 ++--
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/RecordInfoResponseMessageHandler.java |   17 
 src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamStatusListMsgListener.java                                     |   83 ++--
 src/main/resources/all-application.yml                                                                                             |    2 
 src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisAlarmMsgListener.java                                                    |   99 ++--
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/CatalogResponseMessageHandler.java    |  125 +++---
 src/main/java/com/genersoft/iot/vmp/gb28181/SipLayer.java                                                                          |    2 
 sql/mysql.sql                                                                                                                      |   33 
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommanderFroPlatform.java                                         |   11 
 src/main/java/com/genersoft/iot/vmp/gb28181/auth/DigestServerAuthenticationHelper.java                                             |   72 ---
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java                                |    9 
 src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisGbPlayMsgListener.java                                                   |  173 ++++----
 17 files changed, 476 insertions(+), 563 deletions(-)

diff --git a/sql/mysql.sql b/sql/mysql.sql
index 869482c..27c6da1 100644
--- a/sql/mysql.sql
+++ b/sql/mysql.sql
@@ -1,4 +1,4 @@
--- MySQL dump 10.13  Distrib 8.0.30, for Linux (x86_64)
+-- MySQL dump 10.13  Distrib 8.0.31, for Linux (x86_64)
 --
 -- Host: 127.0.0.1    Database: wvp
 -- ------------------------------------------------------
@@ -34,13 +34,13 @@
                           `online` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL,
                           `registerTime` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL,
                           `keepaliveTime` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL,
-                          `ip` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
+                          `ip` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL,
                           `createTime` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
                           `updateTime` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
                           `port` int DEFAULT NULL,
                           `expires` int DEFAULT NULL,
                           `subscribeCycleForCatalog` int DEFAULT NULL,
-                          `hostAddress` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
+                          `hostAddress` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL,
                           `charset` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
                           `subscribeCycleForMobilePosition` int DEFAULT NULL,
                           `mobilePositionSubmissionInterval` int DEFAULT '5',
@@ -48,12 +48,13 @@
                           `ssrcCheck` int DEFAULT '0',
                           `geoCoordSys` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
                           `treeType` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
-                          `mediaServerId` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT 'auto',
-                          `custom_name` varchar(255) COLLATE utf8mb4_general_ci DEFAULT NULL,
-                          `password` varchar(255) COLLATE utf8mb4_general_ci DEFAULT NULL,
+                          `custom_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL,
+                          `password` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL,
+                          `sdpIp` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
+                          `localIp` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
                           PRIMARY KEY (`id`),
                           UNIQUE KEY `device_deviceId_uindex` (`deviceId`)
-) ENGINE=InnoDB AUTO_INCREMENT=47 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
+) ENGINE=InnoDB AUTO_INCREMENT=57 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
 /*!40101 SET character_set_client = @saved_cs_client */;
 
 --
@@ -145,7 +146,7 @@
                                   PRIMARY KEY (`id`),
                                   UNIQUE KEY `device_channel_id_uindex` (`id`),
                                   UNIQUE KEY `device_channel_pk` (`channelId`,`deviceId`)
-) ENGINE=InnoDB AUTO_INCREMENT=60301 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
+) ENGINE=InnoDB AUTO_INCREMENT=74416 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
 /*!40101 SET character_set_client = @saved_cs_client */;
 
 --
@@ -215,7 +216,7 @@
                              PRIMARY KEY (`gbStreamId`) USING BTREE,
                              UNIQUE KEY `app` (`app`,`stream`) USING BTREE,
                              UNIQUE KEY `gbId` (`gbId`) USING BTREE
-) ENGINE=InnoDB AUTO_INCREMENT=301059 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC;
+) ENGINE=InnoDB AUTO_INCREMENT=331060 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC;
 /*!40101 SET character_set_client = @saved_cs_client */;
 
 --
@@ -245,7 +246,7 @@
                        `username` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
                        `createTime` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
                        PRIMARY KEY (`id`) USING BTREE
-) ENGINE=InnoDB AUTO_INCREMENT=733627 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC;
+) ENGINE=InnoDB AUTO_INCREMENT=760908 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC;
 /*!40101 SET character_set_client = @saved_cs_client */;
 
 --
@@ -337,7 +338,7 @@
                                    PRIMARY KEY (`id`),
                                    UNIQUE KEY `parent_platform_id_uindex` (`id`),
                                    UNIQUE KEY `parent_platform_pk` (`serverGBId`)
-) ENGINE=InnoDB AUTO_INCREMENT=44 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC;
+) ENGINE=InnoDB AUTO_INCREMENT=47 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC;
 /*!40101 SET character_set_client = @saved_cs_client */;
 
 --
@@ -389,7 +390,7 @@
                                        `catalogId` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
                                        `deviceChannelId` int NOT NULL,
                                        PRIMARY KEY (`id`)
-) ENGINE=InnoDB AUTO_INCREMENT=102 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
+) ENGINE=InnoDB AUTO_INCREMENT=3146 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
 /*!40101 SET character_set_client = @saved_cs_client */;
 
 --
@@ -415,7 +416,7 @@
                                       `id` int NOT NULL AUTO_INCREMENT,
                                       PRIMARY KEY (`id`),
                                       UNIQUE KEY `platform_gb_stream_pk` (`platformId`,`catalogId`,`gbStreamId`)
-) ENGINE=InnoDB AUTO_INCREMENT=301766 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC;
+) ENGINE=InnoDB AUTO_INCREMENT=391772 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC;
 /*!40101 SET character_set_client = @saved_cs_client */;
 
 --
@@ -457,7 +458,7 @@
                                 `enable_disable_none_reader` bit(1) DEFAULT NULL,
                                 PRIMARY KEY (`id`),
                                 UNIQUE KEY `stream_proxy_pk` (`app`,`stream`)
-) ENGINE=InnoDB AUTO_INCREMENT=548 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
+) ENGINE=InnoDB AUTO_INCREMENT=568 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
 /*!40101 SET character_set_client = @saved_cs_client */;
 
 --
@@ -494,7 +495,7 @@
                                `self` int DEFAULT NULL,
                                PRIMARY KEY (`id`),
                                UNIQUE KEY `stream_push_pk` (`app`,`stream`)
-) ENGINE=InnoDB AUTO_INCREMENT=310558 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
+) ENGINE=InnoDB AUTO_INCREMENT=361492 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
 /*!40101 SET character_set_client = @saved_cs_client */;
 
 --
@@ -572,4 +573,4 @@
 /*!40101 SET COLLATION_CONNECTION=@OLD_COLLATION_CONNECTION */;
 /*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;
 
--- Dump completed on 2022-10-18 17:00:02
+-- Dump completed on 2022-11-29 11:47:46
\ No newline at end of file
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/SipLayer.java b/src/main/java/com/genersoft/iot/vmp/gb28181/SipLayer.java
index 13fa01d..24b88e5 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/SipLayer.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/SipLayer.java
@@ -29,8 +29,6 @@
 	@Autowired
 	private ISIPProcessorObserver sipProcessorObserver;
 
-
-
 	private final Map<String, SipProviderImpl> tcpSipProviderMap = new ConcurrentHashMap<>();
 	private final Map<String, SipProviderImpl> udpSipProviderMap = new ConcurrentHashMap<>();
 
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/auth/DigestServerAuthenticationHelper.java b/src/main/java/com/genersoft/iot/vmp/gb28181/auth/DigestServerAuthenticationHelper.java
index 7c319ef..fdb05e5 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/auth/DigestServerAuthenticationHelper.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/auth/DigestServerAuthenticationHelper.java
@@ -25,10 +25,9 @@
  */
 package com.genersoft.iot.vmp.gb28181.auth;
 
-import java.security.MessageDigest;
-import java.security.NoSuchAlgorithmException;
-import java.time.Instant;
-import java.util.Random;
+import gov.nist.core.InternalErrorHandler;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import javax.sip.address.URI;
 import javax.sip.header.AuthorizationHeader;
@@ -36,10 +35,10 @@
 import javax.sip.header.WWWAuthenticateHeader;
 import javax.sip.message.Request;
 import javax.sip.message.Response;
-
-import gov.nist.core.InternalErrorHandler;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+import java.time.Instant;
+import java.util.Random;
 
 /**
  * Implements the HTTP digest authentication method server side functionality.
@@ -201,12 +200,13 @@
         // String ncStr = new DecimalFormat("00000000").format(Integer.parseInt(nc + "", 16));
 
         String A1 = username + ":" + realm + ":" + pass;
+
         String A2 = request.getMethod().toUpperCase() + ":" + uri.toString();
+
         byte mdbytes[] = messageDigest.digest(A1.getBytes());
         String HA1 = toHexString(mdbytes);
         logger.debug("A1: " + A1);
         logger.debug("A2: " + A2);
-
         mdbytes = messageDigest.digest(A2.getBytes());
         String HA2 = toHexString(mdbytes);
         logger.debug("HA1: " + HA1);
@@ -238,58 +238,4 @@
 
     }
 
-//     public static void main(String[] args) throws NoSuchAlgorithmException {
-//         String realm = "3402000000";
-//         String username = "44010000001180008012";
-
-
-//         String nonce = "07cab60999fbf643264ace27d3b7de8b";
-//         String uri = "sip:34020000002000000001@3402000000";
-//         // qop 淇濇姢璐ㄩ噺 鍖呭惈auth锛堥粯璁ょ殑锛夊拰auth-int锛堝鍔犱簡鎶ユ枃瀹屾暣鎬ф娴嬶級涓ょ绛栫暐
-//         String qop = "auth";
-
-//         // 瀹㈡埛绔殢鏈烘暟锛岃繖鏄竴涓笉閫忔槑鐨勫瓧绗︿覆鍊硷紝鐢卞鎴风鎻愪緵锛屽苟涓斿鎴风鍜屾湇鍔″櫒閮戒細浣跨敤锛屼互閬垮厤鐢ㄦ槑鏂囨枃鏈��
-//         // 杩欎娇寰楀弻鏂归兘鍙互鏌ラ獙瀵规柟鐨勮韩浠斤紝骞跺娑堟伅鐨勫畬鏁存�ф彁渚涗竴浜涗繚鎶�
-//         //String cNonce = authHeader.getCNonce();
-
-//         // nonce璁℃暟鍣紝鏄竴涓�16杩涘埗鐨勬暟鍊硷紝琛ㄧず鍚屼竴nonce涓嬪鎴风鍙戦�佸嚭璇锋眰鐨勬暟閲�
-//         int nc = 1;
-//         String ncStr = new DecimalFormat("00000000").format(nc);
-// //        String ncStr = new DecimalFormat("00000000").format(Integer.parseInt(nc + "", 16));
-//         MessageDigest messageDigest = MessageDigest.getInstance(DEFAULT_ALGORITHM);
-//         String A1 = username + ":" + realm + ":" + "12345678";
-//         String A2 = "REGISTER" + ":" + uri;
-//         byte mdbytes[] = messageDigest.digest(A1.getBytes());
-//         String HA1 = toHexString(mdbytes);
-//         System.out.println("A1: " + A1);
-//         System.out.println("A2: " + A2);
-
-//         mdbytes = messageDigest.digest(A2.getBytes());
-//         String HA2 = toHexString(mdbytes);
-//         System.out.println("HA1: " + HA1);
-//         System.out.println("HA2: " + HA2);
-//         String cnonce = "0a4f113b";
-//         System.out.println("nonce: " + nonce);
-//         System.out.println("nc: " + ncStr);
-//         System.out.println("cnonce: " + cnonce);
-//         System.out.println("qop: " + qop);
-//         String KD = HA1 + ":" + nonce;
-
-//         if (qop != null && qop.equals("auth") ) {
-//             if (nc != -1) {
-//                 KD += ":" + ncStr;
-//             }
-//             if (cnonce != null) {
-//                 KD += ":" + cnonce;
-//             }
-//             KD += ":" + qop;
-//         }
-//         KD += ":" + HA2;
-//         System.out.println("KD: " + KD);
-//         mdbytes = messageDigest.digest(KD.getBytes());
-//         String mdString = toHexString(mdbytes);
-//         System.out.println("mdString: " + mdString);
-//         String response = "4f0507d4b87cdecff04bdaf4c96348f0";
-//         System.out.println("response: " + response);
-//     }
 }
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommanderFroPlatform.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommanderFroPlatform.java
index 0f234f5..a641d9b 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommanderFroPlatform.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommanderFroPlatform.java
@@ -1,7 +1,6 @@
 package com.genersoft.iot.vmp.gb28181.transmit.cmd.impl;
 
 import com.alibaba.fastjson2.JSON;
-import com.alibaba.fastjson2.JSONObject;
 import com.genersoft.iot.vmp.gb28181.SipLayer;
 import com.genersoft.iot.vmp.gb28181.bean.*;
 import com.genersoft.iot.vmp.gb28181.event.SipSubscribe;
@@ -9,13 +8,13 @@
 import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommanderForPlatform;
 import com.genersoft.iot.vmp.gb28181.transmit.cmd.SIPRequestHeaderPlarformProvider;
 import com.genersoft.iot.vmp.gb28181.utils.SipUtils;
-import com.genersoft.iot.vmp.storager.dao.dto.PlatformRegisterInfo;
-import com.genersoft.iot.vmp.utils.DateUtil;
 import com.genersoft.iot.vmp.media.zlm.ZLMRTPServerFactory;
 import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;
 import com.genersoft.iot.vmp.service.IMediaServerService;
 import com.genersoft.iot.vmp.service.bean.GPSMsgInfo;
 import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
+import com.genersoft.iot.vmp.storager.dao.dto.PlatformRegisterInfo;
+import com.genersoft.iot.vmp.utils.DateUtil;
 import gov.nist.javax.sip.message.MessageFactoryImpl;
 import gov.nist.javax.sip.message.SIPRequest;
 import org.slf4j.Logger;
@@ -26,8 +25,10 @@
 import org.springframework.stereotype.Component;
 import org.springframework.util.ObjectUtils;
 
-import javax.sip.*;
-import javax.sip.header.*;
+import javax.sip.InvalidArgumentException;
+import javax.sip.SipException;
+import javax.sip.header.CallIdHeader;
+import javax.sip.header.WWWAuthenticateHeader;
 import javax.sip.message.Request;
 import java.text.ParseException;
 import java.util.ArrayList;
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java
index 4df7d63..db922f9 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java
@@ -11,7 +11,6 @@
 import com.genersoft.iot.vmp.gb28181.transmit.cmd.impl.SIPCommander;
 import com.genersoft.iot.vmp.gb28181.transmit.event.request.ISIPRequestProcessor;
 import com.genersoft.iot.vmp.gb28181.transmit.event.request.SIPRequestProcessorParent;
-import com.genersoft.iot.vmp.gb28181.utils.Coordtransform;
 import com.genersoft.iot.vmp.gb28181.utils.NumericUtil;
 import com.genersoft.iot.vmp.gb28181.utils.SipUtils;
 import com.genersoft.iot.vmp.gb28181.utils.XmlUtil;
@@ -31,7 +30,6 @@
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Component;
 import org.springframework.util.ObjectUtils;
-import org.springframework.util.StringUtils;
 
 import javax.sip.InvalidArgumentException;
 import javax.sip.RequestEvent;
@@ -77,8 +75,6 @@
 	@Autowired
 	private IDeviceChannelService deviceChannelService;
 
-	private boolean taskQueueHandlerRun = false;
-
 	private ConcurrentLinkedQueue<HandlerCatchData> taskQueue = new ConcurrentLinkedQueue<>();
 
 	@Qualifier("taskExecutor")
@@ -98,9 +94,9 @@
 		}catch (SipException | InvalidArgumentException | ParseException e) {
 			e.printStackTrace();
 		}
+		boolean runed = !taskQueue.isEmpty();
 		taskQueue.offer(new HandlerCatchData(evt, null, null));
-		if (!taskQueueHandlerRun) {
-			taskQueueHandlerRun = true;
+		if (!runed) {
 			taskExecutor.execute(()-> {
 				while (!taskQueue.isEmpty()) {
 					try {
@@ -128,7 +124,6 @@
 						logger.error("澶勭悊NOTIFY娑堟伅鏃堕敊璇�", e);
 					}
 				}
-				taskQueueHandlerRun = false;
 			});
 		}
 	}
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/AlarmNotifyMessageHandler.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/AlarmNotifyMessageHandler.java
index bb14978..09a5ffc 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/AlarmNotifyMessageHandler.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/AlarmNotifyMessageHandler.java
@@ -9,7 +9,6 @@
 import com.genersoft.iot.vmp.gb28181.transmit.event.request.SIPRequestProcessorParent;
 import com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.IMessageHandler;
 import com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.notify.NotifyMessageHandler;
-import com.genersoft.iot.vmp.gb28181.utils.Coordtransform;
 import com.genersoft.iot.vmp.gb28181.utils.NumericUtil;
 import com.genersoft.iot.vmp.gb28181.utils.XmlUtil;
 import com.genersoft.iot.vmp.service.IDeviceAlarmService;
@@ -27,17 +26,15 @@
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Component;
 import org.springframework.util.ObjectUtils;
-import org.springframework.util.StringUtils;
 
 import javax.sip.InvalidArgumentException;
 import javax.sip.RequestEvent;
 import javax.sip.SipException;
 import javax.sip.message.Response;
-
 import java.text.ParseException;
 import java.util.concurrent.ConcurrentLinkedQueue;
 
-import static com.genersoft.iot.vmp.gb28181.utils.XmlUtil.*;
+import static com.genersoft.iot.vmp.gb28181.utils.XmlUtil.getText;
 
 /**
  * 鎶ヨ浜嬩欢鐨勫鐞嗭紝鍙傝�冿細9.4
@@ -72,8 +69,6 @@
     @Autowired
     private IDeviceChannelService deviceChannelService;
 
-    private boolean taskQueueHandlerRun = false;
-
     private ConcurrentLinkedQueue<SipMsgInfo> taskQueue = new ConcurrentLinkedQueue<>();
 
     @Qualifier("taskExecutor")
@@ -89,128 +84,128 @@
     @Override
     public void handForDevice(RequestEvent evt, Device device, Element rootElement) {
         logger.info("[鏀跺埌鎶ヨ閫氱煡]璁惧锛歿}", device.getDeviceId());
-
+        boolean isEmpty = taskQueue.isEmpty();
         taskQueue.offer(new SipMsgInfo(evt, device, rootElement));
-        if (!taskQueueHandlerRun) {
-            taskQueueHandlerRun = true;
+        // 鍥炲200 OK
+        try {
+            responseAck((SIPRequest) evt.getRequest(), Response.OK);
+        } catch (SipException | InvalidArgumentException | ParseException e) {
+            logger.error("[鍛戒护鍙戦�佸け璐 鎶ヨ閫氱煡鍥炲: {}", e.getMessage());
+        }
+        if (isEmpty) {
             taskExecutor.execute(() -> {
                 logger.info("[澶勭悊鎶ヨ閫氱煡]寰呭鐞嗘暟閲忥細{}", taskQueue.size() );
                 while (!taskQueue.isEmpty()) {
-                    SipMsgInfo sipMsgInfo = taskQueue.poll();
-                    // 鍥炲200 OK
                     try {
-                        responseAck((SIPRequest) sipMsgInfo.getEvt().getRequest(), Response.OK);
-                    } catch (SipException | InvalidArgumentException | ParseException e) {
-                        logger.error("[澶勭悊鎶ヨ閫氱煡], 鍥炲200OK澶辫触", e);
-                    }
+                        SipMsgInfo sipMsgInfo = taskQueue.poll();
 
-                    Element deviceIdElement = sipMsgInfo.getRootElement().element("DeviceID");
-                    String channelId = deviceIdElement.getText().toString();
+                        Element deviceIdElement = sipMsgInfo.getRootElement().element("DeviceID");
+                        String channelId = deviceIdElement.getText().toString();
 
-                    DeviceAlarm deviceAlarm = new DeviceAlarm();
-                    deviceAlarm.setCreateTime(DateUtil.getNow());
-                    deviceAlarm.setDeviceId(sipMsgInfo.getDevice().getDeviceId());
-                    deviceAlarm.setChannelId(channelId);
-                    deviceAlarm.setAlarmPriority(getText(sipMsgInfo.getRootElement(), "AlarmPriority"));
-                    deviceAlarm.setAlarmMethod(getText(sipMsgInfo.getRootElement(), "AlarmMethod"));
-                    String alarmTime = XmlUtil.getText(sipMsgInfo.getRootElement(), "AlarmTime");
-                    if (alarmTime == null) {
-                        continue;
-                    }
-                    deviceAlarm.setAlarmTime(DateUtil.ISO8601Toyyyy_MM_dd_HH_mm_ss(alarmTime));
-                    String alarmDescription = getText(sipMsgInfo.getRootElement(), "AlarmDescription");
-                    if (alarmDescription == null) {
-                        deviceAlarm.setAlarmDescription("");
-                    } else {
-                        deviceAlarm.setAlarmDescription(alarmDescription);
-                    }
-                    String longitude = getText(sipMsgInfo.getRootElement(), "Longitude");
-                    if (longitude != null && NumericUtil.isDouble(longitude)) {
-                        deviceAlarm.setLongitude(Double.parseDouble(longitude));
-                    } else {
-                        deviceAlarm.setLongitude(0.00);
-                    }
-                    String latitude = getText(sipMsgInfo.getRootElement(), "Latitude");
-                    if (latitude != null && NumericUtil.isDouble(latitude)) {
-                        deviceAlarm.setLatitude(Double.parseDouble(latitude));
-                    } else {
-                        deviceAlarm.setLatitude(0.00);
-                    }
+                        DeviceAlarm deviceAlarm = new DeviceAlarm();
+                        deviceAlarm.setCreateTime(DateUtil.getNow());
+                        deviceAlarm.setDeviceId(sipMsgInfo.getDevice().getDeviceId());
+                        deviceAlarm.setChannelId(channelId);
+                        deviceAlarm.setAlarmPriority(getText(sipMsgInfo.getRootElement(), "AlarmPriority"));
+                        deviceAlarm.setAlarmMethod(getText(sipMsgInfo.getRootElement(), "AlarmMethod"));
+                        String alarmTime = XmlUtil.getText(sipMsgInfo.getRootElement(), "AlarmTime");
+                        if (alarmTime == null) {
+                            continue;
+                        }
+                        deviceAlarm.setAlarmTime(DateUtil.ISO8601Toyyyy_MM_dd_HH_mm_ss(alarmTime));
+                        String alarmDescription = getText(sipMsgInfo.getRootElement(), "AlarmDescription");
+                        if (alarmDescription == null) {
+                            deviceAlarm.setAlarmDescription("");
+                        } else {
+                            deviceAlarm.setAlarmDescription(alarmDescription);
+                        }
+                        String longitude = getText(sipMsgInfo.getRootElement(), "Longitude");
+                        if (longitude != null && NumericUtil.isDouble(longitude)) {
+                            deviceAlarm.setLongitude(Double.parseDouble(longitude));
+                        } else {
+                            deviceAlarm.setLongitude(0.00);
+                        }
+                        String latitude = getText(sipMsgInfo.getRootElement(), "Latitude");
+                        if (latitude != null && NumericUtil.isDouble(latitude)) {
+                            deviceAlarm.setLatitude(Double.parseDouble(latitude));
+                        } else {
+                            deviceAlarm.setLatitude(0.00);
+                        }
 
-                    if (!ObjectUtils.isEmpty(deviceAlarm.getAlarmMethod())) {
-                        if ( deviceAlarm.getAlarmMethod().contains(DeviceAlarmMethod.GPS.getVal() + "")) {
-                            MobilePosition mobilePosition = new MobilePosition();
-                            mobilePosition.setCreateTime(DateUtil.getNow());
-                            mobilePosition.setDeviceId(deviceAlarm.getDeviceId());
-                            mobilePosition.setTime(deviceAlarm.getAlarmTime());
-                            mobilePosition.setLongitude(deviceAlarm.getLongitude());
-                            mobilePosition.setLatitude(deviceAlarm.getLatitude());
-                            mobilePosition.setReportSource("GPS Alarm");
+                        if (!ObjectUtils.isEmpty(deviceAlarm.getAlarmMethod())) {
+                            if ( deviceAlarm.getAlarmMethod().contains(DeviceAlarmMethod.GPS.getVal() + "")) {
+                                MobilePosition mobilePosition = new MobilePosition();
+                                mobilePosition.setCreateTime(DateUtil.getNow());
+                                mobilePosition.setDeviceId(deviceAlarm.getDeviceId());
+                                mobilePosition.setTime(deviceAlarm.getAlarmTime());
+                                mobilePosition.setLongitude(deviceAlarm.getLongitude());
+                                mobilePosition.setLatitude(deviceAlarm.getLatitude());
+                                mobilePosition.setReportSource("GPS Alarm");
 
-                            // 鏇存柊device channel 鐨勭粡绾害
-                            DeviceChannel deviceChannel = new DeviceChannel();
-                            deviceChannel.setDeviceId(sipMsgInfo.getDevice().getDeviceId());
-                            deviceChannel.setChannelId(channelId);
-                            deviceChannel.setLongitude(mobilePosition.getLongitude());
-                            deviceChannel.setLatitude(mobilePosition.getLatitude());
-                            deviceChannel.setGpsTime(mobilePosition.getTime());
+                                // 鏇存柊device channel 鐨勭粡绾害
+                                DeviceChannel deviceChannel = new DeviceChannel();
+                                deviceChannel.setDeviceId(sipMsgInfo.getDevice().getDeviceId());
+                                deviceChannel.setChannelId(channelId);
+                                deviceChannel.setLongitude(mobilePosition.getLongitude());
+                                deviceChannel.setLatitude(mobilePosition.getLatitude());
+                                deviceChannel.setGpsTime(mobilePosition.getTime());
 
-                            deviceChannel = deviceChannelService.updateGps(deviceChannel, sipMsgInfo.getDevice());
+                                deviceChannel = deviceChannelService.updateGps(deviceChannel, sipMsgInfo.getDevice());
 
-                            mobilePosition.setLongitudeWgs84(deviceChannel.getLongitudeWgs84());
-                            mobilePosition.setLatitudeWgs84(deviceChannel.getLatitudeWgs84());
-                            mobilePosition.setLongitudeGcj02(deviceChannel.getLongitudeGcj02());
-                            mobilePosition.setLatitudeGcj02(deviceChannel.getLatitudeGcj02());
+                                mobilePosition.setLongitudeWgs84(deviceChannel.getLongitudeWgs84());
+                                mobilePosition.setLatitudeWgs84(deviceChannel.getLatitudeWgs84());
+                                mobilePosition.setLongitudeGcj02(deviceChannel.getLongitudeGcj02());
+                                mobilePosition.setLatitudeGcj02(deviceChannel.getLatitudeGcj02());
 
-                            if (userSetting.getSavePositionHistory()) {
-                                storager.insertMobilePosition(mobilePosition);
+                                if (userSetting.getSavePositionHistory()) {
+                                    storager.insertMobilePosition(mobilePosition);
+                                }
+                                storager.updateChannelPosition(deviceChannel);
+
+                                // 鍙戦�乺edis娑堟伅銆� 閫氱煡浣嶇疆淇℃伅鐨勫彉鍖�
+                                JSONObject jsonObject = new JSONObject();
+                                jsonObject.put("time", mobilePosition.getTime());
+                                jsonObject.put("serial", deviceChannel.getDeviceId());
+                                jsonObject.put("code", deviceChannel.getChannelId());
+                                jsonObject.put("longitude", mobilePosition.getLongitude());
+                                jsonObject.put("latitude", mobilePosition.getLatitude());
+                                jsonObject.put("altitude", mobilePosition.getAltitude());
+                                jsonObject.put("direction", mobilePosition.getDirection());
+                                jsonObject.put("speed", mobilePosition.getSpeed());
+                                redisCatchStorage.sendMobilePositionMsg(jsonObject);
                             }
-                            storager.updateChannelPosition(deviceChannel);
-
-                            // 鍙戦�乺edis娑堟伅銆� 閫氱煡浣嶇疆淇℃伅鐨勫彉鍖�
-                            JSONObject jsonObject = new JSONObject();
-                            jsonObject.put("time", mobilePosition.getTime());
-                            jsonObject.put("serial", deviceChannel.getDeviceId());
-                            jsonObject.put("code", deviceChannel.getChannelId());
-                            jsonObject.put("longitude", mobilePosition.getLongitude());
-                            jsonObject.put("latitude", mobilePosition.getLatitude());
-                            jsonObject.put("altitude", mobilePosition.getAltitude());
-                            jsonObject.put("direction", mobilePosition.getDirection());
-                            jsonObject.put("speed", mobilePosition.getSpeed());
-                            redisCatchStorage.sendMobilePositionMsg(jsonObject);
                         }
-                    }
-                    if (!ObjectUtils.isEmpty(deviceAlarm.getDeviceId())) {
-                        if (deviceAlarm.getAlarmMethod().contains(DeviceAlarmMethod.Video.getVal() + "")) {
-                            deviceAlarm.setAlarmType(getText(sipMsgInfo.getRootElement().element("Info"), "AlarmType"));
+                        if (!ObjectUtils.isEmpty(deviceAlarm.getDeviceId())) {
+                            if (deviceAlarm.getAlarmMethod().contains(DeviceAlarmMethod.Video.getVal() + "")) {
+                                deviceAlarm.setAlarmType(getText(sipMsgInfo.getRootElement().element("Info"), "AlarmType"));
+                            }
                         }
-                    }
-                    logger.info("[鏀跺埌鎶ヨ閫氱煡]鍐呭锛歿}", JSON.toJSONString(deviceAlarm));
-                    if ("7".equals(deviceAlarm.getAlarmMethod()) ) {
-                        // 鍙戦�佺粰骞冲彴鐨勬姤璀︿俊鎭�� 鍙戦�乺edis閫氱煡
-                        AlarmChannelMessage alarmChannelMessage = new AlarmChannelMessage();
-                        alarmChannelMessage.setAlarmSn(Integer.parseInt(deviceAlarm.getAlarmMethod()));
-                        alarmChannelMessage.setAlarmDescription(deviceAlarm.getAlarmDescription());
-                        alarmChannelMessage.setGbId(channelId);
-                        redisCatchStorage.sendAlarmMsg(alarmChannelMessage);
-                        continue;
-                    }
+                        logger.info("[鏀跺埌鎶ヨ閫氱煡]鍐呭锛歿}", JSON.toJSONString(deviceAlarm));
+                        if ("7".equals(deviceAlarm.getAlarmMethod()) ) {
+                            // 鍙戦�佺粰骞冲彴鐨勬姤璀︿俊鎭�� 鍙戦�乺edis閫氱煡
+                            AlarmChannelMessage alarmChannelMessage = new AlarmChannelMessage();
+                            alarmChannelMessage.setAlarmSn(Integer.parseInt(deviceAlarm.getAlarmMethod()));
+                            alarmChannelMessage.setAlarmDescription(deviceAlarm.getAlarmDescription());
+                            alarmChannelMessage.setGbId(channelId);
+                            redisCatchStorage.sendAlarmMsg(alarmChannelMessage);
+                            continue;
+                        }
 
-                    logger.debug("瀛樺偍鎶ヨ淇℃伅銆佹姤璀﹀垎绫�");
-                    // 瀛樺偍鎶ヨ淇℃伅銆佹姤璀﹀垎绫�
-                    if (sipConfig.isAlarm()) {
-                        deviceAlarmService.add(deviceAlarm);
-                    }
+                        logger.debug("瀛樺偍鎶ヨ淇℃伅銆佹姤璀﹀垎绫�");
+                        // 瀛樺偍鎶ヨ淇℃伅銆佹姤璀﹀垎绫�
+                        if (sipConfig.isAlarm()) {
+                            deviceAlarmService.add(deviceAlarm);
+                        }
 
-                    if (redisCatchStorage.deviceIsOnline(sipMsgInfo.getDevice().getDeviceId())) {
-                        publisher.deviceAlarmEventPublish(deviceAlarm);
+                        if (redisCatchStorage.deviceIsOnline(sipMsgInfo.getDevice().getDeviceId())) {
+                            publisher.deviceAlarmEventPublish(deviceAlarm);
+                        }
+                    }catch (Exception e) {
+                        logger.warn("[鏀跺埌鎶ヨ閫氱煡] 鍙戠幇鏈鐞嗙殑寮傚父, {}\r\n{}",e.getMessage(), evt.getRequest());
                     }
                 }
-                taskQueueHandlerRun = false;
             });
         }
-
-
     }
 
     @Override
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/MobilePositionNotifyMessageHandler.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/MobilePositionNotifyMessageHandler.java
index 7a0ea1c..40d1dcc 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/MobilePositionNotifyMessageHandler.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/MobilePositionNotifyMessageHandler.java
@@ -22,7 +22,6 @@
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Component;
 import org.springframework.util.ObjectUtils;
-import org.springframework.util.StringUtils;
 
 import javax.sip.InvalidArgumentException;
 import javax.sip.RequestEvent;
@@ -57,8 +56,6 @@
     @Autowired
     private IDeviceChannelService deviceChannelService;
 
-    private boolean taskQueueHandlerRun = false;
-
     private ConcurrentLinkedQueue<SipMsgInfo> taskQueue = new ConcurrentLinkedQueue<>();
 
     @Qualifier("taskExecutor")
@@ -73,21 +70,22 @@
     @Override
     public void handForDevice(RequestEvent evt, Device device, Element rootElement) {
 
+        boolean isEmpty = taskQueue.isEmpty();
         taskQueue.offer(new SipMsgInfo(evt, device, rootElement));
-        if (!taskQueueHandlerRun) {
-            taskQueueHandlerRun = true;
+        // 鍥炲200 OK
+        try {
+            responseAck((SIPRequest) evt.getRequest(), Response.OK);
+        } catch (SipException | InvalidArgumentException | ParseException e) {
+            logger.error("[鍛戒护鍙戦�佸け璐 绉诲姩浣嶇疆閫氱煡鍥炲: {}", e.getMessage());
+        }
+        if (isEmpty) {
             taskExecutor.execute(() -> {
                 while (!taskQueue.isEmpty()) {
                     SipMsgInfo sipMsgInfo = taskQueue.poll();
                     try {
                         Element rootElementAfterCharset = getRootElement(sipMsgInfo.getEvt(), sipMsgInfo.getDevice().getCharset());
                         if (rootElementAfterCharset == null) {
-                            try {
-                                logger.warn("[ 绉诲姩璁惧浣嶇疆鏁版嵁閫氱煡 ] content cannot be null, {}", sipMsgInfo.getEvt().getRequest());
-                                responseAck((SIPRequest) sipMsgInfo.getEvt().getRequest(), Response.BAD_REQUEST);
-                            } catch (SipException | InvalidArgumentException | ParseException e) {
-                                logger.error("[鍛戒护鍙戦�佸け璐 绉诲姩璁惧浣嶇疆鏁版嵁閫氱煡 鍐呭涓虹┖: {}", e.getMessage());
-                            }
+                            logger.warn("[绉诲姩浣嶇疆閫氱煡] {}澶勭悊澶辫触锛屾湭璇嗗埆鍒颁俊鎭綋", device.getDeviceId());
                             continue;
                         }
                         MobilePosition mobilePosition = new MobilePosition();
@@ -137,12 +135,6 @@
                             storager.insertMobilePosition(mobilePosition);
                         }
                         storager.updateChannelPosition(deviceChannel);
-                        //鍥炲 200 OK
-                        try {
-                            responseAck((SIPRequest) sipMsgInfo.getEvt().getRequest(), Response.OK);
-                        } catch (SipException | InvalidArgumentException | ParseException e) {
-                            logger.error("[鍛戒护鍙戦�佸け璐 绉诲姩璁惧浣嶇疆鏁版嵁鍥炲200: {}", e.getMessage());
-                        }
 
                         // 鍙戦�乺edis娑堟伅銆� 閫氱煡浣嶇疆淇℃伅鐨勫彉鍖�
                         JSONObject jsonObject = new JSONObject();
@@ -158,14 +150,12 @@
 
                     } catch (DocumentException e) {
                         e.printStackTrace();
+                    } catch (Exception e) {
+                        logger.warn("[绉诲姩浣嶇疆閫氱煡] 鍙戠幇鏈鐞嗙殑寮傚父, {}\r\n{}",e.getMessage(), evt.getRequest());
                     }
-
                 }
-                taskQueueHandlerRun = false;
             });
         }
-
-
     }
 
     @Override
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/CatalogResponseMessageHandler.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/CatalogResponseMessageHandler.java
index 52e0b7f..761481b 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/CatalogResponseMessageHandler.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/CatalogResponseMessageHandler.java
@@ -1,18 +1,11 @@
 package com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.response.cmd;
 
-import com.genersoft.iot.vmp.conf.SipConfig;
-import com.genersoft.iot.vmp.conf.UserSetting;
 import com.genersoft.iot.vmp.gb28181.bean.*;
-import com.genersoft.iot.vmp.gb28181.event.EventPublisher;
 import com.genersoft.iot.vmp.gb28181.session.CatalogDataCatch;
-import com.genersoft.iot.vmp.gb28181.transmit.callback.DeferredResultHolder;
 import com.genersoft.iot.vmp.gb28181.transmit.event.request.SIPRequestProcessorParent;
 import com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.IMessageHandler;
 import com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.response.ResponseMessageHandler;
-import com.genersoft.iot.vmp.gb28181.utils.Coordtransform;
-import com.genersoft.iot.vmp.gb28181.utils.NumericUtil;
 import com.genersoft.iot.vmp.gb28181.utils.XmlUtil;
-import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
 import com.genersoft.iot.vmp.storager.IVideoManagerStorage;
 import gov.nist.javax.sip.message.SIPRequest;
 import org.dom4j.DocumentException;
@@ -24,7 +17,6 @@
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Component;
-import org.springframework.util.StringUtils;
 
 import javax.sip.InvalidArgumentException;
 import javax.sip.RequestEvent;
@@ -45,12 +37,10 @@
     private Logger logger = LoggerFactory.getLogger(CatalogResponseMessageHandler.class);
     private final String cmdType = "Catalog";
 
-    private boolean taskQueueHandlerRun = false;
-
     @Autowired
     private ResponseMessageHandler responseMessageHandler;
 
-    private ConcurrentLinkedQueue<HandlerCatchData> taskQueue = new ConcurrentLinkedQueue<>();
+    private final ConcurrentLinkedQueue<HandlerCatchData> taskQueue = new ConcurrentLinkedQueue<>();
 
     @Autowired
     private IVideoManagerStorage storager;
@@ -69,6 +59,7 @@
 
     @Override
     public void handForDevice(RequestEvent evt, Device device, Element element) {
+        boolean isEmpty = taskQueue.isEmpty();
         taskQueue.offer(new HandlerCatchData(evt, device, element));
         // 鍥炲200 OK
         try {
@@ -76,67 +67,71 @@
         } catch (SipException | InvalidArgumentException | ParseException e) {
             logger.error("[鍛戒护鍙戦�佸け璐 鐩綍鏌ヨ鍥炲: {}", e.getMessage());
         }
-        if (!taskQueueHandlerRun) {
-            taskQueueHandlerRun = true;
+        // 濡傛灉涓嶄负绌哄垯璇存槑宸茬粡寮�鍚秷鎭鐞�
+        if (isEmpty) {
             taskExecutor.execute(() -> {
                 while (!taskQueue.isEmpty()) {
-                    HandlerCatchData take = taskQueue.poll();
-                    Element rootElement = null;
+                    // 鍏ㄥ眬寮傚父鎹曡幏锛屼繚璇佷笅涓�鏉″彲浠ュ緱鍒板鐞�
                     try {
-                        rootElement = getRootElement(take.getEvt(), take.getDevice().getCharset());
-                    } catch (DocumentException e) {
-                        logger.error("[xml瑙f瀽] 澶辫触锛� ", e);
-                        continue;
-                    }
-                    if (rootElement == null) {
-                        logger.warn("[ 鏀跺埌閫氶亾 ] content cannot be null, {}", evt.getRequest());
-                        continue;
-                    }
-                    Element deviceListElement = rootElement.element("DeviceList");
-                    Element sumNumElement = rootElement.element("SumNum");
-                    Element snElement = rootElement.element("SN");
-                    int sumNum = Integer.parseInt(sumNumElement.getText());
-
-                    if (sumNum == 0) {
-                        logger.info("[鏀跺埌閫氶亾]璁惧:{}鐨�: 0涓�", take.getDevice().getDeviceId());
-                        // 鏁版嵁宸茬粡瀹屾暣鎺ユ敹
-                        storager.cleanChannelsForDevice(take.getDevice().getDeviceId());
-                        catalogDataCatch.setChannelSyncEnd(take.getDevice().getDeviceId(), null);
-                    } else {
-                        Iterator<Element> deviceListIterator = deviceListElement.elementIterator();
-                        if (deviceListIterator != null) {
-                            List<DeviceChannel> channelList = new ArrayList<>();
-                            // 閬嶅巻DeviceList
-                            while (deviceListIterator.hasNext()) {
-                                Element itemDevice = deviceListIterator.next();
-                                Element channelDeviceElement = itemDevice.element("DeviceID");
-                                if (channelDeviceElement == null) {
-                                    continue;
-                                }
-                                DeviceChannel deviceChannel = XmlUtil.channelContentHander(itemDevice, device, null);
-                                deviceChannel.setDeviceId(take.getDevice().getDeviceId());
-
-                                channelList.add(deviceChannel);
-                            }
-                            int sn = Integer.parseInt(snElement.getText());
-                            catalogDataCatch.put(take.getDevice().getDeviceId(), sn, sumNum, take.getDevice(), channelList);
-                            logger.info("[鏀跺埌閫氶亾]璁惧: {} -> {}涓紝{}/{}", take.getDevice().getDeviceId(), channelList.size(), catalogDataCatch.get(take.getDevice().getDeviceId()) == null ? 0 : catalogDataCatch.get(take.getDevice().getDeviceId()).size(), sumNum);
-                            if (catalogDataCatch.get(take.getDevice().getDeviceId()).size() == sumNum) {
-                                // 鏁版嵁宸茬粡瀹屾暣鎺ユ敹锛� 姝ゆ椂鍙兘瀛樺湪鏌愪釜璁惧绂荤嚎鍙樹笂绾跨殑鎯呭喌锛屼絾鏄�冭檻鍒版�ц兘锛屾澶勪笉鍋氬鐞嗭紝
-                                // 鐩墠鏀寔璁惧閫氶亾涓婄嚎閫氱煡鏃跺拰璁惧涓婄嚎鏃跺悜涓婄骇閫氱煡
-                                boolean resetChannelsResult = storager.resetChannels(take.getDevice().getDeviceId(), catalogDataCatch.get(take.getDevice().getDeviceId()));
-                                if (!resetChannelsResult) {
-                                    String errorMsg = "鎺ユ敹鎴愬姛锛屽啓鍏ュけ璐ワ紝鍏�" + sumNum + "鏉★紝宸叉帴鏀�" + catalogDataCatch.get(take.getDevice().getDeviceId()).size() + "鏉�";
-                                    catalogDataCatch.setChannelSyncEnd(take.getDevice().getDeviceId(), errorMsg);
-                                } else {
-                                    catalogDataCatch.setChannelSyncEnd(take.getDevice().getDeviceId(), null);
-                                }
-                            }
+                        HandlerCatchData take = taskQueue.poll();
+                        Element rootElement = null;
+                        try {
+                            rootElement = getRootElement(take.getEvt(), take.getDevice().getCharset());
+                        } catch (DocumentException e) {
+                            logger.error("[xml瑙f瀽] 澶辫触锛� ", e);
+                            continue;
                         }
+                        if (rootElement == null) {
+                            logger.warn("[ 鏀跺埌閫氶亾 ] content cannot be null, {}", evt.getRequest());
+                            continue;
+                        }
+                        Element deviceListElement = rootElement.element("DeviceList");
+                        Element sumNumElement = rootElement.element("SumNum");
+                        Element snElement = rootElement.element("SN");
+                        int sumNum = Integer.parseInt(sumNumElement.getText());
 
+                        if (sumNum == 0) {
+                            logger.info("[鏀跺埌閫氶亾]璁惧:{}鐨�: 0涓�", take.getDevice().getDeviceId());
+                            // 鏁版嵁宸茬粡瀹屾暣鎺ユ敹
+                            storager.cleanChannelsForDevice(take.getDevice().getDeviceId());
+                            catalogDataCatch.setChannelSyncEnd(take.getDevice().getDeviceId(), null);
+                        } else {
+                            Iterator<Element> deviceListIterator = deviceListElement.elementIterator();
+                            if (deviceListIterator != null) {
+                                List<DeviceChannel> channelList = new ArrayList<>();
+                                // 閬嶅巻DeviceList
+                                while (deviceListIterator.hasNext()) {
+                                    Element itemDevice = deviceListIterator.next();
+                                    Element channelDeviceElement = itemDevice.element("DeviceID");
+                                    if (channelDeviceElement == null) {
+                                        continue;
+                                    }
+                                    DeviceChannel deviceChannel = XmlUtil.channelContentHander(itemDevice, device, null);
+                                    deviceChannel.setDeviceId(take.getDevice().getDeviceId());
+
+                                    channelList.add(deviceChannel);
+                                }
+                                int sn = Integer.parseInt(snElement.getText());
+                                catalogDataCatch.put(take.getDevice().getDeviceId(), sn, sumNum, take.getDevice(), channelList);
+                                logger.info("[鏀跺埌閫氶亾]璁惧: {} -> {}涓紝{}/{}", take.getDevice().getDeviceId(), channelList.size(), catalogDataCatch.get(take.getDevice().getDeviceId()) == null ? 0 : catalogDataCatch.get(take.getDevice().getDeviceId()).size(), sumNum);
+                                if (catalogDataCatch.get(take.getDevice().getDeviceId()).size() == sumNum) {
+                                    // 鏁版嵁宸茬粡瀹屾暣鎺ユ敹锛� 姝ゆ椂鍙兘瀛樺湪鏌愪釜璁惧绂荤嚎鍙樹笂绾跨殑鎯呭喌锛屼絾鏄�冭檻鍒版�ц兘锛屾澶勪笉鍋氬鐞嗭紝
+                                    // 鐩墠鏀寔璁惧閫氶亾涓婄嚎閫氱煡鏃跺拰璁惧涓婄嚎鏃跺悜涓婄骇閫氱煡
+                                    boolean resetChannelsResult = storager.resetChannels(take.getDevice().getDeviceId(), catalogDataCatch.get(take.getDevice().getDeviceId()));
+                                    if (!resetChannelsResult) {
+                                        String errorMsg = "鎺ユ敹鎴愬姛锛屽啓鍏ュけ璐ワ紝鍏�" + sumNum + "鏉★紝宸叉帴鏀�" + catalogDataCatch.get(take.getDevice().getDeviceId()).size() + "鏉�";
+                                        catalogDataCatch.setChannelSyncEnd(take.getDevice().getDeviceId(), errorMsg);
+                                    } else {
+                                        catalogDataCatch.setChannelSyncEnd(take.getDevice().getDeviceId(), null);
+                                    }
+                                }
+                            }
+
+                        }
+                    }catch (Exception e) {
+                        logger.warn("[鏀跺埌閫氶亾] 鍙戠幇鏈鐞嗙殑寮傚父, {}\r\n{}",e.getMessage(), evt.getRequest());
                     }
                 }
-                taskQueueHandlerRun = false;
             });
         }
 
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/RecordInfoResponseMessageHandler.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/RecordInfoResponseMessageHandler.java
index 286dd56..11d239e 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/RecordInfoResponseMessageHandler.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/RecordInfoResponseMessageHandler.java
@@ -9,7 +9,6 @@
 import com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.IMessageHandler;
 import com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.response.ResponseMessageHandler;
 import com.genersoft.iot.vmp.utils.DateUtil;
-import com.genersoft.iot.vmp.vmanager.bean.WVPResult;
 import gov.nist.javax.sip.message.SIPRequest;
 import org.dom4j.DocumentException;
 import org.dom4j.Element;
@@ -21,17 +20,17 @@
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Component;
 import org.springframework.util.ObjectUtils;
-import org.springframework.util.StringUtils;
 
 import javax.sip.InvalidArgumentException;
 import javax.sip.RequestEvent;
 import javax.sip.SipException;
 import javax.sip.message.Response;
 import java.text.ParseException;
-import java.util.*;
-import java.util.concurrent.BlockingQueue;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.Iterator;
+import java.util.List;
 import java.util.concurrent.ConcurrentLinkedQueue;
-import java.util.concurrent.LinkedBlockingQueue;
 
 import static com.genersoft.iot.vmp.gb28181.utils.XmlUtil.getText;
 
@@ -46,7 +45,6 @@
 
     private ConcurrentLinkedQueue<HandlerCatchData> taskQueue = new ConcurrentLinkedQueue<>();
 
-    private boolean taskQueueHandlerRun = false;
     @Autowired
     private ResponseMessageHandler responseMessageHandler;
 
@@ -70,6 +68,7 @@
 
     @Override
     public void handForDevice(RequestEvent evt, Device device, Element rootElement) {
+        boolean isEmpty = taskQueue.isEmpty();
         try {
             // 鍥炲200 OK
              responseAck((SIPRequest) evt.getRequest(), Response.OK);
@@ -77,8 +76,7 @@
             logger.error("[鍛戒护鍙戦�佸け璐 鍥芥爣绾ц仈 鍥芥爣褰曞儚: {}", e.getMessage());
         }
         taskQueue.offer(new HandlerCatchData(evt, device, rootElement));
-        if (!taskQueueHandlerRun) {
-            taskQueueHandlerRun = true;
+        if (isEmpty) {
             taskExecutor.execute(()->{
                 while (!taskQueue.isEmpty()) {
                     try {
@@ -151,9 +149,10 @@
                         }
                     } catch (DocumentException e) {
                         logger.error("xml瑙f瀽寮傚父锛� ", e);
+                    } catch (Exception e) {
+                        logger.warn("[鍥芥爣褰曞儚] 鍙戠幇鏈鐞嗙殑寮傚父, {}\r\n{}",e.getMessage(), evt.getRequest());
                     }
                 }
-                taskQueueHandlerRun = false;
             });
         }
     }
diff --git a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisAlarmMsgListener.java b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisAlarmMsgListener.java
index d68591c..9bb3bbd 100644
--- a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisAlarmMsgListener.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisAlarmMsgListener.java
@@ -38,8 +38,6 @@
     @Autowired
     private IVideoManagerStorage storage;
 
-    private boolean taskQueueHandlerRun = false;
-
     private ConcurrentLinkedQueue<Message> taskQueue = new ConcurrentLinkedQueue<>();
 
     @Qualifier("taskExecutor")
@@ -49,69 +47,68 @@
     @Override
     public void onMessage(@NotNull Message message, byte[] bytes) {
         logger.info("鏀跺埌鏉ヨ嚜REDIS鐨凙LARM閫氱煡锛� {}", new String(message.getBody()));
-
+        boolean isEmpty = taskQueue.isEmpty();
         taskQueue.offer(message);
-        if (!taskQueueHandlerRun) {
-            taskQueueHandlerRun = true;
+        if (isEmpty) {
             logger.info("[绾跨▼姹犱俊鎭痌娲诲姩绾跨▼鏁帮細{}, 鏈�澶х嚎绋嬫暟锛� {}", taskExecutor.getActiveCount(), taskExecutor.getMaxPoolSize());
             taskExecutor.execute(() -> {
                 while (!taskQueue.isEmpty()) {
                     Message msg = taskQueue.poll();
+                    try {
+                        AlarmChannelMessage alarmChannelMessage = JSON.parseObject(msg.getBody(), AlarmChannelMessage.class);
+                        if (alarmChannelMessage == null) {
+                            logger.warn("[REDIS鐨凙LARM閫氱煡]娑堟伅瑙f瀽澶辫触");
+                            continue;
+                        }
+                        String gbId = alarmChannelMessage.getGbId();
 
-                    AlarmChannelMessage alarmChannelMessage = JSON.parseObject(msg.getBody(), AlarmChannelMessage.class);
-                    if (alarmChannelMessage == null) {
-                        logger.warn("[REDIS鐨凙LARM閫氱煡]娑堟伅瑙f瀽澶辫触");
-                        continue;
-                    }
-                    String gbId = alarmChannelMessage.getGbId();
+                        DeviceAlarm deviceAlarm = new DeviceAlarm();
+                        deviceAlarm.setCreateTime(DateUtil.getNow());
+                        deviceAlarm.setChannelId(gbId);
+                        deviceAlarm.setAlarmDescription(alarmChannelMessage.getAlarmDescription());
+                        deviceAlarm.setAlarmMethod("" + alarmChannelMessage.getAlarmSn());
+                        deviceAlarm.setAlarmPriority("1");
+                        deviceAlarm.setAlarmTime(DateUtil.getNowForISO8601());
+                        deviceAlarm.setAlarmType("1");
+                        deviceAlarm.setLongitude(0);
+                        deviceAlarm.setLatitude(0);
 
-                    DeviceAlarm deviceAlarm = new DeviceAlarm();
-                    deviceAlarm.setCreateTime(DateUtil.getNow());
-                    deviceAlarm.setChannelId(gbId);
-                    deviceAlarm.setAlarmDescription(alarmChannelMessage.getAlarmDescription());
-                    deviceAlarm.setAlarmMethod("" + alarmChannelMessage.getAlarmSn());
-                    deviceAlarm.setAlarmPriority("1");
-                    deviceAlarm.setAlarmTime(DateUtil.getNowForISO8601());
-                    deviceAlarm.setAlarmType("1");
-                    deviceAlarm.setLongitude(0);
-                    deviceAlarm.setLatitude(0);
-
-                    if (ObjectUtils.isEmpty(gbId)) {
-                        // 鍙戦�佺粰鎵�鏈夌殑涓婄骇
-                        List<ParentPlatform> parentPlatforms = storage.queryEnableParentPlatformList(true);
-                        if (parentPlatforms.size() > 0) {
-                            for (ParentPlatform parentPlatform : parentPlatforms) {
-                                try {
-                                    commanderForPlatform.sendAlarmMessage(parentPlatform, deviceAlarm);
-                                } catch (SipException | InvalidArgumentException | ParseException e) {
-                                    logger.error("[鍛戒护鍙戦�佸け璐 鍥芥爣绾ц仈 鍙戦�佹姤璀�: {}", e.getMessage());
+                        if (ObjectUtils.isEmpty(gbId)) {
+                            // 鍙戦�佺粰鎵�鏈夌殑涓婄骇
+                            List<ParentPlatform> parentPlatforms = storage.queryEnableParentPlatformList(true);
+                            if (parentPlatforms.size() > 0) {
+                                for (ParentPlatform parentPlatform : parentPlatforms) {
+                                    try {
+                                        commanderForPlatform.sendAlarmMessage(parentPlatform, deviceAlarm);
+                                    } catch (SipException | InvalidArgumentException | ParseException e) {
+                                        logger.error("[鍛戒护鍙戦�佸け璐 鍥芥爣绾ц仈 鍙戦�佹姤璀�: {}", e.getMessage());
+                                    }
                                 }
                             }
-                        }
-                    }else {
-                        Device device = storage.queryVideoDevice(gbId);
-                        ParentPlatform platform = storage.queryParentPlatByServerGBId(gbId);
-                        if (device != null && platform == null) {
-                            try {
-                                commander.sendAlarmMessage(device, deviceAlarm);
-                            } catch (InvalidArgumentException | SipException | ParseException e) {
-                                logger.error("[鍛戒护鍙戦�佸け璐 鍙戦�佹姤璀�: {}", e.getMessage());
-                            }
-                        }else if (device == null && platform != null){
-                            try {
-                                commanderForPlatform.sendAlarmMessage(platform, deviceAlarm);
-                            } catch (InvalidArgumentException | SipException | ParseException e) {
-                                logger.error("[鍛戒护鍙戦�佸け璐 鍙戦�佹姤璀�: {}", e.getMessage());
-                            }
                         }else {
-                            logger.warn("鏃犳硶纭畾" + gbId + "鏄钩鍙拌繕鏄澶�");
+                            Device device = storage.queryVideoDevice(gbId);
+                            ParentPlatform platform = storage.queryParentPlatByServerGBId(gbId);
+                            if (device != null && platform == null) {
+                                try {
+                                    commander.sendAlarmMessage(device, deviceAlarm);
+                                } catch (InvalidArgumentException | SipException | ParseException e) {
+                                    logger.error("[鍛戒护鍙戦�佸け璐 鍙戦�佹姤璀�: {}", e.getMessage());
+                                }
+                            }else if (device == null && platform != null){
+                                try {
+                                    commanderForPlatform.sendAlarmMessage(platform, deviceAlarm);
+                                } catch (InvalidArgumentException | SipException | ParseException e) {
+                                    logger.error("[鍛戒护鍙戦�佸け璐 鍙戦�佹姤璀�: {}", e.getMessage());
+                                }
+                            }else {
+                                logger.warn("鏃犳硶纭畾" + gbId + "鏄钩鍙拌繕鏄澶�");
+                            }
                         }
+                    }catch (Exception e) {
+                        logger.warn("[REDIS鐨凙LARM閫氱煡] 鍙戠幇鏈鐞嗙殑寮傚父, {}",e.getMessage());
                     }
                 }
-                taskQueueHandlerRun = false;
             });
         }
-
-
     }
 }
diff --git a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisGbPlayMsgListener.java b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisGbPlayMsgListener.java
index 61dea12..35ed99e 100644
--- a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisGbPlayMsgListener.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisGbPlayMsgListener.java
@@ -88,8 +88,6 @@
     @Autowired
     private ZlmHttpHookSubscribe subscribe;
 
-    private boolean taskQueueHandlerRun = false;
-
     private ConcurrentLinkedQueue<Message> taskQueue = new ConcurrentLinkedQueue<>();
 
     @Qualifier("taskExecutor")
@@ -111,107 +109,104 @@
 
     @Override
     public void onMessage(Message message, byte[] bytes) {
-
+        boolean isEmpty = taskQueue.isEmpty();
         taskQueue.offer(message);
-        if (!taskQueueHandlerRun) {
-            taskQueueHandlerRun = true;
+        if (isEmpty) {
             taskExecutor.execute(() -> {
                 while (!taskQueue.isEmpty()) {
                     Message msg = taskQueue.poll();
-                    JSONObject msgJSON = JSON.parseObject(msg.getBody(), JSONObject.class);
-                    WvpRedisMsg wvpRedisMsg = JSON.to(WvpRedisMsg.class, msgJSON);
-                    if (!userSetting.getServerId().equals(wvpRedisMsg.getToId())) {
-                        continue;
-                    }
-                    if (WvpRedisMsg.isRequest(wvpRedisMsg)) {
-                        logger.info("[鏀跺埌REDIS閫氱煡] 璇锋眰锛� {}", new String(msg.getBody()));
-
-                        switch (wvpRedisMsg.getCmd()){
-                            case WvpRedisMsgCmd.GET_SEND_ITEM:
-                                RequestSendItemMsg content = JSON.to(RequestSendItemMsg.class, wvpRedisMsg.getContent());
-                                requestSendItemMsgHand(content, wvpRedisMsg.getFromId(), wvpRedisMsg.getSerial());
-                                break;
-                            case WvpRedisMsgCmd.REQUEST_PUSH_STREAM:
-                                RequestPushStreamMsg param = JSON.to(RequestPushStreamMsg.class, wvpRedisMsg.getContent());;
-                                requestPushStreamMsgHand(param, wvpRedisMsg.getFromId(), wvpRedisMsg.getSerial());
-                                break;
-                            default:
-                                break;
+                    try {
+                        JSONObject msgJSON = JSON.parseObject(msg.getBody(), JSONObject.class);
+                        WvpRedisMsg wvpRedisMsg = JSON.to(WvpRedisMsg.class, msgJSON);
+                        if (!userSetting.getServerId().equals(wvpRedisMsg.getToId())) {
+                            continue;
                         }
+                        if (WvpRedisMsg.isRequest(wvpRedisMsg)) {
+                            logger.info("[鏀跺埌REDIS閫氱煡] 璇锋眰锛� {}", new String(msg.getBody()));
 
-                    }else {
-                        logger.info("[鏀跺埌REDIS閫氱煡] 鍥炲锛� {}", new String(msg.getBody()));
-                        switch (wvpRedisMsg.getCmd()){
-                            case WvpRedisMsgCmd.GET_SEND_ITEM:
+                            switch (wvpRedisMsg.getCmd()){
+                                case WvpRedisMsgCmd.GET_SEND_ITEM:
+                                    RequestSendItemMsg content = JSON.to(RequestSendItemMsg.class, wvpRedisMsg.getContent());
+                                    requestSendItemMsgHand(content, wvpRedisMsg.getFromId(), wvpRedisMsg.getSerial());
+                                    break;
+                                case WvpRedisMsgCmd.REQUEST_PUSH_STREAM:
+                                    RequestPushStreamMsg param = JSON.to(RequestPushStreamMsg.class, wvpRedisMsg.getContent());
+                                    requestPushStreamMsgHand(param, wvpRedisMsg.getFromId(), wvpRedisMsg.getSerial());
+                                    break;
+                                default:
+                                    break;
+                            }
 
-                                WVPResult content  = JSON.to(WVPResult.class, wvpRedisMsg.getContent());
+                        }else {
+                            logger.info("[鏀跺埌REDIS閫氱煡] 鍥炲锛� {}", new String(msg.getBody()));
+                            switch (wvpRedisMsg.getCmd()){
+                                case WvpRedisMsgCmd.GET_SEND_ITEM:
 
-                                String key = wvpRedisMsg.getSerial();
-                                switch (content.getCode()) {
-                                    case 0:
-                                        ResponseSendItemMsg responseSendItemMsg =JSON.to(ResponseSendItemMsg.class, content.getData());
-                                        PlayMsgCallback playMsgCallback = callbacks.get(key);
-                                        if (playMsgCallback != null) {
-                                            callbacksForError.remove(key);
-                                            try {
-                                                playMsgCallback.handler(responseSendItemMsg);
-                                            } catch (ParseException e) {
-                                                logger.error("[REDIS娑堟伅澶勭悊寮傚父] ", e);
+                                   WVPResult content  = JSON.to(WVPResult.class, wvpRedisMsg.getContent());
+
+                                    String key = wvpRedisMsg.getSerial();
+                                    switch (content.getCode()) {
+                                        case 0:
+                                           ResponseSendItemMsg responseSendItemMsg =JSON.to(ResponseSendItemMsg.class, content.getData());
+                                            PlayMsgCallback playMsgCallback = callbacks.get(key);
+                                            if (playMsgCallback != null) {
+                                                callbacksForError.remove(key);
+                                                try {
+                                                    playMsgCallback.handler(responseSendItemMsg);
+                                                } catch (ParseException e) {
+                                                    logger.error("[REDIS娑堟伅澶勭悊寮傚父] ", e);
+                                                }
                                             }
-                                        }
-                                        break;
-                                    case ERROR_CODE_MEDIA_SERVER_NOT_FOUND:
-                                    case ERROR_CODE_OFFLINE:
-                                    case ERROR_CODE_TIMEOUT:
-                                        PlayMsgErrorCallback errorCallback = callbacksForError.get(key);
-                                        if (errorCallback != null) {
-                                            callbacks.remove(key);
-                                            errorCallback.handler(content);
-                                        }
-                                        break;
-                                    default:
-                                        break;
-                                }
-                                break;
-                            case WvpRedisMsgCmd.REQUEST_PUSH_STREAM:
-                                WVPResult wvpResult  = JSON.to(WVPResult.class, wvpRedisMsg.getContent());
-                                String serial = wvpRedisMsg.getSerial();
-                                switch (wvpResult.getCode()) {
-                                    case 0:
-                                        JSONObject jsonObject = (JSONObject)wvpResult.getData();
-                                        PlayMsgCallbackForStartSendRtpStream playMsgCallback = callbacksForStartSendRtpStream.get(serial);
-                                        if (playMsgCallback != null) {
-                                            callbacksForError.remove(serial);
-                                            playMsgCallback.handler(jsonObject);
-                                        }
-                                        break;
-                                    case ERROR_CODE_MEDIA_SERVER_NOT_FOUND:
-                                    case ERROR_CODE_OFFLINE:
-                                    case ERROR_CODE_TIMEOUT:
-                                        PlayMsgErrorCallback errorCallback = callbacksForError.get(serial);
-                                        if (errorCallback != null) {
-                                            callbacks.remove(serial);
-                                            errorCallback.handler(wvpResult);
-                                        }
-                                        break;
-                                    default:
-                                        break;
-                                }
-                                break;
-                            default:
-                                break;
+                                            break;
+                                        case ERROR_CODE_MEDIA_SERVER_NOT_FOUND:
+                                        case ERROR_CODE_OFFLINE:
+                                        case ERROR_CODE_TIMEOUT:
+                                            PlayMsgErrorCallback errorCallback = callbacksForError.get(key);
+                                            if (errorCallback != null) {
+                                                callbacks.remove(key);
+                                                errorCallback.handler(content);
+                                            }
+                                            break;
+                                        default:
+                                            break;
+                                    }
+                                    break;
+                                case WvpRedisMsgCmd.REQUEST_PUSH_STREAM:
+                                    WVPResult wvpResult  = JSON.to(WVPResult.class, wvpRedisMsg.getContent());
+                                    String serial = wvpRedisMsg.getSerial();
+                                    switch (wvpResult.getCode()) {
+                                        case 0:
+                                            JSONObject jsonObject = (JSONObject)wvpResult.getData();
+                                            PlayMsgCallbackForStartSendRtpStream playMsgCallback = callbacksForStartSendRtpStream.get(serial);
+                                            if (playMsgCallback != null) {
+                                                callbacksForError.remove(serial);
+                                                playMsgCallback.handler(jsonObject);
+                                            }
+                                            break;
+                                        case ERROR_CODE_MEDIA_SERVER_NOT_FOUND:
+                                        case ERROR_CODE_OFFLINE:
+                                        case ERROR_CODE_TIMEOUT:
+                                            PlayMsgErrorCallback errorCallback = callbacksForError.get(serial);
+                                            if (errorCallback != null) {
+                                                callbacks.remove(serial);
+                                                errorCallback.handler(wvpResult);
+                                            }
+                                            break;
+                                        default:
+                                            break;
+                                    }
+                                    break;
+                                default:
+                                    break;
+                            }
+
                         }
+                    }catch (Exception e) {
+                        logger.warn("[RedisGbPlayMsg] 鍙戠幇鏈鐞嗙殑寮傚父, {}",e.getMessage());
                     }
                 }
-                taskQueueHandlerRun = false;
             });
         }
-
-
-
-
-
-
     }
 
     /**
diff --git a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisGpsMsgListener.java b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisGpsMsgListener.java
index c43a937..0c99707 100644
--- a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisGpsMsgListener.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisGpsMsgListener.java
@@ -27,8 +27,6 @@
 
     private final static Logger logger = LoggerFactory.getLogger(RedisGpsMsgListener.class);
 
-    private boolean taskQueueHandlerRun = false;
-
     @Autowired
     private IRedisCatchStorage redisCatchStorage;
 
@@ -44,17 +42,20 @@
 
     @Override
     public void onMessage(@NotNull Message message, byte[] bytes) {
+        boolean isEmpty = taskQueue.isEmpty();
         taskQueue.offer(message);
-        if (!taskQueueHandlerRun) {
-            taskQueueHandlerRun = true;
+        if (isEmpty) {
             taskExecutor.execute(() -> {
                 while (!taskQueue.isEmpty()) {
                     Message msg = taskQueue.poll();
-                    GPSMsgInfo gpsMsgInfo = JSON.parseObject(msg.getBody(), GPSMsgInfo.class);
-                    // 鍙槸鏀惧叆redis缂撳瓨璧锋潵
-                    redisCatchStorage.updateGpsMsgInfo(gpsMsgInfo);
+                    try {
+                        GPSMsgInfo gpsMsgInfo = JSON.parseObject(msg.getBody(), GPSMsgInfo.class);
+                        // 鍙槸鏀惧叆redis缂撳瓨璧锋潵
+                        redisCatchStorage.updateGpsMsgInfo(gpsMsgInfo);
+                    }catch (Exception e) {
+                        logger.warn("[REDIS鐨凙LARM閫氱煡] 鍙戠幇鏈鐞嗙殑寮傚父, {}",e.getMessage());
+                    }
                 }
-                taskQueueHandlerRun = false;
             });
         }
     }
diff --git a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamResponseListener.java b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamResponseListener.java
index 05d662d..33eae1e 100644
--- a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamResponseListener.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamResponseListener.java
@@ -1,7 +1,6 @@
 package com.genersoft.iot.vmp.service.redisMsg;
 
 import com.alibaba.fastjson2.JSON;
-import com.genersoft.iot.vmp.service.bean.GPSMsgInfo;
 import com.genersoft.iot.vmp.service.bean.MessageForPushChannelResponse;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -26,8 +25,6 @@
 
     private final static Logger logger = LoggerFactory.getLogger(RedisPushStreamResponseListener.class);
 
-    private boolean taskQueueHandlerRun = false;
-
     private ConcurrentLinkedQueue<Message> taskQueue = new ConcurrentLinkedQueue<>();
 
     @Qualifier("taskExecutor")
@@ -43,24 +40,27 @@
 
     @Override
     public void onMessage(Message message, byte[] bytes) {
-        logger.warn("[REDIS娑堟伅-璇锋眰鎺ㄦ祦缁撴灉]锛� {}", new String(message.getBody()));
+        logger.info("[REDIS娑堟伅-璇锋眰鎺ㄦ祦缁撴灉]锛� {}", new String(message.getBody()));
+        boolean isEmpty = taskQueue.isEmpty();
         taskQueue.offer(message);
-        if (!taskQueueHandlerRun) {
-            taskQueueHandlerRun = true;
+        if (isEmpty) {
             taskExecutor.execute(() -> {
                 while (!taskQueue.isEmpty()) {
                     Message msg = taskQueue.poll();
-                    MessageForPushChannelResponse response = JSON.parseObject(new String(msg.getBody()), MessageForPushChannelResponse.class);
-                    if (response == null || ObjectUtils.isEmpty(response.getApp()) || ObjectUtils.isEmpty(response.getStream())){
-                        logger.info("[REDIS娑堟伅-璇锋眰鎺ㄦ祦缁撴灉]锛氬弬鏁颁笉鍏�");
-                        continue;
-                    }
-                    // 鏌ョ湅姝e湪绛夊緟鐨刬nvite娑堟伅
-                    if (responseEvents.get(response.getApp() + response.getStream()) != null) {
-                        responseEvents.get(response.getApp() + response.getStream()).run(response);
+                    try {
+                        MessageForPushChannelResponse response = JSON.parseObject(new String(msg.getBody()), MessageForPushChannelResponse.class);
+                        if (response == null || ObjectUtils.isEmpty(response.getApp()) || ObjectUtils.isEmpty(response.getStream())){
+                            logger.info("[REDIS娑堟伅-璇锋眰鎺ㄦ祦缁撴灉]锛氬弬鏁颁笉鍏�");
+                            continue;
+                        }
+                        // 鏌ョ湅姝e湪绛夊緟鐨刬nvite娑堟伅
+                        if (responseEvents.get(response.getApp() + response.getStream()) != null) {
+                            responseEvents.get(response.getApp() + response.getStream()).run(response);
+                        }
+                    }catch (Exception e) {
+                        logger.warn("[REDIS鐨凙LARM閫氱煡] 鍙戠幇鏈鐞嗙殑寮傚父, {}",e.getMessage());
                     }
                 }
-                taskQueueHandlerRun = false;
             });
         }
     }
diff --git a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamStatusListMsgListener.java b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamStatusListMsgListener.java
index 15e37ec..d8ed1a0 100644
--- a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamStatusListMsgListener.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamStatusListMsgListener.java
@@ -6,7 +6,6 @@
 import com.genersoft.iot.vmp.service.IGbStreamService;
 import com.genersoft.iot.vmp.service.IMediaServerService;
 import com.genersoft.iot.vmp.service.IStreamPushService;
-import com.genersoft.iot.vmp.service.bean.GPSMsgInfo;
 import com.genersoft.iot.vmp.utils.DateUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -18,7 +17,8 @@
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.concurrent.ConcurrentLinkedQueue;
 
 /**
@@ -38,7 +38,6 @@
     @Resource
     private IGbStreamService gbStreamService;
 
-    private boolean taskQueueHandlerRun = false;
 
     private ConcurrentLinkedQueue<Message> taskQueue = new ConcurrentLinkedQueue<>();
 
@@ -49,54 +48,56 @@
     @Override
     public void onMessage(Message message, byte[] bytes) {
         logger.info("[REDIS娑堟伅-鎺ㄦ祦璁惧鍒楄〃鏇存柊]锛� {}", new String(message.getBody()));
-
+        boolean isEmpty = taskQueue.isEmpty();
         taskQueue.offer(message);
-        if (!taskQueueHandlerRun) {
-            taskQueueHandlerRun = true;
+        if (isEmpty) {
             taskExecutor.execute(() -> {
                 while (!taskQueue.isEmpty()) {
                     Message msg = taskQueue.poll();
-                    List<StreamPushItem> streamPushItems = JSON.parseArray(new String(msg.getBody()), StreamPushItem.class);
-                    //鏌ヨ鍏ㄩ儴鐨刟pp+stream 鐢ㄤ簬鍒ゆ柇鏄坊鍔犺繕鏄慨鏀�
-                    List<String> allAppAndStream = streamPushService.getAllAppAndStream();
+                    try {
+                        List<StreamPushItem> streamPushItems = JSON.parseArray(new String(msg.getBody()), StreamPushItem.class);
+                        //鏌ヨ鍏ㄩ儴鐨刟pp+stream 鐢ㄤ簬鍒ゆ柇鏄坊鍔犺繕鏄慨鏀�
+                        List<String> allAppAndStream = streamPushService.getAllAppAndStream();
 
-                    /**
-                     * 鐢ㄤ簬瀛樺偍鏇村叿APP+Stream杩囨护鍚庣殑鏁版嵁锛屽彲浠ョ洿鎺ュ瓨鍏tream_push琛ㄤ笌gb_stream琛�
-                     */
-                    List<StreamPushItem> streamPushItemForSave = new ArrayList<>();
-                    List<StreamPushItem> streamPushItemForUpdate = new ArrayList<>();
-                    for (StreamPushItem streamPushItem : streamPushItems) {
-                        String app = streamPushItem.getApp();
-                        String stream = streamPushItem.getStream();
-                        boolean contains = allAppAndStream.contains(app + stream);
-                        //涓嶅瓨鍦ㄥ氨娣诲姞
-                        if (!contains) {
-                            streamPushItem.setStreamType("push");
-                            streamPushItem.setCreateTime(DateUtil.getNow());
-                            streamPushItem.setMediaServerId(mediaServerService.getDefaultMediaServer().getId());
-                            streamPushItem.setOriginType(2);
-                            streamPushItem.setOriginTypeStr("rtsp_push");
-                            streamPushItem.setTotalReaderCount("0");
-                            streamPushItemForSave.add(streamPushItem);
-                        } else {
-                            //瀛樺湪灏卞彧淇敼 name鍜実bId
-                            streamPushItemForUpdate.add(streamPushItem);
+                        /**
+                         * 鐢ㄤ簬瀛樺偍鏇村叿APP+Stream杩囨护鍚庣殑鏁版嵁锛屽彲浠ョ洿鎺ュ瓨鍏tream_push琛ㄤ笌gb_stream琛�
+                         */
+                        List<StreamPushItem> streamPushItemForSave = new ArrayList<>();
+                        List<StreamPushItem> streamPushItemForUpdate = new ArrayList<>();
+                        for (StreamPushItem streamPushItem : streamPushItems) {
+                            String app = streamPushItem.getApp();
+                            String stream = streamPushItem.getStream();
+                            boolean contains = allAppAndStream.contains(app + stream);
+                            //涓嶅瓨鍦ㄥ氨娣诲姞
+                            if (!contains) {
+                                streamPushItem.setStreamType("push");
+                                streamPushItem.setCreateTime(DateUtil.getNow());
+                                streamPushItem.setMediaServerId(mediaServerService.getDefaultMediaServer().getId());
+                                streamPushItem.setOriginType(2);
+                                streamPushItem.setOriginTypeStr("rtsp_push");
+                                streamPushItem.setTotalReaderCount("0");
+                                streamPushItemForSave.add(streamPushItem);
+                            } else {
+                                //瀛樺湪灏卞彧淇敼 name鍜実bId
+                                streamPushItemForUpdate.add(streamPushItem);
+                            }
                         }
-                    }
-                    if (streamPushItemForSave.size() > 0) {
+                        if (streamPushItemForSave.size() > 0) {
 
-                        logger.info("娣诲姞{}鏉�",streamPushItemForSave.size());
-                        logger.info(JSONObject.toJSONString(streamPushItemForSave));
-                        streamPushService.batchAdd(streamPushItemForSave);
+                            logger.info("娣诲姞{}鏉�",streamPushItemForSave.size());
+                            logger.info(JSONObject.toJSONString(streamPushItemForSave));
+                            streamPushService.batchAdd(streamPushItemForSave);
 
-                    }
-                    if(streamPushItemForUpdate.size()>0){
-                        logger.info("淇敼{}鏉�",streamPushItemForUpdate.size());
-                        logger.info(JSONObject.toJSONString(streamPushItemForUpdate));
-                        gbStreamService.updateGbIdOrName(streamPushItemForUpdate);
+                        }
+                        if(streamPushItemForUpdate.size()>0){
+                            logger.info("淇敼{}鏉�",streamPushItemForUpdate.size());
+                            logger.info(JSONObject.toJSONString(streamPushItemForUpdate));
+                            gbStreamService.updateGbIdOrName(streamPushItemForUpdate);
+                        }
+                    }catch (Exception e) {
+                        logger.warn("[REDIS鐨凙LARM閫氱煡] 鍙戠幇鏈鐞嗙殑寮傚父, {}",e.getMessage());
                     }
                 }
-                taskQueueHandlerRun = false;
             });
         }
     }
diff --git a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamStatusMsgListener.java b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamStatusMsgListener.java
index 4fafa1c..96ff8e8 100644
--- a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamStatusMsgListener.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamStatusMsgListener.java
@@ -29,8 +29,6 @@
 
     private final static Logger logger = LoggerFactory.getLogger(RedisPushStreamStatusMsgListener.class);
 
-    private boolean taskQueueHandlerRun = false;
-
     @Autowired
     private IRedisCatchStorage redisCatchStorage;
 
@@ -50,37 +48,40 @@
 
     @Override
     public void onMessage(Message message, byte[] bytes) {
+        boolean isEmpty = taskQueue.isEmpty();
         logger.warn("[REDIS娑堟伅-鎺ㄦ祦璁惧鐘舵�佸彉鍖朷锛� {}", new String(message.getBody()));
         taskQueue.offer(message);
 
-        if (!taskQueueHandlerRun) {
-            taskQueueHandlerRun = true;
+        if (isEmpty) {
             taskExecutor.execute(() -> {
                 while (!taskQueue.isEmpty()) {
                     Message msg = taskQueue.poll();
-                    PushStreamStatusChangeFromRedisDto statusChangeFromPushStream = JSON.parseObject(msg.getBody(), PushStreamStatusChangeFromRedisDto.class);
-                    if (statusChangeFromPushStream == null) {
-                        logger.warn("[REDIS娑堟伅]鎺ㄦ祦璁惧鐘舵�佸彉鍖栨秷鎭В鏋愬け璐�");
-                        continue;
-                    }
-                    // 鍙栨秷瀹氭椂浠诲姟
-                    dynamicTask.stop(VideoManagerConstants.VM_MSG_GET_ALL_ONLINE_REQUESTED);
-                    if (statusChangeFromPushStream.isSetAllOffline()) {
-                        // 鎵�鏈夎澶囩绾�
-                        streamPushService.allStreamOffline();
-                    }
-                    if (statusChangeFromPushStream.getOfflineStreams() != null
-                            && statusChangeFromPushStream.getOfflineStreams().size() > 0) {
-                        // 鏇存柊閮ㄥ垎璁惧绂荤嚎
-                        streamPushService.offline(statusChangeFromPushStream.getOfflineStreams());
-                    }
-                    if (statusChangeFromPushStream.getOnlineStreams() != null &&
-                            statusChangeFromPushStream.getOnlineStreams().size() > 0) {
-                        // 鏇存柊閮ㄥ垎璁惧涓婄嚎
-                        streamPushService.online(statusChangeFromPushStream.getOnlineStreams());
+                    try {
+                        PushStreamStatusChangeFromRedisDto statusChangeFromPushStream = JSON.parseObject(msg.getBody(), PushStreamStatusChangeFromRedisDto.class);
+                        if (statusChangeFromPushStream == null) {
+                            logger.warn("[REDIS娑堟伅]鎺ㄦ祦璁惧鐘舵�佸彉鍖栨秷鎭В鏋愬け璐�");
+                            continue;
+                        }
+                        // 鍙栨秷瀹氭椂浠诲姟
+                        dynamicTask.stop(VideoManagerConstants.VM_MSG_GET_ALL_ONLINE_REQUESTED);
+                        if (statusChangeFromPushStream.isSetAllOffline()) {
+                            // 鎵�鏈夎澶囩绾�
+                            streamPushService.allStreamOffline();
+                        }
+                        if (statusChangeFromPushStream.getOfflineStreams() != null
+                                && statusChangeFromPushStream.getOfflineStreams().size() > 0) {
+                            // 鏇存柊閮ㄥ垎璁惧绂荤嚎
+                            streamPushService.offline(statusChangeFromPushStream.getOfflineStreams());
+                        }
+                        if (statusChangeFromPushStream.getOnlineStreams() != null &&
+                                statusChangeFromPushStream.getOnlineStreams().size() > 0) {
+                            // 鏇存柊閮ㄥ垎璁惧涓婄嚎
+                            streamPushService.online(statusChangeFromPushStream.getOnlineStreams());
+                        }
+                    }catch (Exception e) {
+                        logger.warn("[REDIS鐨凙LARM閫氱煡] 鍙戠幇鏈鐞嗙殑寮傚父, {}",e.getMessage());
                     }
                 }
-                taskQueueHandlerRun = false;
             });
         }
     }
diff --git a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisStreamMsgListener.java b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisStreamMsgListener.java
index 3e73fc0..1cdc527 100644
--- a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisStreamMsgListener.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisStreamMsgListener.java
@@ -33,8 +33,6 @@
     @Autowired
     private ZLMMediaListManager zlmMediaListManager;
 
-    private boolean taskQueueHandlerRun = false;
-
     private ConcurrentLinkedQueue<Message> taskQueue = new ConcurrentLinkedQueue<>();
 
     @Qualifier("taskExecutor")
@@ -43,48 +41,50 @@
 
     @Override
     public void onMessage(Message message, byte[] bytes) {
-
+        boolean isEmpty = taskQueue.isEmpty();
         taskQueue.offer(message);
-        if (!taskQueueHandlerRun) {
-            taskQueueHandlerRun = true;
+        if (isEmpty) {
             taskExecutor.execute(() -> {
                 while (!taskQueue.isEmpty()) {
                     Message msg = taskQueue.poll();
-                    JSONObject steamMsgJson = JSON.parseObject(msg.getBody(), JSONObject.class);
-                    if (steamMsgJson == null) {
-                        logger.warn("[鏀跺埌redis 娴佸彉鍖朷娑堟伅瑙f瀽澶辫触");
-                        continue;
-                    }
-                    String serverId = steamMsgJson.getString("serverId");
+                    try {
+                        JSONObject steamMsgJson = JSON.parseObject(msg.getBody(), JSONObject.class);
+                        if (steamMsgJson == null) {
+                            logger.warn("[鏀跺埌redis 娴佸彉鍖朷娑堟伅瑙f瀽澶辫触");
+                            continue;
+                        }
+                        String serverId = steamMsgJson.getString("serverId");
 
-                    if (userSetting.getServerId().equals(serverId)) {
-                        // 鑷繁鍙戦�佺殑娑堟伅蹇界暐鍗冲彲
-                        continue;
-                    }
-                    logger.info("[鏀跺埌redis 娴佸彉鍖朷锛� {}", new String(message.getBody()));
-                    String app = steamMsgJson.getString("app");
-                    String stream = steamMsgJson.getString("stream");
-                    boolean register = steamMsgJson.getBoolean("register");
-                    String mediaServerId = steamMsgJson.getString("mediaServerId");
-                    OnStreamChangedHookParam onStreamChangedHookParam = new OnStreamChangedHookParam();
-                    onStreamChangedHookParam.setSeverId(serverId);
-                    onStreamChangedHookParam.setApp(app);
-                    onStreamChangedHookParam.setStream(stream);
-                    onStreamChangedHookParam.setRegist(register);
-                    onStreamChangedHookParam.setMediaServerId(mediaServerId);
-                    onStreamChangedHookParam.setCreateStamp(System.currentTimeMillis()/1000);
-                    onStreamChangedHookParam.setAliveSecond(0L);
-                    onStreamChangedHookParam.setTotalReaderCount("0");
-                    onStreamChangedHookParam.setOriginType(0);
-                    onStreamChangedHookParam.setOriginTypeStr("0");
-                    onStreamChangedHookParam.setOriginTypeStr("unknown");
-                    if (register) {
-                        zlmMediaListManager.addPush(onStreamChangedHookParam);
-                    }else {
-                        zlmMediaListManager.removeMedia(app, stream);
+                        if (userSetting.getServerId().equals(serverId)) {
+                            // 鑷繁鍙戦�佺殑娑堟伅蹇界暐鍗冲彲
+                            continue;
+                        }
+                        logger.info("[鏀跺埌redis 娴佸彉鍖朷锛� {}", new String(message.getBody()));
+                        String app = steamMsgJson.getString("app");
+                        String stream = steamMsgJson.getString("stream");
+                        boolean register = steamMsgJson.getBoolean("register");
+                        String mediaServerId = steamMsgJson.getString("mediaServerId");
+                        OnStreamChangedHookParam onStreamChangedHookParam = new OnStreamChangedHookParam();
+                        onStreamChangedHookParam.setSeverId(serverId);
+                        onStreamChangedHookParam.setApp(app);
+                        onStreamChangedHookParam.setStream(stream);
+                        onStreamChangedHookParam.setRegist(register);
+                        onStreamChangedHookParam.setMediaServerId(mediaServerId);
+                        onStreamChangedHookParam.setCreateStamp(System.currentTimeMillis()/1000);
+                        onStreamChangedHookParam.setAliveSecond(0L);
+                        onStreamChangedHookParam.setTotalReaderCount("0");
+                        onStreamChangedHookParam.setOriginType(0);
+                        onStreamChangedHookParam.setOriginTypeStr("0");
+                        onStreamChangedHookParam.setOriginTypeStr("unknown");
+                        if (register) {
+                            zlmMediaListManager.addPush(onStreamChangedHookParam);
+                        }else {
+                            zlmMediaListManager.removeMedia(app, stream);
+                        }
+                    }catch (Exception e) {
+                        logger.warn("[REDIS鐨凙LARM閫氱煡] 鍙戠幇鏈鐞嗙殑寮傚父, {}",e.getMessage());
                     }
                 }
-                taskQueueHandlerRun = false;
             });
         }
     }
diff --git a/src/main/resources/all-application.yml b/src/main/resources/all-application.yml
index 6240e44..ba150fb 100644
--- a/src/main/resources/all-application.yml
+++ b/src/main/resources/all-application.yml
@@ -150,8 +150,6 @@
         enable: true
         # [鍙�塢 鍦ㄦ鑼冨洿鍐呴�夋嫨绔彛鐢ㄤ簬濯掍綋娴佷紶杈�, 蹇呴』鎻愬墠鍦▃lm涓婇厤缃灞炴�э紝涓嶇劧鑷姩閰嶇疆姝ゅ睘鎬у彲鑳戒笉鎴愬姛
         port-range: 30000,30500 # 绔彛鑼冨洿
-        # [鍙�塢 鍥芥爣绾ц仈鍦ㄦ鑼冨洿鍐呴�夋嫨绔彛鍙戦�佸獟浣撴祦
-        send-port-range: 30000,30500 # 绔彛鑼冨洿
     # 褰曞儚杈呭姪鏈嶅姟锛� 閮ㄧ讲姝ゆ湇鍔″彲浠ュ疄鐜皕lm褰曞儚鐨勭鐞嗕笌涓嬭浇锛� 0 琛ㄧず涓嶄娇鐢�
     record-assist-port: 0
 

--
Gitblit v1.8.0