C# Kepserver client

1.界面

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
    }
}