基本信息
源码名称：Siemens OPC_ua_client程序(S7-1500)
源码大小：5.42M
文件格式：.rar
开发语言：C#
更新时间：2018-04-28
友情提示：（无需注册或充值，赞助后即可获取资源下载链接）
嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：78630559
本次赞助数额为： 2 元×
微信扫码支付：2 元
×
请留下您的邮箱，我们将在2小时内将文件发到您的邮箱
源码介绍
//=============================================================================
// 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
}
}