luosheng/Modbus.Net
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add Comments

Browse Source
This commit is contained in:
parallelbgls
2017-12-22 16:21:48 +08:00
parent 477ab33c36
commit d3e25ea820
22 changed files with 201 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
Modbus.Net/Modbus.Net.Modbus/AddressTranslatorModbus.cs
View File

@@ -3,6 +3,9 @@ using System.Linq;
namespace Modbus.Net.Modbus
{
/// <summary>
/// Modbus地址翻译器基类
/// </summary>
public abstract class ModbusTranslatorBase : AddressTranslator
{
/// <summary>

2
Modbus.Net/Modbus.Net.Modbus/ModbusAsciiInTcpProtocol.cs
View File

@@ -21,7 +21,7 @@ namespace Modbus.Net.Modbus
/// <summary>
/// 构造函数
/// </summary>
/// <param name="com">串口地址</param>
/// <param name="ip">ip地址</param>
/// <param name="slaveAddress">从站号</param>
/// <param name="masterAddress">主站号</param>
/// <param name="endian">端格式</param>

4
Modbus.Net/Modbus.Net.Modbus/ModbusMachine.cs
View File

@@ -12,6 +12,7 @@ namespace Modbus.Net.Modbus
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="connectionType">连接类型</param>
/// <param name="connectionString">连接地址</param>
/// <param name="getAddresses">读写的地址</param>
@@ -33,6 +34,7 @@ namespace Modbus.Net.Modbus
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="connectionType">连接类型</param>
/// <param name="connectionString">连接地址</param>
/// <param name="getAddresses">读写的地址</param>
@@ -55,6 +57,7 @@ namespace Modbus.Net.Modbus
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="connectionType">连接类型</param>
/// <param name="connectionString">连接地址</param>
/// <param name="getAddresses">读写的地址</param>
@@ -76,6 +79,7 @@ namespace Modbus.Net.Modbus
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="connectionType">连接类型</param>
/// <param name="connectionString">连接地址</param>
/// <param name="getAddresses">读写的地址</param>

1
Modbus.Net/Modbus.Net.Modbus/ModbusProtocol.cs
View File

@@ -396,7 +396,6 @@ namespace Modbus.Net.Modbus
var translateAddress = addressTranslator.AddressTranslate(startAddress, false, true);
FunctionCode = (byte) translateAddress.Area;
StartAddress = (ushort) translateAddress.Address;
int a = 0, b = 0;
var writeByteValue =
FunctionCode == (byte) ModbusProtocolWriteDataFunctionCode.WriteSingleCoil
? ((bool) writeValue

6
Modbus.Net/Modbus.Net.Modbus/ModbusProtocolLinkerBytesExtend.cs
View File

@@ -5,11 +5,17 @@ using System.Text;
namespace Modbus.Net.Modbus
{
/// <summary>
/// Rtu透传字节伸缩
/// </summary>
public class ModbusRtuInTcpProtocolLinkerBytesExtend : ModbusRtuProtocolLinkerBytesExtend
{
}
/// <summary>
/// Ascii透传字节伸缩
/// </summary>
public class ModbusAsciiInTcpProtocolLinkerBytesExtend : ModbusAsciiProtocolLinkerBytesExtend
{

3
Modbus.Net/Modbus.Net.Modbus/ModbusRtuInTcpProtocol.cs
View File

@@ -35,7 +35,8 @@ namespace Modbus.Net.Modbus
/// <summary>
/// 构造函数
/// </summary>
/// <param name="com">串口</param>
/// <param name="ip">ip地址</param>
/// <param name="port">端口号</param>
/// <param name="slaveAddress">从站号</param>
/// <param name="masterAddress">主站号</param>
/// <param name="endian">端格式</param>

3
Modbus.Net/Modbus.Net.Modbus/ModbusUtility.cs
View File

@@ -35,6 +35,9 @@ namespace Modbus.Net.Modbus
AsciiInTcp = 4,
}
/// <summary>
/// 写单个单元的方法接口
/// </summary>
public interface IUtilityMethodWriteSingle : IUtilityMethod
{
/// <summary>

2
Modbus.Net/Modbus.Net.OPC/FBox/FBoxOpcDaManchine.cs
View File

@@ -11,6 +11,7 @@ namespace Modbus.Net.OPC.FBox
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="localSequence">页名称</param>
/// <param name="linkerName">设备名称</param>
/// <param name="getAddresses">获取地址</param>
@@ -36,6 +37,7 @@ namespace Modbus.Net.OPC.FBox
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="localSequence">页名称</param>
/// <param name="linkerName">设备名称</param>
/// <param name="getAddresses">获取地址</param>

4
Modbus.Net/Modbus.Net.OPC/OpcDaMachine.cs
View File

@@ -14,6 +14,7 @@ namespace Modbus.Net.OPC
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="connectionString">连接地址</param>
/// <param name="getAddresses">需要读写的数据</param>
/// <param name="keepConnect">是否保持连接</param>
@@ -29,6 +30,7 @@ namespace Modbus.Net.OPC
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="connectionString">连接地址</param>
/// <param name="getAddresses">需要读写的数据</param>
public OpcDaMachine(TKey id, string connectionString, IEnumerable<AddressUnit<TUnitKey>> getAddresses)
@@ -45,6 +47,7 @@ namespace Modbus.Net.OPC
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="connectionString">连接地址</param>
/// <param name="getAddresses">需要读写的数据</param>
/// <param name="keepConnect">是否保持连接</param>
@@ -60,6 +63,7 @@ namespace Modbus.Net.OPC
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="connectionString">连接地址</param>
/// <param name="getAddresses">需要读写的数据</param>
public OpcDaMachine(string id, string connectionString, IEnumerable<AddressUnit> getAddresses)

2
Modbus.Net/Modbus.Net.OPC/OpcMachine.cs
View File

@@ -12,6 +12,7 @@ namespace Modbus.Net.OPC
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="getAddresses">需要读写的地址</param>
/// <param name="keepConnect">是否保持连接</param>
protected OpcMachine(TKey id, IEnumerable<AddressUnit<TUnitKey>> getAddresses, bool keepConnect)
@@ -30,6 +31,7 @@ namespace Modbus.Net.OPC
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="getAddresses">需要读写的地址</param>
/// <param name="keepConnect">是否保持连接</param>
protected OpcMachine(string id, IEnumerable<AddressUnit> getAddresses, bool keepConnect)

4
Modbus.Net/Modbus.Net.OPC/OpcUaMachine.cs
View File

@@ -14,6 +14,7 @@ namespace Modbus.Net.OPC
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="connectionString">连接地址</param>
/// <param name="getAddresses">需要读写的数据</param>
/// <param name="keepConnect">是否保持连接</param>
@@ -29,6 +30,7 @@ namespace Modbus.Net.OPC
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="connectionString">连接地址</param>
/// <param name="getAddresses">需要读写的数据</param>
public OpcUaMachine(TKey id, string connectionString, IEnumerable<AddressUnit<TUnitKey>> getAddresses)
@@ -45,6 +47,7 @@ namespace Modbus.Net.OPC
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="connectionString">连接地址</param>
/// <param name="getAddresses">需要读写的数据</param>
/// <param name="keepConnect">是否保持连接</param>
@@ -60,6 +63,7 @@ namespace Modbus.Net.OPC
/// <summary>
/// 构造函数
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="connectionString">连接地址</param>
/// <param name="getAddresses">需要读写的数据</param>
public OpcUaMachine(string id, string connectionString, IEnumerable<AddressUnit> getAddresses)

7
Modbus.Net/Modbus.Net/BaseConnector.cs
View File

@@ -18,11 +18,18 @@ namespace Modbus.Net
//protected event MessageReturnDelegate MessageReturn;
/// <summary>
/// 增加传输控制器
/// </summary>
/// <param name="controller">传输控制器</param>
public void AddController(IController controller)
{
Controller = controller;
}
/// <summary>
/// 传输控制器
/// </summary>
protected IController Controller { get; set; }
/// <summary>

60
Modbus.Net/Modbus.Net/BaseController.cs
View File

@@ -7,18 +7,30 @@ using Serilog;
namespace Modbus.Net
{
/// <summary>
/// 控制器基类
/// </summary>
public abstract class BaseController : IController
{
/// <summary>
/// 等待的消息队列
/// </summary>
protected List<MessageWaitingDef> WaitingMessages { get; set; }
/// <summary>
/// 消息维护线程
/// </summary>
protected Task SendingThread { get; set; }
protected bool _taskCancel = false;
/// <summary>
/// 构造器
/// </summary>
protected BaseController()
{
WaitingMessages = new List<MessageWaitingDef>();
}
/// <inheritdoc cref="IController.AddMessage(byte[])" />
public MessageWaitingDef AddMessage(byte[] sendMessage)
{
var def = new MessageWaitingDef
@@ -32,13 +44,15 @@ namespace Modbus.Net
return def;
}
/// <summary>
/// 发送消息的实际内部方法
/// </summary>
protected abstract void SendingMessageControlInner();
public void SendStop()
{
_taskCancel = true;
}
/// <inheritdoc cref="IController.SendStop" />
public abstract void SendStop();
/// <inheritdoc cref="IController.SendStart" />
public void SendStart()
{
if (SendingThread == null)
@@ -47,6 +61,7 @@ namespace Modbus.Net
}
}
/// <inheritdoc cref="IController.Clear" />
public void Clear()
{
lock (WaitingMessages)
@@ -55,6 +70,10 @@ namespace Modbus.Net
}
}
/// <summary>
/// 将信息添加到队列
/// </summary>
/// <param name="def">需要添加的信息信息</param>
protected virtual void AddMessageToList(MessageWaitingDef def)
{
lock (WaitingMessages)
@@ -63,8 +82,14 @@ namespace Modbus.Net
}
}
/// <summary>
/// 获取信息的检索关键字
/// </summary>
/// <param name="message">待确认的信息</param>
/// <returns>信息的检索关键字</returns>
protected abstract string GetKeyFromMessage(byte[] message);
/// <inheritdoc cref="IController.ConfirmMessage(byte[])" />
public bool ConfirmMessage(byte[] receiveMessage)
{
var def = GetMessageFromWaitingList(receiveMessage);
@@ -81,8 +106,15 @@ namespace Modbus.Net
return false;
}
/// <summary>
/// 从等待队列中匹配信息
/// </summary>
/// <param name="receiveMessage">返回的信息</param>
/// <returns>从等待队列中匹配的信息</returns>
protected abstract MessageWaitingDef GetMessageFromWaitingList(byte[] receiveMessage);
/// <inheritdoc cref="IController.ForceRemoveWaitingMessage(MessageWaitingDef)"/>
/// <param name="def"></param>
public void ForceRemoveWaitingMessage(MessageWaitingDef def)
{
lock (WaitingMessages)
@@ -92,16 +124,34 @@ namespace Modbus.Net
}
}
/// <summary>
/// 等待信息的定义
/// </summary>
public class MessageWaitingDef
{
/// <summary>
/// 信息的关键字
/// </summary>
public string Key { get; set; }
/// <summary>
/// 发送的信息
/// </summary>
public byte[] SendMessage { get; set; }
/// <summary>
/// 接收的信息
/// </summary>
public byte[] ReceiveMessage { get; set; }
/// <summary>
/// 发送的信号
/// </summary>
public EventWaitHandle SendMutex { get; set; }
/// <summary>
/// 接收的信号
/// </summary>
public EventWaitHandle ReceiveMutex { get; set; }
}
}

10
Modbus.Net/Modbus.Net/BaseMachine.cs
View File

@@ -92,6 +92,7 @@ namespace Modbus.Net
/// <summary>
/// 构造器
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="getAddresses">需要与设备通讯的地址</param>
protected BaseMachine(string id, IEnumerable<AddressUnit> getAddresses) : base(id, getAddresses)
{
@@ -100,6 +101,7 @@ namespace Modbus.Net
/// <summary>
/// 构造器
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="getAddresses">需要与设备通讯的地址</param>
/// <param name="keepConnect">是否保持连接</param>
protected BaseMachine(string id, IEnumerable<AddressUnit> getAddresses, bool keepConnect)
@@ -110,6 +112,7 @@ namespace Modbus.Net
/// <summary>
/// 构造器
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="getAddresses">需要与设备通讯的地址</param>
/// <param name="keepConnect">是否保持连接</param>
/// <param name="slaveAddress">从站地址</param>
@@ -134,6 +137,7 @@ namespace Modbus.Net
/// <summary>
/// 构造器
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="getAddresses">需要与设备通讯的地址</param>
protected BaseMachine(TKey id, IEnumerable<AddressUnit<TUnitKey>> getAddresses)
: this(id, getAddresses, false)
@@ -143,6 +147,7 @@ namespace Modbus.Net
/// <summary>
/// 构造器
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="getAddresses">需要与设备通讯的地址</param>
/// <param name="keepConnect">是否保持连接</param>
protected BaseMachine(TKey id, IEnumerable<AddressUnit<TUnitKey>> getAddresses, bool keepConnect)
@@ -155,6 +160,7 @@ namespace Modbus.Net
/// <summary>
/// 构造器
/// </summary>
/// <param name="id">设备的ID号</param>
/// <param name="getAddresses">需要与设备通讯的地址</param>
/// <param name="keepConnect">是否保持连接</param>
/// <param name="slaveAddress">从站地址</param>
@@ -188,8 +194,8 @@ namespace Modbus.Net
/// </summary>
public AddressTranslator AddressTranslator
{
get { return BaseUtility.AddressTranslator; }
set { BaseUtility.AddressTranslator = value; }
get => BaseUtility.AddressTranslator;
set => BaseUtility.AddressTranslator = value;
}
/// <summary>

9
Modbus.Net/Modbus.Net/ComConnector.cs
View File

@@ -377,6 +377,9 @@ namespace Modbus.Net
return returnBytes.ByteToString();
}
/// <summary>
/// 确认串口是否已经打开，如果没有打开则尝试打开两次，连续失败直接释放连接资源
/// </summary>
protected void CheckOpen()
{
if (!SerialPort.IsOpen)
@@ -439,6 +442,10 @@ namespace Modbus.Net
return messageSendingdef;
}
/// <summary>
/// 发送数据，不确认
/// </summary>
/// <param name="message">需要发送的数据</param>
protected override async Task SendMsgWithoutConfirm(byte[] message)
{
using (await SerialPort.Lock.LockAsync())
@@ -459,11 +466,13 @@ namespace Modbus.Net
}
}
/// <inheritdoc />
protected override void ReceiveMsgThreadStart()
{
_receiveThread = Task.Run(()=>ReceiveMessage());
}
/// <inheritdoc />
protected override void ReceiveMsgThreadStop()
{
_taskCancel = true;

21
Modbus.Net/Modbus.Net/FifoController.cs
View File

@@ -8,17 +8,30 @@ using Serilog;
namespace Modbus.Net
{
/// <summary>
/// 先入先出式控制器
/// </summary>
public class FifoController : BaseController
{
private MessageWaitingDef _currentSendingPos;
private bool _taskCancel = false;
/// <summary>
/// 间隔时间
/// </summary>
public int AcquireTime { get; }
/// <summary>
/// 构造器
/// </summary>
/// <param name="acquireTime">间隔时间</param>
public FifoController(int acquireTime)
{
AcquireTime = acquireTime;
}
/// <inheritdoc cref="BaseController.SendingMessageControlInner"/>
protected override void SendingMessageControlInner()
{
try
@@ -64,11 +77,19 @@ namespace Modbus.Net
}
/// <inheritdoc cref="BaseController.SendStop"/>
public override void SendStop()
{
_taskCancel = true;
}
/// <inheritdoc cref="BaseController.GetKeyFromMessage(byte[])"/>
protected override string GetKeyFromMessage(byte[] message)
{
return null;
}
/// <inheritdoc cref="BaseController.GetMessageFromWaitingList(byte[])"/>
protected override MessageWaitingDef GetMessageFromWaitingList(byte[] receiveMessage)
{
return WaitingMessages.FirstOrDefault();

30
Modbus.Net/Modbus.Net/IController.cs
View File

@@ -1,17 +1,43 @@
namespace Modbus.Net
{
/// <summary>
/// 传输控制器接口
/// </summary>
public interface IController
{
/// <summary>
/// 增加信息
/// </summary>
/// <param name="sendMessage">需要发送的信息</param>
/// <returns></returns>
MessageWaitingDef AddMessage(byte[] sendMessage);
void SendStop();
/// <summary>
/// 启动传输控制线程
/// </summary>
void SendStart();
/// <summary>
/// 关闭传输控制线程
/// </summary>
void SendStop();
/// <summary>
/// 清空所有待发送的信息
/// </summary>
void Clear();
/// <summary>
/// 将返回的信息绑定到发送的信息上，并对信息进行确认
/// </summary>
/// <param name="receiveMessage">返回的信息</param>
/// <returns>是否正常确认</returns>
bool ConfirmMessage(byte[] receiveMessage);
/// <summary>
/// 没有任何返回时强行删除等待队列上的信息
/// </summary>
/// <param name="def">需要强行删除的信息</param>
void ForceRemoveWaitingMessage(MessageWaitingDef def);
}
}

1
Modbus.Net/Modbus.Net/IProtocol.cs
View File

@@ -9,6 +9,7 @@ namespace Modbus.Net
/// <typeparam name="TParamIn">向Connector传入的类型</typeparam>
/// <typeparam name="TParamOut">从Connector返回的类型</typeparam>
/// <typeparam name="TProtocolUnit">协议单元的类型</typeparam>
/// <typeparam name="TPipeUnit">管道的类型</typeparam>
public interface IProtocol<TParamIn, TParamOut, TProtocolUnit, TPipeUnit>
where TProtocolUnit : class, IProtocolFormatting<TParamIn, TParamOut>
where TParamOut : class

25
Modbus.Net/Modbus.Net/MatchController.cs
View File

@@ -8,20 +8,37 @@ using Serilog;
namespace Modbus.Net
{
/// <summary>
/// 通讯号匹配模式的控制器
/// </summary>
public class MatchController : BaseController
{
private MessageWaitingDef _currentSendingPos;
private bool _taskCancel = false;
/// <summary>
/// 获取间隔
/// </summary>
public int AcquireTime { get; }
/// <summary>
/// 匹配字典
/// </summary>
protected ICollection<int>[] KeyMatches { get; }
/// <summary>
/// 构造器
/// </summary>
/// <param name="keyMatches">匹配字典，每个Collection代表一个匹配集合，每一个匹配集合中的数字代表需要匹配的位置，最后计算出来的数字是所有位置数字按照集合排序后叠放在一起</param>
/// <param name="acquireTime">获取间隔</param>
public MatchController(ICollection<int>[] keyMatches, int acquireTime)
{
KeyMatches = keyMatches;
AcquireTime = acquireTime;
}
/// <inheritdoc cref="BaseController.SendingMessageControlInner" />
protected override void SendingMessageControlInner()
{
try
@@ -67,6 +84,13 @@ namespace Modbus.Net
}
/// <inheritdoc cref="BaseController.SendStop" />
public override void SendStop()
{
_taskCancel = false;
}
/// <inheritdoc cref="BaseController.GetKeyFromMessage(byte[])" />
protected override string GetKeyFromMessage(byte[] message)
{
string ans = "";
@@ -82,6 +106,7 @@ namespace Modbus.Net
return ans;
}
/// <inheritdoc cref="BaseController.GetMessageFromWaitingList(byte[])" />
protected override MessageWaitingDef GetMessageFromWaitingList(byte[] receiveMessage)
{
var returnKey = GetKeyFromMessage(receiveMessage);

9
Modbus.Net/Modbus.Net/SerialPortHelper.cs
View File

@@ -1,12 +1,11 @@
using System;
using System.Collections.Generic;
using System.Globalization;
using System.Linq;
using System.Globalization;
using System.Text;
using System.Threading.Tasks;
namespace Modbus.Net
{
/// <summary>
/// 串口辅助类
/// </summary>
public static class SerialPortHelper
{
/// <summary>

12
Modbus.Net/Modbus.Net/TcpConnector.cs
View File

@@ -237,6 +237,10 @@ namespace Modbus.Net
return messageSendingdef;
}
/// <summary>
/// 发送信息，不进行返回确认
/// </summary>
/// <param name="message">发送的信息</param>
protected override async Task SendMsgWithoutConfirm(byte[] message)
{
var datagram = message;
@@ -261,11 +265,17 @@ namespace Modbus.Net
}
}
/// <summary>
/// 启动获取线程
/// </summary>
protected override void ReceiveMsgThreadStart()
{
_receiveThread = Task.Run(ReceiveMessage);
}
/// <summary>
/// 停止获取线程
/// </summary>
protected override void ReceiveMsgThreadStop()
{
_taskCancel = true;
@@ -317,7 +327,7 @@ namespace Modbus.Net
/// <summary>
/// 接收消息，并转换成字符串
/// </summary>
/// <param name="len"></param>
/// <param name="len">消息的长度</param>
private byte[] CheckReplyDatagram(int len)
{
var replyMessage = new byte[len];