工业数据读取与交互：C# 的奇妙之旅-编程实验室

C#读取组态王数据，DCS数据读取Wincc数据，读取数据库库数据，也可平台互相通讯交互，并支持读取其他PLC仪表数据给到SACADA系统。

在工业自动化领域，数据的读取与交互至关重要。今天咱们就聊聊如何用 C# 实现从组态王、DCS（通过 Wincc 读取）、数据库以及 PLC 仪表等多种数据源读取数据，并将其传递给 SACADA 系统。

一、C# 读取组态王数据

组态王是一款常见的工业自动化软件。要从组态王读取数据，首先得了解它提供的接口。通常可以通过 OPC（OLE for Process Control）协议来实现。

在 C# 中，我们可以借助一些第三方库，比如Kepware.KEPServerEX.V6来操作 OPC。假设我们已经安装并配置好了相关的 OPC 服务器与客户端环境，以下是一段简单的示例代码：

using System; using Kepware.KEPServerEX.V6; class ReadKingviewData { static void Main() { // 创建 OPC 服务器对象 OPCServer server = new OPCServer(); // 连接到 OPC 服务器 server.Connect("Kepware.KEPServerEX.V6"); // 获取 OPC 组对象 OPCGroups groups = server.OPCGroups; OPCGroup group = groups.Add("MyGroup"); // 设置更新速率等属性 group.UpdateRate = 1000; group.IsActive = true; // 获取 OPC 项对象 OPCItems items = group.OPCItems; OPCItem item = items.AddItem("KingviewTagName", 1); // 读取数据 object value; item.Read(out value); Console.WriteLine($"从组态王读取到的数据: {value}"); // 释放资源 item.Remove(); group.Remove(); server.Disconnect(); } }

代码分析：

首先引入Kepware.KEPServerEX.V6命名空间，这是与 OPC 服务器交互的关键。
创建OPCServer对象并连接到指定的 OPC 服务器，这里是"Kepware.KEPServerEX.V6"，不同环境可能不同。
创建并配置OPCGroup，设置更新速率和激活状态，这决定了数据获取的频率和是否生效。
添加OPCItem，这里的"KingviewTagName"是组态王中定义的标签名，要根据实际情况修改。
调用Read方法读取数据，并输出到控制台。最后释放相关资源，确保程序优雅结束。

二、DCS 数据读取 Wincc 数据

Wincc 也是工业界常用的监控软件，很多 DCS 系统会与之集成。同样可以利用 OPC 来读取 Wincc 数据，C# 代码结构与读取组态王数据类似。

using System; using Kepware.KEPServerEX.V6; class ReadWinccDataFromDCS { static void Main() { OPCServer server = new OPCServer(); server.Connect("WinccOPCServer"); OPCGroups groups = server.OPCGroups; OPCGroup group = groups.Add("WinccGroup"); group.UpdateRate = 1000; group.IsActive = true; OPCItems items = group.OPCItems; OPCItem item = items.AddItem("WinccTagName", 1); object value; item.Read(out value); Console.WriteLine($"从 Wincc（DCS 相关）读取到的数据: {value}"); item.Remove(); group.Remove(); server.Disconnect(); } }

这里主要区别在于连接的 OPC 服务器名称"WinccOPCServer"以及标签名"WinccTagName"，要依据实际的 Wincc 配置来。

三、读取数据库数据

读取数据库数据是编程中常见的操作，以 SQL Server 为例，在 C# 中可以使用System.Data.SqlClient命名空间。

using System; using System.Data.SqlClient; class ReadDatabaseData { static void Main() { string connectionString = "Data Source=YOUR_SERVER_NAME;Initial Catalog=YOUR_DATABASE_NAME;User ID=YOUR_USERNAME;Password=YOUR_PASSWORD"; using (SqlConnection connection = new SqlConnection(connectionString)) { string query = "SELECT ColumnName FROM YourTableName"; SqlCommand command = new SqlCommand(query, connection); connection.Open(); SqlDataReader reader = command.ExecuteReader(); while (reader.Read()) { Console.WriteLine(reader.GetString(0)); } reader.Close(); } } }

代码分析：

定义连接字符串，包含服务器名称、数据库名称、用户名和密码，需要根据实际数据库信息修改。
使用SqlConnection建立数据库连接，并在using块中确保连接使用完毕后正确释放。
定义 SQL 查询语句，这里简单查询表中的某一列。
创建SqlCommand对象执行查询，打开连接后通过ExecuteReader获取数据读取器。
使用SqlDataReader逐行读取数据并输出。

四、平台互相通讯交互及读取 PLC 仪表数据给到 SACADA 系统

要实现平台间的通讯交互以及将 PLC 仪表数据传递给 SACADA 系统，可以借助消息队列、Web 服务等技术。以 Web 服务为例，假设 SACADA 系统提供了接收数据的 Web API。

using System; using System.Net.Http; using System.Threading.Tasks; class SendPLCDataToSACADA { static async Task Main() { // 模拟从 PLC 仪表读取到的数据 string plcData = "SomePLCValue"; using (HttpClient client = new HttpClient()) { var content = new StringContent(plcData, System.Text.Encoding.UTF8, "application/json"); HttpResponseMessage response = await client.PostAsync("http://SACADA_System_API_Url", content); if (response.IsSuccessStatusCode) { Console.WriteLine("数据成功发送到 SACADA 系统"); } else { Console.WriteLine($"发送失败，状态码: {response.StatusCode}"); } } } }

代码分析：