C#实现实时读取西门子PLC数据，并存到Redis数据库中

using S7.Net;

using StackExchange.Redis;

using System.Threading.Channels;

// ====== PLC配置 ======

public class PlcConfig
{
public string Ip { get; set; } = "192.168.0.1";

public int Rack { get; set; } = 0;

public int Slot { get; set; } = 1;

public CpuType CpuType { get; set; } = CpuType.S71200;

}

// ====== Redis配置 ======

public class RedisConfig
{

public string ConnectionString { get; set; } = "localhost:6379";

public int Database { get; set; } = 0;

}

// ====== 主服务类 ======

public class PlcToRedisService
{

private readonly Plc _plc; private readonly IDatabase _redisDb;

private readonly Channel<PlcData> _dataChannel = Channel.CreateUnbounded<PlcData>(); private CancellationTokenSource _cts = new();

public PlcToRedisService(PlcConfig plcConfig, RedisConfig redisConfig)
{

_plc = new Plc(plcConfig.CpuType, plcConfig.Ip, plcConfig.Rack, plcConfig.Slot) { ReadTimeout = 500, WriteTimeout = 500

};

var redis = ConnectionMultiplexer.Connect(redisConfig.ConnectionString);

_redisDb = redis.GetDatabase(redisConfig.Database);

}

public async Task StartAsync()
{
// PLC读取线程

var readTask = Task.Run(async () => { while (!_cts.IsCancellationRequested)
{
 try
 {

if (!_plc.IsConnected) await _plc.OpenAsync();

// 读取DB100中前20字节（根据实际PLC地址修改）

var data = await _plc.ReadBytesAsync(DataType.DataBlock, 100, 0, 20);

var plcData = ParseData(data); // 自定义数据解析

await _dataChannel.Writer.WriteAsync(plcData, _cts.Token);
}

catch (Exception ex)
{

Console.WriteLine($"PLC读取失败: {ex.Message}");

await ReconnectPlc();
}

await Task.Delay(100, _cts.Token); // 100ms采样周期

} }); // Redis写入线程

var writeTask = Task.Run(async () => { await foreach (var data in _dataChannel.Reader.ReadAllAsync(_cts.Token))
{

try

{
// 使用Hash存储数据到
Redis var entries = new HashEntry[]
{
new("Temperature", data.Temperature), new("Pressure", data.Pressure), new("Timestamp", DateTime.UtcNow.Ticks)
};

await _redisDb.HashSetAsync($"plc:{data.DeviceId}", entries);

await _redisDb.KeyExpireAsync($"plc:{data.DeviceId}", TimeSpan.FromMinutes(10));

}

catch (Exception ex)
{
Console.WriteLine($"Redis写入失败: {ex.Message}"); } } });
await Task.WhenAll(readTask, writeTask);
}

private PlcData ParseData(byte[] rawData)
{
// 示例解析逻辑（需根据实际PLC数据结构实现）
return new PlcData { DeviceId = 1, Temperature = BitConverter.ToSingle(rawData, 0), // 前4字节转float Pressure = BitConverter.ToInt16(rawData, 4) // 5-6字节转short };
}

private async Task ReconnectPlc()
{
_plc.Close(); for (int i = 0; i < 3; i++)
{
try
{

await _plc.OpenAsync(); Console.WriteLine("PLC重连成功"); return; }

catch { await Task.Delay(1000);

}

}

throw new Exception("PLC无法连接");

}

public async Task StopAsync()
{
_cts.Cancel(); _plc.Close();
await _redisDb.Multiplexer.CloseAsync();

}

}

// ====== 数据模型 ======

public class PlcData
{
public int DeviceId { get; set; }
public float Temperature { get; set; }
public short Pressure { get; set; }
}

// ====== 使用示例 ======

var plcConfig = new PlcConfig();
var redisConfig = new RedisConfig();
var service = new PlcToRedisService(plcConfig, redisConfig);
await service.StartAsync();

// 运行中... await Task.Delay(TimeSpan.FromMinutes(60));

await service.StopAsync();