C#/.NET 6 实战：用Sharp7库读写西门子S7-1200 PLC数据（附完整源码）
工业自动化领域正经历着IT与OT技术的深度融合，而.NET开发者如何快速接入PLC控制系统成为许多项目中的关键需求。西门子S7-1200/1500系列作为市场主流PLC设备，其数据交互能力直接影响着工业物联网系统的构建效率。本文将完整演示如何基于.NET 6+环境，使用Sharp7库实现稳定可靠的PLC通信解决方案。
1. 环境准备与项目配置
1.1 开发环境要求
- 开发工具：Visual Studio 2022（社区版即可）
- 目标框架：.NET 6.0 LTS或更高版本
- 硬件准备：
- 西门子S7-1200 PLC（固件版本V4.0+）
- 工业级交换机或直连网线
- 配置好IP地址的工控网络环境
1.2 NuGet包引入
在Package Manager Console执行：
Install-Package Sharp7 -Version 1.4.1或通过NuGet UI搜索安装Sharp7包。该库提供了原生S7协议实现，相比OPC UA等方案具有更低延迟。
注意：生产环境建议锁定具体版本号，避免自动升级导致兼容性问题
2. PLC通信基础架构
2.1 建立TCP连接
创建S7Client实例并实现连接管理：
public class PlcService : IDisposable { private readonly S7Client _client = new(); private readonly string _ip; private readonly int _rack; private readonly int _slot; public PlcService(string ip, int rack = 0, int slot = 1) { _ip = ip; _rack = rack; _slot = slot; } public bool Connect() { int result = _client.ConnectTo(_ip, _rack, _slot); if (result == 0) { Console.WriteLine($"PDU Size: {_client.PduSizeNegotiated}"); return true; } throw new Exception($"连接失败: {_client.ErrorText(result)}"); } public void Dispose() => _client.Disconnect(); }2.2 连接状态检测
建议添加心跳检测机制：
public bool IsConnected { get { var status = _client.GetConnectionStatus(); return status == S7Client.ConnStatus.Connected; } }3. 数据读写核心操作
3.1 基本数据类型处理
Sharp7支持多种PLC数据类型转换：
| PLC类型 | C#类型 | 读取方法 | 写入方法 |
|---|---|---|---|
| Bool | bool | GetBitAt | SetBitAt |
| Int | short | GetIntAt | SetIntAt |
| DInt | int | GetDIntAt | SetDIntAt |
| Real | float | GetRealAt | SetRealAt |
| String | string | GetStringAt | SetStringAt |
3.2 单值读写示例
读取DB块中的温度值（REAL类型）：
public float ReadTemperature(int dbNumber, int startOffset) { byte[] buffer = new byte[4]; int result = _client.DBRead(dbNumber, startOffset, 4, buffer); if (result != 0) throw new Exception(_client.ErrorText(result)); return S7.GetRealAt(buffer, 0); }写入设备状态（BOOL类型）：
public void SetDeviceStatus(int dbNumber, int byteOffset, int bitOffset, bool status) { byte[] buffer = new byte[1]; int result = _client.DBRead(dbNumber, byteOffset, 1, buffer); if (result != 0) throw new Exception(_client.ErrorText(result)); S7.SetBitAt(ref buffer, 0, bitOffset, status); _client.DBWrite(dbNumber, byteOffset, 1, buffer); }4. 高级应用与性能优化
4.1 批量读写技术
使用S7MultiVar提升吞吐量：
public Dictionary<string, object> ReadBatchData(int dbNumber, params (int offset, Type type)[] items) { var multiVar = new S7MultiVar(_client); var buffers = new Dictionary<int, byte[]>(); // 准备缓冲区 foreach (var item in items) { int size = GetTypeSize(item.type); byte[] buffer = new byte[size]; buffers.Add(item.offset, buffer); multiVar.Add(S7Consts.S7AreaDB, S7Consts.S7WLByte, dbNumber, item.offset, size, ref buffer); } // 执行批量读取 int result = multiVar.Read(); if (result != 0) throw new Exception(_client.ErrorText(result)); // 转换数据 var results = new Dictionary<string, object>(); foreach (var item in items) { object value = ConvertBuffer(buffers[item.offset], item.type); results.Add($"DB{dbNumber}.DB{item.offset}", value); } return results; } private int GetTypeSize(Type type) => type.Name switch { nameof(Boolean) => 1, nameof(Int16) => 2, nameof(Int32) => 4, nameof(Single) => 4, _ => throw new NotSupportedException() };4.2 异常处理策略
建议实现重试机制：
public T ExecuteWithRetry<T>(Func<T> action, int maxRetries = 3) { int retries = 0; while (true) { try { return action(); } catch (Exception ex) when (retries < maxRetries) { retries++; Thread.Sleep(100 * retries); if (!IsConnected) Connect(); } } }5. 实战项目集成
5.1 WinForms监控界面
创建实时数据看板：
public partial class PlcMonitor : Form { private readonly PlcService _plc; private readonly System.Timers.Timer _timer; public PlcMonitor(string ip) { _plc = new PlcService(ip); _plc.Connect(); _timer = new System.Timers.Timer(1000); _timer.Elapsed += async (s, e) => await UpdateDataAsync(); _timer.Start(); } private async Task UpdateDataAsync() { var temp = await Task.Run(() => _plc.ReadTemperature(1, 10)); this.Invoke(() => lblTemperature.Text = $"{temp}°C"); } }5.2 完整解决方案结构
推荐项目目录组织：
S7Communication/ ├── S7Core/ # 核心通信库 │ ├── PlcService.cs │ └── Models/ ├── S7WebAPI/ # REST API接口层 ├── S7WinForms/ # 桌面监控程序 └── S7Tests/ # 单元测试6. 常见问题排查
6.1 连接故障诊断
检查清单：
- 确认PLC IP地址与PC在同一网段
- 关闭Windows防火墙或添加出入站规则
- 检查PLC连接属性中的"允许PUT/GET通信"
- 使用ping测试基础网络连通性
6.2 数据不一致分析
典型场景处理：
- 字节序问题：西门子PLC使用大端序，需确认Sharp7的转换逻辑
- 数据类型不匹配：确保DB块定义与代码类型一致
- 偏移量错误：使用TIA Portal查看变量实际存储位置
调试时可先用DB块查看器确认原始数据
7. 性能调优建议
7.1 通信参数优化
关键配置项：
| 参数 | 推荐值 | 说明 |
|---|---|---|
| PDU大小 | 480字节 | 最大支持值 |
| 轮询间隔 | ≥100ms | 根据实际需求调整 |
| TCP KeepAlive | 启用 | 防止连接意外断开 |
7.2 内存管理技巧
避免频繁分配缓冲区：
// 使用ArrayPool优化 public float ReadOptimized(int dbNumber, int offset) { var buffer = ArrayPool<byte>.Shared.Rent(4); try { _client.DBRead(dbNumber, offset, 4, buffer); return S7.GetRealAt(buffer, 0); } finally { ArrayPool<byte>.Shared.Return(buffer); } }8. 安全实施方案
8.1 访问控制策略
建议措施：
- 在PLC端配置访问密码
- 使用防火墙限制源IP
- 实现应用层的用户权限管理
- 敏感操作记录审计日志
8.2 数据验证模式
防止无效值写入：
public void SafeWrite(int dbNumber, int offset, float value) { if (float.IsNaN(value)) throw new ArgumentException("无效的浮点数值"); if (value < 0 || value > 1000) throw new ArgumentOutOfRangeException("数值超出安全范围"); byte[] buffer = new byte[4]; S7.SetRealAt(buffer, 0, value); _client.DBWrite(dbNumber, offset, 4, buffer); }9. 扩展应用场景
9.1 云端数据集成
通过MQTT转发PLC数据：
public class PlcMqttBridge { private readonly PlcService _plc; private readonly IMqttClient _mqtt; public async Task StartAsync() { var factory = new MqttFactory(); _mqtt = factory.CreateMqttClient(); await _mqtt.ConnectAsync(new MqttClientOptionsBuilder() .WithTcpServer("iot.example.com") .Build()); _ = Task.Run(() => PublishDataAsync()); } private async Task PublishDataAsync() { while (true) { var temp = _plc.ReadTemperature(1, 10); var message = new MqttApplicationMessageBuilder() .WithTopic("factory/plc/temperature") .WithPayload(temp.ToString()) .Build(); await _mqtt.PublishAsync(message); await Task.Delay(1000); } } }9.2 历史数据存储
使用时序数据库方案：
public void SaveToInfluxDB(float value) { var point = PointData.Measurement("plc_data") .Tag("device", "S7-1200") .Field("temperature", value) .Timestamp(DateTime.UtcNow, WritePrecision.Ns); using var client = InfluxDBClientFactory.Create("http://localhost:8086"); using var writeApi = client.GetWriteApi(); writeApi.WritePoint("factory_db", "autogen", point); }10. 源码工程实践
完整解决方案包含以下关键组件：
- 核心通信库：封装所有Sharp7交互逻辑
- 依赖注入配置：方便在不同项目中复用
- 配置管理：支持appsettings.json配置PLC参数
- 日志系统：集成Serilog记录通信细节
- 单元测试：包含模拟PLC的测试用例
典型使用示例：
// 在Program.cs中配置服务 builder.Services.AddPlcService(options => { options.IPAddress = "192.168.0.10"; options.Rack = 0; options.Slot = 1; options.RetryCount = 3; }); // 在控制器中使用 [ApiController] [Route("api/[controller]")] public class PlcController : ControllerBase { private readonly IPlcService _plc; public PlcController(IPlcService plc) => _plc = plc; [HttpGet("temperature")] public ActionResult<float> GetTemperature() => Ok(_plc.ReadTemperature(1, 10)); }实际部署时发现，合理的连接超时设置（建议2-3秒）能显著提升系统稳定性。对于高频数据采集场景，建议采用后台服务集中读取再分发的架构，避免多个客户端直接连接PLC造成负载压力。
