opc Client OPC Server/OPCClient OPCServer 客户端/服务端程序/kepserver源码

# OpcUaHelper  [](https://www.nuget.org/packages/OpcUaHelper/)  [](http://shang.qq.com/wpa/qunwpa?idkey=2278cb9c2e0c04fc305c43e41acff940499a34007dfca9e83a7291e726f9c4e8) [](https://blogs.msdn.microsoft.com/dotnet/2016/08/24/whats-new-in-csharp-7-0/) [](https://www.visualstudio.com/zh-hans/)   一个通用的二次封装的opc ua客户端类库，基于.net 4.6.1创建，基于官方opc ua基金会跨平台库创建，方便的实现和OPC Server进行数据交互。本类库每个几个月就同步官方的类库。 ## 免责声明 OpcUa相关的组件版权归OPC UA基金会所有，使用本库时请遵循OPC UA基金会的授权规则。 1. 非商用情况，如果你的项目仅仅是自己公司使用的，那么需要注册为OPC基金会的成员，否则，必须开源。 2. 商用都是需要额外授权的，请联系OPC基金会。 ## FormBrowseServer 在开发客户端之前，需要使用本窗口来进行查看服务器的节点状态，因为在请求服务器的节点数据之前，必须知道节点的名称，而节点的名称可以通过这个窗口获取。以下演示实例化操作 ``` OpcUaHelper.Forms.FormBrowseServer formBrowseServer = new Forms.FormBrowseServer( ); formBrowseServer.ShowDialog( ); ``` 当然你可以固定住这个地址，传入地址即可，此处为示例： ``` OpcUaHelper.Forms.FormBrowseServer formBrowseServer = new Forms.FormBrowseServer( "opc.tcp://127.0.0.1:62541/SharpNodeSettings/OpcUaServer" ); formBrowseServer.ShowDialog( ); ``` 界面效果如下，包含了节点的查看，订阅操作，双击值表格，还可以修改服务器的值（如果这个节点支持修改的话），查看节点的信息：  ## Server Prepare 如果你没有opc ua的服务器的话，可以参照本示例的服务器，本示例的服务器是项目 [SharpNodeSettings](https://github.com/dathlin/SharpNodeSettings) 的示例。可以直接下载这个项目运行服务器软件。 或者选择在线的客户端测试: opc.tcp://118.24.36.220:62547/DataAccessServer ## OpcUaClient 实例化操作 ``` OpcUaClient m_OpcUaClient = new OpcUaClient(); ``` 设置匿名连接 ``` m_OpcUaClient.UserIdentity = new UserIdentity( new AnonymousIdentityToken( ) ); ``` 设置用户名连接 ``` m_OpcUaClient.UserIdentity = new UserIdentity( "user", "password" ); ``` 使用证书连接 ``` X509Certificate2 certificate = new X509Certificate2( "[证书的路径]", "[密钥]", X509KeyStorageFlags.MachineKeySet | X509KeyStorageFlags.Exportable ); m_OpcUaClient.UserIdentity = new UserIdentity( certificate ); ``` 设置完连接的权限之后，就可以真正的启动连接操作了，连接的操作必须要放到try...catch...之前，必须使用async标记方法 ``` private async void button1_Click( object sender, EventArgs e ) { // connect to server, this is a sample try { await m_OpcUaClient.ConnectServer( "opc.tcp://127.0.0.1:62541/SharpNodeSettings/OpcUaServer" ); } catch (Exception ex) { ClientUtils.HandleException( "Connected Failed", ex ); } } ``` ### Read/Write Node 如果我们想要读取上图节点浏览器的温度数据，节点字符串为 ``` ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/温度 ``` 类型为Int16, 所以我们使用下面的方法读取 ``` try { short value = m_OpcUaClient.ReadNode<short>( "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/温度" ); } catch(Exception ex) { ClientUtils.HandleException( this.Text, ex ); } ``` 你也可以使用异步读取，只是外面的方法上需要使用async标记 ``` try { short value = await m_OpcUaClient.ReadNodeAsync<short>( "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/温度" ); } catch (Exception ex) { ClientUtils.HandleException( this.Text, ex ); } ``` 接下来写入节点操作，如果该节点的权限不支持写的话，就会触发异常 ``` try { m_OpcUaClient.WriteNode( "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/温度", (short)123 ); } catch (Exception ex) { ClientUtils.HandleException( this.Text, ex ); } ``` 批量读取的操作，分为类型不一致和类型一致两种操作，下面都做个示例 ``` try { // 添加所有的读取的节点，此处的示例是类型不一致的情况 List<NodeId> nodeIds = new List<NodeId>( ); nodeIds.Add( new NodeId( "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/温度" ) ); nodeIds.Add( new NodeId( "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/风俗" ) ); nodeIds.Add( new NodeId( "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/转速" ) ); nodeIds.Add( new NodeId( "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/机器人关节" ) ); nodeIds.Add( new NodeId( "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/cvsdf" ) ); nodeIds.Add( new NodeId( "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/条码" ) ); nodeIds.Add( new NodeId( "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/开关量" ) ); // dataValues按顺序定义的值，每个值里面需要重新判断类型 List<DataValue> dataValues = m_OpcUaClient.ReadNodes( nodeIds.ToArray() ); // 如果你批量读取的值的类型都是一样的，比如float，那么有简便的方式 List<string> tags = new List<string>( ); tags.Add( "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/风俗" ); tags.Add( "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/转速" ); // 按照顺序定义的值 List<float> values = m_OpcUaClient.ReadNodes<float>( tags.ToArray() ); } catch (Exception ex) { ClientUtils.HandleException( this.Text, ex ); } ``` 批量写入的操作如下： ``` try { // 此处演示写入一个short，2个float类型的数据批量写入操作 bool success = m_OpcUaClient.WriteNodes( new string[] { "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/温度", "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/风俗", "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/转速"}, new object[] { (short)1234, 123.456f, 123f } ); if (success) { // 写入成功 } else { // 写入失败，一个失败即为失败 } } catch (Exception ex) { ClientUtils.HandleException( this.Text, ex ); } ``` ### Read History ``` try { // 此处演示读取历史数据的操作，读取8月18日12点到13点的数据，如果想要读取成功，该节点是支持历史记录的 List<float> values = m_OpcUaClient.ReadHistoryRawDataValues<float>( "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/转速", new DateTime( 2018, 8, 18, 12, 0, 0 ), new DateTime( 2018, 8, 18, 13, 0, 0 ) ).ToList( ); // 列表数据可用于显示曲线之类的操作 } catch (Exception ex) { ClientUtils.HandleException( this.Text, ex ); } ``` ### Read Attribute 本类库支持读取一个节点的相关的所有的属性，主要包含了值，描述，名称，权限等级，等等操作 ``` try { OpcNodeAttribute[] nodeAttributes = m_OpcUaClient.ReadNoteAttributes( "ns=2;s=Devices/分厂一/车间二/ModbusTcp客户端/温度" ); foreach (var item in nodeAttributes) { Console.Write( string.Format( "{0,-30}", item.Name )