OPC:服务器开发(⼀)如何开发OPCServer
⼀、什么是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
1. 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; i<NumbrGroups(); i++){
pGroup = pSvrObject->GetGroup(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)){
groupby是什么函数 // If error - delete group and return
delete (pGroup);
return r1;
}
pSvrObject->AddNewGroup(pGroup);
最后将新建组的接⼝指针返回给客户端。
*phServerGroup = pGroup->ServerGroupHandle;
2. IOPCServer::GetErrorString
为Server的错误代码返回相应的错误字符串,函数声明:
HRESULT GetErrorString([in] HRESULT dwError, [in] LCID dwLocale, [ out, string ] LPWSTR *ppString);
3. IOPCServer::GetGroupByName
通过指定的组名(由同⼀客户端建⽴的)到该组的接⼝指针。此⽅法实现⽐较简单,只要根据提供的名⼦循环从组列表中到该组的接⼝指针,并返回给客户端。函数声明:
HRESULT GetGroupByName( [in, string] LPCWSTR szName, [in] REFIID riid, [out, iid_is(riid)] LPUNKNOWN *ppUnk );
4. IOPCServer::GetStatus
返回当前Server的状态信息。此⽅法⽐较简单,但要注意的是在使⽤OPCSERVERSTAUS前要进⾏内存分配。函数声明:
HRESULT GetStatus( [out] OPCSERVERSTATUS **ppServerStatus );
5. IOPCServer::RemoveGroup
从服务器中删除指定组,在组列表中到指定的组,并将其删除。函数声明:
HRESULT RemoveGroup( [in] OPCHANDLE hServerGroup, [in] BOOL bForce ;)
使⽤实例:
for (i = 0; i<NumbrGroups(); i++){
pGroup = pSvrObject->GetGroup(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);
}
}
6. IOPCServer::CreateGroupEnumerator
为Server上所提供的组建⽴不同的列举器。函数声明:
HRESULT CreateGroupEnumerator( [in] OPCENUMSCOPE dwScope,[in] REFIID riid, [out, iid_is(riid)] LPUNKNOWN *ppUnk ;} ``
版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。
发表评论