天天看點
傳回

onvif開發之裝置發現功能的實作--轉

忙了一個多月，onvif總算告一段落了。這幾個星期忙着其他的項目，也沒有好好整理一下onvif的東西。接下來得好好整理一下自己的項目思路和項目經驗，同時将自己的一些心得寫出來，希望對人有所幫助。

        相信大多數兄弟和我一樣，onvif開發，最開始做的就是發現功能。這兩天登入onvif的官網看才發現，onvif版本在八月份有更新，已經更新到V2.4了，于是下載下傳最新的版本來進行。代碼的生成可以詳見我的前一篇文章。V2.4版本新增了一個wsdl檔案，現在用于生成源碼的檔案一共有18個。為了保證全功能，最好一次性生成包含所有功能的源碼。然後根據最新生成的源碼來實作onvif用戶端和服務端的發現功能。

1. 建立onvif_test目錄。以下這些源碼由最新的gsoap（2.8.16）和最新的onvif的wsdl檔案（2.4）生成。（截止2013.09.16）

onvif.h

soapClientLib.c

soapServerLib.c

soapC.c

soapClient.c

soapH.h

soapServer.c

soapStub.h

2.以下檔案來自gsoap_2.8.16\gsoap-2.8\gsoap

stdsoap2.c

stdsoap2.h

3.以下檔案來自gsoap_2.8.16\gsoap-2.8\gsoap\custom

duration.c

4.生成的soapClientLib.c和soapServerLib.c無實際作用，可直接删除。

5.增加自定義檔案：

onvif_server.c   onvif服務端實作代碼

onvif_client.c   onvif用戶端實作代碼

onvif_server_interface.c   onvif服務端接口實作

onvif_function.c  onvif實作函數，公用

onvif_function.h  onvif實作函數，公用

onvif_server.c為服務端的實作代碼，主要是定義main函數，服務端主要是監聽，并處理和應答消息。

Main函數定義如下：

int main(int argc,char ** argv)  

{  

    printf("[%s][%d][%s][%s] start \n", __FILE__, __LINE__, __TIME__, __func__);  

    int count = 0;  

    struct soap ServerSoap;  

    struct ip_mreq mcast;  

    soap_init1(&ServerSoap, SOAP_IO_UDP | SOAP_XML_IGNORENS);  

    soap_set_namespaces(&ServerSoap,  namespaces);  

    printf("[%s][%d][%s][%s] ServerSoap.version = %d \n", __FILE__, __LINE__, __TIME__, __func__, ServerSoap.version);  

    if(!soap_valid_socket(soap_bind(&ServerSoap, NULL, ONVIF_LISTEN_PORT, 10)))  

    {  

        soap_print_fault(&ServerSoap, stderr);  

        exit(1);  

    }  

    mcast.imr_multiaddr.s_addr = inet_addr("239.255.255.250");  

    mcast.imr_interface.s_addr = htonl(INADDR_ANY);  

    if(setsockopt(ServerSoap.master, IPPROTO_IP, IP_ADD_MEMBERSHIP, (char*)&mcast, sizeof(mcast)) < 0)  

            printf("setsockopt error! error code = %d,err string = %s\n",errno,strerror(errno));  

        return 0;  

    for(;;)  

        if(soap_serve(&ServerSoap))  

        {  

            soap_print_fault(&ServerSoap, stderr);  

        }  

        soap_destroy(&ServerSoap);  

        soap_end(&ServerSoap);  

        //用戶端的IP位址  

        printf("RECEIVE count %d, connection from IP = %lu.%lu.%lu.%lu socket = %d \r\n", count, ((ServerSoap.ip)>>24)&0xFF, ((ServerSoap.ip)>>16)&0xFF, ((ServerSoap.ip)>>8)&0xFF,(ServerSoap.ip)&0xFF, (ServerSoap.socket));  

        count++;  

    //分離運作時的環境  

    soap_done(&ServerSoap);  

    return 0;  

}  

onvif_server_interface.c   此檔案用來定義所有服務端需要填充的接口。這裡我們填充__wsdd__Probe接口即可，其他贊不支援的接口可以用宏統一處理。

__wsdd__Probe的填充如下：

SOAP_FMAC5 int SOAP_FMAC6  __wsdd__Probe(struct soap* soap, struct wsdd__ProbeType *wsdd__Probe)  

    #define MACH_ADDR_LENGTH 6  

    #define INFO_LENGTH 512  

    #define LARGE_INFO_LENGTH 1024  

    #define SMALL_INFO_LENGTH 512  

    printf("[%d] __wsdd__Probe start !\n", __LINE__);  

    unsigned char macaddr[6] = {0};  

    char _IPAddr[INFO_LENGTH] = {0};  

    char _HwId[1024] = {0};  

    wsdd__ProbeMatchesType ProbeMatches;  

    ProbeMatches.ProbeMatch = (struct wsdd__ProbeMatchType *)soap_malloc(soap, sizeof(struct wsdd__ProbeMatchType));  

    ProbeMatches.ProbeMatch->XAddrs = (char *)soap_malloc(soap, sizeof(char) * INFO_LENGTH);  

    ProbeMatches.ProbeMatch->Types = (char *)soap_malloc(soap, sizeof(char) * INFO_LENGTH);  

    ProbeMatches.ProbeMatch->Scopes = (struct wsdd__ScopesType*)soap_malloc(soap,sizeof(struct wsdd__ScopesType));  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.ReferenceProperties = (struct wsa__ReferencePropertiesType*)soap_malloc(soap,sizeof(struct wsa__ReferencePropertiesType));  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.ReferenceParameters = (struct wsa__ReferenceParametersType*)soap_malloc(soap,sizeof(struct wsa__ReferenceParametersType));  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.ServiceName = (struct wsa__ServiceNameType*)soap_malloc(soap,sizeof(struct wsa__ServiceNameType));  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.PortType = (char **)soap_malloc(soap, sizeof(char *) * SMALL_INFO_LENGTH);  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.__any = (char **)soap_malloc(soap, sizeof(char*) * SMALL_INFO_LENGTH);  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.__anyAttribute = (char *)soap_malloc(soap, sizeof(char) * SMALL_INFO_LENGTH);  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.Address = (char *)soap_malloc(soap, sizeof(char) * INFO_LENGTH);  

    netGetMac("eth4", macaddr); //eth0  根據實際情況填充  

    macaddr[0]=0x01;macaddr[1]=0x01;macaddr[2]=0x01;macaddr[3]=0x01;macaddr[4]=0x01;macaddr[5]=0x01;  

    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]);  

    unsigned int localIp = 0;  

    netGetIp("eth4", &localIp); //eth0 根據實際情況填充  

    sprintf(_IPAddr, "http://%s/onvif/device_service", inet_ntoa(*((struct in_addr *)&localIp)));  

    printf("[%d] _IPAddr ==== %s\n", __LINE__, _IPAddr);  

    ProbeMatches.__sizeProbeMatch = 1;  

    ProbeMatches.ProbeMatch->Scopes->__item =(char *)soap_malloc(soap, 1024);  

    memset(ProbeMatches.ProbeMatch->Scopes->__item,0,sizeof(ProbeMatches.ProbeMatch->Scopes->__item));    

    //Scopes MUST BE  

    strcat(ProbeMatches.ProbeMatch->Scopes->__item, "onvif://www.onvif.org/type/NetworkVideoTransmitter");  

    ProbeMatches.ProbeMatch->Scopes->MatchBy = NULL;  

    strcpy(ProbeMatches.ProbeMatch->XAddrs, _IPAddr);  

    strcpy(ProbeMatches.ProbeMatch->Types, wsdd__Probe->Types);  

    printf("wsdd__Probe->Types=%s\n",wsdd__Probe->Types);  

    ProbeMatches.ProbeMatch->MetadataVersion = 1;  

    //ws-discovery規定 為可選項  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.ReferenceProperties->__size = 0;  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.ReferenceProperties->__any = NULL;  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.ReferenceParameters->__size = 0;  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.ReferenceParameters->__any = NULL;  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.PortType[0] = (char *)soap_malloc(soap, sizeof(char) * SMALL_INFO_LENGTH);  

    strcpy(ProbeMatches.ProbeMatch->wsa__EndpointReference.PortType[0], "ttl");  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.ServiceName->__item = NULL;  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.ServiceName->PortName = NULL;  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.ServiceName->__anyAttribute = NULL;  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.__any[0] = (char *)soap_malloc(soap, sizeof(char) * SMALL_INFO_LENGTH);  

    strcpy(ProbeMatches.ProbeMatch->wsa__EndpointReference.__any[0], "Any");  

    strcpy(ProbeMatches.ProbeMatch->wsa__EndpointReference.__anyAttribute, "Attribute");  

    ProbeMatches.ProbeMatch->wsa__EndpointReference.__size = 0;  

    strcpy(ProbeMatches.ProbeMatch->wsa__EndpointReference.Address, _HwId);  

    soap->header->wsa__To = "http://schemas.xmlsoap.org/ws/2004/08/addressing/role/anonymous";  

    soap->header->wsa__Action = "http://schemas.xmlsoap.org/ws/2005/04/discovery/ProbeMatches";  

    soap->header->wsa__RelatesTo = (struct wsa__Relationship*)soap_malloc(soap, sizeof(struct wsa__Relationship));  

    soap->header->wsa__RelatesTo->__item = soap->header->wsa__MessageID;  

    soap->header->wsa__RelatesTo->RelationshipType = NULL;  

    soap->header->wsa__RelatesTo->__anyAttribute = NULL;  

    soap->header->wsa__MessageID =(char *)soap_malloc(soap, sizeof(char) * INFO_LENGTH);  

    strcpy(soap->header->wsa__MessageID,_HwId+4);  

        if (SOAP_OK == soap_send___wsdd__ProbeMatches(soap, "http://", NULL, &ProbeMatches))  

        printf("send ProbeMatches success !\n");  

        return SOAP_OK;  

    printf("[%d] soap error: %d, %s, %s\n", __LINE__, soap->error, *soap_faultcode(soap), *soap_faultstring(soap));    

    return soap->error;;  

onvif_client.c   onvif用戶端實作代碼，主要是定義用戶端的main函數：

Main定義如下：

int main()    

{    

    int result = 0;    

    wsdd__ProbeType req;  

    struct __wsdd__ProbeMatches resp;  

    wsdd__ScopesType sScope;  

    struct SOAP_ENV__Header header;    

    struct soap *soap;    

    soap = soap_new();    

    if(NULL == soap )    

    {    

        printf("sopa new error\r\n");    

        return -1;    

    }    

    soap->recv_timeout = 10;    

    soap_set_namespaces(soap, namespaces);    

    soap_default_SOAP_ENV__Header(soap, &header);    

    uuid_t uuid;  

    char guid_string[100];  

    uuid_generate(uuid);  

    uuid_unparse(uuid, guid_string);  

    header.wsa__MessageID = guid_string;   

    header.wsa__To = "urn:schemas-xmlsoap-org:ws:2005:04:discovery";    

    header.wsa__Action = "http://schemas.xmlsoap.org/ws/2005/04/discovery/Probe";    

    soap->header = &header;    

    soap_default_wsdd__ScopesType(soap, &sScope);    

    sScope.__item = "";    

    soap_default_wsdd__ProbeType(soap, &req);    

    req.Scopes = &sScope;    

    req.Types = ""; //"dn:NetworkVideoTransmitter";    

    int i = 0;        

       result = soap_send___wsdd__Probe(soap, MULTICAST_ADDRESS, NULL, &req);    

       while(result == SOAP_OK)    

       {    

        result = soap_recv___wsdd__ProbeMatches(soap, &resp);    

        if(result == SOAP_OK)    

        {    

            if(soap->error)    

            {    

                printf("soap error 1: %d, %s, %s\n", soap->error, *soap_faultcode(soap), *soap_faultstring(soap));    

                result = soap->error;    

            }    

            else    

                printf("guog *********************************************\r\n");    

                if(soap->header->wsa__MessageID)    

                {    

                    printf("MessageID   : %s\r\n", soap->header->wsa__MessageID);    

                }    

                if(soap->header->wsa__RelatesTo && soap->header->wsa__RelatesTo->__item)    

                    printf("RelatesTo   : %s\r\n", soap->header->wsa__RelatesTo->__item);    

                if(soap->header->wsa__To)    

                    printf("To          : %s\r\n", soap->header->wsa__To);    

                if(soap->header->wsa__Action)    

                    printf("Action      : %s\r\n", soap->header->wsa__Action);    

                for(i = 0; i < resp.wsdd__ProbeMatches->__sizeProbeMatch; i++)    

                    printf("__sizeProbeMatch        : %d\r\n", resp.wsdd__ProbeMatches->__sizeProbeMatch);    

                    printf("wsa__EndpointReference       : %p\r\n", resp.wsdd__ProbeMatches->ProbeMatch->wsa__EndpointReference);    

                    printf("Target EP Address       : %s\r\n", resp.wsdd__ProbeMatches->ProbeMatch->wsa__EndpointReference.Address);    

                    printf("Target Type             : %s\r\n", resp.wsdd__ProbeMatches->ProbeMatch->Types);    

                    printf("Target Service Address  : %s\r\n", resp.wsdd__ProbeMatches->ProbeMatch->XAddrs);    

                    printf("Target Metadata Version : %d\r\n", resp.wsdd__ProbeMatches->ProbeMatch->MetadataVersion);    

                    if(resp.wsdd__ProbeMatches->ProbeMatch->Scopes)    

                    {    

                        printf("Target Scopes Address   : %s\r\n", resp.wsdd__ProbeMatches->ProbeMatch->Scopes->__item);    

                    }    

                }  

        }    

        else if (soap->error)    

            printf("[%d] soap error 2: %d, %s, %s\n", __LINE__, soap->error, *soap_faultcode(soap), *soap_faultstring(soap));    

            result = soap->error;    

       }    

    soap_destroy(soap);   

    soap_end(soap);   

    soap_free(soap);  

    printf("[%d] guog discover over !\n", __LINE__);  

    return result;    

}    

6.将wsdd.nsmap改為nsmap.h，并删除其餘的*.nsmap(都一樣)

7.編寫makefile檔案。注意在makefile中打開開關DEBUG，以便跟蹤日志。

8.tcpdump為gcc環境的抓包工具，調試的時候用。

make編譯通過，運作，用戶端發現功能ok；

onvif開發之裝置發現功能的實作--轉

    但是服務端的發現功能卻不行；别急，這是由于SOAP的版本問題；soap的版本是根據命名空間來自動确定的；在soap結構體的version字段表示soap版本；

以下命名空間表示SOAP1.1版本：

{"SOAP-ENV", "http://schemas.xmlsoap.org/soap/envelope/", "http://www.w3.org/*/soap-envelope", NULL},

{"SOAP-ENC", "http://schemas.xmlsoap.org/soap/encoding/", "http://www.w3.org/*/soap-encoding", NULL}, //1.1

以下命名空間表示SOAP1.2版本：

{"SOAP-ENV", "http://www.w3.org/2003/05/soap-envelope", "http://schemas.xmlsoap.org/soap/envelope/", NULL},

{"SOAP-ENC", "http://www.w3.org/2003/05/soap-encoding", "http://schemas.xmlsoap.org/soap/encoding/", NULL},  //1.2

    注意确定自己目前的命名空間。我們用SOAP1.2版本才能被測試工具發現(ONVIF Device Test Tool version 13.06)。

不清楚可以檢視soap_set_namespaces接口和soap_set_local_namespaces接口；

于是将nsmap.h中的命名空間前兩行改為：

再編譯運作，發現功能ok。

onvif開發之裝置發現功能的實作--轉

最後，将所用的工具和源碼提供給大家，大家根據需要下載下傳。

from:http://blog.csdn.net/love_xjhu/article/details/11821037

移動開發 網絡架構 c++ 測試技術 c語言 裝置轉發 轉發功能 開發裝置功能 裝置功能 開發功能實作
上一篇: RTP協定之Header結構解析
下一篇: HTTP協定建立連接配接、通訊與關閉連接配接全過程

繼續閱讀