要在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
事件处理程序将被调用,并在控制台上显示新值。