OPCuaClientPLC.cs 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725
  1. using Opc.Ua;
  2. using Opc.Ua.Client;
  3. using OpcUaHelper;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Linq;
  7. using System.Text;
  8. using System.Threading;
  9. using System.Threading.Tasks;
  10. using TeamAAS_VP.Enums;
  11. using TeamAAS_VP.Interfaces;
  12. using TeamAAS_VP.Models;
  13. namespace TeamAAS_VP.Core.PLCs
  14. {
  15. /// <summary>
  16. /// OPC UA 节点订阅模式。
  17. /// </summary>
  18. public enum OpcUaSubscriptionMode
  19. {
  20. /// <summary>
  21. /// 使用 OPC UA 原生订阅机制,由服务端主动推送节点变更。
  22. /// </summary>
  23. Native,
  24. /// <summary>
  25. /// 使用客户端轮询方式定时读取节点值,并在检测到变化时触发通知。
  26. /// </summary>
  27. CustomPolling
  28. }
  29. /// <summary>
  30. /// OPC UA 订阅配置选项,用于控制订阅模式、轮询间隔以及首次扫描通知行为。
  31. /// </summary>
  32. public class OpcUaSubscriptionOptions
  33. {
  34. /// <summary>
  35. /// 获取或设置订阅模式。
  36. /// 默认为 <see cref="OpcUaSubscriptionMode.Native"/>。
  37. /// </summary>
  38. public OpcUaSubscriptionMode Mode { get; set; } = OpcUaSubscriptionMode.Native;
  39. /// <summary>
  40. /// 获取或设置轮询间隔,单位为毫秒。
  41. /// 仅在 <see cref="Mode"/> 为 <see cref="OpcUaSubscriptionMode.CustomPolling"/> 时生效。
  42. /// 默认值为 50。
  43. /// </summary>
  44. public int PollingInterval { get; set; } = 50;
  45. /// <summary>
  46. /// 获取或设置首次扫描时是否立即通知当前值。
  47. /// 仅在自定义轮询订阅模式下生效。
  48. /// </summary>
  49. public bool NotifyOnFirstScan { get; set; }
  50. }
  51. public class OpcUaClientPLC : IPlc
  52. {
  53. private readonly object _pollingSubscriptionLock = new object();
  54. private readonly Dictionary<string, PollingSubscriptionContext> _pollingSubscriptions = new Dictionary<string, PollingSubscriptionContext>();
  55. public Guid Id{ get; private set; }
  56. public CommunicationType CommunicationType { get; private set; }
  57. public string EndpointUrl { get; private set; }
  58. public int Index { get; set; }
  59. public string Name { get; private set; }
  60. public OpcUaClient OpcUaClient { get; private set; }
  61. public bool IsConnected { get { return OpcUaClient.Connected; } }
  62. /// <summary>
  63. /// 节点头
  64. /// </summary>
  65. public string NodeHeader { get; private set; }
  66. /// <summary>
  67. /// 获取或设置默认的节点订阅模式。
  68. /// 在未显式传入订阅选项时,`SubscribeNodes` 将使用该模式决定采用 OPC UA 原生订阅还是客户端轮询订阅。
  69. /// 默认值为 <see cref="OpcUaSubscriptionMode.Native"/>。
  70. /// </summary>
  71. //public OpcUaSubscriptionMode DefaultSubscriptionMode { get; set; } = OpcUaSubscriptionMode.CustomPolling;
  72. public OpcUaSubscriptionMode DefaultSubscriptionMode { get; set; } = OpcUaSubscriptionMode.Native;
  73. /// <summary>
  74. /// 获取或设置默认的订阅轮询间隔,单位为毫秒。
  75. /// 仅当默认订阅模式或实际订阅选项使用自定义轮询时生效。
  76. /// 默认值为 `100`。
  77. /// </summary>
  78. public int DefaultSubscriptionPollingInterval { get; set; } = 50;
  79. /// <summary>
  80. /// 获取或设置在默认轮询订阅模式下,首次扫描节点时是否立即触发一次数据变更通知。
  81. /// </summary>
  82. public bool DefaultNotifyOnFirstScan { get; set; }
  83. /// <summary>
  84. /// PLC 连接状态变化事件。
  85. /// 当 OPC UA 客户端完成连接、开始重连或重连完成时触发,第二个参数表示当前连接状态。
  86. /// </summary>
  87. public event Action<object, bool> ConnectChangedEvent;
  88. /// <summary>
  89. /// 轮询订阅上下文。
  90. /// 用于保存某个自定义轮询订阅任务的节点集合、上次读取值、回调处理器以及取消控制信息。
  91. /// </summary>
  92. private class PollingSubscriptionContext
  93. {
  94. /// <summary>
  95. /// 订阅唯一标识,用于区分不同的订阅任务。
  96. /// </summary>
  97. public string Key { get; set; }
  98. /// <summary>
  99. /// 当前订阅需要轮询的节点集合。
  100. /// </summary>
  101. public List<string> NodeIds { get; set; }
  102. /// <summary>
  103. /// 记录每个节点上一次读取到的值,用于比较是否发生变化。
  104. /// </summary>
  105. public Dictionary<string, object> LastValues { get; } = new Dictionary<string, object>();
  106. /// <summary>
  107. /// 节点值发生变化时执行的回调委托。
  108. /// </summary>
  109. public Action<(string key, string nodeId, object value)> DataChangeHandler { get; set; }
  110. /// <summary>
  111. /// 用于控制轮询任务取消的令牌源。
  112. /// </summary>
  113. public CancellationTokenSource CancellationTokenSource { get; set; }
  114. /// <summary>
  115. /// 轮询周期,单位为毫秒。
  116. /// </summary>
  117. public int PollingInterval { get; set; }
  118. /// <summary>
  119. /// 指示首次扫描时是否立即上报当前节点值。
  120. /// </summary>
  121. public bool NotifyOnFirstScan { get; set; }
  122. }
  123. public OpcUaClientPLC(Guid id,int index, string name, string endpointUrl,string nodeHeader, CommunicationType communicationType)
  124. {
  125. Id = id;
  126. Index = index;
  127. Name = name;
  128. EndpointUrl = endpointUrl;
  129. NodeHeader = nodeHeader;
  130. CommunicationType = communicationType;
  131. OpcUaClient = new OpcUaClient();
  132. // 初始化PLC连接
  133. OpcUaClient.UserIdentity = new UserIdentity(new AnonymousIdentityToken());
  134. // connect to server, this is a sample
  135. try
  136. {
  137. OpcUaClient.ConnectComplete += OpcUaClient_ConnectComplete;
  138. OpcUaClient.ReconnectStarting += OpcUaClient_ReconnectStarting;
  139. OpcUaClient.ReconnectComplete += OpcUaClient_ReconnectComplete;
  140. OpcUaClient.OpcStatusChange += OpcUaClient_OpcStatusChange;
  141. }
  142. catch (Exception)
  143. {
  144. return;
  145. }
  146. }
  147. public OpcUaClientPLC(PlcInfo plcInfo)
  148. {
  149. Id = plcInfo.Id;
  150. Index=plcInfo.Index;
  151. Name = plcInfo.Name;
  152. NodeHeader=plcInfo.NodeHeader;
  153. EndpointUrl = plcInfo.EndpointUrl;
  154. CommunicationType = plcInfo.CommunicationType;
  155. OpcUaClient = new OpcUaClient();
  156. // 初始化PLC连接
  157. OpcUaClient.UserIdentity = new UserIdentity(new AnonymousIdentityToken());
  158. // connect to server, this is a sample
  159. try
  160. {
  161. OpcUaClient.ConnectComplete += OpcUaClient_ConnectComplete;
  162. OpcUaClient.ReconnectStarting += OpcUaClient_ReconnectStarting;
  163. OpcUaClient.ReconnectComplete += OpcUaClient_ReconnectComplete;
  164. OpcUaClient.OpcStatusChange += OpcUaClient_OpcStatusChange;
  165. }
  166. catch (Exception)
  167. {
  168. return;
  169. }
  170. }
  171. public void Connect()
  172. {
  173. OpcUaClient.ConnectServer(EndpointUrl);
  174. }
  175. public Task ConnectAsync()
  176. {
  177. return OpcUaClient.ConnectServer(EndpointUrl);
  178. }
  179. public void Disconnect()
  180. {
  181. OpcUaClient.Disconnect();
  182. }
  183. public void Dispose()
  184. {
  185. StopAllPollingSubscriptions();
  186. OpcUaClient.Disconnect();
  187. OpcUaClient.ConnectComplete -= OpcUaClient_ConnectComplete;
  188. OpcUaClient.ReconnectStarting -= OpcUaClient_ReconnectStarting;
  189. OpcUaClient.ReconnectComplete -= OpcUaClient_ReconnectComplete;
  190. OpcUaClient.OpcStatusChange -= OpcUaClient_OpcStatusChange;
  191. }
  192. /// <summary>
  193. /// 读取多个节点的值
  194. /// </summary>
  195. /// <param name="nodeIds"></param>
  196. /// <returns></returns>
  197. public Dictionary<string, object> ReadNodes(string[] nodeIds)
  198. {
  199. var result = new Dictionary<string, object>();
  200. var readNodeIds = nodeIds.Select(s =>
  201. {
  202. if (s.StartsWith(NodeHeader))
  203. {
  204. return s;
  205. }
  206. else
  207. {
  208. return NodeHeader + s;
  209. }
  210. }).ToArray();
  211. List<NodeId> readNodeIdList = new List<NodeId>();
  212. foreach (var readNodeId in readNodeIds)
  213. {
  214. readNodeIdList.Add(new NodeId(readNodeId));
  215. }
  216. var values = OpcUaClient.ReadNodes(readNodeIdList.ToArray());
  217. for (int i = 0; i < nodeIds.Length; i++)
  218. {
  219. result[nodeIds[i]] = values[i].Value;
  220. }
  221. return result;
  222. }
  223. /// <summary>
  224. /// 异步读取多个节点的值
  225. /// </summary>
  226. /// <param name="nodeIds"></param>
  227. /// <returns></returns>
  228. public async Task<Dictionary<string, object>> ReadNodesAsync(string[] nodeIds)
  229. {
  230. var result = new Dictionary<string, object>();
  231. var readNodeIds = nodeIds.Select(s =>
  232. {
  233. if (s.StartsWith(NodeHeader))
  234. {
  235. return s;
  236. }
  237. else
  238. {
  239. return NodeHeader + s;
  240. }
  241. }).ToArray();
  242. List<NodeId> readNodeIdList = new List<NodeId>();
  243. foreach (var readNodeId in readNodeIds)
  244. {
  245. readNodeIdList.Add(new NodeId(readNodeId));
  246. }
  247. var values = await OpcUaClient.ReadNodesAsync(readNodeIdList.ToArray());
  248. for (int i = 0; i < nodeIds.Length; i++)
  249. {
  250. result[nodeIds[i]] = values[i].Value;
  251. }
  252. return result;
  253. }
  254. /// <summary>
  255. /// 读取单个PLC Bool布尔节点值
  256. /// </summary>
  257. /// <param name="nodeId">Excel里PLC变量名 Stop.XXX</param>
  258. /// <returns>bool类型真实状态</returns>
  259. public bool ReadBoolNode(string nodeId)
  260. {
  261. string readNodeId = nodeId;
  262. if (!nodeId.StartsWith(NodeHeader))
  263. {
  264. readNodeId = NodeHeader + nodeId;
  265. }
  266. var value = OpcUaClient.ReadNode(new NodeId(readNodeId));
  267. // 安全转换为布尔类型
  268. return Convert.ToBoolean(value.Value);
  269. }
  270. /// <summary>
  271. /// 读取单个节点的值
  272. /// </summary>
  273. /// <param name="nodeId"></param>
  274. /// <returns></returns>
  275. public object ReadNode(string nodeId)
  276. {
  277. string readNodeId = nodeId;
  278. if (!nodeId.StartsWith(NodeHeader))
  279. {
  280. readNodeId = NodeHeader + nodeId;
  281. }
  282. var value = OpcUaClient.ReadNode(new NodeId(readNodeId));
  283. return value.Value;
  284. }
  285. /// <summary>
  286. /// 异步读取单个节点的值
  287. /// </summary>
  288. /// <param name="nodeId"></param>
  289. /// <returns></returns>
  290. public Task<object> ReadNodeAsync(string nodeId)
  291. {
  292. return Task.Run(() =>
  293. {
  294. return ReadNode(nodeId);
  295. });
  296. }
  297. /// <summary>
  298. /// 读取单个节点的值
  299. /// </summary>
  300. /// <typeparam name="T"></typeparam>
  301. /// <param name="nodeId"></param>
  302. /// <returns></returns>
  303. public T ReadNode<T>(string nodeId)
  304. {
  305. string readNodeId = nodeId;
  306. if (!nodeId.StartsWith(NodeHeader))
  307. {
  308. readNodeId = NodeHeader + nodeId;
  309. }
  310. return OpcUaClient.ReadNode<T>(readNodeId);
  311. }
  312. /// <summary>
  313. /// 异步读取单个节点的值
  314. /// </summary>
  315. /// <typeparam name="T"></typeparam>
  316. /// <param name="nodeId"></param>
  317. /// <returns></returns>
  318. public async Task<T> ReadNodeAsync<T>(string nodeId)
  319. {
  320. string readNodeId = nodeId;
  321. if (!nodeId.StartsWith(NodeHeader))
  322. {
  323. readNodeId = NodeHeader + nodeId;
  324. }
  325. return await OpcUaClient.ReadNodeAsync<T>(readNodeId);
  326. }
  327. /// <summary>
  328. /// 写入单个节点的值
  329. /// </summary>
  330. /// <typeparam name="T"></typeparam>
  331. /// <param name="nodeId"></param>
  332. /// <param name="value"></param>
  333. /// <returns></returns>
  334. public bool WriteNode<T>(string nodeId, T value)
  335. {
  336. string writeNodeId = nodeId;
  337. if (!nodeId.StartsWith(NodeHeader))
  338. {
  339. writeNodeId = NodeHeader + nodeId;
  340. }
  341. return OpcUaClient.WriteNode<T>(writeNodeId, value);
  342. }
  343. /// <summary>
  344. /// 异步写入单个节点的值
  345. /// </summary>
  346. /// <typeparam name="T"></typeparam>
  347. /// <param name="nodeId"></param>
  348. /// <param name="value"></param>
  349. /// <returns></returns>
  350. public async Task<bool> WriteNodeAsync<T>(string nodeId, T value)
  351. {
  352. string writeNodeId = nodeId;
  353. if (!nodeId.StartsWith(NodeHeader))
  354. {
  355. writeNodeId = NodeHeader + nodeId;
  356. }
  357. return await OpcUaClient.WriteNodeAsync<T>(writeNodeId, value);
  358. }
  359. /// <summary>
  360. /// 写入多个节点
  361. /// </summary>
  362. /// <param name="nodeValues"></param>
  363. /// <returns></returns>
  364. public bool WriteNodes(Dictionary<string, object> nodeValues)
  365. {
  366. var writeNodeValues = new Dictionary<string, object>();
  367. foreach (var kvp in nodeValues)
  368. {
  369. string writeNodeId = kvp.Key;
  370. if (!kvp.Key.StartsWith(NodeHeader))
  371. {
  372. writeNodeId = NodeHeader + kvp.Key;
  373. }
  374. writeNodeValues[writeNodeId] = kvp.Value;
  375. }
  376. return OpcUaClient.WriteNodes(writeNodeValues.Keys.ToArray(), writeNodeValues.Values.ToArray());
  377. }
  378. /// <summary>
  379. /// 写入多个节点异步
  380. /// </summary>
  381. /// <param name="nodeValues"></param>
  382. /// <returns></returns>
  383. public Task<bool> WriteNodesAsync(Dictionary<string, object> nodeValues)
  384. {
  385. return Task.Run(() =>
  386. {
  387. return WriteNodes(nodeValues);
  388. });
  389. }
  390. /// <summary>
  391. /// 使用当前实例的默认订阅配置订阅多个节点。
  392. /// </summary>
  393. /// <param name="key">订阅唯一标识,用于区分和管理同一客户端上的不同订阅任务。</param>
  394. /// <param name="nodeIds">需要订阅的节点标识集合,可传入带或不带 <see cref="NodeHeader"/> 前缀的节点名。</param>
  395. /// <param name="dataChangeHandler">节点值变化时触发的回调,返回订阅键、节点标识和值。</param>
  396. public void SubscribeNodes(string key, List<string> nodeIds, Action<(string key,string nodeId,object value)> dataChangeHandler)
  397. {
  398. SubscribeNodes(key, nodeIds, dataChangeHandler, new OpcUaSubscriptionOptions
  399. {
  400. Mode = DefaultSubscriptionMode,
  401. PollingInterval = DefaultSubscriptionPollingInterval,
  402. NotifyOnFirstScan = DefaultNotifyOnFirstScan
  403. });
  404. }
  405. /// <summary>
  406. /// 根据传入的OpcUaSubscriptionMode选项订阅多个节点
  407. /// </summary>
  408. /// <param name="key"></param>
  409. /// <param name="nodeIds"></param>
  410. /// <param name="dataChangeHandler"></param>
  411. /// <param name="mode"></param>
  412. public void SubscribeNodes(string key, List<string> nodeIds, Action<(string key, string nodeId, object value)> dataChangeHandler, OpcUaSubscriptionMode mode)
  413. {
  414. var options = new OpcUaSubscriptionOptions
  415. {
  416. Mode = mode,
  417. PollingInterval = DefaultSubscriptionPollingInterval,
  418. NotifyOnFirstScan = DefaultNotifyOnFirstScan
  419. };
  420. SubscribeNodes(key, nodeIds, dataChangeHandler, options);
  421. }
  422. /// <summary>
  423. /// 根据指定订阅选项订阅多个节点。
  424. /// </summary>
  425. /// <remarks>
  426. /// 该方法会先停止同一 <paramref name="key"/> 对应的轮询订阅,再根据 <paramref name="options"/> 中的模式
  427. /// 选择使用 OPC UA 原生订阅或客户端轮询订阅。节点列表会自动去重并忽略空白项。
  428. /// </remarks>
  429. /// <param name="key">订阅唯一标识,不能为空或仅包含空白字符。</param>
  430. /// <param name="nodeIds">待订阅的节点集合。</param>
  431. /// <param name="dataChangeHandler">节点值变化通知回调。</param>
  432. /// <param name="options">订阅配置;为 <c>null</c> 时使用默认配置。</param>
  433. /// <exception cref="ArgumentException"><paramref name="key"/> 为空或仅包含空白字符时抛出。</exception>
  434. /// <exception cref="ArgumentNullException"><paramref name="nodeIds"/> 或 <paramref name="dataChangeHandler"/> 为 <c>null</c> 时抛出。</exception>
  435. public void SubscribeNodes(string key, List<string> nodeIds, Action<(string key, string nodeId, object value)> dataChangeHandler, OpcUaSubscriptionOptions options)
  436. {
  437. if (string.IsNullOrWhiteSpace(key))
  438. {
  439. throw new ArgumentException("订阅Key不能为空。", nameof(key));
  440. }
  441. if (nodeIds == null)
  442. {
  443. throw new ArgumentNullException(nameof(nodeIds));
  444. }
  445. if (dataChangeHandler == null)
  446. {
  447. throw new ArgumentNullException(nameof(dataChangeHandler));
  448. }
  449. var subscriptionOptions = options ?? new OpcUaSubscriptionOptions();
  450. var normalizedNodeIds = nodeIds.Where(s => !string.IsNullOrWhiteSpace(s)).Distinct().ToList();
  451. StopPollingSubscription(key);
  452. if (subscriptionOptions.Mode == OpcUaSubscriptionMode.CustomPolling)
  453. {
  454. StartPollingSubscription(key, normalizedNodeIds, dataChangeHandler, subscriptionOptions);
  455. return;
  456. }
  457. SubscribeNodesByOpc(key, normalizedNodeIds, dataChangeHandler);
  458. }
  459. /// <summary>
  460. /// 使用 OPC UA 原生订阅机制订阅节点。
  461. /// </summary>
  462. /// <remarks>
  463. /// 订阅前会自动补齐节点前缀;收到服务端推送后,会移除返回节点中的 <see cref="NodeHeader"/> 前缀,
  464. /// 再将变化值通过回调透出给业务层。
  465. /// </remarks>
  466. /// <param name="key">订阅唯一标识。</param>
  467. /// <param name="nodeIds">节点集合。</param>
  468. /// <param name="dataChangeHandler">节点值变化回调。</param>
  469. private void SubscribeNodesByOpc(string key, List<string> nodeIds, Action<(string key, string nodeId, object value)> dataChangeHandler)
  470. {
  471. OpcUaClient.AddSubscription(key, nodeIds.Select(s =>
  472. {
  473. return NormalizeNodeId(s);
  474. }).ToArray(), (key1, monitoredItem, args) =>
  475. {
  476. MonitoredItemNotification notification = args.NotificationValue as MonitoredItemNotification;
  477. if (notification == null)
  478. {
  479. return;
  480. }
  481. string nodeId = monitoredItem.StartNodeId.ToString();
  482. nodeId = TrimNodeHeader(nodeId);
  483. // 触发数据变化事件
  484. dataChangeHandler?.Invoke((key1, nodeId, notification.Value.WrappedValue.Value));
  485. });
  486. }
  487. /// <summary>
  488. /// 启动自定义轮询订阅任务。
  489. /// </summary>
  490. /// <remarks>
  491. /// 该方法会创建轮询上下文并登记到内部订阅字典中,然后在后台任务中执行轮询循环。
  492. /// 轮询间隔最小限制为 10 毫秒,以避免过于频繁的读取请求。
  493. /// </remarks>
  494. /// <param name="key">订阅唯一标识。</param>
  495. /// <param name="nodeIds">需要轮询的节点集合。</param>
  496. /// <param name="dataChangeHandler">节点值变化回调。</param>
  497. /// <param name="options">轮询订阅选项。</param>
  498. private void StartPollingSubscription(string key, List<string> nodeIds, Action<(string key, string nodeId, object value)> dataChangeHandler, OpcUaSubscriptionOptions options)
  499. {
  500. var context = new PollingSubscriptionContext
  501. {
  502. Key = key,
  503. NodeIds = nodeIds,
  504. DataChangeHandler = dataChangeHandler,
  505. CancellationTokenSource = new CancellationTokenSource(),
  506. PollingInterval = Math.Max(10, options.PollingInterval),
  507. NotifyOnFirstScan = options.NotifyOnFirstScan
  508. };
  509. lock (_pollingSubscriptionLock)
  510. {
  511. _pollingSubscriptions[key] = context;
  512. }
  513. Task.Run(() => PollingSubscriptionLoopAsync(context));
  514. }
  515. /// <summary>
  516. /// 执行轮询订阅的后台循环。
  517. /// </summary>
  518. /// <remarks>
  519. /// 当客户端已连接且存在待轮询节点时,循环会批量读取节点值,并与上次缓存值进行比较:
  520. /// 首次读取时根据配置决定是否立即通知,后续仅在值发生变化时触发回调。
  521. /// 当取消令牌触发或发生取消异常时,循环退出。
  522. /// </remarks>
  523. /// <param name="context">轮询订阅上下文。</param>
  524. /// <returns>表示异步轮询操作的任务。</returns>
  525. private async Task PollingSubscriptionLoopAsync(PollingSubscriptionContext context)
  526. {
  527. while (!context.CancellationTokenSource.IsCancellationRequested)
  528. {
  529. try
  530. {
  531. if (IsConnected && context.NodeIds.Count > 0)
  532. {
  533. var values = await ReadNodesAsync(context.NodeIds.ToArray()).ConfigureAwait(false);
  534. foreach (var nodeId in context.NodeIds)
  535. {
  536. object currentValue;
  537. if (!values.TryGetValue(nodeId, out currentValue))
  538. {
  539. continue;
  540. }
  541. object lastValue;
  542. if (!context.LastValues.TryGetValue(nodeId, out lastValue))
  543. {
  544. context.LastValues[nodeId] = currentValue;
  545. if (context.NotifyOnFirstScan)
  546. {
  547. context.DataChangeHandler?.Invoke((context.Key, nodeId, currentValue));
  548. }
  549. continue;
  550. }
  551. if (!Utils.IsEqual(lastValue, currentValue))
  552. {
  553. context.LastValues[nodeId] = currentValue;
  554. context.DataChangeHandler?.Invoke((context.Key, nodeId, currentValue));
  555. }
  556. }
  557. }
  558. }
  559. catch (OperationCanceledException)
  560. {
  561. break;
  562. }
  563. catch (Exception)
  564. {
  565. }
  566. try
  567. {
  568. await Task.Delay(context.PollingInterval, context.CancellationTokenSource.Token).ConfigureAwait(false);
  569. }
  570. catch (OperationCanceledException)
  571. {
  572. break;
  573. }
  574. }
  575. }
  576. /// <summary>
  577. /// 停止指定键对应的轮询订阅。
  578. /// </summary>
  579. /// <param name="key">要停止的订阅唯一标识。</param>
  580. private void StopPollingSubscription(string key)
  581. {
  582. PollingSubscriptionContext context = null;
  583. lock (_pollingSubscriptionLock)
  584. {
  585. if (_pollingSubscriptions.TryGetValue(key, out context))
  586. {
  587. _pollingSubscriptions.Remove(key);
  588. }
  589. }
  590. context?.CancellationTokenSource.Cancel();
  591. context?.CancellationTokenSource.Dispose();
  592. }
  593. /// <summary>
  594. /// 停止并清理当前实例中的所有轮询订阅。
  595. /// </summary>
  596. private void StopAllPollingSubscriptions()
  597. {
  598. List<PollingSubscriptionContext> contexts;
  599. lock (_pollingSubscriptionLock)
  600. {
  601. contexts = _pollingSubscriptions.Values.ToList();
  602. _pollingSubscriptions.Clear();
  603. }
  604. foreach (var context in contexts)
  605. {
  606. context.CancellationTokenSource.Cancel();
  607. context.CancellationTokenSource.Dispose();
  608. }
  609. }
  610. /// <summary>
  611. /// 规范化节点标识,确保其包含节点头前缀。
  612. /// </summary>
  613. /// <param name="nodeId">原始节点标识。</param>
  614. /// <returns>包含 <see cref="NodeHeader"/> 前缀的完整节点标识。</returns>
  615. private string NormalizeNodeId(string nodeId)
  616. {
  617. if (nodeId.StartsWith(NodeHeader))
  618. {
  619. return nodeId;
  620. }
  621. return NodeHeader + nodeId;
  622. }
  623. /// <summary>
  624. /// 去除节点标识中的节点头前缀。
  625. /// </summary>
  626. /// <param name="nodeId">完整节点标识。</param>
  627. /// <returns>移除 <see cref="NodeHeader"/> 前缀后的节点标识;若原值不包含此前缀则直接返回原值。</returns>
  628. private string TrimNodeHeader(string nodeId)
  629. {
  630. if (nodeId.StartsWith(NodeHeader))
  631. {
  632. return nodeId.Substring(NodeHeader.Length);
  633. }
  634. return nodeId;
  635. }
  636. #region OPC事件
  637. private void OpcUaClient_OpcStatusChange(object sender, OpcUaStatusEventArgs e)
  638. {
  639. //LogHelper.WriteLogInfo($"OPC状态发生改变:Error:{e.Error},Time:{e.Time},Text:{e.Text}");
  640. }
  641. private void OpcUaClient_ReconnectComplete(object sender, EventArgs e)
  642. {
  643. ConnectChangedEvent?.Invoke(this, OpcUaClient.Connected);
  644. }
  645. private void OpcUaClient_ReconnectStarting(object sender, EventArgs e)
  646. {
  647. ConnectChangedEvent?.Invoke(this, OpcUaClient.Connected);
  648. }
  649. private void OpcUaClient_ConnectComplete(object sender, EventArgs e)
  650. {
  651. ConnectChangedEvent?.Invoke(this, OpcUaClient.Connected);
  652. }
  653. #endregion
  654. }
  655. }