搭配zgyw，实现gb28181
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
panlinlin
2021-01-15 cf8a22f50b81fa30abaa518bdce660cd65deabea 
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/SIPRequestHeaderPlarformProvider.java


@@ -4,22 +4,22 @@


import com.genersoft.iot.vmp.gb28181.bean.Device;


import com.genersoft.iot.vmp.gb28181.bean.Host;


import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform;


import com.genersoft.iot.vmp.gb28181.event.SipSubscribe;


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


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


import org.springframework.stereotype.Component;


import org.springframework.util.DigestUtils;




import javax.sip.InvalidArgumentException;


import javax.sip.PeerUnavailableException;


import javax.sip.SipFactory;


import javax.sip.SipProvider;


import javax.sip.*;


import javax.sip.address.Address;


import javax.sip.address.SipURI;


import javax.sip.header.*;


import javax.sip.message.Request;


import javax.validation.constraints.NotNull;


import java.nio.channels.Channel;


import java.text.ParseException;


import java.util.ArrayList;


import java.util.List;


import java.util.UUID;




/**


@@ -193,4 +193,38 @@


      return registerRequest;


   }






   public Request createMessageRequest(ParentPlatform parentPlatform, String content, String fromTag) throws PeerUnavailableException, ParseException, InvalidArgumentException {


      Request request = null;


      // sipuri


      SipURI requestURI = sipFactory.createAddressFactory().createSipURI(parentPlatform.getServerGBId(), parentPlatform.getServerIP()+ ":" + parentPlatform.getServerPort());


      // via


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


      ViaHeader viaHeader = sipFactory.createHeaderFactory().createViaHeader(parentPlatform.getDeviceIp(), Integer.parseInt(parentPlatform.getDevicePort()),


            parentPlatform.getTransport(), null);


      viaHeader.setRPort();


      viaHeaders.add(viaHeader);


      // from


      SipURI fromSipURI = sipFactory.createAddressFactory().createSipURI(parentPlatform.getServerGBId(),


            parentPlatform.getDeviceIp() + ":" + parentPlatform.getDevicePort());


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


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


      // to


      SipURI toSipURI = sipFactory.createAddressFactory().createSipURI(parentPlatform.getDeviceGBId(), parentPlatform.getServerGBDomain());


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


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


      // callid


      CallIdHeader callIdHeader = parentPlatform.getTransport().equals("TCP") ? tcpSipProvider.getNewCallId()


            : udpSipProvider.getNewCallId();


      // Forwards


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


      // ceq


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




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


            toHeader, viaHeaders, maxForwards);


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


      request.setContent(content, contentTypeHeader);


      return request;


   }


}