package com.ard.gb28181.transmit.event.response.impl;
|
|
import com.ard.gb28181.api.bean.Gb28181Sdp;
|
import com.ard.gb28181.api.utils.SipUtils;
|
import com.ard.gb28181.transmit.ISIPProcessorObserver;
|
import com.ard.gb28181.transmit.SIPSender;
|
import com.ard.gb28181.transmit.cmd.SIPRequestHeaderProvider;
|
import com.ard.gb28181.transmit.event.response.SIPResponseProcessorAbstract;
|
import com.ard.gb28181.utils.IpPortUtil;
|
import gov.nist.javax.sip.ResponseEventExt;
|
import gov.nist.javax.sip.message.SIPResponse;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import javax.sdp.SdpParseException;
|
import javax.sdp.SessionDescription;
|
import javax.sip.InvalidArgumentException;
|
import javax.sip.ResponseEvent;
|
import javax.sip.SipException;
|
import javax.sip.SipFactory;
|
import javax.sip.address.SipURI;
|
import javax.sip.message.Request;
|
import javax.sip.message.Response;
|
import java.text.ParseException;
|
|
|
/**
|
* @description: 处理INVITE响应
|
* @author: panlinlin
|
* @date: 2021年11月5日 16：40
|
*/
|
@Slf4j
|
@Component
|
public class InviteResponseProcessor extends SIPResponseProcessorAbstract {
|
|
private final String method = "INVITE";
|
|
@Autowired
|
private ISIPProcessorObserver sipProcessorObserver;
|
|
@Autowired
|
private SIPSender sipSender;
|
|
@Autowired
|
private SIPRequestHeaderProvider headerProvider;
|
|
@Override
|
public void afterPropertiesSet() throws Exception {
|
// 添加消息处理的订阅
|
sipProcessorObserver.addResponseProcessor(method, this);
|
}
|
|
|
/**
|
* 处理invite响应
|
*
|
* @param evt 响应消息
|
* @throws ParseException
|
*/
|
@Override
|
public void process(ResponseEvent evt) {
|
log.debug("接收到消息：" + evt.getResponse());
|
try {
|
SIPResponse response = (SIPResponse) evt.getResponse();
|
int statusCode = response.getStatusCode();
|
// trying不会回复
|
if (statusCode == Response.TRYING) {
|
}
|
// 成功响应
|
// 下发ack
|
if (statusCode == Response.OK) {
|
ResponseEventExt event = (ResponseEventExt) evt;
|
|
String contentString = new String(response.getRawContent());
|
Gb28181Sdp gb28181Sdp = SipUtils.parseSDP(contentString);
|
SessionDescription sdp = gb28181Sdp.getBaseSdb();
|
SipURI requestUri = SipFactory.getInstance().createAddressFactory().createSipURI(sdp.getOrigin().getUsername(), IpPortUtil.concatenateIpAndPort(event.getRemoteIpAddress(), String.valueOf(event.getRemotePort())));
|
Request reqAck = headerProvider.createAckRequest(response.getLocalAddress().getHostAddress(), requestUri, response);
|
|
log.info("[回复ack] {}-> {}:{} ", sdp.getOrigin().getUsername(), event.getRemoteIpAddress(), event.getRemotePort());
|
sipSender.transmitRequest(response.getLocalAddress().getHostAddress(), reqAck);
|
}
|
} catch (InvalidArgumentException | ParseException | SipException | SdpParseException e) {
|
log.info("[点播回复ACK]，异常：", e);
|
}
|
}
|
|
}
|
