当前位置： 移动技术网 > IT编程>开发语言>JavaScript > NodeJs 模仿SIP话机注册的方法

NodeJs 模仿SIP话机注册的方法

2019年07月18日  | 移动技术网IT编程  | 我要评论

本项目需要对应的后端接口、信令环境才能正常运行，本文章只涉及前端内容。

项目依赖模块：

  • nodejs
  • readline：命令行输入
  • ws：与服务端建立websocket连接
  • superagent：与服务端建立请求连接，效果类似ajax请求
  • tsk_md5：项目登录密码使用md5加密

项目需求

模拟sip话机频繁向服务器发起注册请求，以得到服务器最大sip注册数

项目实现概述

  1. 终端输入连续注册分机的开始分机号和结束分机号
  2. 终端输入统一的sip注册密码
  3. 终端输入服务器地址
  4. 先进行用户登录鉴权，用户登录鉴权通过后再发起sip注册

代码分析

1. 引入项目所需模块

var websocket = require('ws'),
 superagent = require('superagent'),
 tskmd5 = require('./tsk_md5')
 const readline = require('readline');

2. 创建readline 接口实例

const rl = readline.createinterface({
    input: process.stdin,
    output: process.stdout,
    prompt: 'ohai> '
 });

3. 定义所需变量

var obj = {}, httpheader = {}, baseurl ='', pass = '', ip = '', websocketurl = ''
var keepwsalive, readystate

4. 读取readline 输入信息函数

function getreadline() {
 const lines = []; // 用于保存所有输入信息。
 console.log('please input the range of extensions(eg: 1001,1010):\n')
 rl.on("line", function(line) {
  if (line ==='') {
   console.log('the input is empty, please input again:\n')
  } else {
   lines.push(line);
   if (lines.length === 1) {
    obj.extensionsarr = line.split(',');
    console.log('please input the password(eg:1234aa):\n')
   } else if (lines.length === 2) {
    obj.password = line;
    pass = line;
    console.log('please input the ip(eg:192.168.124.125):\n')
   } else if (lines.length === 3) {
    websocketurl = 'ws://' + line + ':8089/ws';
    obj.websocketurl = websocketurl;
    obj.ip = line;
    ip = line;
    console.log('starting register...\n');
    // 开始注册事件
    loopregister(obj) 
   }
  }
 });
 
 // close事件监听
 rl.on("close", function(){
  // 结束程序
  process.exit(0);
 });
 }

终端运行截图

 

5.注册事件中包含几个动作

1）设置httpheader：浏览器与服务器ajax请求有固定的请求头信息，此处模拟浏览器的请求头信息。

用于后续发送请求进行用户登录鉴权。

function sethttpheader(username) {
  httpheader = {
   accept:'application/json, text/javascript, */*; q=0.01',
   'accept-encoding': 'gzip, deflate',
   'accept-language': 'zh-cn,zh;q=0.9,en;q=0.8,pt;q=0.7',
   'cache-control': 'no-cache',
   connection: 'keep-alive',
   'content-type': 'application/x-www-form-urlencoded; charset=utf-8',
   cookie: 'trackid='+trackid+'; session-identify=sid121076289-1520217430; username=admin; user_id=0',
   host: ip +':8089',
   origin: 'http://'+ip+':8089',
   pragma: 'no-cache',
   referer: 'http://'+ip+':8089/gswave/',
   'user-agent': 'mozilla/5.0 (windows nt 6.1; wow64) applewebkit/537.36 (khtml, like gecko) chrome/38.0.2125.122 safari/537.36 se 2.x metasr 1.0',
   'x-requested-with':'xmlhttprequest'
  }
  var accountdata = {
   action:'challenge',
   user:username
  }
  baseurl = 'http://'+ip+':8089/webrtccgi?';
  getchanllenge(accountdata, username) // 用户鉴权函数
 }

2）用户登录鉴权(本项目中与服务器交互需要使用，具体使用看服务器端设置)

<!--账号密码 鉴权-->
function getchanllenge(accountdata, username) {
  console.log('start getchangllenge')
  var challenge = ''
  //获取challenge
   superagent
    .post(baseurl)
    .set(httpheader)
    .type('form')
    .send(accountdata)
    .redirects(0)
    .end(function(err, result) {
     if (typeof(result) == 'undefined') {
      console.error("get challenge is error, result is undefined");
     } else {
      var responce = result.body
      if(responce && responce.status === 0) {
       challenge = responce.response.challenge
       getcookie(challenge, username)
      } else {
       console.error('get challenge is error, result.body.status is not 0')
      }
     }
    });
 }

 <!--cookie 鉴权-->
 
 function getcookie(challenge, username) {
  var md5key = tskmd5.md5.hexdigest(challenge + pass) // md5加密用户登录密码
  var subdata={
   token: md5key,
   action: 'login',
   user: username
  }
  // 开始请求进行用户登录密码鉴权，类似ajax请求
  superagent
   .post(baseurl)
   .set(httpheader)
   .type('form')
   .send(subdata)
   .redirects(0)
   .end(function(err, res) {
    if (typeof(res) == 'undefined') {
     console.log("get cookie is error, result is undefined");
    } else {
     var responce = res.body
     if(responce && responce.status === 0) {
     // 登录鉴权通过，开始执行sip注册
      var cookie = responce.response.cookie
      // 注册函数
      startsocket(username)
     } else {
      console.log('get cookie is error, result.body.status is not 0')
     }
    }
   })
 }

与服务器建立websocket连接

项目中信令交互信息均通过websocket发送

var ws = new websocket(websocketurl, "sip"); # 注意建立的是sip类型的websocket

 ws.on('open', function open() {
  console.log('ws open message1' + message1)
  readystate = websocket.open
  // 发送相关信息
  ws.send(message); 
 });
 
 ws.on('message', function incoming(data) {
  a++;
  var dataarr = data.split('\r\n')
  if (dataarr[0].indexof('401') > -1 && a === 1) {
   // 发送注册信令函数（其中发送信令信息，均参考浏览器的发送头进行拼接）
   startregister(ws, dataarr, username)
  } else if (dataarr[0].indexof('200')) {
   // ws.close()
   // console.log('register sucess...')
  } else {
  }
 });

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持移动技术网。

您可能感兴趣的文章:

如对本文有疑问， 点击进行留言回复！！

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网