C# 调用动态链接库实现OPC连接

参考文献链接：http://www.cnblogs.com/zjjking/archive/2009/01/23/1380218.html

客户端的实现：安装了KepServer的驱动，引用了Interop.OPCAutomation.dll

客户端程序：

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using OPCAutomation;
using System.Threading;

namespace OPCClient
{
    public partial class Form1 : Form
    {
        //public enum MyOPCType : ushort
        //{
        //    _byte = 0,
        //    _short = 1,
        //    _bool = 2,
        //    _string = 3,
        //    _string2 = 4,
        //};
        //OPCType mytype;
        public struct aItem
        {
            public string NameForOPC;
            //public MyOPCType opc_type;
            public object Value;
            public bool Writeable;
            public string Descrip;
            public string Timestamps;
            public string Quality;

            public int itmHandleClient;
            public int itmHandleServer;
        }
        aItem[] Data_Array;
        aItem[] Data_Array2;
        public Form1()
        {
            InitializeComponent();
        }
        #region 私有变量
        OPCServer MyServer;
        OPCGroups MyGroups;

        OPCGroup MyGroup;
        OPCGroup MyGroup2;

        OPCItems MyItems;
        OPCItems MyItems2;

        OPCItem[] MyItem;
        OPCItem[] MyItem2;
        #endregion
        string strHostIP = "";
        string strHostName = "";

        private void Form1_Load(object sender, EventArgs e)
        {
            GetLocalServer();
            Data_Array = new aItem[5];

            Data_Array[0].NameForOPC = "A0000";
            Data_Array[0].Value = 0;
            //Data_Array[0].opc_type = MyOPCType._byte;
            Data_Array[0].itmHandleClient = 0;
            Data_Array[0].Writeable = false;


            Data_Array[1].NameForOPC = "A0001";
            Data_Array[1].Value = 0;
            //Data_Array[1].opc_type = MyOPCType._short;
            Data_Array[1].itmHandleClient = 1;
            Data_Array[1].Writeable = false;

            Data_Array[2].NameForOPC = "A0002";
            Data_Array[2].Value = false;
            //Data_Array[2].opc_type = MyOPCType._bool;
            Data_Array[2].itmHandleClient = 2;
            Data_Array[2].Writeable = false;

            Data_Array[3].NameForOPC = "B001";
            Data_Array[3].Value = "";
            //Data_Array[3].opc_type = MyOPCType._string;
            Data_Array[3].itmHandleClient = 3;
            Data_Array[3].Writeable = false;

            Data_Array[4].NameForOPC = "B002";
            Data_Array[4].Value = "";
            //Data_Array[4].opc_type = MyOPCType._string2;
            Data_Array[4].itmHandleClient = 4;
            Data_Array[4].Writeable = false;

            Data_Array2 = new aItem[4];

            Data_Array2[0].NameForOPC = "B001";
            Data_Array2[0].Value = "";
            //Data_Array2[0].opc_type = MyOPCType._string;
            Data_Array2[0].itmHandleClient = 3;
            Data_Array2[0].Writeable = false;

            Data_Array2[1].NameForOPC = "B002";
            Data_Array2[1].Value = "";
            //Data_Array2[1].opc_type = MyOPCType._string;
            Data_Array2[1].itmHandleClient = 0;
            Data_Array2[1].Writeable = false;

            Data_Array2[2].NameForOPC = "W01";
            Data_Array2[2].Value = "";
            //Data_Array2[2].opc_type = MyOPCType._string;
            Data_Array2[2].itmHandleClient = 1;
            Data_Array2[2].Writeable = true;

            Data_Array2[3].NameForOPC = "W02";
            Data_Array2[3].Value = "";
            //Data_Array2[3].opc_type = MyOPCType._string;
            Data_Array2[3].itmHandleClient = 2;
            Data_Array2[3].Writeable = true;
        }
        private void GetLocalServer()
        {
            strHostName = System.Net.Dns.GetHostName();
            System.Net.IPHostEntry ipEntry = System.Net.Dns.GetHostEntry(strHostName);
            for (int i = 0; i < ipEntry.AddressList.Length; i++)
            {
                if (ipEntry.AddressList[i].AddressFamily == System.Net.Sockets.AddressFamily.InterNetwork)
                {
                    strHostIP = ipEntry.AddressList[i].ToString();
                    break;
                }
            }

            try
            {
                MyServer = new OPCServer();
                object serverList = MyServer.GetOPCServers(strHostName);

                foreach (string alist in (Array)serverList)
                {
                    comboBox_ServerNames.Items.Add(alist);
                }
                if (comboBox_ServerNames.Items.Count >= 1)
                {
                    comboBox_ServerNames.SelectedIndex = 0;
                }
                textBox_IP.Text = strHostIP;
            }
            catch(Exception err)
            {
                throw new Exception("GetLoaclServer :" + err.Message);
            }
        }

        private void buttonConnect_Click(object sender, EventArgs e)
        {
            try
            {

                //MyServer.Connect(comboBox_ServerNames.SelectedItem.ToString(), strHostIP);
                MyServer.Connect(comboBox_ServerNames.SelectedItem.ToString(), "");  //连接本机,后面的IP就不需要了

                if (MyServer.ServerState == (int)OPCServerState.OPCRunning)         //判断是否连接上了
                {
                    CreateGroup();
                }
                else
                {
                    throw new Exception("ServerState: " + MyServer.ServerState);
                }

                MyServer.ServerShutDown += ServerShutDown;//服务器断开事件,没有发现他在哪里用的。

            }
            catch (Exception err)
            {
                MessageBox.Show("ConnectServer:" + err.Message);
            }
        }
        private bool CreateGroup()
        {
            try
            {
                MyGroups = MyServer.OPCGroups;
                MyGroup = MyServer.OPCGroups.Add("Group1");
                MyGroup2 = MyServer.OPCGroups.Add("Group2");
                OPCGroup Mygroup3 = MyGroups.Add("Test3");      //待删除的组
                //以下设置属性
                {
                    MyGroups.DefaultGroupIsActive = true;      //激活组
                    MyGroups.DefaultGroupDeadband = 0;         //死区值，设为0时，服务器端该组内任何数据变化都通知组
                    MyGroups.DefaultGroupUpdateRate = 200;     //默认组群的刷新频率为200ms

                    MyGroup.UpdateRate = 100;           //刷新频率为1秒
                    MyGroup.IsSubscribed = true;        //使用订阅功能，即可以异步，默认为false。
                                                        //如果没有订阅，则该组的DataChange回调事件不会发生
                    MyGroup2.UpdateRate = 100;
                    MyGroup2.IsSubscribed = true;
                }
                MyGroup.DataChange += new DIOPCGroupEvent_DataChangeEventHandler(GroupDataChange);

                MyGroup2.DataChange += new DIOPCGroupEvent_DataChangeEventHandler(GroupDataChange2);
                MyGroup2.AsyncWriteComplete += new DIOPCGroupEvent_AsyncWriteCompleteEventHandler(GroupAsyncWriteComplete);
                MyGroup2.AsyncReadComplete += new DIOPCGroupEvent_AsyncReadCompleteEventHandler(GroupAsyncReadComplete);

                MyServer.OPCGroups.Remove("Test3");//移除组
                //添加Item
                AddGroupItems();  //设置组内的Items
            }
            catch (Exception err)
            {
                throw new Exception("CreateGroup:" + err.Message);
            }
            return true;
        }
        private void AddGroupItems()
        {
            #region Important clue
            //没有搞懂以下的意义。经测试，感觉不是这样的，如果有好几个string,clienthandle都是3的话，那订阅的
            //DataChange事件在触发的时候clienthandle都是一样的，这样不知道如何分辨是哪一个Item的值了。所以我用的
            //都是比3要大的值。

            //MyItem2[0] = MyItems2.AddItem("BPJ.Db1.dbb96", 0);//byte
            //MyItem2[1] = MyItems2.AddItem("BPJ.Db1.dbw10", 1);//short
            //MyItem2[2] = MyItems2.AddItem("BPJ.Db16.dbx0", 2);//bool
            //MyItem2[3] = MyItems2.AddItem("BPJ.Db11.S0", 3);//string
            #endregion

            MyItems = MyGroup.OPCItems;
            MyItems2 = MyGroup2.OPCItems;

            MyItem = new OPCItem[Data_Array.Length];
            MyItem2 = new OPCItem[Data_Array2.Length];

            for (int i = 0; i < Data_Array.Length; i++)
            {
                //MyItem[i] = MyItems.AddItem(Data_Array[i].NameForOPC, (int)(Data_Array[i].opc_type));
                MyItem[i] = MyItems.AddItem(Data_Array[i].NameForOPC, Data_Array[i].itmHandleClient);
            }

            for (int i = 0; i < Data_Array2.Length; i++)
            {
                //MyItem2[i] = MyItems2.AddItem(Data_Array2[i].NameForOPC, (int)(Data_Array2[i].opc_type));
                MyItem2[i] = MyItems2.AddItem(Data_Array2[i].NameForOPC, Data_Array2[i].itmHandleClient);
            }
            //移除组内Item的方法
            //Array Errors;
            //int[] temp = new int[] { 0, MyItem[3].ServerHandle };
            //Array serverHandle = (Array)temp;
            //MyItems.Remove(1, ref serverHandle, out Errors);
            //MyItem[3] = MyItems.AddItem("BPJ.Db11.S0", 3);//string

        }

        public void ServerShutDown(string Reason)//服务器先行断开
        {
            MyServer.OPCGroups.RemoveAll();
            MyServer.Disconnect();
        }
        void GroupDataChange(int TransactionID, int NumItems, ref Array ClientHandles, ref Array ItemValues, ref Array Qualities, ref Array TimeStamps)
        {
            bool UpdateFlg = false;
            int UpdateNum = -1;
            for (int i = 1; i <= NumItems; i++)
            {
                for (int j = 0; j < Data_Array.Length; j++)
                {
                    //if (Data_Array[j].itmHandleClient == Convert.ToInt32(ClientHandles.GetValue(i)))
                    if (Data_Array[j].itmHandleClient == Convert.ToInt32(ClientHandles.GetValue(i)))
                    {
                        Data_Array[j].Value = ItemValues.GetValue(i).ToString();
                        Data_Array[j].Quality = Qualities.GetValue(i).ToString();
                        Data_Array[j].Timestamps = TimeStamps.GetValue(i).ToString();

                        UpdateFlg = true;
                        UpdateNum = j;
                        break;
                    }
                }
                if (UpdateFlg == true)
                {
                    switch (UpdateNum)
                    {
                        case 0:
                            this.textBoxA0.Text = Data_Array[0].Value.ToString();
                            break;
                        case 1:
                            this.textBoxA1.Text = Data_Array[1].Value.ToString();
                            break;
                        case 2:
                            this.textBoxA2.Text = Data_Array[2].Value.ToString();
                            break;
                        case 3:
                            this.textBoxB1.Text = Data_Array[3].Value.ToString();
                            break;
                        case 4:
                            this.textBoxB2.Text = Data_Array[4].Value.ToString();
                            break;
                    }
                    UpdateFlg = false;
                }

            }
        }
        void GroupDataChange2(int TransactionID, int NumItems, ref Array ClientHandles, ref Array ItemValues, ref Array Qualities, ref Array TimeStamps)
        {
            
            for (int i = 1; i <= NumItems; i++)
            {
                for (int j = 0; j < Data_Array2.Length; j++)
                {
                    if (Data_Array2[j].itmHandleClient == Convert.ToInt32(ClientHandles.GetValue(i)))
                    {
                        Data_Array2[j].Value = ItemValues.GetValue(i).ToString();
                        Data_Array2[j].Quality = Qualities.GetValue(i).ToString();
                        Data_Array2[j].Timestamps = TimeStamps.GetValue(i).ToString();
                        
                        break;
                    }
                }
                
            }
        }
        void GroupAsyncWriteComplete(int TransactionID, int NumItems, ref Array ClientHandles, ref Array Errors)
        {
            labelSysWrite.Text = "异步写完成。NumItems:" + NumItems.ToString() + "\r\n时间：" + DateTime.Now.ToString();
        }
        void GroupAsyncReadComplete(int TransactionID, int NumItems, ref System.Array ClientHandles, ref System.Array ItemValues, ref System.Array Qualities, ref System.Array TimeStamps, ref System.Array Errors)
        {
            bool UpdateFlg = false;
            int UpdateNum = -1;
            for (int i = 1; i <= NumItems; i++)
            {
                for (int j = 0; j < Data_Array2.Length; j++)
                {
                    if (Data_Array2[j].itmHandleClient == Convert.ToInt32(ClientHandles.GetValue(i)))
                    {
                        Data_Array2[j].Value = ItemValues.GetValue(i).ToString();
                        Data_Array2[j].Quality = Qualities.GetValue(i).ToString();
                        Data_Array2[j].Timestamps = TimeStamps.GetValue(i).ToString();
                        UpdateFlg = true;
                        UpdateNum = j;
                        break;
                    }
                }
                if (UpdateFlg)
                {
                    switch (UpdateNum)
                    {
                        case 0:
                            this.textBoxB1_2.Text = ItemValues.GetValue(i).ToString();
                            break;
                        case 1:
                            this.textBoxB2_2.Text = ItemValues.GetValue(i).ToString();
                            break;
                        default:
                            break;
                    }
                    UpdateFlg = false;
                }
            }
            labelSysRead.Text = "异步读完成。NumItems:" + NumItems.ToString() + "\r\n时间：" + DateTime.Now.ToString();
        }

        private void buttonSysRead_Click(object sender, EventArgs e)
        {
            //同步读
            object ItemValues, Qualities, TimeStamps;

            MyItem2[0].Read(1, out ItemValues, out Qualities, out TimeStamps);
            this.textBoxB1_2.Text = Convert.ToString(ItemValues);

            MyItem2[1].Read(1, out ItemValues, out Qualities, out TimeStamps);
            this.textBoxB2_2.Text = Convert.ToString(ItemValues);
        }
        private void buttonASysRead_Click(object sender, EventArgs e)
        {
            //异步读，会在事件中给出读的值
            int[] tmp = new int[] { 0, MyItem2[0].ServerHandle, MyItem2[1].ServerHandle };
            Array serverHandles = (Array)tmp;
            Array Errors;
            int cancelID;
            MyGroup2.AsyncRead(2, ref serverHandles, out Errors, 1, out cancelID);

            //经测试，也可以读出数据。有的时候会有些延迟
            //this.textBoxB1_2.Text = MyItem2[0].Value;
            //this.textBoxB2_2.Text = MyItem2[1].Value;
        }
        private void buttonSysWrite_Click(object sender, EventArgs e)
        {
            //同步写
            MyItem2[2].Write(textBoxW1_2.Text);
            MyItem2[3].Write(textBoxW2_2.Text);

            this.textBoxW1_2.Text = "";
            this.textBoxW2_2.Text = "";
        }

        private void buttonASysWrite_Click(object sender, EventArgs e)
        {
            //异步写
            //异步写时，Array数组从下标1开始而非0！
            int[] tmp = new int[] { 0, MyItem2[2].ServerHandle, MyItem2[3].ServerHandle };
            Array serverHandles = (Array)tmp;
            object[] valueTemp = new object[3] { "", textBoxW1_2.Text, textBoxW2_2.Text };
            Array values = (Array)valueTemp;
            Array Errors;
            int cancelID;
            MyGroup2.AsyncWrite(2, ref serverHandles, ref values, out Errors, 1, out cancelID);

            this.textBoxW1_2.Text = "";
            this.textBoxW2_2.Text = "";
        }

        private void buttonSysRead2_Click(object sender, EventArgs e)
        {
            //同步读
            object ItemValues, Qualities, TimeStamps;

            MyItem2[2].Read(1, out ItemValues, out Qualities, out TimeStamps);
            this.textBoxW1_2.Text = Convert.ToString(ItemValues);

            MyItem2[3].Read(1, out ItemValues, out Qualities, out TimeStamps);
            this.textBoxW2_2.Text = Convert.ToString(ItemValues);
        }

        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            //善后，关闭之前的工作。
            if (MyGroup != null)
            {
                MyGroup.DataChange += new DIOPCGroupEvent_DataChangeEventHandler(GroupDataChange);
            }

            if (MyGroup2 != null)
            {
                MyGroup2.DataChange += new DIOPCGroupEvent_DataChangeEventHandler(GroupDataChange2);
                MyGroup2.AsyncWriteComplete += new DIOPCGroupEvent_AsyncWriteCompleteEventHandler(GroupAsyncWriteComplete);
                MyGroup2.AsyncReadComplete += new DIOPCGroupEvent_AsyncReadCompleteEventHandler(GroupAsyncReadComplete);
            }
            if (MyServer != null)
            {
                //MyServer.OPCGroups.RemoveAll();
                MyServer.Disconnect();
            }
        }


    }
}

服务器的实现：OPCDAAuto.dll(regsvr32注册)、引用WtOPCsvr_Library.dll、WtOPCSvr.dll(破解)

服务器端程序：

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Runtime.InteropServices;
using System.Threading;
namespace OPCServer_1
{
    
    
    public partial class Form1 : Form
    {
        const string CLSID_Value = "{7A078FB8-5286-417C-B94F-E948D2D9DFF0}";
        WtOPCsvr_Library.WtOPCsvr_DLL.WriteNotificationDelegate WriteCallBack;
        public delegate void UpdateTextBox(string Content1, string Content2, string Content3, string Content4, string Content5);
        public enum MyOPCType : ushort
        {
            _byte = 0,
            _short = 1,
            _bool = 2,
            _string = 3,
        };
        public struct aItem
        {
            public string NameForOPC;
            public MyOPCType opc_type;
            public object Value;
            public bool Writeable;
            public string Descrip;

            public uint TagHandle;
        }
        aItem[] Data_Array;

        System.Timers.Timer UpdateTimer;
        public Form1()
        {
            InitializeComponent();

            WriteCallBack = new WtOPCsvr_Library.WtOPCsvr_DLL.WriteNotificationDelegate(MyWriteCallBack);
        }
        public void MyWriteCallBack(UInt32 hItem, ref Object Value, ref UInt32 ResultCode)
        {
            if (hItem == Data_Array[5].TagHandle)
            {
                Data_Array[5].Value = Convert.ToString(Value);

                textBoxW1.Text = Data_Array[5].Value.ToString();

            }
            else if (hItem == Data_Array[6].TagHandle)
            {
                Data_Array[6].Value = Convert.ToString(Value);
                textBoxW2.Text = Data_Array[6].Value.ToString();

            }


        }
        private void buttonSend_Click(object sender, EventArgs e)
        {
            CreateTag();
            UpdateTimer.Enabled = true;

            this.buttonSend.Enabled = false;
        }
        private void Init_Timer()
        {
            UpdateTimer = new System.Timers.Timer(5000);
            UpdateTimer.Elapsed += new System.Timers.ElapsedEventHandler(UpdateTimer_Elapsed);
            UpdateTimer.AutoReset = false;
            UpdateTimer.Enabled = false;
        }
        private void UpdateTimer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
        {
            Random rad = new Random();

            Data_Array[0].Value = rad.Next(0, 255);
            Data_Array[1].Value = rad.Next(-255, 1000);
            Data_Array[2].Value = !Convert.ToBoolean(Data_Array[2].Value);
            Data_Array[3].Value = (((double)rad.Next(0, 100) - 50.0) / 100).ToString();
            Data_Array[4].Value = (((double)rad.Next(0, 100) - 50.0) / 100).ToString();

            for (int i = 0; i < 5; i++)//仅仅对前5个进行更新
            {
                WtOPCsvr_Library.WtOPCsvr_DLL.UpdateTagByName(Data_Array[i].NameForOPC, Data_Array[i].Value, 192);
            }
            UpdateTextBox updatetextbox = new UpdateTextBox(UpdateUI);

            this.BeginInvoke(updatetextbox, Data_Array[0].Value.ToString(), Data_Array[1].Value.ToString(),
                Data_Array[2].Value.ToString(), Data_Array[3].Value.ToString(), Data_Array[4].Value.ToString());


            UpdateTimer.Enabled = true;
        }
        private void UpdateUI(string Content1, string Content2, string Content3, string Content4, string Content5)
        {
            textBoxA0.Text = Content1;
            textBoxA1.Text = Content2;
            textBoxA2.Text = Content3;

            textBoxB1.Text = Content4;
            textBoxB2.Text = Content5;
        }
        private void Form1_Load(object sender, EventArgs e)
        {
            Check_Register();
            Init_OPCSvr();
            //CreateTag();

            Init_Timer();
        }
        # region OPC
        private void Check_Register()
        {
            Microsoft.Win32.RegistryKey Key_Clsid = Microsoft.Win32.Registry.ClassesRoot.OpenSubKey("OPC服务器_1", false);
            if (Key_Clsid == null)
            {
                //注册
                string exePath = Application.StartupPath + "\\OPCServer_1.exe";
                bool Flg = WtOPCsvr_Library.WtOPCsvr_DLL.UpdateRegistry(CLSID_Value, "OPC服务器_1", "_1OPC服务器", exePath);

            }
            //WtOPCsvr_Library.WtOPCsvr_DLL.UnregisterServer(CLSID_Value, "临时OPC服务器");
        }
        [DllImport("WtOPCSvr.dll")]
        public static extern UInt32 Deactivate30MinTimer([MarshalAs(UnmanagedType.LPStr)] String SerailNum);
        private void Init_OPCSvr()
        {
            UInt32 tt = 22;
            string key = "JVRPS53R5V64226N62H4";
            tt = Deactivate30MinTimer(key);
            WtOPCsvr_Library.WtOPCsvr_DLL.SetVendorInfo("University");
            WtOPCsvr_Library.WtOPCsvr_DLL.InitWTOPCsvr(CLSID_Value, 5000);
            //开启回写
            WtOPCsvr_Library.WtOPCsvr_DLL.EnableWriteNotification(WriteCallBack, true);
        }
        private void CreateTag()
        {
            Data_Array = new aItem[7];
            Data_Array[0].NameForOPC="A0000";
            Data_Array[0].Value = 0;
            Data_Array[0].opc_type = MyOPCType._byte;
            Data_Array[0].Writeable = false;

            Data_Array[1].NameForOPC = "A0001";
            Data_Array[1].Value = 0;
            Data_Array[1].opc_type = MyOPCType._short;
            Data_Array[1].Writeable = false;

            Data_Array[2].NameForOPC = "A0002";
            Data_Array[2].Value = false;
            Data_Array[2].opc_type = MyOPCType._bool;
            Data_Array[2].Writeable = false;

            Data_Array[3].NameForOPC = "B001";
            Data_Array[3].Value = "";
            Data_Array[3].opc_type = MyOPCType._string;
            Data_Array[3].Writeable = false;

            Data_Array[4].NameForOPC = "B002";
            Data_Array[4].Value = "";
            Data_Array[4].opc_type = MyOPCType._string;
            Data_Array[4].Writeable = true;

            Data_Array[5].NameForOPC = "W01"; //回写
            Data_Array[5].Value = "";
            Data_Array[5].opc_type = MyOPCType._string;
            Data_Array[5].Writeable = true;

            Data_Array[6].NameForOPC = "W02";  //回写
            Data_Array[6].Value = "";
            Data_Array[6].opc_type = MyOPCType._string;
            Data_Array[6].Writeable = true;

            for (int i = 0; i < Data_Array.Length; i++)
            {
                Data_Array[i].TagHandle = WtOPCsvr_Library.WtOPCsvr_DLL.CreateTag(Data_Array[i].NameForOPC, Data_Array[i].Value, (ushort)Data_Array[i].opc_type, Data_Array[i].Writeable);
            }
        }
        #endregion
    }
}