devbox
盐析白兔
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

设备发现协议SSDP实现_239.255.255.250

作者：盐析白兔 | 2024-04-23 17:24:07

赞

踩

239.255.255.250

原理：

1.将socket加入239.255.255.250，端口 1900

2.客户端：通过设置setsockopt +IPPROTO_IP,IP_ADD_MEMBERSHIP属性，可向ssdp组进行组播。

3.服务端：通过设置绑定239.255.255.250:1900进行数据接收，通过setsockopt +IPPROTO_IP,IP_ADD_MEMBERSHIP属性 加入组播。

容易错误的地方：

服务端打印sendto成功，但是通过wireshark抓包发现没有组播发送到239.255.255.250

这是因为：sendto的时候，用的sockaddr_in是通过recvfrom得到的：recvfrom得到的是具体的某个从组播拷贝的数据的源ip,这是单播。如果要组播发送，则要发送到这个地址：
    m_cddr.sin_family = AF_INET;
    m_cddr.sin_addr.s_addr = inet_addr("239.255.255.250");
    m_cddr.sin_port = htons(1900);

客户端代码：

  1. /*
  2. Author:zhuoyong
  3. Date:2022-04-07
  4. Mark:人脸识别客户端代码
  5. */
  6.  
  7. #ifndef CSSDPCLIENT_H
  8. #define CSSDPCLIENT_H
  9. #include<string>
  10. #include<string.h>
  11. #include<queue>
  12. #include<stdio.h>
  13. #include<stdlib.h>
  14. #include<arpa/inet.h>
  15. #include<thread>
  16. #include<chrono>
  17. #include<unistd.h>
  18. #include<netinet/in.h>
  19. #include<arpa/inet.h>
  20. #include<net/if.h>
  21. #include<pthread.h>
  22. #include<fcntl.h>
  23. #define ERR printf
  24. #define RTM printf
  25. #define MAXSSDPSIZE 1024
  26.  
  27. using namespace std;
  28.  
  29. class CSSDPClient
  30. {
  31. public:
  32.     static  void    Discover();
  33.     //最终加密后的pssword=：md5(<uuid>:<uid>:<pwd>)
  34.     static  void    ModifyNet(string &strUuid,string&strUid,string&strPwd,string &strMask,string&strGateway,string &strDns);
  35.     //strCryptPwd=base64(AES(pwd))
  36.     static  void    ModifyUser(string &strUuid,string&strUid,string&strPwd);
  37. protected:
  38.     CSSDPClient();
  39.     ~CSSDPClient();
  40.     void    SendMsg(const string&str);
  41.     void    RecvMsg();
  42.     void    NotifyOne(const string&str);
  43.     string  MakeSSDHeader();
  44.     string  MakeSearchMsg();
  45.     string  MakeModifyNetMsg();
  46.     string  MakeModifyUserMsg();
  47.     static  CSSDPClient *Ins();
  48.     void    InerDiscover(const string&str);
  49.     void    InitSocket();
  50. private:
  51.     static CSSDPClient *    g_in;
  52.     sockaddr_in             m_sddr ;
  53.     int                     m_ssdps;
  54.     queue<string>           m_que;
  55.     pthread_cond_t          m_cd;
  56.     pthread_mutex_t         m_mt;
  57. };
  58.  
  59. #endif // CSSDPCLIENT_H
  1. /*
  2.  * ===========================================================================
  3.  *
  4.  *       Filename:  SSDPClient.cpp
  5.  *    Description:  客户端设备发现 xml协议
  6.  *        Version:  1.0
  7.  *        Created:  20220406-12:07
  8.  *       Revision:  none
  9.  *       Compiler:  g++
  10.  *         Author:   (zhouyongku),
  11.  *        Company:  
  12.  *
  13.  * ===========================================================================
  14.  */
  15.  
  16. #include"SSDPClient.h"
  17.  
  18.  
  19.  
  20. CSSDPClient *CSSDPClient::g_in=NULL;
  21. //全局变量
  22.  
  23.  
  24. //解析IP地址
  25. CSSDPClient::CSSDPClient()
  26. {
  27.     m_mt=PTHREAD_MUTEX_INITIALIZER;
  28.     m_cd=PTHREAD_COND_INITIALIZER;
  29.  
  30.     std::thread t([&]
  31.     {
  32.         InitSocket();
  33.         while(true)
  34.         {
  36.             pthread_mutex_lock(&m_mt); // 拿到互斥锁，进入临界区
  37.             if( m_que.size()<=0 )pthread_cond_wait(&m_cd,&m_mt); // 令线程等待在条件变量上
  38.             pthread_mutex_unlock(&m_mt); // 释放互斥锁
  40.             InerDiscover(m_que.front());
  42.             m_que.pop();
  44.         }
  47.     });
  48.     t.detach();
  49. }
  50.  
  51. CSSDPClient::~CSSDPClient()
  52. {
  53.  
  54. }
  55.  
  56. CSSDPClient *CSSDPClient::Ins()
  57. {
  58.     if( CSSDPClient::g_in == nullptr )
  59.     {
  60.         CSSDPClient::g_in = new CSSDPClient();
  61.     }
  62.  
  63.     return CSSDPClient::g_in;
  64. }
  65.  
  66. void CSSDPClient::InerDiscover(const string&str)
  67. {
  68.     SendMsg( str );
  69.     RecvMsg( );
  70. }
  71.  
  72. void CSSDPClient::InitSocket()
  73. {
  74.     struct timeval TimeOut;
  75.     TimeOut.tv_sec = 1;
  76.     TimeOut.tv_usec = 0;
  77.  
  78.  
  79.     m_ssdps=socket(AF_INET,SOCK_DGRAM,0);
  80.     if( m_ssdps < 0)
  81.     {
  82.         ERR("CSSDPClient::InitSocket failed of create socket 239.255.255.250:1900");
  83.         return;
  84.     }
  85.  
  86.     bzero(&m_sddr, sizeof(m_sddr));
  87.     m_sddr.sin_family = AF_INET;
  88.     m_sddr.sin_addr.s_addr = inet_addr("239.255.255.250");
  89.     m_sddr.sin_port = htons(1900);
  90.     setsockopt(m_ssdps, SOL_SOCKET, SO_RCVTIMEO, (char *)&TimeOut, sizeof(TimeOut));
  91.     ip_mreq mreq;
  92.     bzero(&mreq,sizeof(mreq));
  93.     mreq.imr_multiaddr.s_addr =inet_addr("239.255.255.250");
  94.     mreq.imr_interface.s_addr =htonl(INADDR_ANY);
  95.     if( setsockopt(m_ssdps, IPPROTO_IP,IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq)) <0 )
  96.     {
  97.         ERR("CSSDPServer::InitSocket failed of setsockopt IP_ADD_MEMBERSHIP");
  98.         return;
  99.     }
  100.  
  101. //    if( bind(m_ssdps, (struct sockaddr *)&m_sddr, sizeof(m_sddr)) < 0 )
  102. //    {
  103. //        ERR("CSSDPClient::InitSocket failed of bind socket %s:%d",SSDP_MCAST_ADDR,SSDP_PORT);
  104. //    }
  105. }
  106.  
  107. void CSSDPClient::Discover()
  108. {
  109.     string str=CSSDPClient::Ins()->MakeSearchMsg();
  110.     CSSDPClient::Ins()->NotifyOne(str);
  111.  
  112. }
  113.  
  114. void CSSDPClient::ModifyNet(string &strUuid, string &strUid, string &strPwd, string &strMask, string &strGateway, string &strDns)
  115. {
  116.     string str=CSSDPClient::Ins()->MakeModifyNetMsg();
  117.     CSSDPClient::Ins()->NotifyOne(str);
  118. }
  119.  
  120. void CSSDPClient::ModifyUser(string &strUuid, string &strUid, string &strPwd)
  121. {
  122.     string str=CSSDPClient::Ins()->MakeModifyUserMsg();
  123.     CSSDPClient::Ins()->NotifyOne(str);
  124. }
  125.  
  126. void CSSDPClient::NotifyOne(const string&str)
  127. {
  128.     RTM("CSSDPClient::NotifyOne quesize=%d",m_que.size());
  129.     pthread_mutex_lock(&m_mt); // 拿到互斥锁，进入临界区
  130.     m_que.push( str );
  131.     pthread_cond_signal(&m_cd); // 通知等待在条件变量上的消费者
  132.     pthread_mutex_unlock(&m_mt); // 释放互斥锁
  133. }
  134.  
  135. string CSSDPClient::MakeSSDHeader()
  136. {
  137.     string strMsg="M-SEARCH * HTTP/1.1\n";
  138.     strMsg +="HOST: 239.255.255.250:1900\n";
  139.     strMsg +="MAN: \"ssdp:discover\"\n";
  140.     strMsg +="MX: 1\n";
  141.     strMsg +="ST: urn:dial-multiscreen-org:service:dial:1\n";
  142.     strMsg +="USER-AGENT:arm\n";
  143.     return strMsg;
  144. }
  145.  
  146. string CSSDPClient::MakeSearchMsg()
  147. {
  148.  
  149.     string strMsg=MakeSSDHeader();
  150.     strMsg +="<?xml version=\"1.0\" encoding=\"utf-8\"?>\n";
  151.     strMsg +="<Probe>\n";
  152.         strMsg +="  <Uuid>";
  153.         strMsg += "uuid-test";
  154.         strMsg +="</Uuid>\n";
  155.         strMsg +="  <Types>inquiry</Types>\n";
  156.         strMsg +="  <DeviceType>";
  157.         strMsg += "wodepingban";
  158.         strMsg +="</DeviceType>\n";
  159.     strMsg +="</Probe>";
  160.     return strMsg;
  161. }
  162.  
  163. string CSSDPClient::MakeModifyNetMsg()
  164. {
  165.     string strMsg=MakeSSDHeader();
  166.     char szMsg[MAXSSDPSIZE]={0};
  167.     sprintf( szMsg,
  168.     "%s\n"
  169.     "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n"
  170.     "<Probe>\n"
  171.     "<Uuid>testuuid</Uuid>\n"
  172.     "<Types>update</Types>\n"
  173.     "<DeviceSN>123456sdflsdfjl1023-1asdfgh</DeviceSN>\n"
  174.     "<method>modifyipdns</method>\n"
  175.     "<MAC>ab-cd-ef-gh-kh</MAC>\n"
  176.     "<IPv4Address>192.168.66.24</IPv4Address>\n"
  177.     "<IPv4SubnetMask>255.255.255.0</IPv4SubnetMask>\n"
  178.     "<IPv4Gateway>192.168.66.254</IPv4Gateway>\n"
  179.     "<IPv6Address>::</IPv6Address>\n"
  180.     "<IPv6Gateway>::</IPv6Gateway>\n"
  181.     "<IPv6MaskLen>64</IPv6MaskLen>\n"
  182.     "<DHCP>false</DHCP>\n"
  183.     "<Password>kFnsMaQrzmGi89g+6txepC1RNnZMSi/fA16x+UdjFOmqBmoVCc/zeZ8X6oZmLBdWaXnvwTxjLIQBsLsDP0xjHw==</Password>\n"
  184.     "</Probe>\n",
  185.     strMsg.c_str());
  186.     return string(szMsg);
  187.  
  188. }
  189.  
  190. string CSSDPClient::MakeModifyUserMsg()
  191. {
  192.     string strMsg=MakeSSDHeader();
  193.  
  194.  
  195.     char szMsg[MAXSSDPSIZE]={0};
  196.     sprintf( szMsg,
  197.     "%s\n"
  198.      "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n"
  199.      "<Probe>\n"
  200.      "<Uuid>your uuid>\n"
  201.      "<Types>update</Types>\n"
  202.      "<DeviceSN>your device sn</DeviceSN>\n"
  203.      "<method>modifypassword</method>\n"
  204.      "<newpassword>your new md5 password</newpassword>\n"
  205.      "<Password>your md5 password</Password>\n"
  206.      "</Probe>\n");
  207.     return string(szMsg);
  208. }
  209.  
  210.  
  211. //发送ssdp:discover消息
  212. void CSSDPClient::SendMsg(const string&str)
  213. {
  214.     RTM("CSSDPClient::SendMsg msg=%s",str.c_str());
  215.  
  216.     socklen_t len = sizeof(m_sddr);
  217.     int nRet=sendto(m_ssdps,str.c_str(),str.length(),0,(sockaddr*)&m_sddr,len);
  218.     if( nRet >0 )
  219.     {
  220.         RTM("CSSDPClient::SendMsg leng=%d",nRet);
  221.  
  222.     }
  223.  
  224.     char szMsg[MAXSSDPSIZE]={0};
  225.     nRet = recvfrom( m_ssdps,szMsg,MAXSSDPSIZE,0,(sockaddr*)&m_sddr,&len);
  226.     if( nRet >0 )
  227.     {
  228.         RTM("CSSDPClient::SendMsg RECV MSG=%s",szMsg);
  229.     }
  230. }
  231.  
  232. void CSSDPClient::RecvMsg()
  233. {
  234.     socklen_t len = sizeof(m_sddr);
  235.     char szMsg[MAXSSDPSIZE]={0};
  236.     int num = recvfrom(m_ssdps,szMsg,MAXSSDPSIZE,0,(sockaddr*)&m_sddr,&len);
  237.     if( num >0 )
  238.     {
  239.         string str;
  240.         //ParseMsg(buf);
  241.     }
  242. }
  243.  
  244.  
  245.  
  246.  
  247.

服务端：

  1. #ifndef CSSDPSERVER_H
  2. #define CSSDPSERVER_H
  3. /*
  4. Author:zhuoyong
  5. Date:2022-04-07
  6. Mark:设备发现服务端代码
  7. */
  8. #include<string>
  9. #include<string.h>
  10. #include<queue>
  11. #include<stdio.h>
  12. #include<stdlib.h>
  13. #include<arpa/inet.h>
  14. #include<thread>
  15. #include<chrono>
  16. #include<unistd.h>
  17. #include<netinet/in.h>
  18. #include<arpa/inet.h>
  19. #include<net/if.h>
  20. #include<pthread.h>
  21. #include<fcntl.h>
  22. #include<mutex>
  23. #define ERR printf
  24. #define RTM printf
  25. #define MAXSSDPSIZE 1024
  26.  
  27. using namespace std;
  28.  
  29.  
  30. class CSSDPServer
  31. {
  32. public:
  33.     static  void    Init(  );
  34.  
  35. protected:
  36.     CSSDPServer(  );
  37.     ~CSSDPServer();
  38.     void    SendMsg(const string&str);
  39.     void    RecvMsg();
  40.     string  MakeSSDHeader();
  41.     string  MakeResponseSearchMsg( );
  42.     static  CSSDPServer *Ins();
  43.     void    InitSendSocket();
  44.     void    InitRecvSocket();
  45.     void    ProcesMsg( const char *strMsg );
  46. private:
  47.     static CSSDPServer *    g_in;
  48.     sockaddr_in             m_sddr ;
  49.     sockaddr_in             m_cddr ;
  50.     int                     m_ssdps;
  51.     int                     m_ssdpc;
  52.     queue<string>           m_que;
  53.     pthread_cond_t          m_cd;
  54.     pthread_mutex_t         m_mt;
  55. };
  56.  
  57. #endif // CSSDPSERVER_H
  1. /*
  2.  * ===========================================================================
  3.  *
  4.  *       Filename:  SSDPServer.cpp
  5.  *    Description:  服务端设备发现 xml协议
  6.  *        Version:  1.0
  7.  *        Created:  20220406-12:07
  8.  *       Revision:  none
  9.  *       Compiler:  g++
  10.  *         Author:   (zhouyongku),
  11.  *        Company:  
  12.  *
  13.  * ===========================================================================
  14.  */
  15.  
  16.  
  17. #include"SSDPServer.h"
  18.  
  19. CSSDPServer *CSSDPServer::g_in=NULL;
  20. //全局变量
  21.  
  22.  
  23. //解析IP地址
  24. CSSDPServer::CSSDPServer(  )
  25. {
  26.     m_mt=PTHREAD_MUTEX_INITIALIZER;
  27.     m_cd=PTHREAD_COND_INITIALIZER;
  28.     RTM("CSSDPServer::CSSDPServer");
  29.     std::thread t([&]
  30.     {
  31.         RTM("CSSDPServer::CSSDPServer create thread");
  32.         InitSendSocket();
  33.         InitRecvSocket();
  34.         char szMsg[MAXSSDPSIZE]={0};
  35.         socklen_t len = sizeof(m_sddr);
  36.         while( true )
  37.         {
  38.             if((recvfrom(m_ssdps, szMsg, MAXSSDPSIZE, 0, (sockaddr*)&m_sddr, &len)) >= 0)
  39.             {
  40.                 //printf("recvfrom success ip=%s,msg=%s",inet_ntoa(m_sddr.sin_addr),szMsg);
  42.                 ProcesMsg( szMsg );
  43.                 memset(szMsg,0,sizeof(szMsg));
  44.             }
  45.             std::this_thread::sleep_for(std::chrono::seconds(10));
  46.         }
  47.     });
  48.     t.detach();
  49. }
  50. void CSSDPServer::ProcesMsg( const char *strMsg )
  51. {
  52.     //and your code here
  53.  
  54.  
  55.  
  56.  
  57.     SendMsg( MakeResponseSearchMsg( ) );
  58.  
  59.  
  60. }
  61.  
  62.  
  63. CSSDPServer::~CSSDPServer()
  64. {
  65.  
  66. }
  67.  
  68. CSSDPServer *CSSDPServer::Ins(  )
  69. {
  70.     if( CSSDPServer::g_in == nullptr )
  71.     {
  72.         CSSDPServer::g_in = new CSSDPServer(  );
  73.     }
  74.  
  75.     return CSSDPServer::g_in;
  76. }
  77.  
  78.  
  79. void CSSDPServer::InitSendSocket()
  80. {
  81.     struct timeval TimeOut;
  82.     TimeOut.tv_sec = 1;
  83.     TimeOut.tv_usec = 0;
  84.  
  85.  
  86.     m_ssdpc=socket(AF_INET,SOCK_DGRAM,0);
  87.     if( m_ssdpc < 0)
  88.     {
  89.         ERR("CSSDPClient::InitSocket failed of create socket 239.255.255.250:1900");
  90.         return;
  91.     }
  92.  
  93.     bzero(&m_cddr, sizeof(m_cddr));
  94.     m_cddr.sin_family = AF_INET;
  95.     m_cddr.sin_addr.s_addr = inet_addr("239.255.255.250");
  96.     m_cddr.sin_port = htons(1900);
  97.     setsockopt(m_ssdpc, SOL_SOCKET, SO_RCVTIMEO, (char *)&TimeOut, sizeof(TimeOut));
  98.     ip_mreq mreq;
  99.     bzero(&mreq,sizeof(mreq));
  100.     mreq.imr_multiaddr.s_addr =inet_addr("239.255.255.250");
  101.     mreq.imr_interface.s_addr =htonl(INADDR_ANY);
  102.     if( setsockopt(m_ssdpc, IPPROTO_IP,IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq)) <0 )
  103.     {
  104.         ERR("CSSDPServer::InitSocket failed of setsockopt IP_ADD_MEMBERSHIP");
  105.         return;
  106.     }
  107. }
  108.  
  109. void CSSDPServer::InitRecvSocket()
  110. {
  111.     RTM("CSSDPServer::InitRecvSocket");
  112.     struct timeval TimeOut;
  113.     TimeOut.tv_sec = 1;
  114.     TimeOut.tv_usec = 0;
  115.  
  116.     m_ssdps=socket(AF_INET,SOCK_DGRAM,0);
  117.     if( m_ssdps < 0)
  118.     {
  119.         ERR("CSSDPServer::InitSocket failed of create socket 239.255.255.250:1900");
  120.         return;
  121.     }
  122.  
  123.     bzero(&m_sddr, sizeof(m_sddr));
  124.     m_sddr.sin_family = AF_INET;
  125.     m_sddr.sin_addr.s_addr = INADDR_ANY;
  126.     m_sddr.sin_port = htons(1900);
  127.  
  128.     if( bind(m_ssdps, (struct sockaddr *)&m_sddr, sizeof(m_sddr)) < 0 )
  129.     {
  130.         ERR("CSSDPServer::InitSocket failed of bind socket 0.0.0.0:1900");
  131.         return ;
  132.     }
  133.     ip_mreq mreq;
  134.     bzero(&mreq,sizeof(mreq));
  135.     mreq.imr_multiaddr.s_addr =inet_addr("239.255.255.250");
  136.     mreq.imr_interface.s_addr =htonl(INADDR_ANY);
  137.     if( setsockopt(m_ssdps, IPPROTO_IP,IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq)) <0 )
  138.     {
  139.         ERR("CSSDPServer::InitSocket failed of setsockopt IP_ADD_MEMBERSHIP");
  140.         return;
  141.     }
  142.     RTM("CSSDPServer::InitRecvSocket success");
  143.  
  144. }
  145.  
  146. void CSSDPServer::Init( )
  147. {
  148.     CSSDPServer::Ins(  );
  149. }
  150.  
  151.  
  152. string CSSDPServer::MakeSSDHeader()
  153. {
  154.     string strMsg="NOTIFY * HTTP/1.1\n"
  155.             "HOST: 239.255.255.250:1900\n"
  156.             "CACHE-CONTROL: max-age=66\n"
  157.             "LOCATION:xml\n"
  158.             "OPT:ns=01\n"
  159.             "01-NLS:0\n"
  160.             "NT: urn:schemas-upnp-org:service:AVTransport:1\n"
  161.             "NTS: ssdp:alive\n"
  162.             "SERVER: Ubuntu/16.04\n"
  163.             "X-User-Agent: redsonic\n"
  164.             "USN:1\n";
  165.     return strMsg;
  166. }
  167.  
  168.  
  169. string CSSDPServer::MakeResponseSearchMsg()
  170. {
  171.  
  172.     string strMsg=MakeSSDHeader();
  173.  
  174.     char szMsg[MAXSSDPSIZE]={0};
  175.  
  176.         snprintf( szMsg,MAXSSDPSIZE,
  177.                   "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n"
  178.                   "<ProbeMatch>\n"
  179.                   "<mount>your msg</mount>\n"
  180.                   "<enable>your msg</enable>\n"
  181.                   "<platformip>%s</platformip>\n"
  182.                   "<Uuid>your msg</Uuid>\n"
  183.                   "<Types>inquiry</Types>\n"
  184.                   "<DeviceType>CDZSFACEBOX</DeviceType>\n"
  185.                   "<DeviceSN>your msg</DeviceSN>\n"
  186.                   "<DeviceName>your msg</DeviceName>\n"
  187.                   "<MAC>your msg</MAC>\n"
  188.                   "<IPv4Address>your msg</IPv4Address>\n"
  189.                   "<IPv4SubnetMask>your msg</IPv4SubnetMask>\n"
  190.                   "<IPv4Gateway>your msg</IPv4Gateway>\n"
  191.                   "<IPv6Address>::</IPv6Address>\n"
  192.                   "<IPv6Gateway>::</IPv6Gateway>\n"
  193.                   "<IPv6MaskLen>64</IPv6MaskLen>\n"
  194.                   "<DHCP>::</DHCP>\n"
  195.                   "<SoftwareVersion>your msg</SoftwareVersion>\n"
  196.                   "<BootTime>your msg</BootTime>\n"
  197.                   "<Diskrate>your msg</Diskrate >\n"
  198.                   "<Cpurate>your msg</Cpurate >\n"
  199.                   "<Memoryrate>%s</Memoryrate >\n"
  200.                   "</ProbeMatch>");
  201.  
  202.  
  203.     strMsg += szMsg;
  204.     return strMsg;
  205. }
  206.  
  207.  
  208. //发送ssdp:discover消息
  209. void CSSDPServer::SendMsg(const string&str)
  210. {
  211.     RTM("CSSDPServer::SendMsg msg=%s",str.c_str());
  212.  
  213.     socklen_t len = sizeof(m_cddr);
  214.     int nLen = sendto(m_ssdps,str.c_str(),str.length(),0,(sockaddr*)&m_cddr,len);
  215.     if( nLen >0 )
  216.     {
  217.         RTM("CSSDPServer::SendMsg success to send to %s msg len=%d",inet_ntoa(m_cddr.sin_addr),nLen);
  218.     }
  219.     else
  220.     {
  221.         RTM("CSSDPServer::SendMsg failed to send msg");
  222.     }
  223. }
  224.  
  225. void CSSDPServer::RecvMsg()
  226. {
  227.     socklen_t len = sizeof(m_sddr);
  228.     char szMsg[MAXSSDPSIZE]={0};
  229.     int num = recvfrom(m_ssdps,szMsg,MAXSSDPSIZE,0,(sockaddr*)&m_sddr,&len);
  230.     if( num >0 )
  231.     {
  232.         string str;
  233.         //ParseMsg(buf);
  234.     }
  235. }
  236.  
  237.  
  238.  
  239.  
  240.

测试代码：

  1. #include<SSDPClient.h>
  2.  
  3. int main(int argc, char *argv[])
  4. {
  5.     while( true )
  6.     {
  7.         CSSDPClient::Discover();
  8.         std::this_thread::sleep_for( std::chrono::seconds(10) );
  9.     }
  10.  
  11.     return 0;
  12. }
  13.  
  1. #include"SSDPServer.h"
  2. int main(int argc, char *argv[])
  3. {
  4.  
  5.     CSSDPServer::Init( );
  6.  
  7.  
  8.     std::this_thread::sleep_for( std::chrono::seconds(100000) );
  9.  
  10.     return 0;
  11. }
  12.

抓包：

发送方：ssdpclient 192.168.66.44 发送 search命令

接收方 ssdpserv (我在同一个电脑上测试 ip都是192.168.66.44)

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/盐析白兔/article/detail/475133
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号