package com.ard.gb28181.transmit.event.request.impl;
|
|
import com.ard.common.core.constant.SecurityConstants;
|
import com.ard.common.core.domain.RtpServerParam;
|
import com.ard.gb28181.api.domain.SsrcTransaction;
|
import com.ard.gb28181.session.SipInviteSessionManager;
|
import com.ard.gb28181.transmit.ISIPProcessorObserver;
|
import com.ard.gb28181.transmit.SIPSender;
|
import com.ard.gb28181.transmit.event.request.ISIPRequestProcessor;
|
import com.ard.gb28181.transmit.event.request.SIPRequestProcessorParent;
|
import com.ard.zlm.api.RemoteZlmService;
|
import gov.nist.javax.sip.message.SIPRequest;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.InitializingBean;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import javax.sip.RequestEvent;
|
import javax.sip.SipException;
|
import javax.sip.header.CallIdHeader;
|
import javax.sip.message.Response;
|
|
@Slf4j
|
@Component
|
public class ByeRequestProcessor extends SIPRequestProcessorParent implements InitializingBean, ISIPRequestProcessor {
|
|
public final String method = "BYE";
|
|
@Autowired
|
private ISIPProcessorObserver sipProcessorObserver;
|
|
@Autowired
|
private SIPSender sipSender;
|
|
@Autowired
|
private SipInviteSessionManager sessionManager;
|
|
@Autowired
|
private RemoteZlmService remoteZlmService;
|
|
@Override
|
public void afterPropertiesSet() throws Exception {
|
sipProcessorObserver.addRequestProcessor(method, this);
|
}
|
|
@Override
|
public void process(RequestEvent evt) {
|
SIPRequest request = (SIPRequest) evt.getRequest();
|
CallIdHeader callIdHeader = request.getCallIdHeader();
|
String callId = callIdHeader.getCallId();
|
|
log.info("[收到 BYE 请求] callId: {}", callId);
|
|
try {
|
Response okResponse = getMessageFactory().createResponse(Response.OK, request);
|
sipSender.transmitRequest(request.getLocalAddress().getHostAddress(), okResponse);
|
|
SsrcTransaction ssrcTransaction = sessionManager.getSsrcTransactionByCallId(callId);
|
if (ssrcTransaction != null) {
|
log.info("[BYE 清理资源] deviceId: {}, channelId: {}, app: {}, stream: {}, ssrc: {}",
|
ssrcTransaction.getDeviceId(),
|
ssrcTransaction.getChannelId(),
|
ssrcTransaction.getApp(),
|
ssrcTransaction.getStream(),
|
ssrcTransaction.getSsrc());
|
|
sessionManager.removeByCallId(callId);
|
remoteZlmService.releaseSsrc(ssrcTransaction.getMediaServerId(), ssrcTransaction.getSsrc(), SecurityConstants.INNER);
|
|
RtpServerParam rtpServerParam = new RtpServerParam();
|
rtpServerParam.setMediaServerId(ssrcTransaction.getMediaServerId());
|
rtpServerParam.setApp(ssrcTransaction.getApp());
|
rtpServerParam.setStream(ssrcTransaction.getStream());
|
rtpServerParam.setSsrc(ssrcTransaction.getSsrc());
|
rtpServerParam.setGbDeviceId(ssrcTransaction.getDeviceId());
|
rtpServerParam.setGbChannelId(ssrcTransaction.getChannelId());
|
remoteZlmService.closeRTPServer(ssrcTransaction.getMediaServerId(), rtpServerParam, SecurityConstants.INNER);
|
}
|
} catch (Exception e) {
|
log.error("[BYE 处理异常]", e);
|
}
|
}
|
}
|
