|  |  |  | 
|---|
|  |  |  | import com.genersoft.iot.vmp.gb28181.event.EventPublisher; | 
|---|
|  |  |  | 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.request.impl.RegisterRequestProcessor; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.notify.cmd.KeepaliveNotifyMessageHandler; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.gb28181.transmit.event.response.ISIPResponseProcessor; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.gb28181.transmit.event.timeout.ITimeoutProcessor; | 
|---|
|  |  |  | import gov.nist.javax.sip.message.SIPRequest; | 
|---|
|  |  |  | import org.slf4j.Logger; | 
|---|
|  |  |  | import org.slf4j.LoggerFactory; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
|---|
|  |  |  | 
|---|
|  |  |  | import org.springframework.stereotype.Component; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import javax.sip.*; | 
|---|
|  |  |  | import javax.sip.address.SipURI; | 
|---|
|  |  |  | import javax.sip.address.URI; | 
|---|
|  |  |  | import javax.sip.header.*; | 
|---|
|  |  |  | import javax.sip.message.Request; | 
|---|
|  |  |  | import javax.sip.message.Response; | 
|---|
|  |  |  | import java.net.InetAddress; | 
|---|
|  |  |  | import java.util.Map; | 
|---|
|  |  |  | import java.util.Objects; | 
|---|
|  |  |  | import java.util.concurrent.ConcurrentHashMap; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private final static Logger logger = LoggerFactory.getLogger(SIPProcessorObserver.class); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private static Map<String, ISIPRequestProcessor> requestProcessorMap = new ConcurrentHashMap<>(); | 
|---|
|  |  |  | private static Map<String,  ISIPRequestProcessor> requestProcessorMap = new ConcurrentHashMap<>(); | 
|---|
|  |  |  | private static Map<String, ISIPResponseProcessor> responseProcessorMap = new ConcurrentHashMap<>(); | 
|---|
|  |  |  | private static ITimeoutProcessor timeoutProcessor; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private EventPublisher eventPublisher; | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 添加 request订阅 | 
|---|
|  |  |  | 
|---|
|  |  |  | * @param requestEvent RequestEvent事件 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | @Async | 
|---|
|  |  |  | @Async("taskExecutor") | 
|---|
|  |  |  | public void processRequest(RequestEvent requestEvent) { | 
|---|
|  |  |  | logger.debug("\n收到请求:\n{}", requestEvent.getRequest()); | 
|---|
|  |  |  | String method = requestEvent.getRequest().getMethod(); | 
|---|
|  |  |  | ISIPRequestProcessor sipRequestProcessor = requestProcessorMap.get(method); | 
|---|
|  |  |  | if (sipRequestProcessor == null) { | 
|---|
|  |  |  | logger.warn("不支持方法{}的request", method); | 
|---|
|  |  |  | // TODO 回复错误玛 | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | requestProcessorMap.get(method).process(requestEvent); | 
|---|
|  |  |  | 
|---|
|  |  |  | * @param responseEvent responseEvent事件 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | @Async | 
|---|
|  |  |  | @Async("taskExecutor") | 
|---|
|  |  |  | public void processResponse(ResponseEvent responseEvent) { | 
|---|
|  |  |  | Response response = responseEvent.getResponse(); | 
|---|
|  |  |  | logger.debug("\n收到响应:\n{}", responseEvent.getResponse()); | 
|---|
|  |  |  | int status = response.getStatusCode(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (((status >= 200) && (status < 300)) || status == Response.UNAUTHORIZED) { // Success! | 
|---|
|  |  |  | // Success | 
|---|
|  |  |  | if (((status >= Response.OK) && (status < Response.MULTIPLE_CHOICES)) || status == Response.UNAUTHORIZED) { | 
|---|
|  |  |  | CSeqHeader cseqHeader = (CSeqHeader) responseEvent.getResponse().getHeader(CSeqHeader.NAME); | 
|---|
|  |  |  | String method = cseqHeader.getMethod(); | 
|---|
|  |  |  | ISIPResponseProcessor sipRequestProcessor = responseProcessorMap.get(method); | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } else if ((status >= 100) && (status < 200)) { | 
|---|
|  |  |  | } else if ((status >= Response.TRYING) && (status < Response.OK)) { | 
|---|
|  |  |  | // 增加其它无需回复的响应,如101、180等 | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | logger.warn("接收到失败的response响应!status:" + status + ",message:" + response.getReasonPhrase()/* .getContent().toString()*/); | 
|---|
|  |  |  | logger.warn("接收到失败的response响应!status:" + status + ",message:" + response.getReasonPhrase()); | 
|---|
|  |  |  | if (responseEvent.getResponse() != null && sipSubscribe.getErrorSubscribesSize() > 0 ) { | 
|---|
|  |  |  | CallIdHeader callIdHeader = (CallIdHeader)responseEvent.getResponse().getHeader(CallIdHeader.NAME); | 
|---|
|  |  |  | if (callIdHeader != null) { | 
|---|
|  |  |  | 
|---|
|  |  |  | public void processTimeout(TimeoutEvent timeoutEvent) { | 
|---|
|  |  |  | logger.info("[消息发送超时]"); | 
|---|
|  |  |  | ClientTransaction clientTransaction = timeoutEvent.getClientTransaction(); | 
|---|
|  |  |  | eventPublisher.requestTimeOut(timeoutEvent); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (clientTransaction != null) { | 
|---|
|  |  |  | logger.info("[发送错误订阅] clientTransaction != null"); | 
|---|
|  |  |  | Request request = clientTransaction.getRequest(); | 
|---|
|  |  |  | if (request != null) { | 
|---|
|  |  |  | logger.info("[发送错误订阅] request != null"); | 
|---|
|  |  |  | CallIdHeader callIdHeader = (CallIdHeader) request.getHeader(CallIdHeader.NAME); | 
|---|
|  |  |  | if (callIdHeader != null) { | 
|---|
|  |  |  | logger.info("[发送错误订阅]"); | 
|---|
|  |  |  | SipSubscribe.Event subscribe = sipSubscribe.getErrorSubscribe(callIdHeader.getCallId()); | 
|---|
|  |  |  | SipSubscribe.EventResult eventResult = new SipSubscribe.EventResult(timeoutEvent); | 
|---|
|  |  |  | subscribe.response(eventResult); | 
|---|
|  |  |  | if (subscribe != null){ | 
|---|
|  |  |  | subscribe.response(eventResult); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | sipSubscribe.removeOkSubscribe(callIdHeader.getCallId()); | 
|---|
|  |  |  | sipSubscribe.removeErrorSubscribe(callIdHeader.getCallId()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //        Timeout timeout = timeoutEvent.getTimeout(); | 
|---|
|  |  |  | //        ServerTransaction serverTransaction = timeoutEvent.getServerTransaction(); | 
|---|
|  |  |  | //        if (serverTransaction != null) { | 
|---|
|  |  |  | //            Request request = serverTransaction.getRequest(); | 
|---|
|  |  |  | //            URI requestURI = request.getRequestURI(); | 
|---|
|  |  |  | //            Header header = request.getHeader(FromHeader.NAME); | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | //        if(timeoutProcessor != null) { | 
|---|
|  |  |  | //            timeoutProcessor.process(timeoutEvent); | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | eventPublisher.requestTimeOut(timeoutEvent); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void processTransactionTerminated(TransactionTerminatedEvent transactionTerminatedEvent) { | 
|---|
|  |  |  | //        if (transactionTerminatedEvent.isServerTransaction()) { | 
|---|
|  |  |  | //            ServerTransaction serverTransaction = transactionTerminatedEvent.getServerTransaction(); | 
|---|
|  |  |  | //            serverTransaction.get | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //        Transaction transaction = null; | 
|---|
|  |  |  | //        System.out.println("processTransactionTerminated"); | 
|---|
|  |  |  | //        if (transactionTerminatedEvent.isServerTransaction()) { | 
|---|