阅读量:0
要在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服务器的URL string 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"); // 更改为您的变量节点ID MonitoredItem 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事件处理程序将被调用，并在控制台上显示新值。
