| | |
|---|
| | |
|
|---|
| | | import java.text.ParseException;
|
|---|
| | |
|
|---|
| | | import javax.sip.ClientTransaction;
|
|---|
| | | import javax.sip.Dialog;
|
|---|
| | | import javax.sip.InvalidArgumentException;
|
|---|
| | | import javax.sip.ResponseEvent;
|
|---|
| | |
|---|
| | | import com.genersoft.iot.vmp.gb28181.transmit.SIPProcessorFactory;
|
|---|
| | | import com.genersoft.iot.vmp.gb28181.transmit.response.ISIPResponseProcessor;
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * @Description:处理INVITE响应
|
|---|
| | | * @author: swwheihei
|
|---|
| | | * @author: songww
|
|---|
| | | * @date: 2020年5月3日 下午4:43:52
|
|---|
| | | */
|
|---|
| | | @Component
|
|---|
| | |
|---|
| | | /**
|
|---|
| | | * 处理invite响应
|
|---|
| | | *
|
|---|
| | | * @param evt
|
|---|
| | | * 响应消息
|
|---|
| | | * @param evt 响应消息
|
|---|
| | | * @throws ParseException
|
|---|
| | | */
|
|---|
| | | @Override
|
|---|
| | | public void process(ResponseEvent evt, SipLayer layer, SipConfig config) {
|
|---|
| | | public void process(ResponseEvent evt, SipLayer layer, SipConfig config) throws ParseException {
|
|---|
| | | try {
|
|---|
| | | Response response = evt.getResponse();
|
|---|
| | | int statusCode = response.getStatusCode();
|
|---|
| | | //trying不会回复
|
|---|
| | | if(statusCode == Response.TRYING){
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | | //成功响应
|
|---|
| | | //下发ack
|
|---|
| | |
|---|
| | | // return;
|
|---|
| | | // }
|
|---|
| | | // Dialog clientDialog = clientTransaction.getDialog();
|
|---|
| | | //
|
|---|
| | | // CSeqHeader clientCSeqHeader = (CSeqHeader) response.getHeader(CSeqHeader.NAME);
|
|---|
| | |
|
|---|
| | | // CSeqHeader clientCSeqHeader = (CSeqHeader)
|
|---|
| | | // response.getHeader(CSeqHeader.NAME);
|
|---|
| | | // long cseqId = clientCSeqHeader.getSeqNumber();
|
|---|
| | | // /*
|
|---|
| | | // createAck函数，创建的ackRequest，会采用Invite响应的200OK，中的contact字段中的地址，作为目标地址。
|
|---|
| | |
|---|
| | | // Request ackRequest = clientDialog.createAck(cseqId);
|
|---|
| | | // SipURI requestURI = (SipURI) ackRequest.getRequestURI();
|
|---|
| | | // ViaHeader viaHeader = (ViaHeader) response.getHeader(ViaHeader.NAME);
|
|---|
| | | // try {
|
|---|
| | | // requestURI.setHost(viaHeader.getHost());
|
|---|
| | | // } catch (Exception e) {
|
|---|
| | | // e.printStackTrace();
|
|---|
| | | // }
|
|---|
| | | // requestURI.setPort(viaHeader.getPort());
|
|---|
| | | // clientDialog.sendAck(ackRequest);
|
|---|
| | |
|
|---|
| | | Dialog dialog = evt.getDialog();
|
|---|
| | | Request reqAck =dialog.createAck(1L);
|
|---|
| | | CSeqHeader cseq = (CSeqHeader) response.getHeader(CSeqHeader.NAME);
|
|---|
| | | Request reqAck = dialog.createAck(cseq.getSeqNumber());
|
|---|
| | |
|
|---|
| | | SipURI requestURI = (SipURI) reqAck.getRequestURI();
|
|---|
| | | ViaHeader viaHeader = (ViaHeader) response.getHeader(ViaHeader.NAME);
|
|---|
| | | // String viaHost =viaHeader.getHost();
|
|---|
| | | //getHost()函数取回的IP地址是“[xxx.xxx.xxx.xxx:yyyy]”的格式，需用正则表达式截取为“xxx.xxx.xxx.xxx"格式
|
|---|
| | | // Pattern p = Pattern.compile("(?<=//|)((\\w)+\\.)+\\w+");
|
|---|
| | | // Matcher matcher = p.matcher(viaHeader.getHost());
|
|---|
| | | // if (matcher.find()) {
|
|---|
| | | // requestURI.setHost(matcher.group());
|
|---|
| | | // }
|
|---|
| | | requestURI.setHost(viaHeader.getHost());
|
|---|
| | | requestURI.setPort(viaHeader.getPort());
|
|---|
| | | reqAck.setRequestURI(requestURI);
|
|---|
| | | dialog.sendAck(reqAck);
|
|---|
| | | }
|
|---|
| | | } catch (InvalidArgumentException | SipException e) {
|
|---|
