如何使用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服务器的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事件处理程序将被调用，并在控制台上显示新值。

0 赞

0 踩