当前位置：首页 > 行业动态 > 正文

c#同步读取opc数据库

admin
行业动态
2025-02-27
2

在C#中，可以使用OP C客户端库来同步读取OPC数据库。

在工业自动化领域，OPC（OLE for Process Control）技术被广泛应用于实现不同设备和系统之间的数据通信，对于使用C#语言进行开发的应用程序来说，同步读取OPC数据库是一项常见的需求，下面将详细介绍如何在C#中实现这一功能。

前提条件

1、安装OPC基金会的OPC .NET SDK：确保你的开发环境中已经安装了OPC .NET SDK，这是与OPC服务器进行交互的必要组件。

2、添加引用：在你的C#项目中，需要添加对OPC .NET SDK相关DLL文件的引用，这些文件位于安装目录的Bin文件夹下。

代码实现步骤

导入命名空间

using System;
using OpcComKit;
using OpcNetApi;

创建连接并订阅OPC服务器

需要创建一个OpcServer对象，并通过它连接到OPC服务器，可以创建一个或多个OpcGroup对象来组织和管理项集合。

// 定义OPC服务器的ProgID或URL
string opcServerProgId = "Matrikon.OPC.Simulation.1"; // 示例ProgID，实际使用时需替换为真实的ProgID
// 创建OPC服务器对象
OpcServer server = null;
try
{
    server = new OpcServer(null, opcServerProgId, null, null);
    // 连接到OPC服务器
    server.Connect();
}
catch (Exception ex)
{
    Console.WriteLine("连接到OPC服务器失败: " + ex.Message);
    return;
}
// 创建OPC组对象
OpcGroup group = null;
try
{
    group = new OpcGroup(server, "MyGroup", "GroupName", 500, 0.5);
    // 添加项到组中（这里以一个模拟的标签为例）
    OpcItem item = new OpcItem("Random.Int4", "Random_Int4");
    group.Add(new OpcItem[] { item });
}
catch (Exception ex)
{
    Console.WriteLine("创建OPC组失败: " + ex.Message);
    if (server != null)
    {
        server.Disconnect();
    }
    return;
}

同步读取数据

一旦OPC组和项被成功创建并添加到组中，就可以通过调用Read方法来同步读取数据。

// 定义读取选项
OpcDataAccess[] readOptions = new OpcDataAccess[1];
readOptions[0] = new OpcDataAccess();
readOptions[0].ClientHandle = item.ClientHandle;
readOptions[0].ItemName = item.ItemName;
readOptions[0].NumValues = 1;
readOptions[0].StartTime = DateTime.MinValue;
readOptions[0].EndTime = DateTime.Now;
// 执行读取操作
OpcItemResult[] results = group.Read(readOptions, out int numItemsRead, out int quality, out int timeStamp);
if (results != null && results.Length > 0)
{
    foreach (var result in results)
    {
        Console.WriteLine("项名: " + result.ItemName);
        Console.WriteLine("值: " + result.Value);
        Console.WriteLine("质量: " + result.Quality);
        Console.WriteLine("时间戳: " + result.Timestamp);
    }
}
else
{
    Console.WriteLine("读取数据失败");
}

断开连接并清理资源

完成数据读取后，记得断开与OPC服务器的连接，并释放相关资源。

// 从组中移除项
group.Remove(new int[] { item.ClientHandle }, out int numRemoved);
// 销毁组对象
group.Destroy();
// 断开与OPC服务器的连接
server.Disconnect();

完整示例代码

以下是一个完整的示例代码，展示了如何使用C#同步读取OPC数据库：

c#同步读取opc数据库

using System;
using OpcComKit;
using OpcNetApi;
class Program
{
    static void Main(string[] args)
    {
        string opcServerProgId = "Matrikon.OPC.Simulation.1"; // 替换为实际的ProgID
        OpcServer server = null;
        OpcGroup group = null;
        OpcItem item = null;
        try
        {
            // 创建并连接OPC服务器
            server = new OpcServer(null, opcServerProgId, null, null);
            server.Connect();
            // 创建OPC组并添加项
            group = new OpcGroup(server, "MyGroup", "GroupName", 500, 0.5);
            item = new OpcItem("Random.Int4", "Random_Int4");
            group.Add(new OpcItem[] { item });
            // 定义读取选项并执行读取操作
            OpcDataAccess[] readOptions = new OpcDataAccess[1];
            readOptions[0] = new OpcDataAccess();
            readOptions[0].ClientHandle = item.ClientHandle;
            readOptions[0].ItemName = item.ItemName;
            readOptions[0].NumValues = 1;
            readOptions[0].StartTime = DateTime.MinValue;
            readOptions[0].EndTime = DateTime.Now;
            OpcItemResult[] results = group.Read(readOptions, out int numItemsRead, out int quality, out int timeStamp);
            if (results != null && results.Length > 0)
            {
                foreach (var result in results)
                {
                    Console.WriteLine("项名: " + result.ItemName);
                    Console.WriteLine("值: " + result.Value);
                    Console.WriteLine("质量: " + result.Quality);
                    Console.WriteLine("时间戳: " + result.Timestamp);
                }
            }
            else
            {
                Console.WriteLine("读取数据失败");
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine("异常: " + ex.Message);
        }
        finally
        {
            // 清理资源
            if (group != null)
            {
                group.Remove(new int[] { item.ClientHandle }, out int numRemoved);
                group.Destroy();
            }
            if (server != null)
            {
                server.Disconnect();
            }
        }
    }
}