OPC UA C#的訂閱與發(fā)布模式

c#
小樊
151
2024-08-08 22:26:40

在OPC UA中，訂閱與發(fā)布模式是一種常用的通信模式，用于在客戶端和服務(wù)器之間實(shí)現(xiàn)實(shí)時(shí)數(shù)據(jù)傳輸。下面是一個(gè)簡(jiǎn)單的示例，演示如何在C#中使用OPC UA庫(kù)實(shí)現(xiàn)訂閱與發(fā)布模式：

  1. 首先，需要引用OPC UA庫(kù)?？梢酝ㄟ^NuGet包管理器安裝"Opc.Ua"庫(kù)。

  2. 創(chuàng)建一個(gè)OPC UA客戶端，并連接到OPC UA服務(wù)器：

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;
  1. 創(chuàng)建一個(gè)訂閱對(duì)象，并添加訂閱回調(diào)函數(shù)：
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}");
    }
};
  1. 啟動(dòng)訂閱，并等待數(shù)據(jù)更新：
subscription.ApplyChanges();
subscription.SetPublishingMode(true);
session.KeepAlive += (sender, args) => session.KeepAlive();

通過以上步驟，我們實(shí)現(xiàn)了一個(gè)簡(jiǎn)單的OPC UA訂閱與發(fā)布模式的示例。在實(shí)際應(yīng)用中，可以根據(jù)需求添加更多訂閱項(xiàng)和處理邏輯。

0 踩