1.界面
image.png
2.源码
using OPCAutomation;
using System;
using System.Drawing;
using System.Windows.Forms;
namespace KepserverTest
{
/*
1.连接KepServer服务器：OPCServer.Connect(string ProgID, object Node);
2.配置通道：OPCGroup OPCServer.OPCGroups.Add(chanel);
3.配置item：OPCItem OPCItems.AddItem(string ItemID, int ClientHandle);
(1)读：OPCItem.Read(short Source, out object Value, out object Quality, out object TimeStamp);
(2)写：OPCItem.Write(object Value);
*/
public partial class Form1 : Form
{
string def_chanel = "通道 3";
string def_item = "通道 3.设备 1.M1";
string remoteServerName, remoteServerIP;//服务器明和服务器IP地址
OPCServer KepServer;
OPCGroup KepGroup;
OPCItem KepItem1;//动态数据
OPCItem KepItem;//读取写入
int[] ServerHandle = new int[2];
bool isStart = false;
/*初始化*/
public Form1()
{
InitializeComponent();
KepServer = new OPCServer();
}
/*连接按钮*/
private void button1_Click(object sender, EventArgs e)
{
//获取服务器IP地址和服务器名
remoteServerIP = this.tb_server_ip.Text;
remoteServerName = this.tb_server_name.Text;
//连接服务器
ConnectRemoteServer(remoteServerIP, remoteServerName);
}
/*断开按钮*/
private void button2_Click(object sender, EventArgs e)
{
//断开连接
DisConnectRemoteServer();
}
/*读取按钮*/
private void btn_read_syn_Click(object sender, EventArgs e)
{
object ItemValues;
object Qualities;
object TimeStamps;
try
{
//准备ID信息
string chanel = this.tb_chanel.Text;
string device = this.tb_device.Text;
string key = this.tb_mark.Text;
//SetGroup(chanel);
KepItem = KepGroup.OPCItems.AddItem(chanel+"."+device + "." +key, 1);//创建Item
//KepItem = KepGroup.OPCItems.GetOPCItem(ServerHandle[0]);
//ServerHandle[1] = KepItem.ServerHandle;//？？？
System.Threading.Thread.Sleep(500);//服务器扫描速率为100ms
//读取数据，并输出
KepItem.Read(1, out ItemValues, out Qualities, out TimeStamps);
//显示数据
this.listBox2.Items.Insert(0,
"[Value] " + string.Format("{0}", KepItem.Value) + " " +
"[Quality] " + string.Format("{0}", KepItem.Quality) + " " +
"[TimeStamp] " + string.Format("{0}", KepItem.TimeStamp)
);
//输出日志
Log("【信息】读取"+KepItem.ItemID);
}
catch (System.Exception ex)
{
Log("【异常】" + ex.Message);
}
}
/*写入按钮*/
private void btn_write_Click_1(object sender, EventArgs e)
{
try
{
string chanel = this.tb_chanel.Text;
string device = this.tb_device.Text;
string mark = this.tb_mark.Text;
int value = int.Parse(this.tb_value_write.Text);
KepItem = KepGroup.OPCItems.AddItem(chanel + "." + device + "." + mark, 1);
//ServerHandle[1] = KepItem.ServerHandle;
System.Threading.Thread.Sleep(200);
KepItem.Write(value);
Log("【信息】写入"+KepItem.ItemID);
}
catch (System.Exception error)
{
Log("【异常】" + error.Message);
}
}
/*启动/关闭*/
private void btn_power_Click(object sender, EventArgs e)
{
try
{
string chanel = this.tb_chanel.Text;
string device = this.tb_device.Text;
string mark = this.tb_mark.Text;
bool value = !isStart;
KepItem = KepGroup.OPCItems.AddItem(chanel + "." + device + "." + mark, 1);
//ServerHandle[1] = KepItem.ServerHandle;
System.Threading.Thread.Sleep(200);
KepItem.Write(value);
this.btn_power.Text = isStart ? "启动" : "关闭";
Log("【信息】写入" + KepItem.ItemID+" : "+isStart);
}
catch (System.Exception error)
{
Log("【异常】" + error.Message);
}
}
/*动态读取按钮*/
private void btn_read_dyn_Click(object sender, EventArgs e)
{
KepItem1 = KepGroup.OPCItems.AddItem(def_item, 1);
//绑定委托：数据改变
KepGroup.DataChange += new DIOPCGroupEvent_DataChangeEventHandler(MyOpcGroup_DataChange);
}
/*连接服务器*/
private bool ConnectRemoteServer(string remoteServerIP, string remoteServerName)
{
string status;
try
{
this.KepServer.Connect(remoteServerName, remoteServerIP);
if (KepServer.ServerState == (int)OPCServerState.OPCRunning)
{
status = "【连接】" + KepServer.ServerName + " ";
}
else
{
//这里你可以根据返回的状态来自定义显示信息，请查看自动化接口API文档
status = "【状态】" + KepServer.ServerState.ToString() + " ";
}
}
catch (Exception ex)
{
Log("【异常】" + "KepServer"+ex.Message);
return false;
}
//设置组
try
{
//添加通道
KepGroup = KepServer.OPCGroups.Add(def_chanel);//通道标识
//设置通道
KepGroup.IsActive = true;
KepGroup.IsSubscribed = true;
KepGroup.DeadBand = 0;
KepGroup.UpdateRate = 1000;//更新速率
//初始化item1：ModbusSlave测试（通道）>ModbusSlave（从机）>K1（标记）
//KepItem1 = KepGroup.OPCItems.AddItem(def_item, 1);
//ServerHandle[0] = KepItem1.ServerHandle;//？？？
//绑定委托：完成异步写入
KepGroup.AsyncWriteComplete += new DIOPCGroupEvent_AsyncWriteCompleteEventHandler(MyOpcGroup_AsyncWriteComplete);
//绑定委托：完成异步读取
KepGroup.AsyncReadComplete += new DIOPCGroupEvent_AsyncReadCompleteEventHandler(MyOpcGroup_AsyncReadComplete);
//绑定委托：？？？
KepGroup.AsyncCancelComplete += new DIOPCGroupEvent_AsyncCancelCompleteEventHandler(MyOpcGroup_AsyncCancelComplete);
//绑定委托：数据改变
//KepGroup.DataChange += new DIOPCGroupEvent_DataChangeEventHandler(MyOpcGroup_DataChange);
}
catch (System.Exception ex)
{
Log("【异常】" + "KepGroup," + ex.Message);
return false;
}
Log(status);
return true;
}
/*断开连接*/
private void DisConnectRemoteServer()
{
try
{
this.KepServer.Disconnect();
Log( "【断开】" + remoteServerIP);
}
catch(Exception ex)
{
Log("【异常】" + ex.Message);
}
}
void MyOpcGroup_AsyncCancelComplete(int CancelID)
{
throw new NotImplementedException();
}
void MyOpcGroup_AsyncReadComplete(int TransactionID, int NumItems, ref Array ClientHandles, ref Array ItemValues, ref Array Qualities, ref Array TimeStamps, ref Array Errors)
{
throw new NotImplementedException();
}
void MyOpcGroup_AsyncWriteComplete(int TransactionID, int NumItems, ref Array ClientHandles, ref Array Errors)
{
throw new NotImplementedException();
}
/*DataChange事件*/
void MyOpcGroup_DataChange(int TransactionID, int NumItems, ref Array ClientHandles, ref Array ItemValues, ref Array Qualities, ref Array TimeStamps)
{
try
{
this.listBox2.Items.Clear();
this.listBox2.Items.Insert(0,
"[Value] " + string.Format("{0}", KepItem1.Value) + " " +
"[Quality] " + string.Format("{0}", KepItem1.Quality) + " " +
"[TimeStamp] " + string.Format("{0}", KepItem1.TimeStamp)
);
}
catch (System.Exception ex)
{
Log("【异常】" + ex.Message);
}
}
#region 管理数据显示
private void lb3_clear_all_Click(object sender, EventArgs e)
{
listBox3.Items.Clear();
}
private void listBox3_MouseUp(object sender, MouseEventArgs e)
{
if (e.Button == MouseButtons.Right)
{
ms_lb3.Show(listBox3, new Point(e.X, e.Y));
}
}
private void listBox2_MouseUp(object sender, MouseEventArgs e)
{
if (e.Button == MouseButtons.Right)
{
ms_lb2.Show(listBox2, new Point(e.X, e.Y));
}
}
private void lb2_clear_all_Click(object sender, EventArgs e)
{
listBox2.Items.Clear();
}
void Log(string info)
{
this.listBox3.Items.Insert(0, "[" + DateTime.Now.ToString() + "] " + info);
}
#endregion
}
}
