视频监控接入平台，ONVIF设备发现（onvif Discovery） 源代码解释和分享
ONVIF协议中的Discovery机制提供了一种动态发现服务的方式，使得客户端能够在不知道目标服务地址的情况下，找到并与之建立连接。在ONVIF协议中，Discovery（设备发现）主要完成探测目标、接收和解析、建立设备列表等。
目录
一、前言
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 微信名片”字样，就会出现我的二维码，欢迎沟通探讨。
瓜分20万奖金 获得内推名额 丰厚实物奖励 易参与易上手
更多推荐
23
0- 0
已为社区贡献4条内容
所有评论(0)