织梦CMS - 轻松建站从此开始!

罗索实验室

当前位置: 主页 > 流媒体开发 > 流媒体开发 >

onvif规范的实现:server端Discovery实现,通过OnvifTestTool12

落鹤生 发布于 2013-03-15 17:15 点击:次 
onvif规范的实现:server端Discovery实现,通过OnvifTestTool12.06测试:网上关于ONVIF开发的文章并不多,也更找不到具体的实例来入门学习。只能靠翻阅各种Specification摸索中前进,下面是最近几天的成果。调通了服务端(或者说设备端)的Discovery,使用OnvifTestTool1
TAG:

说明:网上关于ONVIF开发的文章并不多,也更找不到具体的实例来入 门学习。只能靠翻阅各种Specification摸索中前进,下面是最近几天的成果。调通了服务端(或者说设备端)的Discovery,使用 OnvifTestTool12.06能够搜到我的设备。【来自http://blog.csdn.net/ghostyu】

1、在使用wsdl2h产生头文件前需要修改typemap.dat,

修改的依据在这里:http://www.cs.fsu.edu/~engelen/soap.html,在FAQ页面下的How do I use gSOAP for the ONVIF specifications?

  1. #Use gSOAP 2.8.10 and up. In the typemap.dat file used by wsdl2h, add: 
  2. #   ONVIF recommended prefixes 
  3. tds = "http://www.onvif.org/ver10/device/wsdl" 
  4. tev = "http://www.onvif.org/ver10/events/wsdl" 
  5. tls = "http://www.onvif.org/ver10/display/wsdl" 
  6. tmd = "http://www.onvif.org/ver10/deviceIO/wsdl" 
  7. timg    = "http://www.onvif.org/ver20/imaging/wsdl" 
  8. trt = "http://www.onvif.org/ver10/media/wsdl" 
  9. tptz    = "http://www.onvif.org/ver20/ptz/wsdl" 
  10. trv = "http://www.onvif.org/ver10/receiver/wsdl" 
  11. trc = "http://www.onvif.org/ver10/recording/wsdl" 
  12. tse = "http://www.onvif.org/ver10/search/wsdl" 
  13. trp = "http://www.onvif.org/ver10/replay/wsdl" 
  14. tan = "http://www.onvif.org/ver20/analytics/wsdl" 
  15. tad = "http://www.onvif.org/ver10/analyticsdevice/wsdl" 
  16. tdn = "http://www.onvif.org/ver10/network/wsdl" 
  17. tt  = "http://www.onvif.org/ver10/schema" 
  18. #   OASIS recommended prefixes 
  19. wsnt    = "http://docs.oasis-open.org/wsn/b-2" 
  20. wsntw   = "http://docs.oasis-open.org/wsn/bw-2" 
  21. wsrfbf  = "http://docs.oasis-open.org/wsrf/bf-2" 
  22. wsrfr   = "http://docs.oasis-open.org/wsrf/r-2" 
  23. wsrfrw  = "http://docs.oasis-open.org/wsrf/rw-2" 
  24. wstop   = "http://docs.oasis-open.org/wsn/t-1" 
  25. #   WS-Discovery 1.0 remapping 
  26. wsdd10__HelloType       = | wsdd__HelloType 
  27. wsdd10__ByeType         = | wsdd__ByeType 
  28. wsdd10__ProbeType       = | wsdd__ProbeType 
  29. wsdd10__ProbeMatchesType    = | wsdd__ProbeMatchesType 
  30. wsdd10__ProbeMatchType      = | wsdd__ProbeMatchType 
  31. wsdd10__ResolveType     = | wsdd__ResolveType 
  32. wsdd10__ResolveMatchesType  = | wsdd__ResolveMatchesType 
  33. wsdd10__ResolveMatchType    = | wsdd__ResolveMatchType 
  34. #   SOAP-ENV mapping 
  35. SOAP_ENV__Envelope  = struct SOAP_ENV__Envelope {
  36.  struct SOAP_ENV__Header *SOAP_ENV__Header; _XML SOAP_ENV__Body; };
  37.  | struct SOAP_ENV__Envelope 
  38. SOAP_ENV__Header    = | struct SOAP_ENV__Header 
  39. SOAP_ENV__Fault     = | struct SOAP_ENV__Fault 
  40. SOAP_ENV__Detail    = | struct SOAP_ENV__Detail 
  41. SOAP_ENV__Code      = | struct SOAP_ENV__Code 
  42. SOAP_ENV__Subcode   = | struct SOAP_ENV__Subcode 
  43. SOAP_ENV__Reason    = | struct SOAP_ENV__Reason 

2、根据onvif官网提供的remotediscovery.wsdl产生onvif.h头文件

关于onvif所有的wsdl都在这里:http://www.onvif.org/Documents/Specifications.aspx中的 ONVIF WSDL and XML Schemas Specifications一节,虽然可以全部下载为wsdl文件,但是wsdl文件中存在相互依赖的关系,并且是带有存储的依赖,所以最好直接使用 url来产生头文件,不要下载下来。

  1. wsdl2h -o onvif.h -c -s -t ./typemap.dat
  2.  http://www.onvif.org/onvif/ver10/network/wsdl/remotediscovery.wsdl 

3、使用onvif.h来产生骨架代码

  1. soapcpp2 -c onvif.h -x -I /root/onvif/gsoap-2.8/gsoap/import -I /root/onvif/gsoap-2.8/gsoap/ 

4、ProbeMatches代码

这样就创建了基本的服务端和客户端的代码了,下面需要添加具体的代码了。

其中包括:

(1)创建组播用的udp socket,绑定组播地址为239.255.255.250,端口为3702,因为ws-discovery的组播地址和端口就是为239.255.255.250和3702

(2)在产生的Probe函数中添加ProbeMatches代码
首先是udp socket

  1. int bind_server_udp1(int server_s) 
  2.     struct sockaddr_in local_addr; 
  3.     memset(&local_addr,0,sizeof(local_addr)); 
  4.     local_addr.sin_family = AF_INET; 
  5.     local_addr.sin_addr.s_addr = htonl(INADDR_ANY); 
  6.     local_addr.sin_port = htons(3702); 
  7.     return bind(server_s,(struct sockaddr*)&local_addr,sizeof(local_addr)); 
  8.  
  9. static int create_server_socket_udp(void
  10.     int server_udp; 
  11.     unsigned char one = 1; 
  12.     int sock_opt = 1; 
  13.      
  14.     //server_udp = socket(PF_INET, SOCK_DGRAM, 0); 
  15.     server_udp = socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP); 
  16.     if (server_udp == -1) { 
  17.         printf("unable to create socket\n"); 
  18.     } 
  19.  
  20.     /* reuse socket addr */ 
  21.     if ((setsockopt(server_udp, SOL_SOCKET, SO_REUSEADDR, (void *) &sock_opt, 
  22.                     sizeof (sock_opt))) == -1) { 
  23.         printf("setsockopt\n"); 
  24.     } 
  25.     if ((setsockopt(server_udp, IPPROTO_IP, IP_MULTICAST_LOOP, 
  26.                        &one, sizeof (unsigned char))) == -1) { 
  27.         printf("setsockopt\n"); 
  28.     } 
  29.  
  30.     struct ip_mreq mreq; 
  31.     mreq.imr_multiaddr.s_addr = inet_addr("239.255.255.250"); 
  32.     mreq.imr_interface.s_addr = htonl(INADDR_ANY); 
  33.  
  34.     if(setsockopt(server_udp,IPPROTO_IP,IP_ADD_MEMBERSHIP,&mreq,sizeof(mreq))==-1){ 
  35.         perror("memberchip error\n"); 
  36.     } 
  37.  
  38.     return server_udp; 

需要注意几点:1/设置socket属性SO_REUSEADDR,2、设置socket属性IP_ADD_MEMBERSHIP,目的是让3702的端口能够重复绑定,一家加入组播组。

其次是添加ProbeMatches代码
(1)首先复制client的soap_send___wsdd__ProbeMatches函数到服务端来,因为soap_send___wsdd__ProbeMatches已经写好了用于响应Probe消息的框架了,不用白不用啊。
(2)编写__wsdd__Probe函数,添加如下内容

  1. int  __wsdd__Probe(struct soap* soap, struct wsdd__ProbeType *wsdd__Probe) 
  2.     DBG("__wsdd__Probe\n"); 
  3.     char macaddr[6]; 
  4.     char _IPAddr[INFO_LENGTH]; 
  5.     char _HwId[1024]; 
  6.      
  7.     wsdd__ProbeMatchesType ProbeMatches; 
  8.     ProbeMatches.ProbeMatch
  9.  = (struct wsdd__ProbeMatchType *)soap_malloc(soap, sizeof(struct wsdd__ProbeMatchType)); 
  10.     ProbeMatches.ProbeMatch->XAddrs
  11.  = (char *)soap_malloc(soap, sizeof(char) * INFO_LENGTH); 
  12.     ProbeMatches.ProbeMatch->Types
  13.  = (char *)soap_malloc(soap, sizeof(char) * INFO_LENGTH); 
  14.     ProbeMatches.ProbeMatch->Scopes
  15.  = (struct wsdd__ScopesType*)soap_malloc(soap,sizeof(struct wsdd__ScopesType)); 
  16.     ProbeMatches.ProbeMatch->wsa__EndpointReference.ReferenceProperties
  17.  = (struct wsa__ReferencePropertiesType*)soap_malloc(soap
  18. ,sizeof(struct wsa__ReferencePropertiesType)); 
  19.     ProbeMatches.ProbeMatch->wsa__EndpointReference.ReferenceParameters
  20.  = (struct wsa__ReferenceParametersType*)soap_malloc(soap
  21. ,sizeof(struct wsa__ReferenceParametersType)); 
  22.     ProbeMatches.ProbeMatch->wsa__EndpointReference.ServiceName
  23.  = (struct wsa__ServiceNameType*)soap_malloc(soap,sizeof(struct wsa__ServiceNameType)); 
  24.     ProbeMatches.ProbeMatch->wsa__EndpointReference.PortType
  25.  = (char **)soap_malloc(soap, sizeof(char *) * SMALL_INFO_LENGTH); 
  26.     ProbeMatches.ProbeMatch->wsa__EndpointReference.__any
  27.  = (char **)soap_malloc(soap, sizeof(char*) * SMALL_INFO_LENGTH); 
  28.     ProbeMatches.ProbeMatch->wsa__EndpointReference.__anyAttribute
  29.  = (char *)soap_malloc(soap, sizeof(char) * SMALL_INFO_LENGTH); 
  30.     ProbeMatches.ProbeMatch->wsa__EndpointReference.Address
  31.  = (char *)soap_malloc(soap, sizeof(char) * INFO_LENGTH); 
  32.  
  33.     macaddr[0]=0x01;macaddr[1]=0x01;macaddr[2]=0x01;
  34. macaddr[3]=0x01;macaddr[4]=0x01;macaddr[5]=0x01; 
  35.     sprintf(_HwId,"urn:uuid:2419d68a-2dd2-21b2-a205-%02X%02X%02X%02X%02X%02X",macaddr[0]
  36. , macaddr[1], macaddr[2], macaddr[3], macaddr[4], macaddr[5]); 
  37.  
  38.     sprintf(_IPAddr, "http://%03d.%03d.%1d.%03d/onvif/device_service", 192, 168, 1, 233); 
  39.     ProbeMatches.__sizeProbeMatch = 1; 
  40.     ProbeMatches.ProbeMatch->Scopes->__item =(char *)soap_malloc(soap, 1024); 
  41.     memset(ProbeMatches.ProbeMatch->Scopes->__item,0
  42. ,sizeof(ProbeMatches.ProbeMatch->Scopes->__item));   
  43.  
  44.     //Scopes MUST BE 
  45.     strcat(ProbeMatches.ProbeMatch->Scopes->__item
  46. "onvif://www.onvif.org/type/NetworkVideoTransmitter"); 
  47.  
  48.     ProbeMatches.ProbeMatch->Scopes->MatchBy = NULL; 
  49.     strcpy(ProbeMatches.ProbeMatch->XAddrs, _IPAddr); 
  50.     strcpy(ProbeMatches.ProbeMatch->Types, wsdd__Probe->Types); 
  51.     DBG("wsdd__Probe->Types=%s\n",wsdd__Probe->Types); 
  52.     ProbeMatches.ProbeMatch->MetadataVersion = 1; 
  53.     //ws-discovery规定 为可选项 
  54.     ProbeMatches.ProbeMatch->wsa__EndpointReference.ReferenceProperties->__size = 0; 
  55.     ProbeMatches.ProbeMatch->wsa__EndpointReference.ReferenceProperties->__any = NULL; 
  56.     ProbeMatches.ProbeMatch->wsa__EndpointReference.ReferenceParameters->__size = 0; 
  57.     ProbeMatches.ProbeMatch->wsa__EndpointReference.ReferenceParameters->__any = NULL; 
  58.      
  59.     ProbeMatches.ProbeMatch->wsa__EndpointReference.PortType[0]
  60.  = (char *)soap_malloc(soap, sizeof(char) * SMALL_INFO_LENGTH); 
  61.     //ws-discovery规定 为可选项 
  62.     strcpy(ProbeMatches.ProbeMatch->wsa__EndpointReference.PortType[0], "ttl"); 
  63.     ProbeMatches.ProbeMatch->wsa__EndpointReference.ServiceName->__item = NULL; 
  64.     ProbeMatches.ProbeMatch->wsa__EndpointReference.ServiceName->PortName = NULL; 
  65.     ProbeMatches.ProbeMatch->wsa__EndpointReference.ServiceName->__anyAttribute = NULL; 
  66.     ProbeMatches.ProbeMatch->wsa__EndpointReference.__any[0]
  67.  = (char *)soap_malloc(soap, sizeof(char) * SMALL_INFO_LENGTH); 
  68.     strcpy(ProbeMatches.ProbeMatch->wsa__EndpointReference.__any[0], "Any"); 
  69.     strcpy(ProbeMatches.ProbeMatch->wsa__EndpointReference.__anyAttribute, "Attribute"); 
  70.     ProbeMatches.ProbeMatch->wsa__EndpointReference.__size = 0; 
  71.     strcpy(ProbeMatches.ProbeMatch->wsa__EndpointReference.Address, _HwId); 
  72.  
  73.     /*注释的部分为可选,注释掉onvif test也能发现ws-d*/ 
  74. //soap->header->wsa__To = "http://schemas.xmlsoap.org/ws/2004/08/addressing/role/anonymous"; 
  75. //soap->header->wsa__Action = "http://schemas.xmlsoap.org/ws/2005/04/discovery/ProbeMatches"; 
  76.     soap->header->wsa__RelatesTo
  77.  = (struct wsa__Relationship*)soap_malloc(soap, sizeof(struct wsa__Relationship)); 
  78.     //it's here 
  79.     soap->header->wsa__RelatesTo->__item = soap->header->wsa__MessageID; 
  80.     soap->header->wsa__RelatesTo->RelationshipType = NULL; 
  81.     soap->header->wsa__RelatesTo->__anyAttribute = NULL; 
  82.  
  83.     soap->header->wsa__MessageID =(char *)soap_malloc(soap, sizeof(char) * INFO_LENGTH); 
  84.     strcpy(soap->header->wsa__MessageID,_HwId+4); 
  85.  
  86.     /* send over current socket as HTTP OK response: */ 
  87.     /*测试过,第二参数必须http,action随意*/ 
  88.     soap_send___wsdd__ProbeMatches(soap, "http://", NULL, &ProbeMatches); 
  89.     return SOAP_OK; 
  90.  

想要写出上述代码,是一定要了解SOAP格式的,在WS-Discovery中描述了discovery所用的soap格式

1首先是了解消息头header和ProbeMatches中的内容,非常重要,可以参考这里http://www.w3.org/Submission/ws-addressing/  最好详细的学习一下,里面的内容非常重要。

2其次需要理解的是,其实当你看完ws-addressing后你会发现,骨架代码中的结构体和SOAP消息中的内容是一一对应的,例如:

结构体osap->header对应SOAP消息的<SOAP-ENV:Header></SOAP-ENV:Header>中的内容,包含在header里的内容当然会包含在SOAP的header内。例如:

结构体soap->header->wsa__RelatesTo对应的是<wsa:RelatesTo></wsa:RelatesTo>。

3最后需要理解的是,在代码中的"__"双下划线一般对应xml中的命名空间的":",下划线前是命名空间,后是具体内容。

4最后的最后是要详细的阅读ONVIF Core Specification

下图为响应OnvifTestTool的Probe命令的SOAP消息

结合上图再分析代码就亲切多了。在ONVIF Core Specification的7.3.2.2  Scopes 一节描述了onvif需要的Scopes,这个是需要在程序里填充,具体填充什么,文档里说的很明确:

注意点是在太多,随便漏掉一个都可能会导致搜不到设备,下图是非常重要的一个:

SOAP1.1和SOAP1.2所使用的SOAP-ENV是不同的,ONVIF使用的是SOAP1.1,如果soapcpp2产生的nsmap文件中的SOAP-ENV是SOAP1.2版本的话,那么OnvifTestTool是不会识别设备发出的SOAP消息的。

5、该main函数登场了

  1. int main() 
  2.     int server_udp; 
  3.      
  4.     int retval=0; 
  5.     struct soap *soap_udp; 
  6.     int fault_flag = 0; 
  7.      
  8.     server_udp = create_server_socket_udp(); 
  9.     bind_server_udp1(server_udp); 
  10.     while(1){ 
  11.         soap_udp=soap_new(); 
  12.         soap_init1(soap_udp, SOAP_IO_UDP); 
  13.         soap_udp->master = server_udp; 
  14.         soap_udp->socket = server_udp; 
  15.         soap_udp->errmode = 0; 
  16.         soap_udp->bind_flags = 1; 
  17.         if (!soap_valid_socket(soap_bind(soap_udp, NULL, 3702, 100))) 
  18.         {     
  19.             soap_print_fault(soap_udp, stderr); 
  20.         } 
  21.         fprintf(stderr,"soap_serve starting..\n"); 
  22.         retval = soap_serve(soap_udp); //阻塞在这里 
  23.         fprintf(stderr,"retval=%d\n",retval); 
  24.         if(retval && !(fault_flag)) 
  25.         { 
  26.             fault_flag = 1; 
  27.         } 
  28.         else if(!retval) 
  29.         { 
  30.             fault_flag = 0; 
  31.         } 
  32.         soap_destroy(soap_udp); 
  33.         soap_end(soap_udp); 
  34.         soap_done(soap_udp); 
  35.         free(soap_udp); 
  36.     } 

soap_server函数会一直阻塞,直到接收到SOAP消息,并且该处理是一次性的,所以要将将soap_server放到while里或者独立的线程中。
最后编译运行

make server

./discovery.tmp

单击OnvifTestTool的Discover Devices,运行discovery.tmp的中会打印调试信息,如图

然后,在OnvifTestTool中会搜索到我的设备

响应Discover Devices的SOAP消息如下:

  1. <?xml version="1.0" encoding="UTF-8"?> 
  2. <SOAP-ENV:Envelope  
  3.     xmlns:SOAP-ENV="http://www.w3.org/2003/05/soap-envelope"  
  4.     xmlns:SOAP-ENC="http://www.w3.org/2003/05/soap-encoding"  
  5.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  6.     xmlns:xsd="http://www.w3.org/2001/XMLSchema"  
  7.     xmlns:wsa="http://schemas.xmlsoap.org/ws/2004/08/addressing"  
  8.     xmlns:wsdd="http://schemas.xmlsoap.org/ws/2005/04/discovery"  
  9.     xmlns:ns1="http://www.onvif.org/ver10/network/wsdl/RemoteDiscoveryBinding"  
  10.     xmlns:ns2="http://www.onvif.org/ver10/network/wsdl/DiscoveryLookupBinding"  
  11.     xmlns:ns3="http://www.onvif.org/ver10/network/wsdl/DiscoveryLookupBinding"  
  12.     xmlns:tdn="http://www.onvif.org/ver10/network/wsdl"> 
  13.  
  14.     <SOAP-ENV:Header> 
  15.         <wsa:MessageID>uuid:2419d68a-2dd2-21b2-a205-010101010101</wsa:MessageID> 
  16.         <wsa:RelatesTo>uuid:88a3958a-6155-4510-8279-69aeafd31681</wsa:RelatesTo> 
  17.         <wsa:To SOAP-ENV:mustUnderstand="true">
  18. urn:schemas-xmlsoap-org:ws:2005:04:discovery</wsa:To> 
  19.         <wsa:Action SOAP-ENV:mustUnderstand="true">
  20. http://schemas.xmlsoap.org/ws/2005/04/discovery/Probe</wsa:Action> 
  21.     </SOAP-ENV:Header> 
  22.  
  23.     <SOAP-ENV:Body> 
  24.         <wsdd:ProbeMatches> 
  25.             <wsdd:ProbeMatch xmlns:_0="http://www.onvif.org/ver10/device/wsdl"> 
  26.                 <wsa:EndpointReference> 
  27.                 <wsa:Address>urn:uuid:2419d68a-2dd2-21b2-a205-010101010101</wsa:Address> 
  28.                 <wsa:ReferenceProperties></wsa:ReferenceProperties> 
  29.                 <wsa:ReferenceParameters></wsa:ReferenceParameters> 
  30.                 <wsa:PortType>ttl</wsa:PortType> 
  31.                 </wsa:EndpointReference> 
  32.                 <wsdd:Types>_0:Device</wsdd:Types> 
  33.                 <wsdd:Scopes>onvif://www.onvif.org/type/NetworkVideoTransmitter</wsdd:Scopes> 
  34.                 <wsdd:XAddrs>http://192.168.1.233/onvif/device_service</wsdd:XAddrs> 
  35.                 <wsdd:MetadataVersion>1</wsdd:MetadataVersion> 
  36.             </wsdd:ProbeMatch> 
  37.         </wsdd:ProbeMatches> 
  38.     </SOAP-ENV:Body> 
  39. </SOAP-ENV:Envelope> 

资料下载

上述完整的代码包在这里,有需要的就去下载吧:http://bbs.rg4.net/thread-14975-1-1.html

另外我参考的部分文档可以再这里下载

ONVIF-Core-Spec-v210.pdf:http://download.csdn.net/detail/ghostyu/4766067

ONVIF-Streaming-Spec-v211.pdf: http://bbs.rg4.net/thread-13670-1-1.html(ONVIF 规范 2.1.1: Data Format Specification)

gSOAP手册:http://download.csdn.net/detail/ghostyu/4766075

OnvifTestTool12.06测试工具网上有的,我就不上传了。

(ghostyu)
本站文章除注明转载外,均为本站原创或编译欢迎任何形式的转载,但请务必注明出处,尊重他人劳动,同学习共成长。转载请注明:文章转载自:罗索实验室 [http://www1.rosoo.net/a/201303/16545.html]
本文出处:CSDN博客 作者:ghostyu 原文
顶一下
(3)
100%
踩一下
(0)
0%
------分隔线----------------------------
发表评论
请自觉遵守互联网相关的政策法规,严禁发布色情、暴力、反动的言论。
评价:
表情:
用户名: 验证码:点击我更换图片
栏目列表
将本文分享到微信
织梦二维码生成器
推荐内容