package com.genersoft.iot.vmp.gb28181.transmit;
|
|
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.stereotype.Component;
|
|
import javax.sip.*;
|
import javax.sip.header.CSeqHeader;
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
/**
|
* @description: SIP信令处理类观察者
|
* @author: panlinlin
|
* @date: 2021年11月5日 下午15：32
|
*/
|
@Component
|
public class SIPProcessorObserver implements SipListener {
|
|
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;
|
|
/**
|
* 添加 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
|
public void processRequest(RequestEvent requestEvent) {
|
String method = requestEvent.getRequest().getMethod();
|
ISIPRequestProcessor sipRequestProcessor = requestProcessorMap.get(method);
|
if (sipRequestProcessor == null) {
|
logger.warn("不支持方法{}的request", method);
|
return;
|
}
|
requestProcessorMap.get(requestEvent.getRequest().getMethod()).process(requestEvent);
|
}
|
|
/**
|
* 分发ResponseEvent事件
|
* @param responseEvent responseEvent事件
|
*/
|
@Override
|
public void processResponse(ResponseEvent responseEvent) {
|
CSeqHeader cseqHeader = (CSeqHeader) responseEvent.getResponse().getHeader(CSeqHeader.NAME);
|
String method = cseqHeader.getMethod();
|
ISIPResponseProcessor sipRequestProcessor = responseProcessorMap.get(method);
|
if (sipRequestProcessor == null) {
|
logger.warn("不支持方法{}的response", method);
|
return;
|
}
|
sipRequestProcessor.process(responseEvent);
|
}
|
|
/**
|
* 向超时订阅发送消息
|
* @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) {
|
|
}
|
|
|
}
|
