using Opc.Ua.Client;
|
using Opc.Ua;
|
using System;
|
using Opc.Ua.Configuration;
|
|
|
namespace HH.WCS.Mobox3.DSZSH.device
|
{
|
internal class OpcUaHelper
|
{
|
private static Opc.Ua.Client.Session session;
|
|
static OpcUaHelper()
|
{
|
CreateUpcSession();
|
}
|
|
/// <summary>
|
/// 连接OPC服务
|
/// </summary>
|
internal static async void CreateUpcSession()
|
{
|
try
|
{
|
// 创建一个应用配置对象，用于设置应用名称、唯一标识、类型、证书和安全策略
|
var config = new ApplicationConfiguration()
|
{
|
ApplicationName = "MyClient",
|
ApplicationUri = Utils.Format(@"urn:{0}:MyClient", System.Net.Dns.GetHostName()),
|
ApplicationType = ApplicationType.Client,
|
SecurityConfiguration = new SecurityConfiguration
|
{
|
ApplicationCertificate = new CertificateIdentifier { StoreType = @"Directory", StorePath = @"%CommonApplicationData%\OPC Foundation\CertificateStores\MachineDefault", SubjectName = "MyClientSubjectName" },
|
TrustedIssuerCertificates = new CertificateTrustList { StoreType = @"Directory", StorePath = @"%CommonApplicationData%\OPC Foundation\CertificateStores\UA Certificate Authorities" },
|
TrustedPeerCertificates = new CertificateTrustList { StoreType = @"Directory", StorePath = @"%CommonApplicationData%\OPC Foundation\CertificateStores\UA Applications" },
|
RejectedCertificateStore = new CertificateTrustList { StoreType = @"Directory", StorePath = @"%CommonApplicationData%\OPC Foundation\CertificateStores\RejectedCertificates" },
|
AutoAcceptUntrustedCertificates = true,
|
RejectSHA1SignedCertificates = false,
|
MinimumCertificateKeySize = 1024,
|
NonceLength = 32,
|
},
|
TransportConfigurations = new TransportConfigurationCollection(),
|
TransportQuotas = new TransportQuotas { OperationTimeout = 15000 },
|
ClientConfiguration = new ClientConfiguration { DefaultSessionTimeout = 60000 },
|
TraceConfiguration = new TraceConfiguration()
|
};
|
|
// 验证应用配置对象
|
await config.Validate(ApplicationType.Client);
|
|
// 设置证书验证事件，用于自动接受不受信任的证书
|
if (config.SecurityConfiguration.AutoAcceptUntrustedCertificates)
|
{
|
config.CertificateValidator.CertificateValidation += (s, e) => { e.Accept = (e.Error.StatusCode == StatusCodes.BadCertificateUntrusted); };
|
}
|
|
// 创建一个应用实例对象，用于检查证书
|
var application = new ApplicationInstance(config);
|
|
// 检查应用实例对象的证书
|
bool check = await application.CheckApplicationInstanceCertificate(false, 2048);
|
// 创建一个会话对象，用于连接到 OPC UA 服务器
|
EndpointDescription endpointDescription = CoreClientUtils.SelectEndpoint("opc.tcp://172.16.57.41:4840", true);
|
EndpointConfiguration endpointConfiguration = EndpointConfiguration.Create(config);
|
ConfiguredEndpoint endpoint = new ConfiguredEndpoint(null, endpointDescription, endpointConfiguration);
|
session = await Session.Create(config, endpoint, false, false, "DataCollector", 60000, new UserIdentity(), null);
|
if (session != null && session.Connected)
|
{
|
Console.WriteLine("The session is connected to the OPC UA server.");
|
LogHelper.Info($"创建OPC连接成功", "OPC");
|
}
|
else
|
{
|
Console.WriteLine("The session is not connected to the OPC UA server.");
|
LogHelper.Info($"创建OPC连接失败", "OPC");
|
}
|
}
|
catch (Exception e)
|
{
|
LogHelper.Info($"连接OPC服务异常" + e.Message, "OPC");
|
}
|
}
|
|
/// <summary>
|
/// 读取OPC节点数据
|
/// </summary>
|
/// <param name="nodeId"></param>
|
internal static object ReadOpcValue(string nodeId)
|
{
|
try
|
{
|
if (session != null && session.Connected)
|
{
|
// 读取数据节点
|
DataValue item = session.ReadValue(nodeId: nodeId);
|
LogHelper.Info($"OPC读取:nodeid:{nodeId},value:{item.Value}", "OPC");
|
return item.Value;
|
}
|
else
|
{
|
Console.WriteLine("The session is not connected to the OPC UA server.");
|
LogHelper.Info($"OPC连接失败", "OPC");
|
CreateUpcSession();
|
}
|
|
}
|
catch (Exception e)
|
{
|
|
LogHelper.Info($"读取OPC数据异常" + e.Message, "OPC");
|
}
|
return null;
|
}
|
|
/// <summary>
|
/// 写OPC节点数据
|
/// </summary>
|
/// <param name="nodeId"></param>
|
/// <param name="val"></param>
|
internal static void WriteOpcValue(string nodeId,bool val)
|
{
|
try
|
{
|
if (session != null && session.Connected)
|
{
|
// 写入数据到节点
|
WriteValue writeValue = new WriteValue
|
{
|
NodeId = new NodeId(nodeId),
|
AttributeId = Attributes.Value,
|
Value = new DataValue(val)
|
};
|
|
StatusCodeCollection results;
|
DiagnosticInfoCollection diagnosticInfos;
|
session.Write(null, new WriteValueCollection { writeValue }, out results, out diagnosticInfos);
|
Console.WriteLine($"Write Status for {nodeId}: {results[0]}");
|
LogHelper.Info($"OPC写入:nodeid:{nodeId},value:{val}", "OPC");
|
}
|
else
|
{
|
Console.WriteLine("The session is not connected to the OPC UA server.");
|
LogHelper.Info($"OPC连接失败", "OPC");
|
CreateUpcSession();
|
}
|
|
}
|
catch (Exception e)
|
{
|
LogHelper.Info($"写入OPC数据异常" + e.Message, "OPC");
|
}
|
}
|
|
/// <summary>
|
/// 写OPC节点数据
|
/// </summary>
|
/// <param name="nodeId"></param>
|
/// <param name="val"></param>
|
internal static void WriteOpcValue(string nodeId, int val)
|
{
|
try
|
{
|
if (session != null && session.Connected)
|
{
|
// 写入数据到节点
|
WriteValue writeValue = new WriteValue
|
{
|
NodeId = new NodeId(nodeId),
|
AttributeId = Attributes.Value,
|
Value = new DataValue(val)
|
};
|
|
StatusCodeCollection results;
|
DiagnosticInfoCollection diagnosticInfos;
|
session.Write(null, new WriteValueCollection { writeValue }, out results, out diagnosticInfos);
|
Console.WriteLine($"Write Status for {nodeId}: {results[0]}");
|
LogHelper.Info($"OPC写入:nodeid:{nodeId},value:{val}", "OPC");
|
}
|
else
|
{
|
Console.WriteLine("The session is not connected to the OPC UA server.");
|
LogHelper.Info($"OPC连接失败", "OPC");
|
CreateUpcSession();
|
}
|
|
}
|
catch (Exception e)
|
{
|
LogHelper.Info($"写入OPC数据异常" + e.Message, "OPC");
|
}
|
}
|
}
|
}
|
