OPC UA C#的订阅与发布模式

在OPC UA中，订阅与发布模式是一种常用的通信模式，用于在客户端和服务器之间实现实时数据传输。下面是一个简单的示例，演示如何在C#中使用OPC UA库实现订阅与发布模式：

1. 首先，需要引用OPC UA库。可以通过NuGet包管理器安装"Opc.Ua"库。

2. 创建一个OPC UA客户端，并连接到OPC UA服务器：

using Opc.Ua;
using Opc.Ua.Client;

Uri serverUri = new Uri("opc.tcp://localhost:4840");
var endpoint = new ConfiguredEndpoint(null, new EndpointDescription(serverUri));
var session = Session.Create(null, endpoint, false, "OPC UA Client", 60000, new UserIdentity(new AnonymousIdentityToken()), null).Result;
session.ReturnDiagnostics = DiagnosticsMasks.All;

3. 创建一个订阅对象，并添加订阅回调函数：

var subscription = new Subscription(session.DefaultSubscription) { PublishingInterval = 1000 };
subscription.Create();
subscription.AddItems(new MonitoredItem(new ReadValueId { NodeId = "ns=2;i=1", AttributeId = Attributes.Value }, MonitoringMode.Reporting, new MonitoringParameters { ClientHandle = 1, QueueSize = 1, DiscardOldest = true }));
subscription.AddItems(new MonitoredItem(new ReadValueId { NodeId = "ns=2;i=2", AttributeId = Attributes.Value }, MonitoringMode.Reporting, new MonitoringParameters { ClientHandle = 2, QueueSize = 1, DiscardOldest = true }));

subscription.Notification += (sender, args) =>
{
    foreach (var notification in args.MonitoredItems)
    {
        Console.WriteLine($"Node: {notification.StartNodeId} Value: {notification.Value}");
    }
};

4. 启动订阅，并等待数据更新：

subscription.ApplyChanges();
subscription.SetPublishingMode(true);
session.KeepAlive += (sender, args) => session.KeepAlive();

通过以上步骤，我们实现了一个简单的OPC UA订阅与发布模式的示例。在实际应用中，可以根据需求添加更多订阅项和处理逻辑。