package com.genersoft.iot.vmp.gb28181.transmit.response.impl;
|
|
import java.text.ParseException;
|
|
import javax.sip.ClientTransaction;
|
import javax.sip.Dialog;
|
import javax.sip.InvalidArgumentException;
|
import javax.sip.ResponseEvent;
|
import javax.sip.SipException;
|
import javax.sip.address.SipURI;
|
import javax.sip.header.CSeqHeader;
|
import javax.sip.header.ViaHeader;
|
import javax.sip.message.Request;
|
import javax.sip.message.Response;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Component;
|
|
import com.genersoft.iot.vmp.conf.SipConfig;
|
import com.genersoft.iot.vmp.gb28181.SipLayer;
|
import com.genersoft.iot.vmp.gb28181.transmit.SIPProcessorFactory;
|
import com.genersoft.iot.vmp.gb28181.transmit.response.ISIPResponseProcessor;
|
|
/**
|
* @Description:处理INVITE响应
|
* @author: songww
|
* @date: 2020年5月3日 下午4:43:52
|
*/
|
@Component
|
public class InviteResponseProcessor implements ISIPResponseProcessor {
|
|
private final static Logger logger = LoggerFactory.getLogger(SIPProcessorFactory.class);
|
|
/**
|
* 处理invite响应
|
*
|
* @param evt
|
* 响应消息
|
*/
|
@Override
|
public void process(ResponseEvent evt, SipLayer layer, SipConfig config) {
|
try {
|
Response response = evt.getResponse();
|
int statusCode = response.getStatusCode();
|
//trying不会回复
|
if(statusCode == Response.TRYING){
|
|
}
|
//成功响应
|
//下发ack
|
if(statusCode == Response.OK){
|
// ClientTransaction clientTransaction = evt.getClientTransaction();
|
// if(clientTransaction == null){
|
// logger.error("回复ACK时，clientTransaction为null >>> {}",response);
|
// return;
|
// }
|
// Dialog clientDialog = clientTransaction.getDialog();
|
//
|
// CSeqHeader clientCSeqHeader = (CSeqHeader) response.getHeader(CSeqHeader.NAME);
|
// long cseqId = clientCSeqHeader.getSeqNumber();
|
// /*
|
// createAck函数，创建的ackRequest，会采用Invite响应的200OK，中的contact字段中的地址，作为目标地址。
|
// 有的终端传上来的可能还是内网地址，会造成ack发送不出去。接受不到音视频流
|
// 所以在此处统一替换地址。和响应消息的Via头中的地址保持一致。
|
// */
|
// Request ackRequest = clientDialog.createAck(cseqId);
|
// SipURI requestURI = (SipURI) ackRequest.getRequestURI();
|
// ViaHeader viaHeader = (ViaHeader) response.getHeader(ViaHeader.NAME);
|
// requestURI.setHost(viaHeader.getHost());
|
// requestURI.setPort(viaHeader.getPort());
|
// clientDialog.sendAck(ackRequest);
|
|
Dialog dialog = evt.getDialog();
|
Request reqAck =dialog.createAck(1L);
|
dialog.sendAck(reqAck);
|
}
|
} catch (InvalidArgumentException | SipException e) {
|
e.printStackTrace();
|
}
|
}
|
|
}
|
