C#l連接OPC進行數據交互


步驟 :引用 OPCNETAPI.DLL&&OPCNETAPI.COM.DLL

          1。查詢服務器      2. 連接服務器  3. 讀取數據     4.寫入數據

1.查詢服務器 :根據IP地址進行查詢

代碼如下 :

          //查詢服務器
            try
            {
                Opc.Server[] servers = m_discovery.GetAvailableServers(Specification.COM_DA_20, “OPC服務器IP地址”, null);
                if (servers != null)
                {   //遍歷所查詢到的所有OPC服務器,將其新增到 comboBox1 下拉列表框中
                    foreach (Opc.Da.Server server in servers)
                    {
                        comboBox1.Items.Add(server.Name);
                    }
                }
                comboBox1.SelectedIndex = 0;
                listBox1.Items.Add("查詢服務器成功.請選擇OPC進行連接");
            }
            catch (Exception ex)
            {

                listBox1.Items.Add(ex.Message);
            }

2. 連接服務器

   

                try
                {
                    Opc.Server[] servers = m_discovery.GetAvailableServers(Specification.COM_DA_20, “OPCIP地址”, null);
                    if (servers != null)
                    {
                        foreach (Opc.Da.Server server in servers)
                        {
                            if (String.Compare(server.Name, comboBox1.Text, true) == 0)//為true忽略大小寫
                            {
                                m_server = server;//建立連接。
                                break;
                            }
                        }
                    }
                }
                catch (Exception ex)
                {

                    listBox1.Items.Add(ex.Message);
                    return;
                }
                if (m_server != null)
                {
                    try
                    {
                        m_server.Connect();
                        listBox1.Items.Add("OPC服務器連接成功,請填寫變量名稱進行讀取數據");

                    }
                    catch (Exception ex)
                    {
                        listBox1.Items.Add(ex.Message);

                    }

                }
                else
                {
                    listBox1.Items.Add("連接失敗,請檢查IP以及服務器對象");
                }
            }

3. 讀取

         try
            {

                state = new Opc.Da.SubscriptionState();//組(訂閱者)狀態,相當於OPC規范中組的參數
                state.Name ="";//組名 可為空
                state.ServerHandle = null;//服務器給該組分配的句柄。
                state.ClientHandle = Guid.NewGuid().ToString();//客戶端給該組分配的句柄。
                state.Active = true;//激活該組。
                state.UpdateRate = 1000;//刷新頻率為1秒。
                state.Deadband = 0;// 死區值,設為0時,服務器端該組內任何數據變化都通知組。
                state.Locale = null;//不設置地區值。
                 subscription = (Opc.Da.Subscription)m_server.CreateSubscription(state);//創建組
                string[] itemName = new string[1];
                itemName[0] = textBox2.Text; //OPC變量名稱(項目代碼)
                Item[] items = new Item[1];//定義數據項,即item
                items[0] = new Item();
                items[0].ClientHandle = Guid.NewGuid().ToString();//客戶端給該數據項分配的句柄。
                items[0].ItemPath = null; //該數據項在服務器中的路徑。
                items[0].ItemName = itemName[0]; //該數據項在服務器中的名字。
                 subscription.AddItems(items);

                 ItemValueResult[] values = subscription.Read(subscription.Items);
                 for (int i = 0; i < values.Length; i++)
                {
                    if (values[i].ToString() != "")
                     {
                        MessageBox.Show("4.1" + values[i].Value.ToString());
                    }
                }
 
                if (values[0].Quality.Equals(Opc.Da.Quality.Good))
                {
                     textBox3.Text = values[0].Value.ToString();//變量接收取到的值
                    listBox1.Items.Add("成功讀取變量為<" + textBox2.Text + ">的數據.值為<" + textBox3.Text + ">");
                 }
               
            }
            catch (Exception ex)
            {
                 listBox1.Items.Add(ex.Message);
            }

 

4. 寫入

            state = new Opc.Da.SubscriptionState();//組(訂閱者)狀態,相當於OPC規范中組的參數
            state.Name = "";// textBox4.Text;//組名
            state.ServerHandle = null;//服務器給該組分配的句柄。
            state.ClientHandle = Guid.NewGuid().ToString();//客戶端給該組分配的句柄。
            state.Active = true;//激活該組。
            state.UpdateRate = 1000;//刷新頻率為1秒。
            state.Deadband = 0;// 死區值,設為0時,服務器端該組內任何數據變化都通知組。
            state.Locale = null;//不設置地區值。 
            subscription = (Opc.Da.Subscription)m_server.CreateSubscription(state);//創建組
            string[] itemName = new string[1];
            itemName[0] =textBox7.Text;  //OPC變量名稱  (項目代碼)
            Item[] items = new Item[1];//定義數據項,即item
            items[0] = new Item();
            items[0].ClientHandle = Guid.NewGuid().ToString();//客戶端給該數據項分配的句柄。
            items[0].ItemPath = null; //該數據項在服務器中的路徑。
            items[0].ItemName = itemName[0]; //該數據項在服務器中的名字。
            subscription.AddItems(items);       
            ItemValue[] itemvalues2 = new ItemValue[3];
            listBox1.Items.Add(string.Format("subscription Items count:{0}", subscription.Items.Length));
            listBox1.Items.Add(string.Format("subscription Items[0]:{0}", subscription.Items[0].ItemName));
            ItemValue iv = new ItemValue((ItemIdentifier)subscription.Items[0]);
            iv.Value = textBox8.Text;//需要寫入OPC中的值
            subscription.Write(new ItemValue[] { iv });
            subscription.RemoveItems(subscription.Items);
            m_server.CancelSubscription(subscription);//m_server前文已說明,通知服務器要求刪除組。

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM