搭配zgyw，实现gb28181
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
648540858
2022-09-09 221f99c764b51c3cd284c6e5a41492c26c5c7ffc 
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/SIPRequestHeaderProvider.java


@@ -3,10 +3,7 @@


import java.text.ParseException;



import java.util.ArrayList;







import javax.sip.Dialog;



import javax.sip.InvalidArgumentException;



import javax.sip.PeerUnavailableException;



import javax.sip.SipFactory;



import javax.sip.*;



import javax.sip.address.Address;



import javax.sip.address.SipURI;



import javax.sip.header.*;



@@ -14,8 +11,13 @@






import com.genersoft.iot.vmp.common.StreamInfo;



import com.genersoft.iot.vmp.gb28181.session.VideoStreamSessionManager;



import com.genersoft.iot.vmp.gb28181.utils.SipUtils;



import com.genersoft.iot.vmp.storager.IRedisCatchStorage;



import gov.nist.javax.sip.SipProviderImpl;



import gov.nist.javax.sip.SipStackImpl;



import gov.nist.javax.sip.stack.SIPDialog;



import org.springframework.beans.factory.annotation.Autowired;



import org.springframework.beans.factory.annotation.Qualifier;



import org.springframework.stereotype.Component;







import com.genersoft.iot.vmp.conf.SipConfig;



@@ -40,6 +42,14 @@






   @Autowired



   private VideoStreamSessionManager streamSession;







   @Autowired



   @Qualifier(value="tcpSipProvider")



   private SipProviderImpl tcpSipProvider;







   @Autowired



   @Qualifier(value="udpSipProvider")



   private SipProviderImpl udpSipProvider;



   



   public Request createMessageRequest(Device device, String content, String viaTag, String fromTag, String toTag, CallIdHeader callIdHeader) throws ParseException, InvalidArgumentException, PeerUnavailableException {



      Request request = null;



@@ -51,23 +61,22 @@


      viaHeader.setRPort();



      viaHeaders.add(viaHeader);



      // from



      SipURI fromSipURI = sipFactory.createAddressFactory().createSipURI(sipConfig.getId(),



            sipConfig.getIp() + ":" + sipConfig.getPort());



      SipURI fromSipURI = sipFactory.createAddressFactory().createSipURI(sipConfig.getId(), sipConfig.getDomain());



      Address fromAddress = sipFactory.createAddressFactory().createAddress(fromSipURI);



      FromHeader fromHeader = sipFactory.createHeaderFactory().createFromHeader(fromAddress, fromTag);



      // to



      SipURI toSipURI = sipFactory.createAddressFactory().createSipURI(device.getDeviceId(), sipConfig.getDomain());



      SipURI toSipURI = sipFactory.createAddressFactory().createSipURI(device.getDeviceId(), device.getHostAddress());



      Address toAddress = sipFactory.createAddressFactory().createAddress(toSipURI);



      ToHeader toHeader = sipFactory.createHeaderFactory().createToHeader(toAddress, toTag);







      // Forwards



      MaxForwardsHeader maxForwards = sipFactory.createHeaderFactory().createMaxForwardsHeader(70);



      // ceq



      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(1L, Request.MESSAGE);



      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(redisCatchStorage.getCSEQ(), Request.MESSAGE);







      request = sipFactory.createMessageFactory().createRequest(requestURI, Request.MESSAGE, callIdHeader, cSeqHeader, fromHeader,



            toHeader, viaHeaders, maxForwards);



      ContentTypeHeader contentTypeHeader = sipFactory.createHeaderFactory().createContentTypeHeader("APPLICATION", "MANSCDP+xml");



      ContentTypeHeader contentTypeHeader = sipFactory.createHeaderFactory().createContentTypeHeader("Application", "MANSCDP+xml");



      request.setContent(content, contentTypeHeader);



      return request;



   }



@@ -83,11 +92,11 @@


      viaHeaders.add(viaHeader);







      //from



      SipURI fromSipURI = sipFactory.createAddressFactory().createSipURI(sipConfig.getId(),sipConfig.getDomain());



      SipURI fromSipURI = sipFactory.createAddressFactory().createSipURI(sipConfig.getId(), sipConfig.getDomain());



      Address fromAddress = sipFactory.createAddressFactory().createAddress(fromSipURI);



      FromHeader fromHeader = sipFactory.createHeaderFactory().createFromHeader(fromAddress, fromTag); //必须要有标记，否则无法创建会话，无法回应ack



      //to



      SipURI toSipURI = sipFactory.createAddressFactory().createSipURI(channelId,sipConfig.getDomain()); 


      SipURI toSipURI = sipFactory.createAddressFactory().createSipURI(channelId, device.getHostAddress());



      Address toAddress = sipFactory.createAddressFactory().createAddress(toSipURI);



      ToHeader toHeader = sipFactory.createHeaderFactory().createToHeader(toAddress,null);



      



@@ -95,7 +104,7 @@


      MaxForwardsHeader maxForwards = sipFactory.createHeaderFactory().createMaxForwardsHeader(70);



      



      //ceq



      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(redisCatchStorage.getCSEQ(Request.INVITE), Request.INVITE);



      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(redisCatchStorage.getCSEQ(), Request.INVITE);



      request = sipFactory.createMessageFactory().createRequest(requestLine, Request.INVITE, callIdHeader, cSeqHeader,fromHeader, toHeader, viaHeaders, maxForwards);



      



      Address concatAddress = sipFactory.createAddressFactory().createAddress(sipFactory.createAddressFactory().createSipURI(sipConfig.getId(), sipConfig.getIp()+":"+sipConfig.getPort()));



@@ -119,11 +128,11 @@


      viaHeader.setRPort();



      viaHeaders.add(viaHeader);



      //from



      SipURI fromSipURI = sipFactory.createAddressFactory().createSipURI(sipConfig.getId(),sipConfig.getDomain());



      SipURI fromSipURI = sipFactory.createAddressFactory().createSipURI(sipConfig.getId(), sipConfig.getDomain());



      Address fromAddress = sipFactory.createAddressFactory().createAddress(fromSipURI);



      FromHeader fromHeader = sipFactory.createHeaderFactory().createFromHeader(fromAddress, fromTag); //必须要有标记，否则无法创建会话，无法回应ack



      //to



      SipURI toSipURI = sipFactory.createAddressFactory().createSipURI(channelId, sipConfig.getDomain());



      SipURI toSipURI = sipFactory.createAddressFactory().createSipURI(channelId, device.getHostAddress());



      Address toAddress = sipFactory.createAddressFactory().createAddress(toSipURI);



      ToHeader toHeader = sipFactory.createHeaderFactory().createToHeader(toAddress,null);



      



@@ -131,7 +140,7 @@


      MaxForwardsHeader maxForwards = sipFactory.createHeaderFactory().createMaxForwardsHeader(70);



      



      //ceq



      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(redisCatchStorage.getCSEQ(Request.INVITE), Request.INVITE);



      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(redisCatchStorage.getCSEQ(), Request.INVITE);



      request = sipFactory.createMessageFactory().createRequest(requestLine, Request.INVITE, callIdHeader, cSeqHeader,fromHeader, toHeader, viaHeaders, maxForwards);



      



      Address concatAddress = sipFactory.createAddressFactory().createAddress(sipFactory.createAddressFactory().createSipURI(sipConfig.getId(), sipConfig.getIp()+":"+sipConfig.getPort()));



@@ -159,7 +168,7 @@


      Address fromAddress = sipFactory.createAddressFactory().createAddress(fromSipURI);



      FromHeader fromHeader = sipFactory.createHeaderFactory().createFromHeader(fromAddress, fromTag); //必须要有标记，否则无法创建会话，无法回应ack



      //to



      SipURI toSipURI = sipFactory.createAddressFactory().createSipURI(channelId,sipConfig.getDomain());



      SipURI toSipURI = sipFactory.createAddressFactory().createSipURI(channelId,device.getHostAddress());



      Address toAddress = sipFactory.createAddressFactory().createAddress(toSipURI);



      ToHeader toHeader = sipFactory.createHeaderFactory().createToHeader(toAddress,toTag);







@@ -167,7 +176,7 @@


      MaxForwardsHeader maxForwards = sipFactory.createHeaderFactory().createMaxForwardsHeader(70);







      //ceq



      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(1L, Request.BYE);



      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(redisCatchStorage.getCSEQ(), Request.BYE);



      CallIdHeader callIdHeader = sipFactory.createHeaderFactory().createCallIdHeader(callId);



      request = sipFactory.createMessageFactory().createRequest(requestLine, Request.BYE, callIdHeader, cSeqHeader,fromHeader, toHeader, viaHeaders, maxForwards);







@@ -187,12 +196,11 @@


      viaHeader.setRPort();



      viaHeaders.add(viaHeader);



      // from



      SipURI fromSipURI = sipFactory.createAddressFactory().createSipURI(sipConfig.getId(),



            sipConfig.getIp() + ":" + sipConfig.getPort());



      SipURI fromSipURI = sipFactory.createAddressFactory().createSipURI(sipConfig.getId(), sipConfig.getDomain());



      Address fromAddress = sipFactory.createAddressFactory().createAddress(fromSipURI);



      FromHeader fromHeader = sipFactory.createHeaderFactory().createFromHeader(fromAddress, fromTag);



      // to



      SipURI toSipURI = sipFactory.createAddressFactory().createSipURI(device.getDeviceId(), sipConfig.getDomain());



      SipURI toSipURI = sipFactory.createAddressFactory().createSipURI(device.getDeviceId(), device.getHostAddress());



      Address toAddress = sipFactory.createAddressFactory().createAddress(toSipURI);



      ToHeader toHeader = sipFactory.createHeaderFactory().createToHeader(toAddress, toTag);







@@ -200,7 +208,7 @@


      MaxForwardsHeader maxForwards = sipFactory.createHeaderFactory().createMaxForwardsHeader(70);







      // ceq



      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(redisCatchStorage.getCSEQ(Request.SUBSCRIBE), Request.SUBSCRIBE);



      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(redisCatchStorage.getCSEQ(), Request.SUBSCRIBE);







      request = sipFactory.createMessageFactory().createRequest(requestURI, Request.SUBSCRIBE, callIdHeader, cSeqHeader, fromHeader,



            toHeader, viaHeaders, maxForwards);



@@ -215,58 +223,58 @@






      // Event



      EventHeader eventHeader = sipFactory.createHeaderFactory().createEventHeader(event);







      int random = (int)Math.random() * 1000000000;



      eventHeader.setEventId(random + "");



      request.addHeader(eventHeader);







      ContentTypeHeader contentTypeHeader = sipFactory.createHeaderFactory().createContentTypeHeader("APPLICATION", "MANSCDP+xml");



      ContentTypeHeader contentTypeHeader = sipFactory.createHeaderFactory().createContentTypeHeader("Application", "MANSCDP+xml");



      request.setContent(content, contentTypeHeader);



      return request;



   }







   public Request createInfoRequest(Device device, StreamInfo streamInfo, String content, Long cseq)



         throws PeerUnavailableException, ParseException, InvalidArgumentException {



      Request request = null;



      Dialog dialog = streamSession.getDialog(streamInfo.getDeviceID(), streamInfo.getChannelId());







      SipURI requestLine = sipFactory.createAddressFactory().createSipURI(device.getDeviceId(),



            device.getHostAddress());



      // via



      ArrayList<ViaHeader> viaHeaders = new ArrayList<ViaHeader>();



      ViaHeader viaHeader = sipFactory.createHeaderFactory().createViaHeader(device.getIp(), device.getPort(),



            device.getTransport(), null);



      viaHeader.setRPort();



      viaHeaders.add(viaHeader);



      // from



      SipURI fromSipURI = sipFactory.createAddressFactory().createSipURI(sipConfig.getId(),



            sipConfig.getDomain());



      Address fromAddress = sipFactory.createAddressFactory().createAddress(fromSipURI);



      FromHeader fromHeader = sipFactory.createHeaderFactory().createFromHeader(fromAddress, dialog.getLocalTag());



      // to



      SipURI toSipURI = sipFactory.createAddressFactory().createSipURI(streamInfo.getChannelId(),



            sipConfig.getDomain());



      Address toAddress = sipFactory.createAddressFactory().createAddress(toSipURI);



      ToHeader toHeader = sipFactory.createHeaderFactory().createToHeader(toAddress, dialog.getRemoteTag());







      // callid



      CallIdHeader callIdHeader = dialog.getCallId();







      // Forwards



      MaxForwardsHeader maxForwards = sipFactory.createHeaderFactory().createMaxForwardsHeader(70);



      if (cseq == null) {



         cseq = redisCatchStorage.getCSEQ(Request.INFO);



   public Request createInfoRequest(Device device, StreamInfo streamInfo, String content)



         throws SipException, ParseException, InvalidArgumentException {



      if (streamInfo == null) {



         return null;



      }



      // ceq



      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory()



            .createCSeqHeader(cseq, Request.INFO);



      Request request = null;



      SIPDialog dialog = streamSession.getDialogByStream(streamInfo.getDeviceID(), streamInfo.getChannelId(), streamInfo.getStream());



      if (dialog == null) {



         return null;



      }







      request = sipFactory.createMessageFactory().createRequest(requestLine, Request.INFO, callIdHeader, cSeqHeader,



            fromHeader, toHeader, viaHeaders, maxForwards);



      SipStack sipStack = udpSipProvider.getSipStack();



      SIPDialog sipDialog = ((SipStackImpl) sipStack).putDialog(dialog);



      if (dialog != sipDialog) {



         dialog = sipDialog;



      }else {



         dialog.setSipProvider(udpSipProvider);



      }



      streamSession.put(streamInfo.getDeviceID(), streamInfo.getChannelId(), dialog.getCallId().getCallId(), dialog);



      Request infoRequest = dialog.createRequest(Request.INFO);



      SipURI sipURI = (SipURI) infoRequest.getRequestURI();



      sipURI.setHost(device.getIp());



      sipURI.setPort(device.getPort());



      sipURI.setUser(streamInfo.getChannelId());







      ViaHeader viaHeader = (ViaHeader) infoRequest.getHeader(ViaHeader.NAME);



      viaHeader.setRPort();



      // 增加Contact header



      Address concatAddress = sipFactory.createAddressFactory().createAddress(sipFactory.createAddressFactory()



            .createSipURI(sipConfig.getId(), sipConfig.getIp() + ":" + sipConfig.getPort()));



      request.addHeader(sipFactory.createHeaderFactory().createContactHeader(concatAddress));



      infoRequest.addHeader(sipFactory.createHeaderFactory().createContactHeader(concatAddress));



      UserAgentHeader userAgentHeader = SipUtils.createUserAgentHeader(sipFactory);



      infoRequest.addHeader(userAgentHeader);







      ContentTypeHeader contentTypeHeader = sipFactory.createHeaderFactory().createContentTypeHeader("Application",



            "MANSRTSP");



      request.setContent(content, contentTypeHeader);



      return request;



      infoRequest.setContent(content, contentTypeHeader);







      CSeqHeader cSeqHeader = (CSeqHeader)infoRequest.getHeader(CSeqHeader.NAME);



      cSeqHeader.setSeqNumber(redisCatchStorage.getCSEQ());



      // ceq



      infoRequest.addHeader(cSeqHeader);



      return infoRequest;



   }



}