using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Net.Sockets;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using System.Windows;
|
using NModbus;
|
using NModbus.Device;
|
using NModbus.Extensions.Enron;
|
using OpenCvSharp;
|
|
namespace SmartScanner
|
{
|
class ModbusTCPClient
|
{
|
public TcpClient _client;
|
public IModbusMaster _master;
|
public ModbusFactory factory = new ModbusFactory();
|
public int isconnnum = 1;
|
public ushort[] previousValus_trigger = { 0, 0 }; //寄存器当前值
|
public ushort[] currentValus_trigger = { 0, 0 }; //寄存器前一个值
|
public ushort[] previousValus_ROIModel = { 0, 0 };
|
public ushort[] currentValus_ROIModel = { 0, 0 };
|
public bool istrigger = false;
|
|
// 重连相关字段
|
public const int MaxReconnectAttempts = 5; // 最大重连次数
|
public const int ReconnectInterval = 5000; // 重连间隔时间(毫秒)
|
private int _reconnectAttempts = 0; // 当前重连尝试次数
|
private bool _isReconnecting = false; // 是否正在重连
|
|
public void ModbudTCP_Connect(string ipAddress, int port)
|
{
|
try
|
{
|
_client = new TcpClient(ipAddress, port);
|
if (_client.Connected)
|
{
|
// 创建 TCP 客户端
|
//MessageBox.Show("连接到服务器成功");
|
// 创建 Modbus 工厂和主机
|
_master = (ModbusMaster)factory.CreateMaster(_client);
|
if (_master == null)
|
{
|
MessageBox.Show("无法创建 Modbus master 实例。");
|
return;
|
}
|
// 连接成功，重置重连计数
|
_reconnectAttempts = 0;
|
}
|
else
|
{
|
if (isconnnum++ < 5)
|
{
|
ModbudTCP_Connect(ipAddress, port);
|
Thread.Sleep(1000);
|
}
|
else
|
{
|
MessageBox.Show("连接到服务器超时");
|
return;
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
MessageBox.Show($"连接到服务器失败：{ex.Message}", "错误", MessageBoxButton.OK, MessageBoxImage.Error);
|
Console.WriteLine("连接到服务器失败");
|
return;
|
}
|
}
|
|
// 重连方法
|
public bool Reconnect(string ipAddress, int port)
|
{
|
// 避免重复重连
|
if (_isReconnecting) return false;
|
|
_isReconnecting = true;
|
|
try
|
{
|
// 释放原有连接
|
_master?.Dispose();
|
_client?.Close();
|
_client = null;
|
|
// 检查是否超过最大重连次数
|
if (_reconnectAttempts >= MaxReconnectAttempts)
|
{
|
Console.WriteLine("Modbus重连失败，已达到最大重连次数");
|
return false;
|
}
|
|
_reconnectAttempts++;
|
Console.WriteLine($"尝试第{_reconnectAttempts}次重连...");
|
|
// 尝试重新连接
|
_client = new TcpClient();
|
var connectTask = _client.ConnectAsync(ipAddress, port);
|
|
// 等待连接完成，最多等待5秒
|
if (connectTask.Wait(5000))
|
{
|
if (_client.Connected)
|
{
|
_master = (ModbusMaster)factory.CreateMaster(_client);
|
if (_master != null)
|
{
|
// 重连成功，重置计数
|
_reconnectAttempts = 0;
|
Console.WriteLine("Modbus重连成功");
|
return true;
|
}
|
}
|
}
|
|
return false;
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"重连失败: {ex.Message}");
|
return false;
|
}
|
finally
|
{
|
_isReconnecting = false;
|
}
|
}
|
|
public ushort[] HoldingRegisterRead(ushort starAddress) //读保持寄存器
|
{
|
try
|
{
|
ushort[] registerValues = _master.ReadHoldingRegisters(1, starAddress, 1);
|
return registerValues;
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"读取保持寄存器失败: {ex.Message}");
|
throw;
|
}
|
}
|
|
public void HoldingRegisterWrite(ushort registerAddress, ushort WriteValue) //写保存寄存器
|
{
|
try
|
{
|
_master.WriteSingleRegister(1, registerAddress, WriteValue);
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"写入保持寄存器失败: {ex.Message}");
|
throw;
|
}
|
}
|
public void SingleCoilWrite(ushort CoilAddress, bool valueToWrite) //写单线圈
|
{
|
try
|
{
|
_master.WriteSingleCoil(1, CoilAddress, valueToWrite);
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"写入单线圈失败: {ex.Message}");
|
throw;
|
}
|
}
|
public void MultipleRegistersWrite(ushort starAddress, ushort[] valueToWrite)
|
{
|
try
|
{
|
_master.WriteMultipleRegisters(1, starAddress, valueToWrite);
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"写入多个寄存器失败: {ex.Message}");
|
throw;
|
}
|
}
|
public ushort[] InputRegistersRead(ushort starAddress)
|
{
|
try
|
{
|
ushort[] registerValues = _master.ReadInputRegisters(1, starAddress, 1);
|
return registerValues;
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"读取输入寄存器失败: {ex.Message}");
|
throw;
|
}
|
}
|
}
|
}
|
