修正设备注册认证时验证Response计算的错误

lawrencehj

2021-08-26 45969a00b74b5a240c0dc6e2c37f5381cd0cb65f

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/response/impl/InviteResponseProcessor.java

@@ -8,9 +8,12 @@
import javax.sip.message.Request;

import javax.sip.message.Response;



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

import gov.nist.javax.sip.ResponseEventExt;

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

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

import org.springframework.stereotype.Component;



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

@@ -27,6 +30,9 @@
public class InviteResponseProcessor implements ISIPResponseProcessor {



    private final static Logger logger = LoggerFactory.getLogger(InviteResponseProcessor.class);



   @Autowired

   private VideoStreamSessionManager streamSession;



   /**

    * 处理invite响应

@@ -46,7 +52,7 @@
         // 下发ack

         if (statusCode == Response.OK) {

            ResponseEventExt event = (ResponseEventExt)evt;

            Dialog dialog = evt.getDialog();

            SIPDialog dialog = (SIPDialog)evt.getDialog();

            CSeqHeader cseq = (CSeqHeader) response.getHeader(CSeqHeader.NAME);

            Request reqAck = dialog.createAck(cseq.getSeqNumber());

            SipURI requestURI = (SipURI) reqAck.getRequestURI();

@@ -54,7 +60,12 @@
            requestURI.setPort(event.getRemotePort());

            reqAck.setRequestURI(requestURI);

            logger.info("向 " + event.getRemoteIpAddress() + ":" + event.getRemotePort() + "回复ack");

            SipURI sipURI = (SipURI)dialog.getRemoteParty().getURI();

            String deviceId = requestURI.getUser();

            String channelId = sipURI.getUser();



            dialog.sendAck(reqAck);



         }

      } catch (InvalidArgumentException | SipException e) {

         e.printStackTrace();