如何使用C#实现OPC UA订阅功能

要在C#中实现OPC UA订阅功能，您需要使用OPC UA客户端库。以下是一个简单的示例，展示了如何使用OPC UA客户端库实现订阅功能：

首先，安装OPC UA客户端库。您可以使用NuGet包管理器安装OPCFoundation.NetStandard.Opc.Ua.Client库。在Visual Studio中，右键单击项目，然后选择“管理NuGet程序包”。在“浏览”选项卡中搜索并安装OPCFoundation.NetStandard.Opc.Ua.Client库。

创建一个新的C#控制台应用程序项目。

在Program.cs文件中，添加以下命名空间引用：

using Opc.Ua;using Opc.Ua.Client;using System;using System.Threading.Tasks;

在Main方法中，添加以下代码以连接到OPC UA服务器并创建一个会话：

// 设置OPC UA服务器的URLstring serverUrl = "opc.tcp://localhost:4840";// 创建一个应用程序配置ApplicationConfiguration config = new ApplicationConfiguration();config.ApplicationName = "OPC UA Client";config.ApplicationType = ApplicationType.Client;config.SecurityConfiguration = new SecurityConfiguration { ApplicationCertificate = new CertificateIdentifier { StoreType = @"Directory", StorePath = @"%CommonApplicationData%\OPC Foundation\CertificateStores\MachineDefault", SubjectName = Utils.Format(@"CN={0}, DC={1}", config.ApplicationName, Environment.UserDomainName) }, 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" } };config.TransportConfigurations = new TransportConfigurationCollection();config.TransportQuotas = new TransportQuotas { OperationTimeout = 15000 };// 创建一个会话Session session = null;try{    session = Session.Create(config, new ConfiguredEndpoint(null, new EndpointDescription(serverUrl)), false, "", 60000, null, null).Result;}catch (Exception ex){    Console.WriteLine("连接失败: " + ex.Message);    return;}

在Main方法中，添加以下代码以创建一个订阅并添加一个监视项：

// 创建一个订阅Subscription subscription = new Subscription(session.DefaultSubscription) { PublishingInterval = 1000 };// 添加一个监视项NodeId nodeId = new NodeId("ns=2;s=MyVariable"); // 更改为您的变量节点IDMonitoredItem monitoredItem = new MonitoredItem(subscription.DefaultItem) { StartNodeId = nodeId, AttributeId = Attributes.Value };monitoredItem.Notification += OnNotification;subscription.AddItem(monitoredItem);// 应用订阅更改subscription.ApplyChanges();

创建一个名为OnNotification的事件处理程序，该处理程序将在收到通知时调用：

private static void OnNotification(MonitoredItem monitoredItem, MonitoredItemNotificationEventArgs e){    foreach (var notification in e.NotificationValue.NotificationData)    {        if (notification is DataChangeNotification dataChangeNotification)        {            foreach (var monitoredItemNotification in dataChangeNotification.MonitoredItEMS)            {                Console.WriteLine($"变量值已更改: {monitoredItemNotification.ItemToMonitor.NodeId} - {monitoredItemNotification.Value.WrappedValue}");            }        }    }}

在Main方法中，添加以下代码以保持应用程序运行，直到用户按下Enter键：

Console.WriteLine("按Enter键退出...");Console.ReadLine();

最后，关闭会话并释放资源：

// 关闭会话if (session != null){    session.Close();    session.Dispose();}

现在，您已经创建了一个简单的C# OPC UA客户端，它可以连接到OPC UA服务器并订阅变量的更改。当变量值发生更改时，OnNotification事件处理程序将被调用，并在控制台上显示新值。