关于OPC-UA客户端调用服务端方法CallMethod节点的问题

2024-03-16 02:04

本文主要是介绍关于OPC-UA客户端调用服务端方法CallMethod节点的问题,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在OpcUaClient中可以通过CallMethodByNodeId调用方法节点

        //// 摘要://     call a server method//// 参数://   tagParent://     方法的父节点tag////   tag://     方法的节点tag////   args://     传递的参数//// 返回结果://     输出的结果值public object[] CallMethodByNodeId(string tagParent, string tag, params object[] args);

注意,调用方法节点时,必须传入指定的参数类型的值,不能传入可以隐式转化的实参

比如在OpcServer服务器上有个方法节点,方法名为readJob,需要传入两个参数 (byte sourceNumber, short jobNo),返回一个工作名称string jobName
       方法整体描述为 string readJob(byte sourceNumber, short jobNo)

传入的实参 new object[]{1,23};会抛出异常,因1和23在C#中是Int32类型,不是byte,short类型

如果需要调用成功,传入的实参必须是new object[]{(byte)1, (short)23};

一、新建Winform应用程序OpcUaCallMethodDemo,将默认的Form1修改为FormOpcUaCallMethod。

并添加Opc客户端类库的引用以及其他必须相关类库文件。

OpcUaHelper.dll

Opc.Ua.Core.dll

Opc.Ua.Client.dll

二、新建类GumOpcUaClientUtil,用于连接Opc服务已经读写标签,调用Opc方法等

GumOpcUaClientUtil.cs源代码下:

using Opc.Ua;
using OpcUaHelper;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;namespace OpcUaCallMethodDemo
{/// <summary>/// 涂胶OPC客户端:连接OPC服务端,读、写标签操作/// </summary>public class GumOpcUaClientUtil{/// <summary>/// 定义一个操作OPC的客户端对象/// </summary>private static OpcUaClient m_OpcUaClient = new OpcUaClient();/// <summary>/// 连接到Opc服务端/// </summary>/// <param name="serverAddress"></param>/// <param name="enabledAnonymousLogin"></param>/// <param name="loginUserName"></param>/// <param name="loginPassword"></param>/// <returns></returns>public static bool ConnectOpcServer(string serverAddress, bool enabledAnonymousLogin, string loginUserName, string loginPassword, Action<string> LogToShow){bool isConnected = false;if (enabledAnonymousLogin){//匿名登录m_OpcUaClient.UserIdentity = new UserIdentity(new AnonymousIdentityToken());}else{//用户名密码登录m_OpcUaClient.UserIdentity = new UserIdentity(loginUserName, loginPassword);}try{LogToShow($"准备连接OPC服务端【{serverAddress}】,匿名登录【{enabledAnonymousLogin}】,用户名【{loginUserName}】,密码【{loginPassword}】");Task task = m_OpcUaClient.ConnectServer(serverAddress);task.Wait(5000);isConnected = m_OpcUaClient.Connected;//HansCommon.SysMsg.MySystemMsg.LogToShow($"获取到 连接OPC服务端【{serverAddress}】结果:{isConnected}", true);}catch (Exception ex){string exMsg = $"连接OPC服务【{serverAddress}】失败,错误原因:{ex.Message}";LogToShow(exMsg);MessageBox.Show(exMsg, "错误");}return isConnected;}/// <summary>/// 断开OPC服务/// </summary>public static void Disconnect(){m_OpcUaClient.RemoveAllSubscription();m_OpcUaClient.Disconnect();}/// <summary>/// 调用OPC的方法/// </summary>/// <param name="tagParent">方法的父标签路径</param>/// <param name="methodName">方法的标签全路径</param>/// <param name="args">参数列表,没有参数请输入null</param>/// <returns></returns>public static object[] CallMethodNode(Action<string> LogToShow, string tagParent, string methodName, params object[] args) {try{object[] methodResult = m_OpcUaClient.CallMethodByNodeId(tagParent, methodName, args);return methodResult;}catch (Exception ex){MessageBox.Show(ex.Message);LogToShow($"调用OPC的方法时出错{ex.Message}");return null;}}/// <summary>/// 读取某一个标签/// </summary>/// <typeparam name="T"></typeparam>/// <param name="tagName"></param>/// <returns></returns>public static bool ReadTagNode<T>(string tagName, Action<string> LogToShow, out T tResult){tResult = default(T);DataValue dataValue = m_OpcUaClient.ReadNode(new NodeId(tagName));if (dataValue == null || dataValue.WrappedValue == Variant.Null){string exMsg = $"[{tagName}]项读取失败,可能是①未连接的opc服务或者连接已断开.②标签路径或数据类型设置错误,注意:标签名区分大小写.③没有权限读取数据";LogToShow(exMsg);return false;}else{object objValue = dataValue.WrappedValue.Value;tResult = (T)objValue;}return true;}public static object ReadTagNode(string tagName, Action<string> LogToShow){DataValue dataValue = m_OpcUaClient.ReadNode(new NodeId(tagName));if (dataValue == null || dataValue.WrappedValue == Variant.Null){string exMsg = $"[{tagName}]项读取失败,可能是①未连接的opc服务或者连接已断开.②标签路径或数据类型设置错误,注意:标签名区分大小写.③没有权限读取数据";LogToShow(exMsg);return null;}else{object objValue = dataValue.WrappedValue.Value;return objValue;}}/// <summary>/// 批量读取/// </summary>/// <typeparam name="T"></typeparam>/// <param name="tagNames"></param>/// <returns></returns>public static List<T> ReadNodeList<T>(string[] tagNames, Action<string> LogToShow){try{List<T> list = m_OpcUaClient.ReadNodes<T>(tagNames);return list;}catch (Exception ex){string exMsg = $"批量读取节点集合出错【{string.Join(",", tagNames)}】,可能是①未连接的opc服务或者连接已断开.②存在标签路径或数据类型设置错误,注意:标签名区分大小写.③没有权限读取数据.异常信息:{ex.Message}";LogToShow(exMsg);throw new Exception(exMsg);}}/// <summary>/// 为指定的标签写入指定类型的值。注意:【写入的标签名 和 写入的值的类型一定要和服务端保持一致】/// </summary>/// <typeparam name="T"></typeparam>/// <param name="tagName"></param>/// <param name="value"></param>/// <returns></returns>public static bool WriteTagNode<T>(string tagName, Action<string> LogToShow, T value){try{return m_OpcUaClient.WriteNode(tagName, value);}catch (Exception ex){string exMsg = $"【{tagName}】项写入【{value}】失败,【写入的标签名 和 写入的值的类型一定要和服务端保持一致】.异常信息:{ex.Message}";LogToShow(exMsg);throw new Exception(exMsg);}}}
}

三、窗体FormOpcUaCallMethod设计器代码如下:

文件FormOpcUaCallMethod.Designer.cs


namespace OpcUaCallMethodDemo
{partial class FormOpcUaCallMethod{/// <summary>/// 必需的设计器变量。/// </summary>private System.ComponentModel.IContainer components = null;/// <summary>/// 清理所有正在使用的资源。/// </summary>/// <param name="disposing">如果应释放托管资源,为 true;否则为 false。</param>protected override void Dispose(bool disposing){if (disposing && (components != null)){components.Dispose();}base.Dispose(disposing);}#region Windows 窗体设计器生成的代码/// <summary>/// 设计器支持所需的方法 - 不要修改/// 使用代码编辑器修改此方法的内容。/// </summary>private void InitializeComponent(){this.rtxtMessage = new System.Windows.Forms.RichTextBox();this.btnConnect = new System.Windows.Forms.Button();this.SuspendLayout();// // rtxtMessage// this.rtxtMessage.Location = new System.Drawing.Point(249, 12);this.rtxtMessage.Name = "rtxtMessage";this.rtxtMessage.ReadOnly = true;this.rtxtMessage.Size = new System.Drawing.Size(700, 495);this.rtxtMessage.TabIndex = 0;this.rtxtMessage.Text = "";// // btnConnect// this.btnConnect.Location = new System.Drawing.Point(27, 72);this.btnConnect.Name = "btnConnect";this.btnConnect.Size = new System.Drawing.Size(152, 36);this.btnConnect.TabIndex = 1;this.btnConnect.Text = "连接Opc服务端并测试";this.btnConnect.UseVisualStyleBackColor = true;this.btnConnect.Click += new System.EventHandler(this.btnConnect_Click);// // FormOpcUaCallMethod// this.AutoScaleDimensions = new System.Drawing.SizeF(6F, 12F);this.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Font;this.ClientSize = new System.Drawing.Size(1018, 531);this.Controls.Add(this.btnConnect);this.Controls.Add(this.rtxtMessage);this.Name = "FormOpcUaCallMethod";this.Text = "使用OpcUaCallMethod调用OpcServer的方法节点";this.ResumeLayout(false);}#endregionprivate System.Windows.Forms.RichTextBox rtxtMessage;private System.Windows.Forms.Button btnConnect;}
}

窗体FormOpcUaCallMethod代码如下:

文件FormOpcUaCallMethod.cs

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;namespace OpcUaCallMethodDemo
{public partial class FormOpcUaCallMethod : Form{public FormOpcUaCallMethod(){InitializeComponent();}/// <summary>/// 显示推送消息/// </summary>/// <param name="msg"></param>private void DisplayMessage(string msg){this.BeginInvoke(new Action(() =>{if (rtxtMessage.TextLength > 409600){rtxtMessage.Clear();}rtxtMessage.AppendText($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}->{msg}\n");rtxtMessage.ScrollToCaret();}));}private void btnConnect_Click(object sender, EventArgs e){//连接OPC服务端string serverAddress = "opc.tcp://192.168.1.20:48030";bool isRun = GumOpcUaClientUtil.ConnectOpcServer(serverAddress, false, "admin", "password123456", DisplayMessage);DisplayMessage($"连接OPC服务端【{serverAddress}】:{(isRun ? "成功" : "失败")}");if (!isRun){DisplayMessage($"连接OPC服务端【{serverAddress}】失败,无法启动");return;}string parentNodeTag = "ns=2;s=A.B.C.ParentTag";string methodNode = "ns=2;s=A.B.C.ParentTag.readJob";//在OpcServer服务器上有个方法节点,方法名为readJob,需要传入两个参数 (byte sourceNumber, short jobNo),返回一个工作名称string jobName//方法整体描述为 string readJob(byte sourceNumber, short jobNo)short jobNo = 12;object[] resultArray = GumOpcUaClientUtil.CallMethodNode(DisplayMessage, parentNodeTag, methodNode, new object[] { (byte)1, jobNo });if (resultArray == null || resultArray.Length < 1){DisplayMessage($"读取readJob节点出错,低于1个元素,当前工作编号为【{jobNo}】");}else{DisplayMessage($"读取readJob节点成功,返回信息【{resultArray[0]}】,当前工作编号为【{jobNo}】");}}}
}

四、测试如图:

【没有连接Opc服务端】

这篇关于关于OPC-UA客户端调用服务端方法CallMethod节点的问题的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/813952

相关文章

Vue3绑定props默认值问题

《Vue3绑定props默认值问题》使用Vue3的defineProps配合TypeScript的interface定义props类型,并通过withDefaults设置默认值,使组件能安全访问传入的... 目录前言步骤步骤1:使用 defineProps 定义 Props步骤2:设置默认值总结前言使用T

JavaScript中比较两个数组是否有相同元素(交集)的三种常用方法

《JavaScript中比较两个数组是否有相同元素(交集)的三种常用方法》:本文主要介绍JavaScript中比较两个数组是否有相同元素(交集)的三种常用方法,每种方法结合实例代码给大家介绍的非常... 目录引言:为什么"相等"判断如此重要?方法1:使用some()+includes()(适合小数组)方法2

504 Gateway Timeout网关超时的根源及完美解决方法

《504GatewayTimeout网关超时的根源及完美解决方法》在日常开发和运维过程中,504GatewayTimeout错误是常见的网络问题之一,尤其是在使用反向代理(如Nginx)或... 目录引言为什么会出现 504 错误?1. 探索 504 Gateway Timeout 错误的根源 1.1 后端

Web服务器-Nginx-高并发问题

《Web服务器-Nginx-高并发问题》Nginx通过事件驱动、I/O多路复用和异步非阻塞技术高效处理高并发,结合动静分离和限流策略,提升性能与稳定性... 目录前言一、架构1. 原生多进程架构2. 事件驱动模型3. IO多路复用4. 异步非阻塞 I/O5. Nginx高并发配置实战二、动静分离1. 职责2

解决升级JDK报错:module java.base does not“opens java.lang.reflect“to unnamed module问题

《解决升级JDK报错:modulejava.basedoesnot“opensjava.lang.reflect“tounnamedmodule问题》SpringBoot启动错误源于Jav... 目录问题描述原因分析解决方案总结问题描述启动sprintboot时报以下错误原因分析编程异js常是由Ja

MySQL 表空却 ibd 文件过大的问题及解决方法

《MySQL表空却ibd文件过大的问题及解决方法》本文给大家介绍MySQL表空却ibd文件过大的问题及解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考... 目录一、问题背景:表空却 “吃满” 磁盘的怪事二、问题复现:一步步编程还原异常场景1. 准备测试源表与数据

python 线程池顺序执行的方法实现

《python线程池顺序执行的方法实现》在Python中,线程池默认是并发执行任务的,但若需要实现任务的顺序执行,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋... 目录方案一:强制单线程(伪顺序执行)方案二:按提交顺序获取结果方案三:任务间依赖控制方案四:队列顺序消

SpringBoot通过main方法启动web项目实践

《SpringBoot通过main方法启动web项目实践》SpringBoot通过SpringApplication.run()启动Web项目,自动推断应用类型,加载初始化器与监听器,配置Spring... 目录1. 启动入口:SpringApplication.run()2. SpringApplicat

解决Nginx启动报错Job for nginx.service failed because the control process exited with error code问题

《解决Nginx启动报错Jobfornginx.servicefailedbecausethecontrolprocessexitedwitherrorcode问题》Nginx启... 目录一、报错如下二、解决原因三、解决方式总结一、报错如下Job for nginx.service failed bec

SysMain服务可以关吗? 解决SysMain服务导致的高CPU使用率问题

《SysMain服务可以关吗?解决SysMain服务导致的高CPU使用率问题》SysMain服务是超级预读取,该服务会记录您打开应用程序的模式,并预先将它们加载到内存中以节省时间,但它可能占用大量... 在使用电脑的过程中,CPU使用率居高不下是许多用户都遇到过的问题,其中名为SysMain的服务往往是罪魁