【核心代碼】

using OPCAutomation;
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.Windows.Forms;

namespace OPCDemo
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }

        #region 私有變量
        /// <summary>
        /// OPCServer Object
        /// </summary>
        OPCServer KepServer;
        /// <summary>
        /// OPCGroups Object
        /// </summary>
        OPCGroups KepGroups;
        /// <summary>
        /// OPCGroup Object
        /// </summary>
        OPCGroup KepGroup;
        /// <summary>
        /// OPCItems Object
        /// </summary>
        OPCItems KepItems;
        /// <summary>
        /// OPCItem Object
        /// </summary>
        OPCItem[] KepItem;
        /// <summary>
        /// 主機(jī)IP
        /// </summary>
        string strHostIP = "";
        /// <summary>
        /// 主機(jī)名稱
        /// </summary>
        string strHostName = "";
        /// <summary>
        /// 連接狀態(tài)
        /// </summary>
        bool opc_connected = false;
        /// <summary>
        /// 客戶端句柄
        /// </summary>
        int itmHandleClient = 0;
        /// <summary>
        /// 服務(wù)端句柄
        /// </summary>
        int itmHandleServer = 0;
        #endregion

        #region 方法
        /// <summary>
        /// 枚舉本地OPC服務(wù)器
        /// </summary>
        private void GetLocalServer()
        {
            //獲取本地計(jì)算機(jī)IP,計(jì)算機(jī)名稱
            IPHostEntry IPHost = Dns.Resolve(Environment.MachineName);
            if (IPHost.AddressList.Length > 0)
            {
                strHostIP = IPHost.AddressList[0].ToString();
            }
            else
            {
                return;
            }
            //通過IP來獲取計(jì)算機(jī)名稱，可用在局域網(wǎng)內(nèi)
            IPHostEntry ipHostEntry = Dns.GetHostByAddress(strHostIP);
            strHostName = ipHostEntry.HostName.ToString();

            //獲取本地計(jì)算機(jī)上的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服務(wù)器出錯(cuò)："   err.Message, "提示信息", MessageBoxButtons.OK, MessageBoxIcon.Warning);
            }

        }


        /// <summary>
                /// 設(shè)置組屬性
                /// </summary>
        private void SetGroupProperty()
        {
            KepServer.OPCGroups.DefaultGroupIsActive = true;
            KepServer.OPCGroups.DefaultGroupDeadband = 0;
            KepServer.OPCGroups.DefaultGroupUpdateRate = 200;
            KepGroup.UpdateRate = 150;
            KepGroup.IsActive = true;
            KepGroup.IsSubscribed = true;//使用訂閱功能
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            KepItem = new OPCItem[4];
            GetLocalServer();
        }


        /// <summary>
                /// 每當(dāng)項(xiàng)數(shù)據(jù)有變化時(shí)執(zhí)行的事件
                /// </summary>
                /// <param name="TransactionID">處理ID</param>
                /// <param name="NumItems">項(xiàng)個(gè)數(shù)</param>
                /// <param name="ClientHandles">項(xiàng)客戶端句柄</param>
                /// <param name="ItemValues">TAG值</param>
                /// <param name="Qualities">品質(zhì)</param>
                /// <param name="TimeStamps">時(shí)間戳</param>
        void KepGroup_DataChange(int TransactionID, int NumItems, ref Array ClientHandles, ref Array ItemValues, ref Array Qualities, ref Array TimeStamps)
        {
            
           
            
            //為了測(cè)試，所以加了控制臺(tái)的輸出，來查看事物ID號(hào)
            //Console.WriteLine("********" TransactionID.ToString() "*********");
            for (int i = 1; i <= NumItems; i  )
            {
                MessageBox.Show(ClientHandles.GetValue(i).ToString()   " _ "  ItemValues.GetValue(i).ToString());
                //Console.WriteLine("********"   ItemValues.GetValue(i).ToString()   "*********");
                //this.txtTagValue.Text = ItemValues.GetValue(i).ToString();
                //this.txtQualities.Text = Qualities.GetValue(i).ToString();
                //this.txtTimeStamps.Text = TimeStamps.GetValue(i).ToString();
            }
            

        }

        /// 寫入TAG值時(shí)執(zhí)行的事件
                /// </summary>
                /// <param name="TransactionID"></param>
                /// <param name="NumItems"></param>
                /// <param name="ClientHandles"></param>
                /// <param name="Errors"></param>
        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>
                /// 創(chuàng)建組
                /// </summary>
        private bool CreateGroup()
        {
            try
            {
                KepGroups = KepServer.OPCGroups;
                KepGroup = KepGroups.Add("ceshi");

                SetGroupProperty();

                KepGroup.DataChange  = new DIOPCGroupEvent_DataChangeEventHandler(KepGroup_DataChange);
                KepGroup.AsyncWriteComplete  = new DIOPCGroupEvent_AsyncWriteCompleteEventHandler(KepGroup_AsyncWriteComplete);
                //添加組成員
                {
                    KepItems = KepGroup.OPCItems;

                    
                    KepItem[0] = KepItems.AddItem("test2_bool",0);
                    KepItem[1] = KepItems.AddItem("test1_int", 1);
                }
                
            }
            catch (Exception err)
            {
                MessageBox.Show("創(chuàng)建組出現(xiàn)錯(cuò)誤："   err.Message, "提示信息", MessageBoxButtons.OK, MessageBoxIcon.Warning);
                return false;
            }
            return true;
        }



        /// <summary>
        /// 列出OPC服務(wù)器中所有節(jié)點(diǎn)
        /// </summary>
        /// <param name="oPCBrowser"></param>
        private void RecurBrowse(OPCBrowser oPCBrowser)
        {
            //展開分支
            oPCBrowser.ShowBranches();
            //展開葉子
            oPCBrowser.ShowLeafs(true);
            foreach (object turn in oPCBrowser)
            {
                listBox1.Items.Add(turn.ToString());
            }
        }

        /// <summary>
                /// 連接OPC服務(wù)器
                /// </summary>
                /// <param name="remoteServerIP">OPCServerIP</param>
                /// <param name="remoteServerName">OPCServer名稱</param>
        private bool ConnectRemoteServer(string remoteServerIP, string remoteServerName)
        {
            try
            {
                KepServer.Connect(remoteServerName, remoteServerIP);

                if (KepServer.ServerState == (int)OPCServerState.OPCRunning)
                {
                    lbl1.Text = "已連接到-"   KepServer.ServerName   "   ";
                }
                else
                {
                    //這里你可以根據(jù)返回的狀態(tài)來自定義顯示信息，請(qǐng)查看自動(dòng)化接口API文檔
                    lbl1.Text = "狀態(tài)："   KepServer.ServerState.ToString()   "   ";
                }
            }
            catch (Exception err)
            {
                MessageBox.Show("連接遠(yuǎn)程服務(wù)器出現(xiàn)錯(cuò)誤："   err.Message, "提示信息", MessageBoxButtons.OK, MessageBoxIcon.Warning);
                return false;
            }
            return true;
        }

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

                // OPC.SimaticHMI.CoRtHmiRTm.1
                //  OPCServer.WinCC.1
                
                if (!ConnectRemoteServer("127.0.0.1", txtConStr.Text))
                {
                    return;
                }

                opc_connected = true;


                RecurBrowse(KepServer.CreateBrowser());

                if (!CreateGroup())
                {
                    MessageBox.Show("創(chuàng)建組失敗！");
                    return;
                }
              

            }
            catch (Exception err)
            {
                MessageBox.Show("初始化出錯(cuò)："   err.Message, "提示信息", MessageBoxButtons.OK, MessageBoxIcon.Warning);
            }
        }

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

        private void bntWrite_Click(object sender, EventArgs e)
        {
            Random rd = new Random();
            
            KepItem[1].Write(rd.Next(100, 500));
        }
    }
}
#endregion