ONVIF协议实现2:码流地址的获取并在ONVIF Device Manager测试成功

goodman

工作平台及工具:
    Ubuntu：12.04 + gcc + OnvifTestTool12.12
    gsoap下载:http://www.cs.fsu.edu/~engelen/soap.html
    PC:live555.exe + test.264
    目前的最新版本为：gsoap2.8.21
通过设备发现的实现，对ONVIF有了很多的了解，也对其开发步骤有了很好地认识，现在实现码流的获取也不难按如下步骤即可：

1.相关概念和前置知识
Profile:参见http://www.onvif.org/Portals/0/d ... ile_Policy_v2-0.pdf
1.1、GetCapabilities   #获取设备能力表
1.2、GetProfiles  # 获取设备的Profile
1.3、GetStreamUri   #填充rtsp路径如：rtsp://192.168.1.101/test.264
1.4、RTSP服务器       #因为我们的设备端不是摄像机所以要借助live555来模拟
1.5、GetVideoSourceConfiguration   #获取视频源配置信息
1.6、GetVideoEncoderConfigurationOptions  #获取编码配置选项
下面我们的框架和具体实现围绕这几个函数开实现。

2.生成框架代码
执行如下代码(我的工程里面有个gen.sh也可以生成代码):
./wsdl2h -o onvif.h -c -s -t ./typemap.dat http://www.onvif.org/onvif/ver10/device/wsdl/devicemgmt.wsdl http://www.onvif.org/onvif/ver10/media/wsdl/media.wsdl
./soapcpp2 -c onvif.h -x -d ./ -I ${HOME}/workspace/source/gsoap-2.8/gsoap/import -I ${HOME}/workspace/source/gsoap-2.8/gsoap/
这里我们最小化实现，只包含这个2个其他的都排除在外，这样生成的代码才最小，将生成的代码从tools目录移动到src目录里面(目录结构请下载对用的工程文件)

我们看到完整的工程包含这么多的WSDL如果全部实现，光是定义相应的函数就够你受得了。

3.启动一个gsoap服务
main函数里面启动了一个soap_server,这里使用8080端口sevice的的端口可以改成你自己的

1. 
   
2. int gsoapInit(struct OnvifApp* app)
   
3. {
   
4.     if (!app->bindPort)
   
5.          app->bindPort = 8080;
   
6.      strcpy(app->hostAddress, "192.168.1.104");
   
7.     snprintf(app->xAddr, sizeof(app->xAddr), "http://%s:%d/onvif/device_service",
   
8.      app->hostAddress, app->bindPort);
   
9.     fprintf(stderr, "xAddr:%s\n", app->xAddr);
   
10.     snprintf(app->xAddrRoot, sizeof(app->xAddrRoot), "http://%s:%d/onvif",
    
11.     app->hostAddress, app->bindPort);
    
12. 
    
13.     soap_init2(&app->soap, SOAP_ENC_MTOM | SOAP_ENC_MIME, 0 );
    
14.     soap_set_namespaces(&app->soap, namespaces);
    
15.     soap_set_recv_logfile(&app->soap, "./log/recv.xml");
    
16.     soap_set_sent_logfile(&app->soap, "./log/send.xml");
    
17.     soap_set_test_logfile(&app->soap, "./log/test.log");
    
18.     app->soap.bind_flags        = SO_REUSEADDR;
    
19.     app->soap.accept_timeout    = 10;
    
20.     app->soap.recv_timeout      = 10;
    
21.     app->soap.send_timeout      = 10;
    
22.     app->soap.max_keep_alive    = 30;
    
23.     app->masterSocket = soap_bind(&app->soap, "0.0.0.0", app->bindPort, 100);
    
24.     if (app->masterSocket < 0) {
    
25.         soap_print_fault(&app->soap, stderr);
    
26.         return -1;
    
27.     }
    
28.     return 0;
    
29. }
    
30. 
    
31. int main(int argc, char* argv[])
    
32. {
    
33. gApp = (struct OnvifApp*)calloc(1, sizeof(*gApp));
    
34. if(!gApp) {
    
35.   fprintf(stderr, "calloc wsapp failed\n");
    
36.   return -1;
    
37. }
    
38. for(;;) {
    
39.   if(gsoapInit(gApp)!=0)  //具体的函数定义请参考工程文件
    
40.    break;
    
41.   if (WsAppRun(gApp, 1) < 0)
    
42.    break;
    
43.   getchar();
    
44.   gsoapFini(gApp);
    
45.   free(gApp);
    
46.   return 0;
    
47. }
    
48. free(gApp);
    
49. return -1;
    
50. }
    

复制代码

4.整理需要实现的函数
上面的框架代码实现好后，一编译就会报一大推的链接错误，我们需要将这些函数实现，我们按命名空间来讲这些函数分类到2个单独的文件离去，分别为
tds_ssom.c 和 trt_ssom.c具体的内容就不贴了比较多，可以参看我工程里的代码。然后再Makefile里面把这2个文件添加上，就能找到这些引用了，这样
做的好处是，每次需要添加第三个WSDL的时候可以保证前面整理的函数都是可用的，这样可以避免很多重复的劳动。

5.实现关键代码
5.1 __tds__GetCapabilities函数

1. 
   
2. SOAP_FMAC5 int SOAP_FMAC6 __tds__GetCapabilities(struct soap* soap, struct _tds__GetCapabilities *tds__GetCapabilities, struct _tds__GetCapabilitiesResponse *tds__GetCapabilitiesResponse)
   
3. {
   
4. printf("%s:%d\n",__FUNCTION__,__LINE__);
   
5.     enum tt__CapabilityCategory CapabilityCategory;
   
6.     if (!tds__GetCapabilities->Category) {
   
7.         CapabilityCategory = tt__CapabilityCategory__All;
   
8.     } else {
   
9.         CapabilityCategory =  *(tds__GetCapabilities->Category);
   
10.     }
    
11.     if (CapabilityCategory != tt__CapabilityCategory__All &&
    
12.         CapabilityCategory != tt__CapabilityCategory__Analytics &&
    
13.         CapabilityCategory != tt__CapabilityCategory__Device &&
    
14.         CapabilityCategory != tt__CapabilityCategory__Events &&
    
15.         CapabilityCategory != tt__CapabilityCategory__Imaging &&
    
16.         CapabilityCategory != tt__CapabilityCategory__Media &&
    
17.         CapabilityCategory != tt__CapabilityCategory__PTZ) {
    
18.         fprintf(stderr, "The requested WSDL service category is not supported by the NVT");
    
19.         //return soap_sender_fault_subcode(soap, "env:Receiver/ter:ActionNotSupported/ter:NoSuchService", "The requested WSDL service category is not supported by the NVT", NULL); ;
    
20.         return SOAP_FAULT;
    
21.     }
    
22.     static struct tt__Capabilities tCapabilities;
    
23.     soap_default_tt__Capabilities(soap, &tCapabilities);
    
24.     tds__GetCapabilitiesResponse->Capabilities = &tCapabilities;
    
25.     /* tt:AnalyticsCapabilities */
    
26.     if ((CapabilityCategory == tt__CapabilityCategory__All) || (CapabilityCategory == tt__CapabilityCategory__Analytics)) {
    
27.         static struct tt__AnalyticsCapabilities tAnalytics;
    
28.         soap_default_tt__AnalyticsCapabilities(soap, &tAnalytics);
    
29.         tCapabilities.Analytics = &tAnalytics;
    
30.         static char Analytics_Addr[256];
    
31.         sprintf(Analytics_Addr, "%sanalytics", gApp->xAddrRoot);
    
32.         tAnalytics.XAddr = Analytics_Addr;
    
33.         tAnalytics.RuleSupport = xsd__boolean__false_;
    
34.         tAnalytics.AnalyticsModuleSupport = xsd__boolean__false_;
    
35.     }
    
36.     /* tt:DeviceCapabilities */
    
37.     if ((CapabilityCategory == tt__CapabilityCategory__All) || (CapabilityCategory == tt__CapabilityCategory__Device)) {
    
38.         static struct tt__DeviceCapabilities tDevice;
    
39.         soap_default_tt__DeviceCapabilities(soap, &tDevice);
    
40.         tCapabilities.Device = &tDevice;
    
41.         static char Device_Addr[64];
    
42.         sprintf(Device_Addr, "%sdevice_service", gApp->xAddrRoot);
    
43.         tDevice.XAddr = Device_Addr;
    
44.         /* tt:NetworkCapabilities */
    
45.         static struct tt__NetworkCapabilities tNetwork;
    
46.         soap_default_tt__NetworkCapabilities(soap, &tNetwork);
    
47.         tDevice.Network = &tNetwork;
    
48.         static enum xsd__boolean  enIPFilter         = xsd__boolean__true_;
    
49.         static enum xsd__boolean  enZeroConfiguration = xsd__boolean__false_;
    
50.         static enum xsd__boolean  enIPVersion6       = xsd__boolean__false_;
    
51.         static enum xsd__boolean  enDynDNS           = xsd__boolean__true_;
    
52.         tNetwork.IPFilter                 = &enIPFilter;
    
53.         tNetwork.ZeroConfiguration        = &enZeroConfiguration;
    
54.         tNetwork.IPVersion6               = &enIPVersion6;
    
55.         tNetwork.DynDNS                   = &enDynDNS;
    
56.         static struct tt__NetworkCapabilitiesExtension tNetworkCapabilitiesExtension;
    
57.         soap_default_tt__NetworkCapabilitiesExtension(soap, &tNetworkCapabilitiesExtension);
    
58.         tNetwork.Extension = &tNetworkCapabilitiesExtension;
    
59.         static enum xsd__boolean enDot11Configuration;
    
60.         tNetworkCapabilitiesExtension.Dot11Configuration = &enDot11Configuration;
    
61.         /* tt:SystemCapabilities */
    
62.         static struct tt__SystemCapabilities tSystemCapabilities;
    
63.         soap_default_tt__SystemCapabilities(soap, &tSystemCapabilities);
    
64.         tDevice.System = &tSystemCapabilities;
    
65.         tSystemCapabilities.DiscoveryResolve = xsd__boolean__false_;
    
66.         tSystemCapabilities.DiscoveryBye = xsd__boolean__true_;
    
67.         tSystemCapabilities.RemoteDiscovery = xsd__boolean__true_;
    
68.         tSystemCapabilities.SystemBackup = xsd__boolean__false_;
    
69.         tSystemCapabilities.SystemLogging = xsd__boolean__false_;
    
70.         tSystemCapabilities.FirmwareUpgrade = xsd__boolean__true_;
    
71.         tSystemCapabilities.__sizeSupportedVersions = 3;
    
72.         static struct tt__OnvifVersion tSupportedVersions[3];
    
73.         tSupportedVersions[0].Major                    = 2;
    
74.         tSupportedVersions[0].Minor                    = 2;
    
75.         tSupportedVersions[1].Major                    = 2;
    
76.         tSupportedVersions[1].Minor                    = 1;
    
77.         tSupportedVersions[2].Major                    = 2;
    
78.         tSupportedVersions[2].Minor                    = 0;
    
79.         tSystemCapabilities.SupportedVersions = tSupportedVersions;
    
80.         static struct tt__SystemCapabilitiesExtension tSystemCapabilitiesExtension;
    
81.         soap_default_tt__SystemCapabilitiesExtension(soap, &tSystemCapabilitiesExtension);
    
82.         tSystemCapabilities.Extension = &tSystemCapabilitiesExtension;
    
83.         static enum xsd__boolean enHttpFirmwareUpgrade = xsd__boolean__true_;
    
84.         static enum xsd__boolean enHttpSystemBackup = xsd__boolean__false_;
    
85.         static enum xsd__boolean enHttpSystemLogging = xsd__boolean__false_;
    
86.         static enum xsd__boolean enHttpSupportInformation = xsd__boolean__false_;
    
87.         tSystemCapabilitiesExtension.HttpFirmwareUpgrade = &enHttpFirmwareUpgrade;
    
88.         tSystemCapabilitiesExtension.HttpSystemBackup = &enHttpSystemBackup;
    
89.         tSystemCapabilitiesExtension.HttpSystemLogging = &enHttpSystemLogging;
    
90.         tSystemCapabilitiesExtension.HttpSupportInformation = &enHttpSupportInformation;
    
91.         /* tt:IOCapabilities */
    
92.         static struct tt__IOCapabilities tIO;
    
93.         soap_default_tt__IOCapabilities(soap, &tIO);
    
94.         tDevice.IO = &tIO;
    
95.         static int iInputConnectors = 1;
    
96.         tIO.InputConnectors = &iInputConnectors;
    
97.         static int iRelayOutputs = 1;
    
98.         tIO.RelayOutputs = &iRelayOutputs;
    
99.         static struct tt__IOCapabilitiesExtension tIOCapabilitiesExtension;
    
100.         soap_default_tt__IOCapabilitiesExtension(soap, &tIOCapabilitiesExtension);
     
101.         tIO.Extension = &tIOCapabilitiesExtension;
     
102.         static enum xsd__boolean enAuxiliary = xsd__boolean__false_;
     
103.         tIOCapabilitiesExtension.Auxiliary = &enAuxiliary;
     
104.         tIOCapabilitiesExtension.__sizeAuxiliaryCommands = 1;
     
105.         static char chAuxiliaryCommands[] = "nothing";
     
106.         static char* p = chAuxiliaryCommands;
     
107.         tIOCapabilitiesExtension.AuxiliaryCommands = &p;//&chAuxiliaryCommands;
     
108.         static struct tt__IOCapabilitiesExtension2 tIOCapabilitiesExtension2;
     
109.         soap_default_tt__IOCapabilitiesExtension2(soap, &tIOCapabilitiesExtension2);
     
110.         tIOCapabilitiesExtension.Extension = &tIOCapabilitiesExtension2;
     
111.   tDevice.Security = NULL;
     
112. }
     
113.   tCapabilities.Events = NULL;
     
114. /* tt:ImagingCapabilities */
     
115.    tCapabilities.Imaging = NULL;
     
116.     if ((CapabilityCategory == tt__CapabilityCategory__All) || (CapabilityCategory == tt__CapabilityCategory__Media)) {
     
117.         static struct  tt__MediaCapabilities tMedia;
     
118.         soap_default_tt__MediaCapabilities(soap, &tMedia);
     
119.         tCapabilities.Media = &tMedia;
     
120.         static char Media_Addr[64];
     
121.         sprintf(Media_Addr, "%sMedia", gApp->xAddrRoot);
     
122.         tMedia.XAddr = Media_Addr;
     
123.         static struct tt__RealTimeStreamingCapabilities tRealTimeStreamingCapabilities;
     
124.         soap_default_tt__RealTimeStreamingCapabilities(soap, &tRealTimeStreamingCapabilities);
     
125.         tMedia.StreamingCapabilities = &tRealTimeStreamingCapabilities;
     
126.         static enum xsd__boolean  enRTPMulticast         = xsd__boolean__false_;
     
127.         static enum xsd__boolean  enRTP_USCORETCP = xsd__boolean__true_;
     
128.         static enum xsd__boolean  enRTP_USCORERTSP_USCORETCP       = xsd__boolean__true_;
     
129.         tRealTimeStreamingCapabilities.RTPMulticast = &enRTPMulticast;
     
130.         tRealTimeStreamingCapabilities.RTP_USCORETCP = &enRTP_USCORETCP;
     
131.         tRealTimeStreamingCapabilities.RTP_USCORERTSP_USCORETCP = &enRTP_USCORERTSP_USCORETCP;
     
132.         static struct tt__MediaCapabilitiesExtension tMediaCapabilitiesExtension;
     
133.         soap_default_tt__MediaCapabilitiesExtension(soap, &tMediaCapabilitiesExtension);
     
134.         tMedia.Extension = &tMediaCapabilitiesExtension;
     
135.         static struct tt__ProfileCapabilities tProfileCapabilities;
     
136.         soap_default_tt__ProfileCapabilities(soap, &tProfileCapabilities);
     
137.         tMediaCapabilitiesExtension.ProfileCapabilities = &tProfileCapabilities;
     
138.         tProfileCapabilities.MaximumNumberOfProfiles = 3;
     
139.     }
     
140.     tCapabilities.PTZ = NULL;
     
141. tCapabilities.Extension = NULL;
     
142. fprintf(stderr, "GetCapabilities ok....\n");
     
143.     return SOAP_OK;
     
144. }
     

复制代码

5.2__trt__GetProfile函数

1. 
   
2. int __trt__GetProfile(struct soap* soap, struct _trt__GetProfile *trt__GetProfile, struct _trt__GetProfileResponse *trt__GetProfileResponse)
   
3. {
   
4. 
   
5. printf("%s:%d\n",__FUNCTION__,__LINE__);
   
6.     return GetProfile(soap, trt__GetProfile->ProfileToken, trt__GetProfileResponse);
   
7. }
   
8. int __trt__GetProfiles(struct soap* soap, struct _trt__GetProfiles *trt__GetProfiles, struct _trt__GetProfilesResponse *trt__GetProfilesResponse)
   
9. {
   
10.     printf("%s:%d\n",__FUNCTION__,__LINE__);
    
11.     return GetProfile(soap, NULL, trt__GetProfilesResponse);
    
12. }
    
13. 5.3__trt__GetStreamUri函数
    
14. int __trt__GetStreamUri(struct soap* soap, struct _trt__GetStreamUri *trt__GetStreamUri, struct _trt__GetStreamUriResponse *trt__GetStreamUriResponse)
    
15. {
    
16. 
    
17. printf("%s:%d\n",__FUNCTION__,__LINE__);
    
18.         if (trt__GetStreamUri->StreamSetup) {
    
19.         if (trt__GetStreamUri->StreamSetup->Stream == 1) {
    
20.             return soap_sender_fault_subcode(soap, "ter:InvalidArgVal/ter:InvalidStreamSetup", "Specification of StreamType or Transport part in StreamSetup is not supported.", NULL);
    
21.         }
    
22.         if (trt__GetStreamUri->StreamSetup->Transport->Protocol== 3) {
    
23.             return soap_sender_fault_subcode(soap, "ter:InvalidArgVal/ter:InvalidStreamSetup", "The HTTP is not supported.", NULL);
    
24.         }
    
25.     } else {
    
26.         return soap_sender_fault_subcode(soap, "ter:InvalidArgVal/ter:GetStreamUri", "Invalid GetStreamUri.", NULL);
    
27.     }
    
28.     static struct tt__MediaUri tMediaUri;
    
29.     static char Dev_Addr[64];
    
30.     const char* v4_address = "192.168.1.101";  // 修改成你自己的流媒体服务器ip
    
31.     if (strcmp(trt__GetStreamUri->ProfileToken, "media_profile1") ==  0) {
    
32.         sprintf(Dev_Addr, "rtsp://%s/test.264", v4_address);
    
33.     } else    if (strcmp(trt__GetStreamUri->ProfileToken, "media_profile2") ==  0) {
    
34.         sprintf(Dev_Addr, "rtsp://%s/live1", v4_address);
    
35.     } else {
    
36.         return SOAP_ERR;
    
37.     }
    
38.     tMediaUri.Uri                 = Dev_Addr;
    
39.     tMediaUri.InvalidAfterConnect = xsd__boolean__false_;
    
40.     tMediaUri.InvalidAfterReboot  = xsd__boolean__false_;
    
41.     static LONG64 SmTimeout;
    
42.     soap_s2xsd__duration(soap,"PT100S",&SmTimeout);
    
43.     tMediaUri.Timeout             = SmTimeout;//"PT100S";
    
44.     trt__GetStreamUriResponse->MediaUri = &tMediaUri;
    
45.     return SOAP_OK;
    
46. }
    

复制代码

5.4.其他函数__trt__GetVideoEncoderConfigurationOptions和__trt__GetVideoSourceConfiguration
这2个函数也很重要，你也可以不实现,现实的话视频的信息无法获取，当然我这里是随便填的，详细参见工程文件，代码比较多

6.运行测试机
由于本次我们没有实现设备发现功能，并且我们的测试机器没有流媒体服务器，将live555.exe和test.264解码出来放在同一个目录
运行live555就得到了流媒体地址(这个地址就是__trt__GetStreamUri里面填的地址)：

我们需要手工的将ONVIF地址添加进来.


点开我们的测试设备，就可以开到视频流了。



7.总结
这样基于ONVIF的流媒体地址搜索就实现了，当然过程也耗费了一点时间调试，里面我基本全部使用了静态变量，
应该使用soap_malloc来动态申请，我没有完全搞明白soap的内存管理机制，所以使用保守的做法，至少不会出现内存泄露。
框架生成好再开发ONVIF协议的就是填充结构体，每个命令就要填一大推的结构体。所有的命令在下面可以看到
http://www.onvif.org/onvif/ver20/util/operationIndex.html
点开每一个都有详细的说明，只要按这个说明填好结构体，ONVIF协议的开发就没有什么难度。tds_ssom.c里面包含了一些基本信息网络等函数，
实现他们就可以在Device Manager的信息栏显示了：

完整的工程下载：http://pan.baidu.com/s/1bnpQnJh 附件包含测试视频，超过20M了丢个外链吧!

_nucong

写的东西非常有价值，先收藏！

beegeen

学习。感谢LZ分享。

david

赞，

hhzh126

先收藏，谢谢分享。

ipook168

我们公司把onvif项目外包，花了几十K的键子，已经搞得差不多了。

xy309428529

目前正接触海思项目，正需要。

liucuqi

谢谢分享！

goodplayer

问下楼主，设备端（服务端）加入鉴权怎么加啊？有没有相关资料啊？

iamheimawangzi

厉害   真厉害   非常有价值  谢谢高手。

sxsong

好东西，楼楼大爱啊

小虫洞

感谢分享！

liujiaqi13

弱弱的问一句，onvif是怎么适应丢包率20%以上的呢？   

kgui

感谢分享

lyd964201

谢谢分享！