C#利用自動化接口編寫OPC客戶端，OPC Client，源碼直接放網盤

大部分源碼參考自某位樂於分享的大佬，但是他的源碼和接口都年代久遠了（2009年的代碼），基本用不了，還存在些許BUG，我的VS版本是2019最新版的，采用的OPC自動化接口也是最新的，修復致命BUG之后已經可以正常使用了，對於初學者來說算是不錯的教程（非常討厭那些寫教程但源碼還要積分下載的偽大佬，我呸！），大家可以先去下個OPC服務器模擬器，不然做出來的客戶端是測不到數據的，相關的服務器模擬器可以百度一下，這個比較好找。

少羅嗦，先看東西，客戶端界面如圖所示↓

客戶端運行圖如圖所示↓

東西看完了，接下來是引用

 

在“解決方案資源管理器”里鼠標右鍵單擊項目依次選擇“添加”→“引用”→“COM”，然后在右上角搜索框搜索“OPC”

選擇下圖這個自動化接口dll就可以了↓

 

並在代碼區的頭部（命名空間處）利用using關鍵詞添加引用，如下圖最后一行↓

准備工作做完了，接下來就是思路了：
1.先掃描本地的OPC服務器，將所有的服務器名加入到下拉框控件里
2.填上IP地址，本地測試一般為127.0.0.1，點擊連接按鈕觸發事件，連接服務器
3.連接上服務器之后創建一個OPCBrowser對象，主要用於展開服務器的“樹枝”和“葉子”，如下圖↓就是服務器那邊所有的節點。

4.創建一個組和設置組的屬性

5.添加一個節點（通過選擇列表里的節點達成添加操作）
6.編寫訂閱事件，當服務器端的數據有變化時，會把第5步添加的節點的對應值返回來，並顯示在對應的文本控件上
7編寫異步寫入事件，可以通過寫入按鈕將對應文本框的值寫入到服務端

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

耐心的同學可以在博客慢慢看，不習慣的同學直接拉到末尾下載源碼，然后在軟件里看會舒服很多

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

using OPCAutomation;

namespace OPCtest4
{
    public partial class Form1 : Form
    {
        OPCServer KepServer;
        OPCGroups KepGroups;
        OPCGroup KepGroup;
        OPCItems KepItems;
        OPCItem KepItem;
        bool opc_connected = false;//連接狀態
        int itmHandleClient = 0;//客戶端的句柄，句柄即控件名稱，如“張三”，用來識別是哪個具體的對象,此處可理解為每個節點的編號
        int itmHandleServer = 0;//服務器的句柄
        public Form1()
        {
            InitializeComponent();
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            GetLocalServer();
        }

        /// <summary>
        /// 獲取本地的OPC服務器名稱
        /// </summary>
        public void GetLocalServer()
        {
            IPHostEntry host = Dns.GetHostEntry("127.0.0.1");
            var strHostName = host.HostName;
            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);
            }
        }


        /// <summary>
        /// "連接"按鈕點擊事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void BtnConnServer_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);
            }
        }


        /// <summary>
        /// 連接服務器
        /// </summary>
        /// <param name="remoteServerIP">服務器IP</param>
        /// <param name="remoteServerName">服務器名稱</param>
        /// <returns></returns>
        public 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;
        }

        /// <summary>
        /// 獲取服務器信息，並顯示在窗體狀態欄上
        /// </summary>
        public void GetServerInfo()
        {
            tsslServerStartTime.Text = "開始時間:" + KepServer.StartTime.ToString() + "    ";
            tsslversion.Text = "版本:" + KepServer.MajorVersion.ToString() + "." + KepServer.MinorVersion.ToString() + "." + KepServer.BuildNumber.ToString();
        }

        /// <summary>
        /// 展開樹枝和葉子
        /// </summary>
        /// <param name="oPCBrowser">opc瀏覽器</param>
        public void RecurBrowse(OPCBrowser oPCBrowser)
        {
            //展開分支
            oPCBrowser.ShowBranches();
            //展開葉子
            oPCBrowser.ShowLeafs(true);
            foreach (object turn in oPCBrowser)
            {
                listBox1.Items.Add(turn.ToString());
            }
        }


        /// <summary>
        /// 創建組，將本地組和服務器上的組對應
        /// </summary>
        /// <returns></returns>
        public bool CreateGroup()
        {
            try
            {
                KepGroups = KepServer.OPCGroups;//將服務端的組集合復制到本地
                KepGroup = KepGroups.Add("S");//添加一個組
                SetGroupProperty();//設置組屬性
                
                KepItems = KepGroup.OPCItems;//將組里的節點集合復制到本地節點集合

                KepGroup.DataChange += KepGroup_DataChange;
                KepGroup.AsyncWriteComplete += KepGroup_AsyncWriteComplete;
            }
            catch (Exception err)
            {
                MessageBox.Show("創建組出現錯誤：" + err.Message, "提示信息", MessageBoxButtons.OK, MessageBoxIcon.Warning);
                return false;
            }
            return true;
        }

      
        /// <summary>
        /// 設置組的屬性，從對應的控件里獲取
        /// </summary>
        public void SetGroupProperty()
        {
            KepServer.OPCGroups.DefaultGroupIsActive = Convert.ToBoolean(txtGroupIsActive.Text);//激活組
            KepServer.OPCGroups.DefaultGroupDeadband = Convert.ToInt32(txtGroupDeadband.Text);// 死區值，設為0時，服務器端該組內任何數據變化都通知組
            KepGroup.UpdateRate = Convert.ToInt32(txtUpdateRate.Text);//服務器向客戶程序提交數據變化的刷新速率
            KepGroup.IsActive = Convert.ToBoolean(txtIsActive.Text);//組的激活狀態標志
            KepGroup.IsSubscribed = Convert.ToBoolean(txtIsSubscribed.Text);//是否訂閱數據
        }


        /// <summary>
        /// 異步寫方法
        /// </summary>
        /// <param name="TransactionID">處理ID</param>
        /// <param name="NumItems">項個數</param>
        /// <param name="ClientHandles">OPC客戶端的句柄</param>
        /// <param name="Errors">錯誤個數</param>
        private 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();
            }

        }


        /// <summary>
        /// 數據訂閱方法
        /// </summary>
        /// <param name="TransactionID">處理ID</param>
        /// <param name="NumItems">項個數</param>
        /// <param name="ClientHandles">OPC客戶端的句柄</param>
        /// <param name="ItemValues">節點的值</param>
        /// <param name="Qualities">節點的質量</param>
        /// <param name="TimeStamps">時間戳</param>
        private void KepGroup_DataChange(int TransactionID, int NumItems, ref Array ClientHandles, ref Array ItemValues, ref Array Qualities, ref Array TimeStamps)
        {
            for (int i = 1; i <= NumItems; i++)//下標一定要從1開始，NumItems參數是每次事件觸發時Group中實際發生數據變化的Item的數量，而不是整個Group里的Items
            {
                this.txtTagValue.Text = ItemValues.GetValue(i).ToString();
                this.txtQualities.Text = Qualities.GetValue(i).ToString();
                this.txtTimeStamps.Text = TimeStamps.GetValue(i).ToString();
            }
        }


        /// <summary>
        /// 選擇列表時觸發的事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        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 = 1;//節點編號為1
                    KepItem = KepItems.AddItem(listBox1.SelectedItem.ToString(), itmHandleClient);//第一個參數為ItemID,第二個參數為節點編號，節點編號可自定義
                    itmHandleServer = KepItem.ServerHandle;//獲取該節點的服務器句柄
                }
                else
                {
                    itmHandleClient = 1;//節點編號為1
                    KepItem = KepItems.AddItem(listBox1.SelectedItem.ToString(), itmHandleClient);//第一個參數為ItemID,第二個參數為節點編號，節點編號可自定義
                    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, "提示信息");
            }
        }


        /// <summary>
        /// 設置組屬性的按鈕點擊事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void BtnSetGroupPro_Click(object sender, EventArgs e)
        {
            SetGroupProperty();
        }


        /// <summary>
        /// “寫入”按鈕點擊事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        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();
        }


        /// <summary>
        /// 關閉窗口事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Form1_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;
        }
    }
}

至此，一個可讀可寫的客戶端就編寫好了，大家要是做得更好（比如多個節點的數據同時顯示在ListView控件上）可以分享出來大家一起學習。

源碼百度雲下載↓

鏈接:https://pan.baidu.com/s/1BmCa622CAdUQRbW8ahXtMg 提取碼:yvdw

該分享連接期限為永久，送給愛學習的人。如果大家發現該源碼里的BUG，或者有更好的解決方案可以在評論區說出來。最后由衷感謝那位不知名的大佬，在網上提供了初版代碼，讓我可以跌跌撞撞地入門學習。