• 基于eXosip2实现的客户端和服务端

    一、源码下载

    Index of /download/exosip2/，这里选择libeXosip2-3.5.0.tar.gz和libosip2-3.5.0.tar.gz

    二、osip2库编译

    1. cd libosip2-3.5.0/
    2. ./configure --enable-static
    3. make
    4. make install

    三、eXosip2库编译

     

    1. cd libeXosip2-3.5.0/
    2. ./configure --enable-static
    3. make 
    4. make install
     

    四、eXosip2客户端
     

    1.  
    2. #include <iostream>
    3. #include <string>
    4. #include <sstream>
    5. #include <osipparser2/osip_message.h>
    6. #include <osipparser2/osip_parser.h>
    7. #include <osipparser2/osip_port.h>
    8.  
    9. #include <eXosip2/eXosip.h>
    10. #include <eXosip2/eX_setup.h>
    11. #include <eXosip2/eX_register.h>
    12. #include <eXosip2/eX_options.h>
    13. #include <eXosip2/eX_message.h>
    14. #include <arpa/inet.h>
    15. #include <sys/types.h>
    16. #include <sys/socket.h>
    17.  
    18. using namespace std;
    19.  
    20.  
    21. #define LISTEN_ADDR ("192.168.50.57")
    22. #define UACPORT ("5061")
    23. #define UACPORTINT (5061)
    24. #define UACCODE ("100110000201000000")
    25. #define UACPWD ("12345")
    26. #define UAS_ADDR ("192.168.50.57")
    27. #define UAS_PORT ("5060")
    28. #define EXPIS 300
    29.  
    30. static int iCurrentStatus;
    31.  
    32. static int iHandle = -1;
    33.  
    34.  
    35. class CSipFromToHeader
    36. {
    37. public:
    38.  CSipFromToHeader()
    39.  {
    40.  }
    41.  ~CSipFromToHeader()
    42.  {
    43.  }
    44.  void SetHeader(string addrCod, string addrI, string addrPor)
    45.  {
    46. 	 addrCode = addrCod;
    47. 	 addrIp = addrI;
    48. 	 addrPort = addrPor;
    49.  }
    50.  string GetFormatHeader()
    51.  {
    52. 	 std::stringstream stream;
    53. 	 stream << "sip: " << addrCode << "@" << addrIp << ":" << addrPort;
    54. 	 return stream.str();
    55.  }
    56.  
    57.  string GetCode()
    58.  {
    59. 	 std::stringstream stream;
    60. 	 stream << addrCode;
    61. 	 return stream.str();
    62.  }
    63.  
    64.  string GetAddr()
    65.  {
    66. 	 std::stringstream stream;
    67. 	 stream << addrIp;
    68. 	 return stream.str();
    69.  }
    70.  
    71.  string GetPort()
    72.  {
    73. 	 std::stringstream stream;
    74. 	 stream << addrPort;
    75. 	 return stream.str();
    76.  }
    77.  
    78. private:
    79.  string addrCode;
    80.  string addrIp;
    81.  string addrPort;
    82. };
    83.  
    84. class CContractHeader: public CSipFromToHeader
    85. {
    86. public:
    87.  CContractHeader()
    88.  {
    89.  }
    90.  ~CContractHeader()
    91.  {
    92.  }
    93.  void SetContractHeader(string addrCod, string addrI, string addrPor)
    94.  {
    95. 	 SetHeader(addrCod, addrI, addrPor);
    96.  }
    97.  string GetContractFormatHeader()
    98.  {
    99.  
    100. 	 std::stringstream stream;
    101. 	 stream << " << GetCode() << "@" << GetAddr() << ":" << GetPort()
    102. 			 << ">";
    103. 	 return stream.str();
    104.  }
    105. };
    106.  
    107.  
    108. int SendRegister(int& registerId, CSipFromToHeader &from, CSipFromToHeader &to,
    109. 	 CContractHeader &contact, const string& userName, const string& pwd,
    110. 	 const int expires, int iType)
    111. {
    112.  cout << "=============================================" << endl;
    113.  if (iType == 0)
    114.  {
    115. 	 cout << "注册请求信息：" << endl;
    116.  }
    117.  else if (iType == 1)
    118.  {
    119. 	 cout << "刷新注册信息：" << endl;
    120.  }
    121.  else
    122.  {
    123. 	 cout << "注销信息:" << endl;
    124.  }
    125.  cout << "registerId " << registerId << endl;
    126.  cout << "from " << from.GetFormatHeader() << endl;
    127.  cout << "to " << to.GetFormatHeader() << endl;
    128.  cout << "contact" << contact.GetContractFormatHeader() << endl;
    129.  cout << "userName" << userName << endl;
    130.  cout << "pwd" << pwd << endl;
    131.  cout << "expires" << expires << endl;
    132.  cout << "=============================================" << endl;
    133.  
    134.  static osip_message_t *regMsg = 0;
    135.  int ret;
    136.  
    137.  ::eXosip_add_authentication_info(userName.c_str(), userName.c_str(),
    138. 		 pwd.c_str(), "MD5", NULL);
    139.  eXosip_lock();
    140.  if (0 == registerId)
    141.  {
    142. 	 registerId = ::eXosip_register_build_initial_register(
    143. 			 from.GetFormatHeader().c_str(), to.GetFormatHeader().c_str(),
    144. 			 contact.GetContractFormatHeader().c_str(), expires, &regMsg);
    145. 	 if (registerId <= 0)
    146. 	 {
    147. 		 return -1;
    148. 	 }
    149.  }
    150.  else
    151.  {
    152. 	 ret = ::eXosip_register_build_register(registerId, expires, &regMsg);
    153. 	 if (ret != OSIP_SUCCESS)
    154. 	 {
    155. 		 return ret;
    156. 	 }
    157. 	 if (expires == 0)
    158. 	 {
    159. 		 osip_contact_t *contact = NULL;
    160. 		 char tmp[128];
    161.  
    162. 		 osip_message_get_contact(regMsg, 0, &contact);
    163. 		 {
    164. 			 sprintf(tmp, ";expires=0",
    165. 					 contact->url->username, contact->url->host,
    166. 					 contact->url->port);
    167. 		 }
    168. 		 //osip_contact_free(contact);
    169. 		 //reset contact header
    170. 		 osip_list_remove(&regMsg->contacts, 0);
    171. 		 osip_message_set_contact(regMsg, tmp);
    172. 		 osip_message_set_header(regMsg, "Logout-Reason", "logout");
    173. 	 }
    174.  }
    175.  ret = ::eXosip_register_send_register(registerId, regMsg);
    176.  if (ret != OSIP_SUCCESS)
    177.  {
    178. 	 registerId = 0;
    179.  }eXosip_unlock();
    180.  
    181.  return ret;
    182. }
    183.  
    184. //注册
    185. void Register()
    186. {
    187.  if (iCurrentStatus == 1)
    188.  {
    189. 	 cout << "当前已经注册" << endl;
    190. 	 return;
    191.  }
    192.  CSipFromToHeader stFrom;
    193.  stFrom.SetHeader(UACCODE, UAS_ADDR, UAS_PORT);
    194.  CSipFromToHeader stTo;
    195.  stTo.SetHeader(UACCODE, UAS_ADDR, UAS_PORT);
    196.  CContractHeader stContract;
    197.  stContract.SetContractHeader(UACCODE, LISTEN_ADDR, UACPORT);
    198.  //发送注册信息
    199.  int registerId = 0;
    200.  if (0 > SendRegister(registerId, stFrom, stTo, stContract, UACCODE, UACPWD,
    201. 		 3000, 0))
    202.  {
    203. 	 cout << "发送注册失败" << endl;
    204. 	 return;
    205.  }
    206.  iCurrentStatus = 1;
    207.  iHandle = registerId;
    208. }
    209. //刷新注册
    210. void RefreshRegister()
    211. {
    212.  if (iCurrentStatus == 0)
    213.  {
    214. 	 cout << "当前未注册，不允许刷新" << endl;
    215. 	 return;
    216.  }
    217.  CSipFromToHeader stFrom;
    218.  stFrom.SetHeader(UACCODE, UAS_ADDR, UAS_PORT);
    219.  CSipFromToHeader stTo;
    220.  stTo.SetHeader(UACCODE, UAS_ADDR, UAS_PORT);
    221.  CContractHeader stContract;
    222.  stContract.SetContractHeader(UACCODE, LISTEN_ADDR, UACPORT);
    223.  //发送注册信息
    224.  if (0 > SendRegister(iHandle, stFrom, stTo, stContract, UACCODE, UACPWD,
    225. 		 3000, 1))
    226.  {
    227. 	 cout << "发送刷新注册失败" << endl;
    228. 	 return;
    229.  }
    230. }
    231. //注销
    232. void UnRegister()
    233. {
    234.  if (iCurrentStatus == 0)
    235.  {
    236. 	 cout << "当前未注册，不允许注销" << endl;
    237. 	 return;
    238.  }
    239.  CSipFromToHeader stFrom;
    240.  stFrom.SetHeader(UACCODE, UAS_ADDR, UAS_PORT);
    241.  CSipFromToHeader stTo;
    242.  stTo.SetHeader(UACCODE, UAS_ADDR, UAS_PORT);
    243.  CContractHeader stContract;
    244.  stContract.SetContractHeader(UACCODE, LISTEN_ADDR, UACPORT);
    245.  //发送注册信息
    246. 269     if (0 > SendRegister( iHandle, stFrom, stTo, stContract, UACCODE, UACPWD,
    247. 		 0, 2))
    248.  {
    249. 	 cout << "发送注销失败" << endl;
    250. 	 return;
    251.  }
    252.  iCurrentStatus = 0;
    253.  iHandle = -1;
    254. }
    255. static void help()
    256. {
    257.  const char
    258. 		 *b =
    259.  "-------------------------------------------------------------------------------\n"
    260.  "SIP Library test process - uac v 1.0 (June 13, 2014)\n\n"
    261.  "SIP UAC端 注册,刷新注册,注销实现\n\n"
    262.  "Author: 程序人生\n\n"
    263.  "博客地址:http://blog.csdn.net/hiwubihe QQ:1269122125\n\n"
    264.  "-------------------------------------------------------------------------------\n"
    265.  "\n"
    266.  "              0:Register\n"
    267.  "              1:RefreshRegister\n"
    268.  "              2:UnRegister\n"
    269.  "              3:clear scream\n"
    270.  "              4:exit\n"
    271.  "-------------------------------------------------------------------------------\n"
    272.  "\n";
    273.  fprintf(stderr, b, strlen(b));
    274.  cout << "please select method :";
    275. }
    276. //服务处理线程
    277. void *serverHandle(void *pUser)
    278. {
    279.  sleep(3);
    280.  help();
    281.  char ch = getchar();
    282.  getchar();
    283.  while (1)
    284.  {
    285. 	 switch (ch)
    286. 	 {
    287. 	 case '0':
    288. 		 //注册
    289. 		 Register();
    290. 		 break;
    291. 	 case '1':
    292. 		 //刷新注册
    293. 		 RefreshRegister();
    294. 		 break;
    295. 	 case '2':
    296. 		 //注销
    297. 		 UnRegister();
    298. 		 break;
    299. 	 case '3':
    300. 		 if (system("clear") < 0)
    301. 		 {
    302. 			 cout << "clear scream error" << endl;
    303. 			 exit(1);
    304. 		 }
    305. 		 break;
    306. 	 case '4':
    307. 		 cout << "exit sipserver......" << endl;
    308. 		 getchar();
    309. 		 exit(0);
    310. 	 default:
    311. 		 cout << "select error" << endl;
    312. 		 break;
    313. 	 }
    314. 	 cout << "press any key to continue......" << endl;
    315. 	 getchar();
    316. 	 help();
    317. 	 ch = getchar();
    318. 	 getchar();
    319.  }
    320.  return NULL;
    321. }
    322.  
    323. //事件处理线程
    324. void *eventHandle(void *pUser)
    325. {
    326.  eXosip_event_t* osipEventPtr = (eXosip_event_t*) pUser;
    327.  switch (osipEventPtr->type)
    328.  {
    329.  //需要继续验证REGISTER是什么类型
    330.  case EXOSIP_REGISTRATION_SUCCESS:
    331.  case EXOSIP_REGISTRATION_FAILURE:
    332.  {
    333. 	 cout<<"收到状态码:"<<osipEventPtr->response->status_code<<"报文"<<endl;
    334. 	 if(osipEventPtr->response->status_code == 401)
    335. 	 {
    336. 		 cout<<"发送鉴权报文"<<endl;
    337. 	 }
    338. 	 else if(osipEventPtr->response->status_code == 200)
    339. 	 {
    340. 		 cout<<"接收成功"<<endl;
    341. 	 }
    342. 	 else
    343. 	 {}
    344.  }
    345. 	 break;
    346.  default:
    347. 	 cout << "The sip event type that not be precessed.the event "
    348. 		 "type is : " << osipEventPtr->type << endl;
    349. 	 break;
    350.  }
    351.  eXosip_event_free(osipEventPtr);
    352.  return NULL;
    353. }
    354.  
    355. int main()
    356. {
    357.  iCurrentStatus = 0;
    358.  //库处理结果
    359.  int result = OSIP_SUCCESS;
    360.  //初始化库
    361.  if (OSIP_SUCCESS != (result = eXosip_init()))
    362.  {
    363. 	 printf("eXosip_init failure.\n");
    364. 	 return 1;
    365.  }
    366.  cout << "eXosip_init success." << endl;
    367.  eXosip_set_user_agent(NULL);
    368.  //监听
    369.  if (OSIP_SUCCESS != eXosip_listen_addr(IPPROTO_UDP, NULL, UACPORTINT,
    370. 		 AF_INET, 0))
    371.  {
    372. 	 printf("eXosip_listen_addr failure.\n");
    373. 	 return 1;
    374.  }
    375.  //设置监听网卡
    376.  if (OSIP_SUCCESS != eXosip_set_option(
    377.  EXOSIP_OPT_SET_IPV4_FOR_GATEWAY,
    378. 		 LISTEN_ADDR))
    379.  {
    380. 	 return -1;
    381.  }
    382.  //开启服务线程
    383.  pthread_t pthser;
    384.  if (0 != pthread_create(&pthser, NULL, serverHandle, NULL))
    385.  {
    386. 	 printf("创建主服务失败\n");
    387. 	 return -1;
    388.  }
    389.  //事件用于等待
    390.  eXosip_event_t* osipEventPtr = NULL;
    391.  //开启事件循环
    392.  while (true)
    393.  {
    394. 	 //等待事件 0的单位是秒，500是毫秒
    395. 	 osipEventPtr = ::eXosip_event_wait(0, 200);
    396. 	 //处理eXosip库默认处理
    397. 	 {
    398. 		 usleep(500 * 1000);
    399. 		 eXosip_lock();
    400. 		 //一般处理401/407采用库默认处理
    401. 		 eXosip_default_action(osipEventPtr);
    402. 		 eXosip_unlock();
    403. 	 }
    404. 	 //事件空继续等待
    405. 	 if (NULL == osipEventPtr)
    406. 	 {
    407. 		 continue;
    408. 	 }
    409. 	 //开启线程处理事件并在事件处理完毕将事件指针释放
    410. 	 pthread_t pth;
    411. 	 if (0 != pthread_create(&pth, NULL, eventHandle, (void*) osipEventPtr))
    412. 	 {
    413. 		 printf("创建线程处理事件失败\n");
    414. 		 continue;
    415. 	 }
    416. 	 osipEventPtr = NULL;
    417.  }
    418. }
     

      g++  test_cli.cpp -o test_cli -I/usr/local/include -L/usr/local/lib -losipparser2 -losip2 -lpthread -leXosip2
     

    四、eXosip2服务端 
     

    1. #include <string.h>
    2. #include <iostream>
    3. #include <string>
    4. #include <sstream>
    5. #include <osipparser2/osip_message.h>
    6. #include <osipparser2/osip_parser.h>
    7. #include <osipparser2/osip_port.h>
    8.  
    9. #include <eXosip2/eXosip.h>
    10. #include <eXosip2/eX_setup.h>
    11. #include <eXosip2/eX_register.h>
    12. #include <eXosip2/eX_options.h>
    13. #include <eXosip2/eX_message.h>
    14. #include <arpa/inet.h>
    15. #include <sys/types.h>
    16. #include <sys/socket.h>
    17.  
    18. using namespace std;
    19.  
    20. #define LISTEN_ADDR ("192.168.50.57")
    21. #define UASPORT (5060)
    22.  
    23.  
    24. //该系数是由UAS维护的，UAS在接收到UAC的未鉴权报文后，给UAC回复401，在该报文中必须要带相关认证系数和认证方法
    25. //UAS赋值的认证随机数
    26. #define NONCE "9bd055"
    27. //UAS默认加密算法
    28. #define ALGORITHTHM "MD5"
    29.  
    30. eXosip_t *m_exosip_t;
    31. //SIP From头部
    32. class CSipFromHeader
    33. {
    34. public:
    35.     CSipFromHeader()
    36.     {
    37.     }
    38.     ~CSipFromHeader()
    39.     {
    40.     }
    41.     void SetHeader(string addrCod, string addrI, string addrPor)
    42.     {
    43.         addrCode = addrCod;
    44.         addrIp = addrI;
    45.         addrPort = addrPor;
    46.     }
    47.     string GetFormatHeader()
    48.     {
    49.         std::stringstream stream;
    50.         stream << " << addrCode << "@" << addrIp << ":" << addrPort
    51.                 << ">";
    52.         return stream.str();
    53.     }
    54.     //主机名称
    55.     string GetRealName()
    56.     {
    57.         std::stringstream stream;
    58.         stream << addrIp;
    59.         return stream.str();
    60.     }
    61. private:
    62.     string addrCode;
    63.     string addrIp;
    64.     string addrPort;
    65. };
    66.  
    67. //SIP Contract头部
    68. class CContractHeader: public CSipFromHeader
    69. {
    70. public:
    71.     CContractHeader()
    72.     {
    73.     }
    74.     ~CContractHeader()
    75.     {
    76.     }
    77.     void SetContractHeader(string addrCod, string addrI, string addrPor,
    78.             int expire)
    79.     {
    80.         SetHeader(addrCod, addrI, addrPor);
    81.         expires = expire;
    82.     }
    83.     string GetContractFormatHeader(bool bExpires)
    84.     {
    85.         if (!bExpires)
    86.         {
    87.             return GetFormatHeader();
    88.         }
    89.         else
    90.         {
    91.             string sTmp = GetFormatHeader();
    92.             std::stringstream stream;
    93.             stream << ";" << "expires=" << expires;
    94.             sTmp += stream.str();
    95.             return sTmp;
    96.         }
    97.  
    98.     }
    99. private:
    100.     int expires;
    101. };
    102.  
    103. struct SipContextInfo
    104. {
    105.     //Sip层返回的请求的标志 响应时返回即可
    106.     int sipRequestId;
    107.     //维护一次注册
    108.     string callId;
    109.     //消息所属的功能方法名字符串
    110.     string method;
    111.     //地址编码@域名或IP地址:连接端口，例如sip:1111@127.0.0.1:5060
    112.     CSipFromHeader from;
    113.     //地址编码@域名或IP地址:连接端口，例如sip:1111@127.0.0.1:5060
    114.     CSipFromHeader proxy;
    115.     //地址编码@域名或IP地址:连接端口，例如sip:1111@127.0.0.1:5060
    116.     CContractHeader contact;
    117.     //消息内容,一般为DDCP消息体XML文档,或者具体协议帧要求的其他字符串文本
    118.     string content;
    119.     //响应状态信息
    120.     string status;
    121.     //超时,时间单位为秒
    122.     int expires;
    123. };
    124.  
    125. struct SipAuthInfo
    126. {
    127.     //平台主机名
    128.     string digestRealm;
    129.     //平台提供的随机数
    130.     string nonce;
    131.     //用户名
    132.     string userName;
    133.     //密码
    134.     string response;
    135.     //“sip:平台地址”,不需要uac赋值
    136.     string uri;
    137.     //加密算法MD5
    138.     string algorithm;
    139. };
    140.  
    141. struct sipRegisterInfo
    142. {
    143.     SipContextInfo baseInfo;
    144.     SipAuthInfo authInfo;
    145.     bool isAuthNull;
    146. };
    147.  
    148. void parserRegisterInfo(osip_message_t*request, int iReqId,
    149.         sipRegisterInfo &regInfo)
    150. {
    151.     std::stringstream stream;
    152.     regInfo.baseInfo.method = request->sip_method;
    153.     regInfo.baseInfo.from.SetHeader(request->from->url->username,
    154.             request->from->url->host, request->from->url->port);
    155.     regInfo.baseInfo.proxy.SetHeader(request->to->url->username,
    156.             request->to->url->host, request->to->url->port);
    157.     //获取expires
    158.     osip_header_t* header = NULL;
    159.     {
    160.         osip_message_header_get_byname(request, "expires",
    161.                 0, &header);
    162.         if (NULL != header && NULL != header->hvalue)
    163.         {
    164.             regInfo.baseInfo.expires = atoi(header->hvalue);
    165.         }
    166.     }
    167.     //contact字段
    168.     osip_contact_t* contact = NULL;
    169.     osip_message_get_contact(request, 0, &contact);
    170.     if (NULL != contact)
    171.     {
    172.         regInfo.baseInfo.contact.SetContractHeader(contact->url->username,
    173.                 contact->url->host, contact->url->port,
    174.                 regInfo.baseInfo.expires);
    175.     }
    176.     //注册返回 由发送方维护的请求ID 接收方接收后原样返回即可
    177.     regInfo.baseInfo.sipRequestId = iReqId;
    178.     //CALL_ID
    179.     {
    180.         stream.str("");
    181.         stream << request->call_id->number;
    182.         regInfo.baseInfo.callId = stream.str();
    183.     }
    184.     //解析content消息
    185.     osip_body_t * body = NULL;
    186.     osip_message_get_body(request, 0, &body);
    187.     if (body != NULL)
    188.     {
    189.         stream.str("");
    190.         stream << body->body;
    191.         regInfo.baseInfo.content = stream.str();
    192.     }
    193.     //鉴权信息
    194.     osip_authorization_t* authentication = NULL;
    195.     {
    196.         osip_message_get_authorization(request, 0, &authentication);
    197.         if (NULL == authentication)
    198.         {
    199.             regInfo.isAuthNull = true;
    200.         }
    201.         else
    202.         {
    203.             regInfo.isAuthNull = false;
    204.             stream.str("");
    205.             stream << authentication->username;
    206.             regInfo.authInfo.userName = stream.str();
    207.             stream.str("");
    208.             stream << authentication->algorithm;
    209.             regInfo.authInfo.algorithm = stream.str();
    210.             stream.str("");
    211.             stream << authentication->realm;
    212.             regInfo.authInfo.digestRealm = stream.str();
    213.             stream.str("");
    214.             stream << authentication->nonce;
    215.             regInfo.authInfo.nonce = stream.str();
    216.             stream.str("");
    217.             stream << authentication->response;
    218.             regInfo.authInfo.response = stream.str();
    219.             stream.str("");
    220.             stream << authentication->uri;
    221.             regInfo.authInfo.uri = stream.str();
    222.         }
    223.     }
    224.     authentication = NULL;
    225. }
    226.  
    227. //打印接收到的响应报文
    228. void printRegisterPkt( sipRegisterInfo&info)
    229. {
    230.     cout<<"接收到报文："<<endl;
    231.     cout<<"=============================================="
    232.             "=================="<<endl;
    233.     cout << "method:" << info.baseInfo.method << endl;
    234.     cout << "from:    " << info.baseInfo.from.GetFormatHeader() << endl;
    235.     cout << "to:" << info.baseInfo.proxy.GetFormatHeader() << endl;
    236.     cout << "contact:" << info.baseInfo.contact.GetContractFormatHeader(false)
    237.             << endl;
    238.  
    239.     //注册返回 由发送方维护的请求ID 接收方接收后原样返回即可
    240.     cout << "sipRequestId:" << info.baseInfo.sipRequestId << endl;
    241.     //CALL_ID
    242.     cout << "CallId:" << info.baseInfo.callId << endl;
    243.     //解析content消息
    244.     cout << "body:" << info.baseInfo.content << endl;
    245.     //获取expires
    246.     cout << "expires:" << info.baseInfo.expires << endl;
    247.     //鉴权信息
    248.     if (info.isAuthNull)
    249.     {
    250.         cout << "当前报文未提供鉴权信息!!!" << endl;
    251.     }
    252.     else
    253.     {
    254.         cout << "当前报文鉴权信息如下:" << endl;
    255.         cout << "username:" << info.authInfo.userName << endl;
    256.         cout << "algorithm:" << info.authInfo.algorithm << endl;
    257.         cout << "Realm:" << info.authInfo.digestRealm << endl;
    258.         cout << "nonce:" << info.authInfo.nonce << endl;
    259.         cout << "response:" << info.authInfo.response << endl;
    260.         cout << "uri:" << info.authInfo.uri << endl;
    261.     }
    262.      cout<<"=================================================="
    263.              "=============="<<endl;
    264.     return;
    265. }
    266. void sendRegisterAnswer( sipRegisterInfo&info)
    267. {
    268.     osip_message_t* answer = NULL;
    269.     int iStatus;
    270.     if (info.isAuthNull)
    271.     {
    272.         iStatus = 401;
    273.     }
    274.     else
    275.     {
    276.         iStatus = 200;
    277.     }
    278. 	eXosip_lock(m_exosip_t);
    279.     {
    280.         int result = ::eXosip_message_build_answer(m_exosip_t, info.baseInfo.sipRequestId,
    281.                 iStatus, &answer);
    282.         if (iStatus == 401)
    283.         {
    284.             //由SIP库生成认证方法和认证参数发送客户端
    285.             std::stringstream stream;
    286.             string nonce=NONCE;
    287.             string algorithm=ALGORITHTHM;
    288.             stream << "Digest realm=\"" << info.baseInfo.from.GetRealName()
    289.                     << "\",nonce=\"" << nonce
    290.                     << "\",algorithm=" << algorithm;
    291.  
    292.             osip_message_set_header(answer, "WWW-Authenticate",
    293.                     stream.str().c_str());
    294.              cout<<"======================================================="
    295.                      "========="<<endl;
    296.              cout<<"发送401报文"<<endl;
    297.              cout<<"========================================================"
    298.                      "========"<<endl;
    299.         }
    300.         else if (iStatus == 200)
    301.         {
    302.             osip_message_set_header(answer, "Contact",
    303.                     info.baseInfo.contact.GetContractFormatHeader(true).c_str());
    304.              cout<<"========================================================="
    305.                      "======="<<endl;
    306.              cout<<"发送200报文"<<endl;
    307.              cout<<"=========================================================="
    308.                      "======"<<endl;
    309.             //string_t b = ";expires=600";
    310.             //osip_message_set_header(answer, "Contact", b.c_str());
    311.         }
    312.         else
    313.         {
    314.             //Do nothing
    315.         }
    316.  
    317.         if (OSIP_SUCCESS != result)
    318.         {
    319.             ::eXosip_message_send_answer(m_exosip_t, info.baseInfo.sipRequestId, 400, NULL);
    320.         }
    321.         else
    322.         {
    323.             //发送消息体
    324.             ::eXosip_message_send_answer(m_exosip_t, info.baseInfo.sipRequestId, iStatus,
    325.                     answer);
    326.         }
    327.         if (0 == info.baseInfo.expires)
    328.         {
    329.             eXosip_register_remove(m_exosip_t, info.baseInfo.sipRequestId);
    330.         }
    331.     }
    332. 	eXosip_unlock(m_exosip_t);
    333. }
    334. void OnRegister(eXosip_event_t *osipEvent)
    335. {
    336.     sipRegisterInfo regInfo;
    337.     parserRegisterInfo(osipEvent->request, osipEvent->tid, regInfo);
    338.     //打印报文
    339.     printRegisterPkt(regInfo);
    340.     //发送应答报文
    341.     sendRegisterAnswer(regInfo);
    342.  
    343. }
    344.  
    345. int main()
    346. {
    347.  
    348.     int result = OSIP_SUCCESS;
    349. 	m_exosip_t = eXosip_malloc();
    350.     // init exosip.
    351.     if (OSIP_SUCCESS != (result = eXosip_init(m_exosip_t)))
    352.     {
    353.         printf("eXosip_init failure.\n");
    354.         return 1;
    355.     }
    356.     cout << "eXosip_init success." << endl;
    357.     //
    358.     //        if (null_ptr != this->receiveSipMessageCallback || null_ptr
    359.     //                != this->sendSipMessageCallback)
    360.     //        {
    361.     //            if (OSIP_SUCCESS != (result = ::eXosip_set_cbsip_message(
    362.     //                    &Sip::MessageCallback)))
    363.     //            {
    364.     //                return;
    365.     //            }
    366.     //        }
    367.     eXosip_set_user_agent(m_exosip_t,NULL);
    368.  
    369.     if (OSIP_SUCCESS != eXosip_listen_addr(m_exosip_t, IPPROTO_UDP, NULL, UASPORT, AF_INET,
    370.             0))
    371.     {
    372.         printf("eXosip_listen_addr failure.\n");
    373.         return 1;
    374.     }
    375.  
    376.     if (OSIP_SUCCESS != eXosip_set_option(m_exosip_t,
    377.     EXOSIP_OPT_SET_IPV4_FOR_GATEWAY,
    378.             LISTEN_ADDR))
    379.     {
    380.         return -1;
    381.     }
    382.     //开启循环消息，实际应用中可以开启多线程同时接收信号
    383.     eXosip_event_t* osipEventPtr = NULL;
    384.  
    385.     while (true)
    386.     {
    387.         // Wait the osip event.
    388.         osipEventPtr = ::eXosip_event_wait(m_exosip_t, 0, 200);// 0的单位是秒，500是毫秒
    389.         // If get nothing osip event,then continue the loop.
    390.         if (NULL == osipEventPtr)
    391.         {
    392.             continue;
    393.         }
    394.         // 事件处理
    395.  
    396.         switch (osipEventPtr->type)
    397.         {
    398.  
    399.         //需要继续验证REGISTER是什么类型
    400.         //case EXOSIP_REGISTRATION_NEW:
    401.             //OnRegister(osipEventPtr);
    402.             //break;
    403.         case EXOSIP_MESSAGE_NEW:
    404.         {
    405.             if (!strncmp(osipEventPtr->request->sip_method, "REGISTER",
    406.                     strlen("REGISTER")))
    407.             {
    408.                 OnRegister(osipEventPtr);
    409.             }
    410.             else if (!strncmp(osipEventPtr->request->sip_method, "MESSAGE",
    411.                     strlen("MESSAGE")))
    412.             {
    413.                 //
    414.             }
    415.         }
    416.             break;
    417.         default:
    418.             cout
    419.                     << "The sip event type that not be precessed.the event "
    420.                             "type is : "
    421.                     << osipEventPtr->type;
    422.             break;
    423.         }
    424.         //ProcessSipEvent(this->osipEventPtrParam);
    425.         eXosip_event_free(osipEventPtr);
    426.         osipEventPtr = NULL;
    427.     }
    428.  
    429.     return 0;
    430. }
     

    g++ test_srv.cpp -o test_srv -I/usr/local/include -L/usr/local/lib -losipparser2 -losip2 -lpthread -leXosip2 
    
                
    
                    
    
                
    • 

                
  • 

                    相关阅读:
    
                    
蓝牙资讯|Q2中国蓝牙耳机市场发布，搭载苹果Find My的蓝牙耳机正逐步推出                            
    
VBA 输出到CMD控制台显示暨更新当前行显示                            
    
Java集合类ArrayList的应用-杨辉三角的前n行                            
    
Node.js实现WebSocket                            
    
【Linux-Windows】千兆网口以及千兆网线                            
    
【Electron将HTML项目打包成桌面应用exe文件】                            
    
有汇源上下界最大流和最小流                            
    
H5页面获取用户位置信息方案及测试流程                            
    
PTL电子标签助力仓储行业转型升级提升拣货效率降低误差率                            
    
2023-09-14力扣每日一题                            
    
                        
                
    • 
                
  • 
                    原文地址：https://blog.csdn.net/thehunters/article/details/133297399
                
    •