实例介绍
【实例简介】
【实例截图】
【核心代码】
//=============================================================================
// Siemens AG
// (c)Copyright (2016) All Rights Reserved
//-----------------------------------------------------------------------------
// Tested with: Windows 7 Ultimate x64
// Engineering: Visual Studio 2013
// Functionality: Simple OPC UA Client
//-----------------------------------------------------------------------------
// Change log table:
// Version Date Expert in charge Changes applied
// 01.00.00 31.08.2016 (Siemens) First released version
//=============================================================================
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IdentityModel;
using System.Linq;
using System.Security.Cryptography.X509Certificates;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using Opc.Ua;
using Opc.Ua.Client;
using Siemens.UAClientHelper;
namespace UA_Client_1500
{
public partial class UAClientForm : Form
{
/// <summary>
/// Fields
/// </summary>
#region Fields
private Session mySession;
private Subscription mySubscription;
private UAClientHelperAPI myClientHelperAPI;
private EndpointDescription mySelectedEndpoint;
private MonitoredItem myMonitoredItem;
private Boolean mySecurity;
private List<String> myRegisteredNodeIdStrings;
#endregion
/// <summary>
/// Form Construction
/// </summary>
#region Construction
public UAClientForm()
{
InitializeComponent();
myClientHelperAPI = new UAClientHelperAPI();
myRegisteredNodeIdStrings = new List<String>();
browsePage.Enabled = false;
rwPage.Enabled = false;
subscribePage.Enabled = false;
}
#endregion
/// <summary>
/// Methods called by the UI
/// </summary>
#region UserInteractions
private void EndpointButton_Click(object sender, EventArgs e)
{
endpointListView.Items.Clear();
//The local discovery URL for the discovery server
string discoveryUrl = discoveryTextBox.Text;
try
{
ApplicationDescriptionCollection servers = myClientHelperAPI.FindServers(discoveryUrl);
foreach (ApplicationDescription ad in servers)
{
foreach (string url in ad.DiscoveryUrls)
{
EndpointDescriptionCollection endpoints = myClientHelperAPI.GetEndpoints(url);
foreach (EndpointDescription ep in endpoints)
{
string securityPolicy = ep.SecurityPolicyUri.Remove(0, 42);
endpointListView.Items.Add("[" ad.ApplicationName "] " " [" ep.SecurityMode "] " " [" securityPolicy "] " " [" ep.EndpointUrl "]").Tag = ep;
}
}
}
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "Error");
}
}
private void SubscribeButton_Click(object sender, EventArgs e)
{
if (myMonitoredItem != null)
{
try
{
myMonitoredItem = myClientHelperAPI.RemoveMonitoredItem(mySubscription, myMonitoredItem);
}
catch
{
;
}
}
try
{
mySubscription = myClientHelperAPI.Subscribe(1000);
myMonitoredItem = myClientHelperAPI.AddMonitoredItem(mySubscription, subscriptionIdTextBox.Text, 1);
myClientHelperAPI.ItemChangedNotification = new MonitoredItemNotificationEventHandler(Notification_MonitoredItem);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "Error");
}
}
private void ConnectServerButton_Click(object sender, EventArgs e)
{
if (mySession != null && !mySession.Disposed)
{
myClientHelperAPI.Disconnect();
mySession = myClientHelperAPI.Session;
connectServerBtn.Text = "Connect to server";
epConnectButton.Text = "Connect to server";
browsePage.Enabled = false;
rwPage.Enabled = false;
subscribePage.Enabled = false;
}
else
{
try
{
myClientHelperAPI.Connect(ServerUriTextbox.Text, mySecurity);
mySession = myClientHelperAPI.Session;
connectServerBtn.Text = "Disconnect from server";
epConnectButton.Text = "Disconnect from server";
myClientHelperAPI.KeepAliveNotification = new KeepAliveEventHandler(Notification_KeepAlive);
browsePage.Enabled = true;
rwPage.Enabled = true;
subscribePage.Enabled = true;
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "Error");
}
}
}
private void EpConnectButton_Click(object sender, EventArgs e)
{
if (mySession != null && !mySession.Disposed)
{
myClientHelperAPI.Disconnect();
mySession = myClientHelperAPI.Session;
connectServerBtn.Text = "Connect to server";
epConnectButton.Text = "Connect to server";
browsePage.Enabled = false;
rwPage.Enabled = false;
subscribePage.Enabled = false;
}
else
{
try
{
myClientHelperAPI.Connect(mySelectedEndpoint);
mySession = myClientHelperAPI.Session;
connectServerBtn.Text = "Disconnect from server";
epConnectButton.Text = "Disconnect from server";
myClientHelperAPI.KeepAliveNotification = new KeepAliveEventHandler(Notification_KeepAlive);
browsePage.Enabled = true;
rwPage.Enabled = true;
subscribePage.Enabled = true;
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "Error");
}
}
}
private void WriteValButton_Click(object sender, EventArgs e)
{
List<String> values = new List<string>();
List<String> nodeIdStrings = new List<string>();
values.Add(writeTextBox.Text);
nodeIdStrings.Add(writeIdTextBox.Text);
try
{
myClientHelperAPI.WriteValues(values, nodeIdStrings);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "Error");
}
}
private void UnsubscribeButton_Click(object sender, EventArgs e)
{
myClientHelperAPI.RemoveSubscription(mySubscription);
subscriptionLabel.Text = "";
}
private void NodeTreeView_BeforeSelect(object sender, TreeViewCancelEventArgs e)
{
descriptionGridView.Rows.Clear();
ReferenceDescription refDesc = (ReferenceDescription)e.Node.Tag;
Node node = myClientHelperAPI.ReadNode(refDesc.NodeId.ToString());
VariableNode variableNode = new VariableNode();
string[] row1 = new string[] { "Node Id", refDesc.NodeId.ToString() };
string[] row2 = new string[] { "Namespace Index", refDesc.NodeId.NamespaceIndex.ToString() };
string[] row3 = new string[] { "Identifier Type", refDesc.NodeId.IdType.ToString() };
string[] row4 = new string[] { "Identifier", refDesc.NodeId.Identifier.ToString() };
string[] row5 = new string[] { "Browse Name", refDesc.BrowseName.ToString() };
string[] row6 = new string[] { "Display Name", refDesc.DisplayName.ToString() };
string[] row7 = new string[] { "Node Class", refDesc.NodeClass.ToString() };
string[] row8 = new string[] { "Description", "null" };
try { row8 = new string[] { "Description", node.Description.ToString() }; }
catch { row8 = new string[] { "Description", "null" }; }
string[] row9 = new string[] { "Type Definition", refDesc.TypeDefinition.ToString() };
string[] row10 = new string[] { "Write Mask", node.WriteMask.ToString() };
string[] row11 = new string[] { "User Write Mask", node.UserWriteMask.ToString() };
if (node.NodeClass == NodeClass.Variable)
{
variableNode = (VariableNode)node.DataLock;
Int32 intVar = 0;
Int32.TryParse(variableNode.DataType.Identifier.ToString(), out intVar);
string[] row12 = new string[] { "Data Type", DataTypes.GetBrowseName(intVar) };
string[] row13 = new string[] { "Value Rank", variableNode.ValueRank.ToString() };
string[] row14 = new string[] { "Array Dimensions", variableNode.ArrayDimensions.Capacity.ToString() };
string[] row15 = new string[] { "Access Level", variableNode.AccessLevel.ToString() };
string[] row16 = new string[] { "Minimum Sampling Interval", variableNode.MinimumSamplingInterval.ToString() };
string[] row17 = new string[] { "Historizing", variableNode.Historizing.ToString() };
object[] rows = new object[] { row1, row2, row3, row4, row5, row6, row7, row8, row9, row10, row11, row12, row13, row14, row15, row16, row17 };
foreach (string[] rowArray in rows)
{
descriptionGridView.Rows.Add(rowArray);
}
}
else
{
object[] rows = new object[] { row1, row2, row3, row4, row5, row6, row7, row8, row9, row10, row11 };
foreach (string[] rowArray in rows)
{
descriptionGridView.Rows.Add(rowArray);
}
}
}
private void ClientForm_FormClosing(object sender, FormClosingEventArgs e)
{
try
{
myClientHelperAPI.Disconnect();
}
catch
{
;
}
}
private void NodeTreeView_BeforeExpand(object sender, TreeViewCancelEventArgs e)
{
e.Node.Nodes.Clear();
ReferenceDescriptionCollection referenceDescriptionCollection;
ReferenceDescription refDesc = (ReferenceDescription)e.Node.Tag;
referenceDescriptionCollection = myClientHelperAPI.BrowseNode(refDesc);
foreach (ReferenceDescription tempRefDesc in referenceDescriptionCollection)
{
e.Node.Nodes.Add(tempRefDesc.DisplayName.ToString()).Tag = tempRefDesc;
}
foreach (TreeNode node in e.Node.Nodes)
{
node.Nodes.Add("");
}
}
private void BrowsePage_Enter(object sender, EventArgs e)
{
descriptionGridView.Rows.Clear();
nodeTreeView.Nodes.Clear();
ReferenceDescriptionCollection referenceDescriptionCollection;
try
{
referenceDescriptionCollection = myClientHelperAPI.BrowseRoot();
foreach (ReferenceDescription refDesc in referenceDescriptionCollection)
{
nodeTreeView.Nodes.Add(refDesc.DisplayName.ToString()).Tag = refDesc;
foreach (TreeNode node in nodeTreeView.Nodes)
{
node.Nodes.Add("");
}
}
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "Error");
}
}
private void ReadValButton_Click(object sender, EventArgs e)
{
List<String> nodeIdStrings = new List<String>();
List<String> values = new List<String>();
nodeIdStrings.Add(readIdTextBox.Text);
try
{
values = myClientHelperAPI.ReadValues(nodeIdStrings);
readTextBox.Text = values.ElementAt<String>(0);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "Error");
}
}
private void EndpointListView_ItemSelectionChanged(object sender, ListViewItemSelectionChangedEventArgs e)
{
mySelectedEndpoint = (EndpointDescription)e.Item.Tag;
}
private void OpcTabControl_Selecting(object sender, TabControlCancelEventArgs e)
{
e.Cancel = !e.TabPage.Enabled;
if (!e.TabPage.Enabled)
{
MessageBox.Show("Establish a connection to a server first.", "Error");
}
}
private void SecurityCheckBox_CheckedChanged(object sender, EventArgs e)
{
mySecurity = securityCheckBox.Checked;
}
private void RegisterButton_Click(object sender, EventArgs e)
{
List<String> nodeIdStrings = new List<String>();
nodeIdStrings.Add(rgNodeIdTextBox.Text);
try
{
myRegisteredNodeIdStrings = myClientHelperAPI.RegisterNodeIds(nodeIdStrings);
regNodeIdTextBox.Text = myRegisteredNodeIdStrings.ElementAt<String>(0);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "Error");
}
}
private void UnregisterButton_Click(object sender, EventArgs e)
{
try
{
myClientHelperAPI.UnregisterNodeIds(myRegisteredNodeIdStrings);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "Error");
}
myRegisteredNodeIdStrings.Clear();
regNodeIdTextBox.Text = "";
rgReadTextBox.Text = "";
rgWriteTextBox.Text = "";
}
private void RgReadButton_Click(object sender, EventArgs e)
{
List<String> values = new List<String>();
try
{
values = myClientHelperAPI.ReadValues(myRegisteredNodeIdStrings);
rgReadTextBox.Text = values.ElementAt<String>(0);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "Error");
}
}
private void RgWriteButton_Click(object sender, EventArgs e)
{
List<String> values = new List<string>();
values.Add(rgWriteTextBox.Text);
try
{
myClientHelperAPI.WriteValues(values, myRegisteredNodeIdStrings);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "Error");
}
}
#endregion
/// <summary>
/// Event handlers
/// </summary>
#region EventHandlers
private void Notification_MonitoredItem(MonitoredItem monitoredItem, MonitoredItemNotificationEventArgs e)
{
if (this.InvokeRequired)
{
this.BeginInvoke(new MonitoredItemNotificationEventHandler(Notification_MonitoredItem), monitoredItem, e);
return;
}
MonitoredItemNotification notification = e.NotificationValue as MonitoredItemNotification;
if (notification == null)
{
return;
}
subscriptionLabel.Text = "Value: " Utils.Format("{0}", notification.Value.WrappedValue.ToString())
";\nStatus Code: " Utils.Format("{0}", notification.Value.StatusCode.ToString())
";\nSource timestamp: " notification.Value.SourceTimestamp.ToString()
"\nServer timestamp: " notification.Value.ServerTimestamp.ToString();
}
private void Notification_KeepAlive(Session sender, KeepAliveEventArgs e)
{
//Handle KeepAlive here
;
}
#endregion
}
}
标签： Client
好例子网口号：伸出你的我的手 — 分享！
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论