【实例简介】

【实例截图】

【核心代码】

///摘要

///程式使用C#.NET 2005 编写

///引用类库OPCDAAuto.dll

///OPCServer采用KEPWare

///在windows xp sp2、sp3、windows 2003上测试通过

///完成于：2008年12月31日

///测试于：2009年01月05日

///

///作者：潇洒草

///Email：zhkai868@163.com

///QQ：44649029

///

///如分发，请保留此摘要。

///鄙视那些拿代码当宝贝的人，鄙视那些拿源码换源码的人，鄙视那些自私的人。

///别人看到你的代码，你能死啊？对你有多大威胁啊？强烈鄙视～～～

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Text;

using System.Windows.Forms;

using System.Net;

using System.Collections;

using OPCAutomation;

namespace OPC测试通过

{

public partial class MainFrom : Form

{

public MainFrom()

{

InitializeComponent();

}

#region 私有变量

///

/// OPCServer Object

///

OPCServer KepServer;

///

/// OPCGroups Object

///

OPCGroups KepGroups;

///

/// OPCGroup Object

///

OPCGroup KepGroup;

///

/// OPCItems Object

///

OPCItems KepItems;

///

/// OPCItem Object

///

OPCItem KepItem;

///

/// 主机IP

///

string strHostIP = "";

///

/// 主机名称

///

string strHostName = "";

///

/// 连接状态

///

bool opc_connected = false;

///

/// 客户端句柄

///

int itmHandleClient = 0;

///

/// 服务端句柄

///

int itmHandleServer = 0;

#endregion

#region 方法

///

/// 枚举本地OPC服务器

///

private void GetLocalServer()

{

//获取本地计算机IP,计算机名称

IPHostEntry IPHost = Dns.Resolve(Environment.MachineName);

if (IPHost.AddressList.Length > 0)

{

strHostIP = IPHost.AddressList[0].ToString();

}

else

{

return;

}

//通过IP来获取计算机名称，可用在局域网内

IPHostEntry ipHostEntry = Dns.GetHostByAddress(strHostIP);

strHostName=ipHostEntry.HostName.ToString();

//获取本地计算机上的OPCServerName

try

{

KepServer = new OPCServer();

object serverList = KepServer.GetOPCServers(strHostName);

foreach (string turn in (Array)serverList)

{

cmbServerName.Items.Add(turn);

}

cmbServerName.SelectedIndex = 0;

btnConnServer.Enabled = true;

}

catch(Exception err)

{

MessageBox.Show("枚举本地OPC服务器出错：" err.Message,"提示信息",MessageBoxButtons.OK,MessageBoxIcon.Warning);

}

}

///

/// 创建组

///

private bool CreateGroup()

{

try

{

KepGroups = KepServer.OPCGroups;

KepGroup = KepGroups.Add("OPCDOTNETGROUP");

SetGroupProperty();

KepGroup.DataChange = new DIOPCGroupEvent_DataChangeEventHandler(KepGroup_DataChange);

KepGroup.AsyncWriteComplete = new DIOPCGroupEvent_AsyncWriteCompleteEventHandler(KepGroup_AsyncWriteComplete);

KepItems = KepGroup.OPCItems;

}

catch (Exception err)

{

MessageBox.Show("创建组出现错误：" err.Message,"提示信息",MessageBoxButtons.OK,MessageBoxIcon.Warning);

return false;

}

return true;

}

///

/// 设置组属性

///

private void SetGroupProperty()

{

KepServer.OPCGroups.DefaultGroupIsActive =Convert.ToBoolean(txtGroupIsActive.Text);

KepServer.OPCGroups.DefaultGroupDeadband = Convert.ToInt32(txtGroupDeadband.Text);

KepGroup.UpdateRate = Convert.ToInt32(txtUpdateRate.Text);

KepGroup.IsActive = Convert.ToBoolean(txtIsActive.Text);

KepGroup.IsSubscribed =Convert.ToBoolean(txtIsSubscribed.Text);

}

///

/// 列出OPC服务器中所有节点

///

///

private void RecurBrowse(OPCBrowser oPCBrowser)

{

//展开分支

oPCBrowser.ShowBranches();

//展开叶子

oPCBrowser.ShowLeafs(true);

foreach (object turn in oPCBrowser)

{

listBox1.Items.Add(turn.ToString());

}

}

///

/// 获取服务器信息，并显示在窗体状态栏上

///

private void GetServerInfo()

{

tsslServerStartTime.Text ="开始时间:" KepServer.StartTime.ToString() " ";

tsslversion.Text ="版本:" KepServer.MajorVersion.ToString() "." KepServer.MinorVersion.ToString() "." KepServer.BuildNumber.ToString();

}

///

/// 连接OPC服务器

///

/// OPCServerIP

/// OPCServer名称

private bool ConnectRemoteServer(string remoteServerIP, string remoteServerName)

{

try

{

KepServer.Connect(remoteServerName, remoteServerIP);

if (KepServer.ServerState == (int)OPCServerState.OPCRunning)

{

tsslServerState.Text = "已连接到-" KepServer.ServerName " ";

}

else

{

//这里你可以根据返回的状态来自定义显示信息，请查看自动化接口API文档

tsslServerState.Text = "状态：" KepServer.ServerState.ToString() " ";

}

}

catch (Exception err)

{

MessageBox.Show("连接远程服务器出现错误：" err.Message, "提示信息", MessageBoxButtons.OK, MessageBoxIcon.Warning);

return false;

}

return true;

}

#endregion

#region 事件

///

/// 写入TAG值时执行的事件

///

///

///

///

///

void KepGroup_AsyncWriteComplete(int TransactionID, int NumItems, ref Array ClientHandles, ref Array Errors)

{

lblState.Text = "";

for (int i = 1; i <= NumItems; i )

{

lblState.Text = "Tran:" TransactionID.ToString() " CH:" ClientHandles.GetValue(i).ToString() " Error:" Errors.GetValue(i).ToString();

}

}

///

/// 每当项数据有变化时执行的事件

///

/// 处理ID

/// 项个数

/// 项客户端句柄

/// TAG值

/// 品质

/// 时间戳

void KepGroup_DataChange(int TransactionID, int NumItems, ref Array ClientHandles, ref Array ItemValues, ref Array Qualities, ref Array TimeStamps)

{

//为了测试，所以加了控制台的输出，来查看事物ID号

//Console.WriteLine("********" TransactionID.ToString() "*********");

for (int i = 1; i <= NumItems; i )

{

this.txtTagValue.Text = ItemValues.GetValue(i).ToString();

this.txtQualities.Text = Qualities.GetValue(i).ToString();

this.txtTimeStamps.Text = TimeStamps.GetValue(i).ToString();

}

}

///

/// 选择列表项时处理的事情

///

///

///

private void listBox1_SelectedIndexChanged(object sender, EventArgs e)

{

try

{

if (itmHandleClient != 0)

{

this.txtTagValue.Text = "";

this.txtQualities.Text ="";

this.txtTimeStamps.Text = "";

Array Errors;

OPCItem bItem = KepItems.GetOPCItem(itmHandleServer);

//注：OPC中以1为数组的基数

int[] temp = new int[2] { 0, bItem.ServerHandle };

Array serverHandle = (Array)temp;

//移除上一次选择的项

KepItems.Remove(KepItems.Count, ref serverHandle, out Errors);

}

itmHandleClient = 1234;

KepItem = KepItems.AddItem(listBox1.SelectedItem.ToString(), itmHandleClient);

itmHandleServer = KepItem.ServerHandle;

}

catch(Exception err)

{

//没有任何权限的项，都是OPC服务器保留的系统项，此处可不做处理。

itmHandleClient = 0;

txtTagValue.Text = "Error ox";

txtQualities.Text = "Error ox";

txtTimeStamps.Text = "Error ox";

MessageBox.Show("此项为系统保留项:" err.Message,"提示信息");

}

}

///

/// 载入窗体时处理的事情

///

private void MainFrom_Load(object sender, EventArgs e)

{

GetLocalServer();

}

///

/// 关闭窗体时处理的事情

///

private void MainFrom_FormClosing(object sender, FormClosingEventArgs e)

{

if (!opc_connected)

{

return;

}

if (KepGroup != null)

{

KepGroup.DataChange -= new DIOPCGroupEvent_DataChangeEventHandler(KepGroup_DataChange);

}

if (KepServer != null)

{

KepServer.Disconnect();

KepServer = null;

}

opc_connected = false;

}

///

/// 【按钮】设置

///

private void btnSetGroupPro_Click(object sender, EventArgs e)

{

SetGroupProperty();

}

///

/// 【按钮】连接ＯＰＣ服务器

///

private void btnConnLocalServer_Click(object sender, EventArgs e)

{

try

{

if (!ConnectRemoteServer(txtRemoteServerIP.Text,cmbServerName.Text))

{

return;

}

btnSetGroupPro.Enabled = true;

opc_connected = true;

GetServerInfo();

RecurBrowse(KepServer.CreateBrowser());

if (!CreateGroup())

{

return;

}

}

catch (Exception err)

{

MessageBox.Show("初始化出错：" err.Message, "提示信息", MessageBoxButtons.OK, MessageBoxIcon.Warning);

}

}

///

/// 【按钮】写入

///

private void btnWrite_Click(object sender, EventArgs e)

{

OPCItem bItem = KepItems.GetOPCItem(itmHandleServer);

int[] temp = new int[2] { 0, bItem.ServerHandle };

Array serverHandles=(Array)temp;

object[] valueTemp = new object[2] {"",txtWriteTagValue.Text };

Array values=(Array)valueTemp;

Array Errors;

int cancelID;

KepGroup.AsyncWrite(1,ref serverHandles,ref values,out Errors, 2009,out cancelID);

//KepItem.Write(txtWriteTagValue.Text);//这句也可以写入，但并不触发写入事件

GC.Collect();

}

#endregion

}

}