JAVA开发SIP会话协议

由于公司需要对接B接口来实现视屏通讯，博主花了一段时间研究，发现用JAVA实现SIP通信的很少，特此在此记录一下，希望能帮助到同行的你

什么是SIP协议？

SIP（Session initialization Protocol，会话初始协议）是由IETF（Internet Engineering Task Force，因特网工程任务组）制定的多媒体通信协议。基于文本的应用层控制协议，用于创建、修改和释放一个或多个参与者的会话。SIP 是一种源于互联网的IP 语音会话控制协议，具有灵活、易于实现、便于扩展等特点。
SIP协议分为请求消息和响应消息

SIP协议的组成

请求行（Request-Line）：由消息类型、请求发送地址、SIP协议版本号组成

消息头（Message Header）：

• Via: Via头域是被服务器插入request中，用来检查路由环的，并且可以使response根据via找到返回的路。
• From: 消息头FROM给出标识会话发起者的URI
• To: 格式：TO:显示名<接收者URI>；tag=n;显示名和tag可选。接收者URI是SIP网络种唯一标识接收终端的标识符
• Call-ID: 当前通话消息唯一标识
• CSeq: 用于标识同一会话中不同事务的序号，通常由一个用作序号的整型数和消息类型组成

消息体（Message Body）

SIP协议请求类型

INVITE：用于发起呼叫 INVITE消息包括消息头和数据区两部分。INVITE 消息头包含主、被呼叫的地址，呼叫主题和呼叫优先级等信息。数据区则是关于会话媒体的信息，可由会话描述协议SDP 来实现。
BYE：当一个用户决定中止会话时，可以使用BYE 来结束会话。
OPTIONS：用于询问被叫端的能力信息，但OPTIONS 本身并不能发起呼叫。
ACK：对已收到的消息进行确认应答。
ACK：对已收到的消息进行确认应答。
REGISTER：用于用户向SIP服务器传送位置信息或地址信息。
CANCEL：取消当前的请求，但它并不能中止已经建立的连接。

查看一下抓包抓取的SIP协议

sip.jpg

SIP服务器实现

gradle依赖

implementation 'javax.sip:jain-sip-api:1.2.1.4'
implementation 'javax.sip:jain-sip-ri:1.2.1.4'

public class SipLayer implements SipListener {

    @Resource
    private SipConfig sipConfig;

    @Resource
    private SIPHandler sipHandler;

    @Resource
    private SipSubscribe sipSubscribe;

    private SipStack sipStack;

    private SipFactory sipFactory;
    
    @Bean("sipFactory")
    @DependsOn("initSipServer")
    private SipFactory createSipFactory() {
        sipFactory = SipFactory.getInstance();
        sipFactory.setPathName("gov.nist");
        return sipFactory;
    }
    
    @Bean("sipStack")
    @DependsOn({"initSipServer", "sipFactory"})
    private SipStack createSipStack() throws PeerUnavailableException {
        Properties properties = new Properties();
        properties.setProperty("javax.sip.STACK_NAME", "GB28181_SIP");
        properties.setProperty("javax.sip.IP_ADDRESS", sipConfig.getSipIp());
        properties.setProperty("gov.nist.javax.sip.LOG_MESSAGE_CONTENT", "false");
        /** 解决 481 Subscription does not exist */
        properties.setProperty("javax.sip.AUTOMATIC_DIALOG_SUPPORT", "off");
        properties.setProperty("gov.nist.javax.sip.DELIVER_UNSOLICITED_NOTIFY", "true");

        properties.setProperty("gov.nist.javax.sip.TRACE_LEVEL", "32");
        properties.setProperty("gov.nist.javax.sip.SERVER_LOG", "sip_server_log.log");
        properties.setProperty("gov.nist.javax.sip.info_LOG", "sip_debug_log.log");
        sipStack = (SipStackImpl) sipFactory.createSipStack(properties);
        return sipStack;
    }

    @Bean("tcpSipProvider")
    @DependsOn("sipStack")
    private SipProvider startTcpListener() {
        ListeningPoint tcpListeningPoint = null;
        SipProvider tcpSipProvider  = null;
        try {
            tcpListeningPoint = sipStack.createListeningPoint(sipConfig.getSipIp(), sipConfig.getSipPort(), "TCP");
            tcpSipProvider = sipStack.createSipProvider(tcpListeningPoint);
            tcpSipProvider.addSipListener(this);
            log.info("Sip Server TCP 启动成功 port {}", sipConfig.getSipPort());
        } catch (TransportNotSupportedException | InvalidArgumentException | TooManyListenersException | ObjectInUseException e) {
            log.error(String.format("创建SIP服务失败: %s", e.getMessage()));
        }
        return tcpSipProvider;
    }
    
    @Bean("udpSipProvider")
    @DependsOn("sipStack")
    private SipProvider startUdpListener() throws Exception {
        ListeningPoint udpListeningPoint = sipStack.createListeningPoint(sipConfig.getSipIp(), sipConfig.getSipPort(), "UDP");
        SipProvider udpSipProvider = sipStack.createSipProvider(udpListeningPoint);
        udpSipProvider.addSipListener(this);
        log.info("Sip Server UDP 启动成功 port {}",sipConfig.getSipPort());
        return udpSipProvider;
    }

   /**
     * 接受请求消息
     * @param evt
     */
    @Override
    public void processRequest(RequestEvent evt) {
        log.info(evt.getRequest().toString());
    }

       
     /**
     * 接受响应消息
     * @param evt
     */
    @Override
    public void processResponse(ResponseEvent evt) {
        Response response = evt.getResponse();
        log.info(evt.getResponse().toString());
    }

    @Override
    public void processTimeout(TimeoutEvent timeoutEvent) {
    }

    @Override
    public void processIOException(IOExceptionEvent exceptionEvent) {
    }

    @Override
    public void processTransactionTerminated(TransactionTerminatedEvent transactionTerminatedEvent) {
    }

    @Override
    public void processDialogTerminated(DialogTerminatedEvent dialogTerminatedEvent) {
    }

}

踩坑提示

• 创建SIP SERVER 绑定的IP地址，必须是IPV4网卡上的地址，不能写localhost、127.0.0.1
• 接受NOTIFY请求事，查看日志提示 481 Subscription does not exist，处理办法，在创建sipFactory 设置属性

       /** 解决 481 Subscription does not exist */
      properties.setProperty("javax.sip.AUTOMATIC_DIALOG_SUPPORT", "off");
      properties.setProperty("gov.nist.javax.sip.DELIVER_UNSOLICITED_NOTIFY", "true");

• 因SIP通信请求和响应的分开的，以此可以通过消息头中CALL-ID获取会话唯一标识，来取决是否是一次完整会话

• 有问题欢迎随时留言咨询