onvif开发实战2--总结框架搭建

完成框架搭建后，编写自己的主函数起onvif服务

编写makefile

objs = onvif.o onvif_func.o duration.o soapC.o soapServer.o stdsoap2.o

onvif:$(objs)
    gcc -o onvif $(objs)

.PHONY:clean
clean:
    #-rm onvif
    rm *[!C.o].o

 

发现提示好多函数没有定义，在头文件soapStub.h中定义的，直接把没有定义的函数声明拷贝到一个onvif_func.c中

暂时用ue等工具实现一个空函数，

将；替换为^p{^p^treturn SOAP_OK；^p}

就可以实现素有函数的空实现，然后编译通过就可以了。。。

 

下面就是启动onvif服务端代码的具体实现了。。

 

组播setsockopt:no such device问题的解决方法

  

 

route add -net 224.0.0.0 netmask 224.0.0.0 eth0

 

然后

 

4、ProbeMatches代码

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

 

 

其中包括：

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

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

 

[cpp] view plaincopy

 

 

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

需要注意几点：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函数，添加如下内容

 

[cpp] view plaincopy

 

 

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

想要写出上述代码，是一定要了解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函数登场了

 

[cpp] view plaincopy

 

 

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

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

问题：哥编译出来的代码，各项都正确啊，就是搜索不到，test工具提示没有返回消息，麻蛋啊。。

自习查看上文才发现，哥的SOAP1.2的，onvif只支持1.1，换了果断可以搜索到。。妹的。。

时间： 2024-09-15 05:59:53

onvif开发实战2--总结框架搭建的相关文章

onvif开发实战1--总结框架搭建

Gsoap及开发框架生成: 一:gsoap下载和编译   1.下载Gsoap:地址:http://sourceforge.net/projects/gsoap2/files/gSOAP/ 2.安装:  ./configure --prefix=你的安装目录                  make                 make install 二:在线生成onvif.h(笔者试了离线生成,各种报错,所以劝各位还是在线生成) wsdl2h -o onvif.h -c -s -t ./

Android之使用Android-query框架开发实战（二）_Android

在上篇文章跟大家介绍了Android之使用Android-query框架开发实战(一),本文继续跟大家介绍有关Android-query框架.具体内容请看下文. 异步网络: 1. 添加权限:<uses-permission android:name="android.permission.INTERNET" />  2. 支持的类型  JSONObject JSONArray String (HTML, XML) XmlDom (XML parsing) XmlPullPa

Android之使用Android-query框架开发实战（一）_Android

开发Android使用Android-query框架能够快速的,比传统开发android所要编写的代码要少得很多,容易阅读等优势.  下载文档及其例子和包的地址:http://code.google.com/p/android-query/  以下内容是我学习的一些心得分享: 第一节: // 必须实现AQuery这个类 AQuery aq = new AQuery(view); // 按顺序分析:取得xml对应控件id,设置图片,设置可以显示,点击事件(方法someMethod必须是public

asp.net微信公众平台开发（二） 多层架构框架搭建和入口实现

上篇已经设计出比较完善的数据库了,这篇开始进入代码.  首先把上篇设计的数据库脚本在数据库中执行下,生成数据库,然后在VS中建立项目,为了方便理解和查看,我设计的都是很直白的类名和文件名,没有命名空间前缀. 采用接口方式,共8个项目:7个类库和一个MVC项目,  分别为: 显示层--MVC项目 业务逻辑层--访问接口IBLL.具体实现BLL 数据访问层--访问接口IDAL.具体实现DAL 数据(模型)--DataModel 通用方法--Common 仓储--Factory 这里的仓储并不为了生产

《Java和Android开发实战详解》——1.4节搭建Java开发环境

1.4 搭建Java开发环境 Java和Android开发实战详解 在开发Java应用程序前需要搭建Java的开发环境,首先需要安装JDK,然后即可配合编辑工具或集成开发环境来创建Java应用程序.本书主要介绍如何使用Eclipse集成开发环境来创建Java和Android应用程序. 1.4.1 安装与设置JDK 一般来说,有些集成开发环境会一并安装JDK,例如JBuilder,不过,大部分集成开发环境需要用户自行安装JDK.本书使用的JDK版本是JDK 7(Java SE Developmen

《Android 平板电脑开发实战详解和典型案例》——1.2节开发环境的搭建

1.2 开发环境的搭建 Android 平板电脑开发实战详解和典型案例 本节开始进入Android的开发,首先介绍开发环境的搭建.开发环境的搭建分为3个步骤:SDK的安装与环境变量配置.Eclipse集成开发环境的搭建.模拟器的创建与使用,下面对其一一进行讲解. 1.2.1 Android SDK的安装与环境变量配置 Android SDK的安装与环境变量配置包括如下几个步骤. (1) 在Oracle的官方网站上,下载相应的JDK软件(网址为:http://www.oracle.com/tech

[原创].NET 业务框架开发实战之十 第一阶段总结，深入浅出，水到渠成（前篇）

原文:[原创].NET 业务框架开发实战之十 第一阶段总结,深入浅出,水到渠成(前篇) .NET 业务框架开发实战之十 第一阶段总结,深入浅出,水到渠成(前篇) 前言:这个系列有段时间没有动了.主要是针对大家的反馈在修改代码.在修改的过程中,也有了一些新的体会,这里和大家分享一下,同时也发布一下业务框架的第一个版本.在本篇文章中,学习到的不是仅仅只是代码,而是设计的思想和实现这种思想的方法.在写本篇时有个感触:把一个东西彻底的讲清楚,不容易.希望大家 多提意见.而且在写本篇的时候,我个人也是很兴

[原创].NET 业务框架开发实战之六 DAL的重构

原文:[原创].NET 业务框架开发实战之六 DAL的重构 .NET 业务框架开发实战之六 DAL的重构 前言:其实这个系列还是之前的".NET 分布式架构开发实战 ",之所以改了名字,主要是因为文章的标题带来了不少的歧义:系列文章中本打算开发一个简化业务发的流程的Framework,然后用这个Framework再来实战,开发一个分布式的应用.改了名字.给大家带来了不便,敬请见谅.   本篇的议题如下:  1. 确定DAL的接口的定义.   系列文章链接:  [原创].NET 分布式架

[原创].NET 业务框架开发实战之八 业务层Mapping的选择策略

原文:[原创].NET 业务框架开发实战之八 业务层Mapping的选择策略 .NET 业务框架开发实战之八 业务层Mapping的选择策略 前言:在上一篇文章中提到了mapping,感觉很像在重新实现NHibernate.其实文章的本意是想反映出Richard在思考的时候的一些选择:利用现有的,还是最后自己用别的方式实现.如果一上来就说什么什么好,那太武断了,也很片面,系列文章反复的在强调一点:技术有它的适用场景,没有完美的技术.很多的朋友说本系列在近似的开发一个ORM,其实不是:ORM就是把