From 6ac131bcf6ec034ffc9e5813c68c56c6e5c32b70 Mon Sep 17 00:00:00 2001
From: xiaoxie <hotcoffie@163.com>
Date: 星期三, 01 十二月 2021 22:45:51 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/wvp-28181-2.0' into wvp-28181-2.0
---
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/SIPProcessorObserver.java | 162 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 162 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/SIPProcessorObserver.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/SIPProcessorObserver.java
new file mode 100644
index 0000000..3724a3b
--- /dev/null
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/SIPProcessorObserver.java
@@ -0,0 +1,162 @@
+package com.genersoft.iot.vmp.gb28181.transmit;
+
+import com.genersoft.iot.vmp.gb28181.event.SipSubscribe;
+import com.genersoft.iot.vmp.gb28181.transmit.event.request.ISIPRequestProcessor;
+import com.genersoft.iot.vmp.gb28181.transmit.event.response.ISIPResponseProcessor;
+import com.genersoft.iot.vmp.gb28181.transmit.event.timeout.ITimeoutProcessor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+import org.springframework.stereotype.Component;
+
+import javax.sip.*;
+import javax.sip.header.CSeqHeader;
+import javax.sip.header.CallIdHeader;
+import javax.sip.message.Response;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * @description: SIP淇′护澶勭悊绫昏瀵熻��
+ * @author: panlinlin
+ * @date: 2021骞�11鏈�5鏃� 涓嬪崍15锛�32
+ */
+@Component
+public class SIPProcessorObserver implements ISIPProcessorObserver {
+
+ private final static Logger logger = LoggerFactory.getLogger(SIPProcessorObserver.class);
+
+ private static Map<String, ISIPRequestProcessor> requestProcessorMap = new ConcurrentHashMap<>();
+ private static Map<String, ISIPResponseProcessor> responseProcessorMap = new ConcurrentHashMap<>();
+ private static ITimeoutProcessor timeoutProcessor;
+
+ @Autowired
+ private SipSubscribe sipSubscribe;
+
+// @Autowired
+// @Qualifier(value = "taskExecutor")
+// private ThreadPoolTaskExecutor poolTaskExecutor;
+
+ /**
+ * 娣诲姞 request璁㈤槄
+ * @param method 鏂规硶鍚�
+ * @param processor 澶勭悊绋嬪簭
+ */
+ public void addRequestProcessor(String method, ISIPRequestProcessor processor) {
+ requestProcessorMap.put(method, processor);
+ }
+
+ /**
+ * 娣诲姞 response璁㈤槄
+ * @param method 鏂规硶鍚�
+ * @param processor 澶勭悊绋嬪簭
+ */
+ public void addResponseProcessor(String method, ISIPResponseProcessor processor) {
+ responseProcessorMap.put(method, processor);
+ }
+
+ /**
+ * 娣诲姞 瓒呮椂浜嬩欢璁㈤槄
+ * @param processor 澶勭悊绋嬪簭
+ */
+ public void addTimeoutProcessor(ITimeoutProcessor processor) {
+ this.timeoutProcessor = processor;
+ }
+
+ /**
+ * 鍒嗗彂RequestEvent浜嬩欢
+ * @param requestEvent RequestEvent浜嬩欢
+ */
+ @Override
+ @Async
+ public void processRequest(RequestEvent requestEvent) {
+ String method = requestEvent.getRequest().getMethod();
+ ISIPRequestProcessor sipRequestProcessor = requestProcessorMap.get(method);
+ if (sipRequestProcessor == null) {
+ logger.warn("涓嶆敮鎸佹柟娉晎}鐨剅equest", method);
+ return;
+ }
+ requestProcessorMap.get(method).process(requestEvent);
+
+ }
+
+ /**
+ * 鍒嗗彂ResponseEvent浜嬩欢
+ * @param responseEvent responseEvent浜嬩欢
+ */
+ @Override
+ @Async
+ public void processResponse(ResponseEvent responseEvent) {
+ logger.debug(responseEvent.getResponse().toString());
+ Response response = responseEvent.getResponse();
+ logger.debug(responseEvent.getResponse().toString());
+ int status = response.getStatusCode();
+ if (((status >= 200) && (status < 300)) || status == 401) { // Success!
+// ISIPResponseProcessor processor = processorFactory.createResponseProcessor(evt);
+ CSeqHeader cseqHeader = (CSeqHeader) responseEvent.getResponse().getHeader(CSeqHeader.NAME);
+ String method = cseqHeader.getMethod();
+ ISIPResponseProcessor sipRequestProcessor = responseProcessorMap.get(method);
+ if (sipRequestProcessor != null) {
+ sipRequestProcessor.process(responseEvent);
+ }
+ if (responseEvent.getResponse() != null && sipSubscribe.getOkSubscribesSize() > 0 ) {
+ CallIdHeader callIdHeader = (CallIdHeader)responseEvent.getResponse().getHeader(CallIdHeader.NAME);
+ if (callIdHeader != null) {
+ SipSubscribe.Event subscribe = sipSubscribe.getOkSubscribe(callIdHeader.getCallId());
+ if (subscribe != null) {
+ SipSubscribe.EventResult eventResult = new SipSubscribe.EventResult(responseEvent);
+ subscribe.response(eventResult);
+ }
+ }
+ }
+ } else if ((status >= 100) && (status < 200)) {
+ // 澧炲姞鍏跺畠鏃犻渶鍥炲鐨勫搷搴旓紝濡�101銆�180绛�
+ } else {
+ logger.warn("鎺ユ敹鍒板け璐ョ殑response鍝嶅簲锛乻tatus锛�" + status + ",message:" + response.getReasonPhrase()/* .getContent().toString()*/);
+ if (responseEvent.getResponse() != null && sipSubscribe.getErrorSubscribesSize() > 0 ) {
+ CallIdHeader callIdHeader = (CallIdHeader)responseEvent.getResponse().getHeader(CallIdHeader.NAME);
+ if (callIdHeader != null) {
+ SipSubscribe.Event subscribe = sipSubscribe.getErrorSubscribe(callIdHeader.getCallId());
+ if (subscribe != null) {
+ SipSubscribe.EventResult eventResult = new SipSubscribe.EventResult(responseEvent);
+ subscribe.response(eventResult);
+ }
+ }
+ }
+ if (responseEvent.getDialog() != null) {
+ responseEvent.getDialog().delete();
+ }
+ }
+
+
+ }
+
+ /**
+ * 鍚戣秴鏃惰闃呭彂閫佹秷鎭�
+ * @param timeoutEvent timeoutEvent浜嬩欢
+ */
+ @Override
+ public void processTimeout(TimeoutEvent timeoutEvent) {
+ if(timeoutProcessor != null) {
+ timeoutProcessor.process(timeoutEvent);
+ }
+ }
+
+ @Override
+ public void processIOException(IOExceptionEvent exceptionEvent) {
+ }
+
+ @Override
+ public void processTransactionTerminated(TransactionTerminatedEvent transactionTerminatedEvent) {
+ }
+
+ @Override
+ public void processDialogTerminated(DialogTerminatedEvent dialogTerminatedEvent) {
+ CallIdHeader callId = dialogTerminatedEvent.getDialog().getCallId();
+ }
+
+
+}
--
Gitblit v1.8.0