GB28181学习笔记6 解析invite命令

一、信令流程

1. 实时信令流程

点播流程：

1. 上级平台向下级发送INVITE请求，请求实时视频
2. 下级平台回复200OK
3. 上级平台回复ACK确认
4. 关闭视频，上级向下级平台发送BYE请求，请求关闭视频
5. 下级平台回复200OK
   请求示例：

摄像头回复示例：

返回给摄像头ACK示例：

正常会有媒体流推送：

2. 点播流程

上级发送INVITE请求

invite content内容区说明：

• Call-ID：唯一标识这次的点播流程，即这次点播的五条信令中的Call-ID都是相同的。
• s=Play：说明请求的是实时视频。
• c= IN IP4:此字段的IP地址为自己平台的流媒体服务器，通过此字段告知对方流媒体的地址（192.168.2.30）。

v=0
o=00000000001310018021 0 0 IN IP4 192.168.0.55
s=Play                        	                //Play标识为点播请求   Playback标识回播请求
c=IN IP4 192.168.0.55             //192.168.0.55:音视频流目的地址
t=0 0                        //t行第一参数为视频开始时间  第二个参数为结束时间    t = 0 0表示实时视音频点播
m=video 5552 RTP/AVP 96 97 98   //video:表示请求音视频流  audio：表示请求音频流  5522:音视频流目的端口  RTP/AVP:视频流使用协议 96 97 98:客户端支持码流格式
a=rtpmap:96 PS/90000
a=rtpmap:97 MPEG4/90000
a=rtpmap:98 H264/90000
a=recvonly
a=streamMode:MAIN
y=0999999999
123456789101112

SDP 说明

SDP字段说明：

v字段：协议版本
o字段：-
a字段：a=rtpmap:<payload type> <encoding name>/<clock rate>  [/<encoding parameters>] 中的<encoding name>,利用该属性携带编码器厂商名称。该属性表明该流为某厂商编码器编码且是不符合gb28181规定的媒体流，符合国标的媒体流不需要该属性。
例如：a=rtpmap:96 DAHUA/90000
    a=rtpmap:96 HIKVISION/90000
a字段有下列格式：
a字段可携带倍数参数，用于文件下载时控制下载速度。格式： a=downloadspeed：下载倍数（整型）
a字段可携带文件大小参数，用于文件下载时的进度计算。格式： a=filesize:文件大小 （单位：Byte）
a字段可携带setup、connection作为TCP连接协商参数。 a=setup：TCP连接方式（表示本SDP发送者在建立RTP over TCP连接时是主动还是被动发起TCP连接，“active”为主动，“passive”为被动）
a字段可携带SVC参数，用于视频传输时的分辨率或者帧频控制。a=svcspace：空域编码方式 【取值整型。 0：不使用  1：1级增强  2：2级增强  3：3级增强 】  a = svctime：时域编码方式

s字段：表示请求媒体流的操作类型，“Play”标识为点播请求   “Playback”标识回播请求   “Download”表示文件下载  “Talk”表示语音对讲；
u字段：u行应填写视音频文件的URL。该URL的取值有两种：简捷方式和普通方式。简捷方式直接采用产生该历史媒体的媒体源（如某个摄像头）的设备ID以及相关参数，参数用“：”分隔；普通方式采样http://储存设备ID[/文件夹]*/文件名；
m字段：描述媒体的媒体类型、端口、传输层协议、负载类型等内容。媒体类型采样“video”标识视频或者视音频混合内容，采样“audio”标识传输音频内容；传输方式采用“RTP/AVP”标识传输层协议为 RTP over UDP，采用“TCP/RTP/AVP”标识传输层协议为RTP over TCP；
t字段：当回放或者下载时，t行值为开始时间，结束时间，采样“ ”分隔；
y字段：十进制整数字符串，标识SSRC值。其中第一位为历史或者实时媒体流的标识位，0为实时，1为历史；第2位到第6位取20位SIP监控域ID之中的4-8位作为域标识；第7-10位作为域内媒体流标识，是一个与当前域内产生的媒体流SSRC值后4位不充分的四位十进制整数；
f字段：f=v/编码格式/分辨率/帧率/码率类型/码率大小  a/编码格式/码率大小/采样率    其中v表示video   a表示audio
12345678910111213141516171819

下级回复200OK

上级回复ACK确认

停止播放

上级发送BYE请求关闭视频

BYE sip:161128022553273720@192.168.0.66:7100 SIP/2.0
Via: SIP/2.0/UDP 192.168.40.55:7100;rport;branch=z9hG4bK1981844232
From: <sip:120105110228023020@192.168.0.55:7100>;tag=2249831759
To: <sip:00000000001310018021@192.168.0.66:7100>;tag=2885333649
Call-ID: 821763613                    // Call-ID：该字段判断请求端口哪一路视频
CSeq: 21 BYE
Contact: <sip:120105110228023020@192.168.0.55:7100>
Max-Forwards: 70
User-Agent: NCG V2.6.0.299938
Content-Length: 0

SIP/2.0 200 OK
Via: SIP/2.0/UDP 192.168.0.55:7100;rport=7100;branch=z9hG4bK1981844232
From: <sip:120105110228023020@192.168.0.55:7100>;tag=2249831759
To: <sip:00000000001310018021@192.168.0.66:7100>;tag=2885333649
Call-ID: 821763613
CSeq: 21 BYE
User-Agent: NCG V2.6.0.299938
Content-Length: 0

下级回复200OK同意关闭视频

二、实现核心代码

/**
 * GB28181服务程序
 */
const parseString = require('xml2js').parseString;
const sip         = require('sip');
const log4js      = require('./sip_log');
const logger      = log4js.getLogger('info');
const command     = require('./sip_command');   //命令都放在这里

let devices = []; // 保存注册上来的设备
let s_rq;
/**
 * SIP服务端
 */
const sip_server={
  /**
  * 启动 sip 服务端
  */ 
  start : function(){
    logger.info('启动sip服务端');
    sip.start({
      logger: { 
        send: function(message, address) { 
          logger.info("==send==:" , message,address); 
        },
        recv: function(message, address) {
          logger.info("==recv==:" , message,address); 
        }
      }
    },
    function(rq) {
      s_rq=rq;
      try {
        if(rq.method ==='REGISTER') {  
          command.register(rq);
        }
        else if(rq.method==='MESSAGE'){
          
          parseString(rq.content,function(err,result){
            if(result.Notify){
              let CmdType = result.Notify.CmdType[0];
              if(CmdType==='Keepalive'){
                // 心跳
                let rs = sip.makeResponse(rq,200,'OK');
                sip.send(rs);
              }else{
                logger.info('未解析的指令',CmdType); 
              }
            }else if(result.Response){
              let CmdType = result.Response.CmdType;
              if(CmdType=='Catalog'){
                // 获取到的设备列表
                if(result.Response.DeviceList){
                  for(let s in  result.Response.DeviceList[0].Item){
                    let temp = result.Response.DeviceList[0].Item[s];
                    let exists = devices.indexOf(temp)>-1;
                    if(!exists) {
                      devices.push(temp);
                    }
                  }
                  logger.info('----------devices---------',devices);
                  sip.send(sip.makeResponse(rq,200,'OK'));
                }
              }
            }
            
          });
          
        }
        else if(rq.method=='ACK'){
          logger.info(rq);
        }
        else if(rq.method=='BYTE'){
          logger.info(rq);
        }
        else {
          logger.debug(rq.method);
          sip.send(sip.makeResponse(rq, 405, 'Method Not Allowed'));
        }
      } catch(e) {
        logger.error(e);
        sip.send(sip.makeResponse(rq, 500, "Server Internal Error"));
      }
    });
  },
  invite:function(target){
    if(s_rq){
      command.invite(s_rq,target);
      return true;
    }
    else{
      return false;
    }
  }
}

module.exports = sip_server;

后面再实现媒体服务器rtp流转发过程。

项目开源地址：https://gitee.com/hfwudao/GB28181_Node_Http