OPC 服务器 操作示例源码

【实例截图】

【核心代码】

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using HaiGrang.Package.OpcNetApiChs.DaNet;
using HaiGrang.Package.OpcNetApiChs.Opc;
using HaiGrang.Package.OpcNetApiChs.Da;


namespace TestOPC
{
    public class OPC_Interface
    {
        /// <summary>OPC服务器打开状态</summary>
        bool openStatus = false;
        /// <summary>OPC服务器地址</summary>
        string serverIp = "";
        /// <summary>OPC服务器名称</summary>
        string serverName = "";
        /// <summary>OPC连接服务对象</summary>
        
        OpcServer _OpcServer;
        /// <summary>读取组对象</summary>
        SyncIOGroup syncIoGroup;
        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="_serverIp">OPC服务器地址</param>
        /// <param name="_serverName">OPC服务器名称</param>
        public OPC_Interface(string _serverIp, string _serverName)
        {
            serverIp = _serverIp;
            serverName = _serverName;
        }

        /// <summary>
        /// 打开OPC服务器
        /// </summary>
        public void OpenServer()
        {
            int rtc = -1;
            try
            {
                _OpcServer = new OpcServer();
                var opcServerType = Type.GetTypeFromProgID(serverName, serverIp);
                //rtc = _OpcServer.Logon("Administrator", "1");
                //Guid _guid = new Guid("b6eacb30-42d5-11d0-9517-0020afaa4b3c");
                rtc = _OpcServer.Connect(serverIp, opcServerType.GUID);
                if (HRESULTS.Succeeded(rtc))
                {
                    openStatus = true;
                    syncIoGroup = new SyncIOGroup(_OpcServer);
                }
                else
                {
                    openStatus = false;
                    _OpcServer = null;
                }
            }
            catch(Exception exp)
            {
                openStatus = false;
                _OpcServer = null;
                throw exp;
                //CommonClass.WriteLog("连接OPC服务器异常："   exp.StackTrace, LogType.Error);
                //记录日志
            }
        }

        /// <summary>
        /// 断开与OPC服务器的连接
        /// </summary>
        public void Close()
        {
            try
            {
                syncIoGroup.Dispose();
                _OpcServer.Disconnect();
            }
            catch (Exception exp)
            {
               // CommonClass.WriteLog("断开OPC服务器连接异常："   exp.StackTrace, LogType.Error);
                //记录日志
            }
        }

        /// <summary>获取OPC服务器打开状态</summary>
        public bool GetOpenStatus()
        {
            return openStatus;
        }

        /// <summary>
        /// 读取OPC服务器内指定item的值
        /// </summary>
        /// <param name="ItemName">item全名称</param>
        /// <returns></returns>
        public object Read(string ItemName)
        {
            object retVal = null;
            try
            {
                if (syncIoGroup.Item(ItemName) == null)
                {
                    syncIoGroup.Add(ItemName);
                }
                ItemDef _OpcItem = syncIoGroup.Item(ItemName);
                OPCDATASOURCE theSrc = OPCDATASOURCE.OPC_DS_DEVICE;
                OPCItemState theVal = new OPCItemState();

                int rtc = syncIoGroup.Read(theSrc, _OpcItem, out theVal);
                if (HRESULTS.Succeeded(rtc))
                {
                    if (theVal.DataValue != null)
                        retVal = theVal.DataValue;
                }                
            }
            catch (Exception exp)
            {
                //记录日志
               // CommonClass.WriteLog(string.Format("从OPC服务器读取Item({0})异常：", ItemName)   exp.StackTrace, LogType.Error);
            }
            return retVal;
        }

        /// <summary>
        /// 向OPC服务器写值
        /// </summary>
        /// <param name="ItemName">item全名称</param>
        /// <param name="theVal">要写入的值</param>
        /// <returns></returns>
        public bool Write(string ItemName, object theVal)
        {
            bool result = false;
            try
            {
                if (syncIoGroup.Item(ItemName) == null)
                {
                    syncIoGroup.Add(ItemName);
                }
                ItemDef _OpcItem = syncIoGroup.Item(ItemName);
                int rtc = syncIoGroup.Write(_OpcItem, theVal);
                if (HRESULTS.Succeeded(rtc))
                {
                    result = true;
                }
            }
            catch (Exception exp)
            {
                //CommonClass.WriteLog(string.Format("从OPC服务器写Item({0})数据异常：", ItemName)   exp.StackTrace, LogType.Error);
                //记录日志
            }
            return result;
        }
    }
}