处理空指针

src/main/java/com/genersoft/iot/vmp/gb28181/transmit/request/impl/ByeRequestProcessor.java

@@ -48,6 +48,7 @@ public class ByeRequestProcessor extends SIPRequestAbstractProcessor {
 				String platformGbId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(FromHeader.NAME)).getAddress().getURI()).getUser();
 				String channelId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(ToHeader.NAME)).getAddress().getURI()).getUser();
 				SendRtpItem sendRtpItem =  redisCatchStorage.querySendRTPServer(platformGbId, channelId);
+				if (sendRtpItem == null) return;
 				String streamId = sendRtpItem.getStreamId();
 				Map<String, Object> param = new HashMap<>();
 				param.put("vhost","__defaultVhost__");

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

@@ -295,25 +295,26 @@ public class ZLMHttpHookListener {
 		
 		String streamId = json.getString("stream");
 		String app = json.getString("app");
-		StreamInfo streamInfo = redisCatchStorage.queryPlayByStreamId(streamId);
-
 
 		if ("rtp".equals(app)){
 			JSONObject ret = new JSONObject();
 			ret.put("code", 0);
 			ret.put("close", true);
-			if (streamInfo != null) {
+			StreamInfo streamInfoForPlayCatch = redisCatchStorage.queryPlayByStreamId(streamId);
-				if (redisCatchStorage.isChannelSendingRTP(streamInfo.getChannelId())) {
+			if (streamInfoForPlayCatch != null) {
+				if (redisCatchStorage.isChannelSendingRTP(streamInfoForPlayCatch.getChannelId())) {
 					ret.put("close", false);
 				} else {
-					cmder.streamByeCmd(streamInfo.getDeviceID(), streamInfo.getChannelId());
+					cmder.streamByeCmd(streamInfoForPlayCatch.getDeviceID(), streamInfoForPlayCatch.getChannelId());
-					redisCatchStorage.stopPlay(streamInfo);
+					redisCatchStorage.stopPlay(streamInfoForPlayCatch);
-					storager.stopPlay(streamInfo.getDeviceID(), streamInfo.getChannelId());
+					storager.stopPlay(streamInfoForPlayCatch.getDeviceID(), streamInfoForPlayCatch.getChannelId());
 				}
 			}else{
-				cmder.streamByeCmd(streamInfo.getDeviceID(), streamInfo.getChannelId());
+				StreamInfo streamInfoForPlayBackCatch = redisCatchStorage.queryPlaybackByStreamId(streamId);
-				streamInfo = redisCatchStorage.queryPlaybackByStreamId(streamId);
+				if (streamInfoForPlayBackCatch != null) {
-				redisCatchStorage.stopPlayback(streamInfo);
+					cmder.streamByeCmd(streamInfoForPlayBackCatch.getDeviceID(), streamInfoForPlayBackCatch.getChannelId());
+					redisCatchStorage.stopPlayback(streamInfoForPlayBackCatch);
+				}
 			}
 			return new ResponseEntity<String>(ret.toString(),HttpStatus.OK);
 		}else {

web_src/src/components/dialog/StreamProxyEdit.vue

@@ -110,7 +110,7 @@ export default {
           type: "default",
           app: null,
           stream: null,
-          url: "rtmp://58.200.131.2:1935/livetv/hunantv",
+          url: "rtmp://58.200.131.2/livetv/cctv5hd",
           src_url: null,
           timeout_ms: null,
           ffmpeg_cmd_key: null,