OPC:服务器开发(一)如何开发OPC Server

您所在的位置:网站首页 中药制剂概论论文 OPC:服务器开发(一)如何开发OPC Server

OPC:服务器开发(一)如何开发OPC Server

2023-08-14 17:41| 来源: 网络整理| 查看: 265

一、什么是OPC

OPC (OLE for Process Control——用于过程控制的OLE)是基于Microsoft公司的DNA(Distributed Internet Application)构架和COM(Component Object Model)技术的一个工业标准接口,是根据易于扩展性而设计的。

二、OPC的用途

OPC主要适用于过程控制和制造自动化等应用领域。 OPC是以OLE/COM机制作为应用程序的通讯标准。OLE/COM是一种客户/服务器模式,具有语言无关性、代码重用性、易于集成性等优点。OPC规范了接口函数,不管现场设备以何种形式存在,客户都以统一的方式去访问,从而保证软件对客户的透明性,使得用户完全从低层的开发中脱离出来

三、OPC Server的组成

一个设备的OPC Server主要有两部组成,一是OPC标准接口的实现;二是与硬件设备的通信模块。我们在这里主要讨论OPC 标准接口。IOPCServer 是OPC Server的主接口,通过它实现OPC Server在操作系统中的安装和注册。此接口是必须要实现的,其所有方法也必须实现。其它的接口都是可选的我们就不做介绍了,下面主要来介绍如何实现IOPCServer接口。   在IOPCServer接口中共有六个方法:AddGroup、GetErrorString、GetGroupByName、GetStatus、RemoveGroup、CreateGroupEnumerator

IOPCServer::AddGroup 此方法是在OPC Server上建立一个组,函数定义:   HRESULT AddGroup( [in, string] LPCWSTR szName,   [in] BOOL bActive,   [in] DWORD dwRequestedUpdateRate,   [in] OPCHANDLE hClientGroup,   [unique, in] LONG *pTimeBias,   [in] FLOAT * pPercentDeadband,   [in] DWORD dwLCID,   [out] OPCHANDLE * phServerGroup,   [out] DWORD *pRevisedUpdateRate,   [in] REFIID riid,   [out, iid_is(riid)] LPUNKNOWN * ppUnk ;

使用实例:   首先要对组名(szName)进行检查,看是否有效或是否已经有这个组。

RequestedName = szName; if (RequestedName == ""){ RequestedName = pSvrObject->DefaultGroupName();   }else{ RequestedName = pSvrObject->DefaultGroupName(); }       for (i = 0; iGetGroup(i); if (RequestedName == pGroup->Name) return (OPC_E_DUPLICATENAME);    }

这需要在内存中存储OPC Group(组) 的列表(还要有OPC项的列表)。 如果szName(组名)正确并且没有建立过该组,就开始根据传过来的参数进行组的建立,建立好后将该组加到自己的组列表中以备后用。

if ((dwRequestedUpdateRate == 0) || (dwRequestedUpdateRate < pApp->ServerTickRate))    ActualRate = pApp->ServerTickRate; else {    ActualRate = dwRequestedUpdateRate;    MinRate = pApp->ServerTickRate;    ActualRate += (MinRate / 2);    ActualRate /= MinRate;    ActualRate *= MinRate;    } if (pRevisedUpdateRate) *pRevisedUpdateRate = ActualRate;   pGroup = new (COPCGroup); if (pGroup == NULL) return (E_OUTOFMEMORY);  pGroup->Name = RequestedName; pGroup->pSvrObject = pSvrObject; pGroup->MarkedForDeletion = FALSE; pGroup->ClientGroupHandle = hClientGroup;  pGroup->UpdateRate = ActualRate;  pGroup->IsActive = bActive; if (pPercentDeadband) pGroup->Deadband = *pPercentDeadband; else    pGroup->Deadband = 0.0; pGroup->LCID = dwLCID; if (pTimeBias) pGroup->TimeBias = *pTimeBias; else { _ftime( &timebuffer) ; pGroup->TimeBias = timebuffer.timezone; // pGroup->TimeBias = 300L;    }   r1 = pGroup->QueryInterface(riid, (LPVOID *)ppUnk); if (FAILED(r1)){    // If error - delete group and return    delete (pGroup);    return r1; } pSvrObject->AddNewGroup(pGroup);

最后将新建组的接口指针返回给客户端。

*phServerGroup = pGroup->ServerGroupHandle; IOPCServer::GetErrorString 为Server的错误代码返回相应的错误字符串,函数声明: HRESULT GetErrorString([in] HRESULT dwError, [in] LCID dwLocale, [ out, string ] LPWSTR *ppString); IOPCServer::GetGroupByName 通过指定的组名(由同一客户端建立的)找到该组的接口指针。此方法实现比较简单,只要根据提供的名子循环从组列表中找到该组的接口指针,并返回给客户端。函数声明: HRESULT GetGroupByName( [in, string] LPCWSTR szName, [in] REFIID riid, [out, iid_is(riid)] LPUNKNOWN *ppUnk ); IOPCServer::GetStatus 返回当前Server的状态信息。此方法比较简单,但要注意的是在使用OPCSERVERSTAUS前要进行内存分配。函数声明: HRESULT GetStatus( [out] OPCSERVERSTATUS **ppServerStatus ); IOPCServer::RemoveGroup 从服务器中删除指定组,在组列表中找到指定的组,并将其删除。函数声明: HRESULT RemoveGroup( [in] OPCHANDLE hServerGroup, [in] BOOL bForce ;)

使用实例:

for (i = 0; iGetGroup(i); if (groupHandleID == pGroup->ServerGroupHandle){ pSvrObject->RemoveGroup(i); // if no outstanding references delete it    if (pGroup->RefCount == 0) {    pSvrObject->LockGroupList();    delete (pGroup);    pSvrObject->UnlockGroupList();    }elseif (bForce){    DeletedGroupList.Add((CObject *)pGroup);    } else {    pGroup->MarkedForDeletion = TRUE;    pGroup->pSvrObject = NULL;    return (OPC_S_INUSE);    } return (S_OK);    }    } IOPCServer::CreateGroupEnumerator 为Server上所提供的组建立不同的列举器。函数声明: HRESULT CreateGroupEnumerator( [in] OPCENUMSCOPE dwScope,[in] REFIID riid, [out, iid_is(riid)] LPUNKNOWN *ppUnk ;} ``


【本文地址】


今日新闻


推荐新闻


CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3