GB28181学习笔记3实现REGISTER设备注册(基于nodejssip库SERVER端)

这里使用一台海康的摄像头做实际测试。
GB28281注册过程有鉴权、不鉴权两种&＃xff0c;本文实现的带鉴权的方式&＃xff0c;基于GB281812016版。
本文原本想用C&＃43;&＃43;库实现&＃xff0c;但我这只有QT&＃xff0c;配置基于第三方sip包的环境太不熟练&＃xff0c;为节省时间暂且用nodejs先代用。

不带鉴权&＃xff1a;

带鉴权&＃xff1a;

1. 设备设置

2. 注册过程

1. 设备发送register注册消息

2. 服务器返回401 未登陆

3. 设备发送登陆认证

主要是要计算当中的response值&＃xff0c;认证计算过程&＃xff1a;
下面使用kd函数&＃xff0c;表示对字符串使用 冒号 拼接后&＃xff0c;计算md5&＃xff0c;即&＃xff1a;
如&＃xff1a; $kd(a,b)\&＃61;md5(a\&＃43;":"\&＃43;b)$
$$HA1\&＃61;kd(username,realm,passwd)HA2\&＃61;kd(Method,Uri)$$
response有两种情况&＃xff0c;一种带nonce&＃xff0c;一种不带。

不带nonce:

$$response\&＃61;kd(ha1,nonce,ha2)$$

带nonce

$$response\&＃61;kd(ha1,nonce,nc,cnonce,qop,ha2)$$

4. 服务端校验正确&＃xff0c;返回200ok

接下来服务端可以请求设备目录。
整体描述&＃xff1a;

本文主要实现REGISTER的部分。

3. 签名校验

依赖&＃xff1a;
https://github.com/kirm/sip.js

1. 启动 sip

sip.start({logger: { send: function(message, address) { // logger.info("&＃61;&＃61;send&＃61;&＃61;:" , message,address); },recv: function(message, address) {// logger.info("&＃61;&＃61;recv&＃61;&＃61;:" , message,address); }}
},function(rq) {
});


返回值解析&＃xff1a;

if(rq.method &＃61;&＃61;&＃61;&＃39;REGISTER&＃39;) { logger.info(&＃39;call register&＃39;);var username &＃61; sip.parseUri(rq.headers.to.uri).user;logger.info(&＃39;register username&＃39;,username);var userinfo &＃61; registry[username];//logger.info(&＃39;userinfo&＃39;, userinfo);if(!userinfo) {// 没有登记的用户&＃xff0c;这里直接禁止授权logger.error(&＃39;没有登记的用户&＃xff0c;这里直接禁止授权:&＃39; , username);var session &＃61; {realm: realm};sip.send(digest.challenge(session, sip.makeResponse(rq, 401, &＃39;Unauthorized&＃39;)));return;}else {userinfo.session &＃61; userinfo.session || {realm: realm};if(!digest.authenticateRequest(userinfo.session, rq, {user: username, password: userinfo.password})) {sip.send(digest.challenge(userinfo.session, sip.makeResponse(rq, 401, &＃39;Unauthorized&＃39;)));}else {// 完成授权userinfo.contact &＃61; rq.headers.contact;var rs &＃61; sip.makeResponse(rq, 200, &＃39;Ok&＃39;);rs.headers.contact &＃61; rq.headers.contact;sip.send(rs);}}}

三、完整代码


var log4js &＃61; require(&＃39;log4js&＃39;);log4js.configure({appenders: {out: { type: &＃39;stdout&＃39; },app: { type: &＃39;file&＃39;, filename: &＃39;application.log&＃39; }},categories: {// getLogger 参数为空时&＃xff0c;默认使用该分类default: { appenders: [ &＃39;out&＃39;, &＃39;app&＃39; ], level: &＃39;debug&＃39; }}
});var logger &＃61; log4js.getLogger();
const log4js_extend &＃61; require("log4js-extend");
log4js_extend(log4js, {path: __dirname &＃43; "/a.log",format: "at &＃64;name (&＃64;file:&＃64;line:&＃64;column)"
});var parseString &＃61; require(&＃39;xml2js&＃39;).parseString;
var sip &＃61; require(&＃39;sip&＃39;);
var digest &＃61; require(&＃39;sip/digest&＃39;);
var os &＃61; require(&＃39;os&＃39;);var server_account &＃61; &＃39;34020000002000000001&＃39;;var registry &＃61; {&＃39;34020000001110000001&＃39;: {password: &＃39;你的设备密码&＃39;}
};debugger;
var realm &＃61;&＃39;3402000000&＃39;; logger.info(&＃39;localhost name&＃61;&＃39;&＃43;realm);
sip.start({logger: { send: function(message, address) { // logger.info("&＃61;&＃61;send&＃61;&＃61;:" , message,address); },recv: function(message, address) {// logger.info("&＃61;&＃61;recv&＃61;&＃61;:" , message,address); }}
},
function(rq) {try {logger.info(&＃39;----------------------&＃39;,rq);if(rq.method &＃61;&＃61;&＃61;&＃39;REGISTER&＃39;) { logger.info(&＃39;call register&＃39;);var username &＃61; sip.parseUri(rq.headers.to.uri).user;logger.info(&＃39;register username&＃39;,username);var userinfo &＃61; registry[username];//logger.info(&＃39;userinfo&＃39;, userinfo);if(!userinfo) {// 没有登记的用户&＃xff0c;这里直接禁止授权logger.error(&＃39;没有登记的用户&＃xff0c;这里直接禁止授权:&＃39; , username);var session &＃61; {realm: realm};sip.send(digest.challenge(session, sip.makeResponse(rq, 401, &＃39;Unauthorized&＃39;)));return;}else {// 这里应该对server_account再校验一下。但有的网上测试IPC程序server_account没用到uri里。这里先简单实现下原理。userinfo.session &＃61; userinfo.session || {realm: realm};if(!digest.authenticateRequest(userinfo.session, rq, {user: username, password: userinfo.password})) {sip.send(digest.challenge(userinfo.session, sip.makeResponse(rq, 401, &＃39;Unauthorized&＃39;)));}else {// 完成授权userinfo.contact &＃61; rq.headers.contact;var rs &＃61; sip.makeResponse(rq, 200, &＃39;Ok&＃39;);rs.headers.contact &＃61; rq.headers.contact;sip.send(rs);}}}} catch(e) {logger.error(e);sip.send(sip.makeResponse(rq, 500, "Server Internal Error"));}
});

正常运行后&＃xff0c;可以看到海康摄像头处于在线状态。