目录

一、前言

1、探测目标服务

2、接收和解析响应

3、建立设备列表

二、代码和解释

 1、代码和注释

2、函数功能说明

（1）COnvifDiscovery方法:

（2）单例模式:

（3）getTime方法:

（4）MyStartThread方法:

（5）MyThreadProc方法:

（6）ThreadProc方法:

---

一、前言

       ONVIF协议中的Discovery机制提供了一种动态发现服务的方式，使得客户端能够在不知道目标服务地址的情况下，找到并与之建立连接。

       在ONVIF协议中，Discovery（设备发现）主要完成探测目标、接收和解析、建立设备列表等。

1、探测目标服务

        当客户端预先不知道目标服务的地址时，Discovery机制允许其动态地探测到可用的目标服务。这主要通过客户端在特定的网络地址和端口上发送Probe消息（探针）来完成。这些Probe消息会向网络中的服务器发送请求，询问是否有可用的服务。

2、接收和解析响应

        一旦服务器接收到Probe消息，它会回复ProbeMatch消息，其中包含有关服务器的信息。客户端接收到这些响应后，会解析其中的信息，从而识别到可用的服务器。

3、建立设备列表

        客户端在成功发现服务器后，会将其添加到设备列表中。这样，客户端就可以知道网络中有哪些设备是可用的，并可以进一步与这些设备进行通信和交互。

这里就把视频监控接入平台的onvif标准的discovery部分代码发出来，可以一起学习、探讨。

二、代码和解释

 1、代码和注释

        直接出代码，如下：

// 引入标准输入输出流库

#include <iostream>
#include "onvifMain.h"
// 引入自定义的 onvifMain 头文件
#include "onvifMain.h"
using namespace std;
using namespace sipOnvif;

// COnvifMain 类中定义 COnvifDiscovery 方法，用于进行ONVIF设备发现

void COnvifMain::COnvifDiscovery(int timeout)

{

    // 定义一个用于存储错误信息的对象
    CerrorSet error;
    // 如果设备列表为空，则创建一个新的设备列表
    if(!devList)
        devList = new map<string, class ConvifDev*>;
    // 如果设备列表不为空
    if(devList){

        // 调用 onvifCtl 对象的 deleteDevList 方法清空设备列表
        onvifCtl.deleteDevList(devList);

        // 调用 onvifCtl 对象的 Discovery 方法进行设备发现
        onvifCtl.Discovery(devList, error, timeout);   

    }

}



// 定义 COnvifMain 类的单例模式成员变量 pInstance
COnvifMain *COnvifMain::pInstance = NULL;



// COnvifMain 类中定义 GetInstance 方法，用于获取类的单例实例
COnvifMain *COnvifMain::GetInstance(void)

{

    // 如果单例实例还未创建
    if (NULL == pInstance)

    {

        // 创建单例实例
        pInstance = new COnvifMain();

        // 如果实例创建失败
        if (NULL == pInstance)

        {
            exit(1);

        }

    }     

    // 返回单例实例
    return pInstance;

}



// COnvifMain 类中定义 getTime 方法，用于获取时间参数
void COnvifMain::getTime(int &timeout,int &geTime, int &delayTime)

{

    // 使用自动锁保护临界区，确保线程安全
    CAutoLock AutoLock(&CritSecTime);

    // 将类的成员变量赋值给引用参数
    timeout = ftimeout;

    geTime = fgeTime;
    delayTime = fdelayTime;
}



// COnvifMain 类中定义 MyStartThread 方法，用于启动新线程
int COnvifMain::MyStartThread(void)

{

    // 定义线程ID
    pthread_t ThreadID;

    // 如果当前线程状态为正在运行
    if (ThreadStatus())

    {      
        return -1;

    }

    // 创建新线程，执行 MyThreadProc 函数
    int nRet = pthread_create(&ThreadID, NULL, COnvifMain::MyThreadProc, this);

    // 如果线程创建失败

    if (nRet != 0)

    {
        return -1;

    }     

    // 线程创建成功，返回 0
    return 0;

}



// COnvifMain 类中定义 MyThreadProc 方法，作为线程入口函数
void* COnvifMain::MyThreadProc(void * pParam)

{

    // 分离线程，使其在线程结束时自动释放资源
    pthread_detach(pthread_self());

   

    // 将传入的参数转换为 COnvifMain 对象的指针
    COnvifMain *obj = static_cast<COnvifMain *>(pParam);

    // 设置线程状态为正在运行
    obj->SetThreadStatus(true);

    // 执行线程的主要处理函数
    obj->ThreadProc();

   

    // 设置线程状态为未运行
    obj->SetThreadStatus(false);

    // 线程执行完毕，返回 NULL
    return NULL;

}



// COnvifMain 类中定义 ThreadProc 方法，作为线程的主要处理函数
int COnvifMain::ThreadProc(void)

{

    // 定义用于存储超时时间、获取时间和延迟时间的变量
    struct timeval tv1, tv2;

    int timeout, geTime, delayTime;

    // 获取时间参数
    getTime(timeout, geTime, delayTime);

    // 调用 COnvifDiscovery 方法进行设备发现
    COnvifDiscovery(timeout);

    // 如果设备列表中有设备
    if(devList->size()){

        // 输出发现设备的数量
        cout << "discovery count is "<< devList->size() << endl;

        // 将设备列表传递给 CCUMain 类的实例
        CCUMain::GetInstance()->putDevList(devList);

    }

   

2、函数功能说明

（1）COnvifDiscovery方法:

void COnvifMain::COnvifDiscovery(int timeout)

{

    CerrorSet error;

    if(!devList)

        devList = new map<string, class ConvifDev*>;

    if(devList){

        onvifCtl.deleteDevList(devList);

        onvifCtl.Discovery(devList, error, timeout);   

    }

}

        这个方法用于进行ONVIF设备的发现。首先，它检查`devList`（可能是一个设备列表）是否为空，如果为空则为其分配内存。然后，如果`devList`非空，它会先清空设备列表，然后调用`onvifCtl`对象的`Discovery`方法进行设备发现。

（2）单例模式:

COnvifMain *COnvifMain::pInstance = NULL;

COnvifMain *COnvifMain::GetInstance(void)

{

    if (NULL == pInstance)

    {

        pInstance = new COnvifMain();

        if (NULL == pInstance)

        {

            exit(1);

        }

    }     

    return pInstance;

}

        这里实现了单例模式，确保整个程序中只有一个`COnvifMain`的实例。`GetInstance`方法用于获取这个实例，如果实例还未创建，则创建它。

（3）getTime方法:

void COnvifMain::getTime(int &timeout,int &geTime, int &delayTime)

{

    CAutoLock AutoLock(&CritSecTime);

    timeout = ftimeout;

    geTime = fgeTime;

    delayTime = fdelayTime;

}

        这个方法用于获取一些与时间相关的参数，如超时时间、获取时间和延迟时间。`CAutoLock`可能是一个自动锁类，用于确保线程安全地访问共享资源。

（4）MyStartThread方法:

int COnvifMain::MyStartThread(void)

{

    pthread_t ThreadID;

    if (ThreadStatus())

    {     

        return -1;

    }

    int nRet = pthread_create(&ThreadID, NULL, COnvifMain::MyThreadProc, this);

    if (nRet != 0)

    {

        return -1;

    }     

    return 0;

}

        这个方法用于启动一个新的线程，执行`MyThreadProc`函数。首先，它检查当前线程状态，如果线程已经在运行，则返回-1。然后，它使用`pthread_create`函数创建线程。

（5）MyThreadProc方法:

void* COnvifMain::MyThreadProc(void * pParam)

{

    pthread_detach(pthread_self());

   

    COnvifMain *obj = static_cast<COnvifMain *>(pParam);

    obj->SetThreadStatus(true);

    obj->ThreadProc();

   

    obj->SetThreadStatus(false);

    return NULL;

}

        这是线程的入口函数。它首先分离线程，使其在线程结束时自动释放资源。然后，它转换传入的参数为`COnvifMain`对象的指针，并设置线程状态为正在运行。接着，它调用`ThreadProc`方法执行实际的线程任务。最后，它将线程状态设置为未运行。

（6）ThreadProc方法:

int COnvifMain::ThreadProc(void)

{

    // ... 省略，请参考上一章 ...

}

        这是线程的主要处理函数。它首先调用`COnvifDiscovery`进行设备发现，并将发现的设备添加到`devList`中。然后，它进入一个循环，在这个循环中，它会周期性地调用`COnvifDiscovery`进行设备发现，并更新设备列表。如果发现新的设备，它会将设备列表传递给`CCUMain`类的实例。

篇幅有限，若想了解更多，文章正下方可以看到我的联系方式：鼠标“点击” 下面的 “威迪斯特-就是video system 微信名片”字样，就会出现我的二维码，欢迎沟通探讨。