乐工具技术知识要在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事件处理程序将被调用，并在控制台上显示新值。
