Modbus TCP批量下发命令部分设备未接收问题求助

核心问题 #

你的场景中出现的批量发送失效，本质是TCP粘包导致网关EKI-1221-BE将多个Modbus请求帧合并为一个TCP包后，仅解析处理了最后一帧。虽然你尝试了事务号和阻塞接收，但未从根源解决TCP层的包合并问题，且事务号的实现可能存在疏漏。

具体解决方案 #

1. 禁用TCP Nagle算法（最关键）

C# Socket默认启用Nagle算法，会将多个小数据包合并发送以优化带宽，但这会破坏Modbus TCP帧的独立性。直接禁用该算法，让每个Send调用立即发送独立的Modbus帧：

// 在初始化ClientSocket时添加
ClientSocket.NoDelay = true;

2. 修复MBAP事务号实现

你之前的代码中事务号固定为0，必须改为唯一递增的16位数值，确保网关能通过事务号区分不同请求并匹配响应：

private ushort _transactionId = 0;

public void SendMessage(int pumpID, int register, int command)
{
    byte[] message = new byte[12];
    
    // 递增事务号，循环避免溢出
    _transactionId = (ushort)((_transactionId + 1) % ushort.MaxValue);
    message[0] = (byte)(_transactionId >> 8); // 事务号高字节
    message[1] = (byte)(_transactionId & 0xFF); // 事务号低字节
    
    message[2] = 0;
    message[3] = 0; // 协议标识固定为0
    message[4] = 0;
    message[5] = 6; // 后续帧长度（功能码+寄存器+数据共6字节）
    message[6] = (byte)pumpID; // 设备地址（若pumpID<=255可直接转换，否则需验证ToHexInDec逻辑）
    message[7] = 6; // 功能码6（写单个寄存器）
    message[8] = (byte)(register >> 8); // 寄存器地址高字节
    message[9] = (byte)(register & 0xFF); // 寄存器地址低字节
    message[10] = (byte)(command >> 8); // 命令高字节
    message[11] = (byte)(command & 0xFF); // 命令低字节

    try
    {
        ClientSocket.Send(message);
    }
    catch
    {
        return;
    }
}

3. 实现完整的响应接收与校验

原Receive调用可能未接收完整响应，或未校验事务号匹配性，导致逻辑混乱。改为分步接收并校验：

public byte[] ReceiveFullResponse()
{
    // 先接收6字节MBAP头
    byte[] mbapHeader = new byte[6];
    int receivedBytes = ClientSocket.Receive(mbapHeader);
    if (receivedBytes != 6)
    {
        throw new InvalidOperationException("MBAP头接收不完整");
    }

    // 解析响应体长度（MBAP第4-5字节为16位长度值）
    int responseBodyLength = (mbapHeader[4] << 8) | mbapHeader[5];
    byte[] responseBody = new byte[responseBodyLength];
    
    // 接收响应体
    receivedBytes = ClientSocket.Receive(responseBody);
    if (receivedBytes != responseBodyLength)
    {
        throw new InvalidOperationException("响应体接收不完整");
    }

    // 合并完整响应并校验事务号
    byte[] fullResponse = new byte[6 + responseBodyLength];
    Array.Copy(mbapHeader, fullResponse, 6);
    Array.Copy(responseBody, 0, fullResponse, 6, responseBodyLength);

    ushort responseTransactionId = (ushort)((fullResponse[0] << 8) | fullResponse[1]);
    if (responseTransactionId != _transactionId)
    {
        throw new InvalidOperationException("响应事务号与请求不匹配");
    }

    return fullResponse;
}

4. 调整网关配置（辅助验证）

查看EKI-1221-BE的配置界面，寻找以下参数并调整：

• Modbus TCP帧超时：缩短超时时间，让网关更快识别连续帧的边界
• TCP包聚合开关：若存在该选项，直接关闭，强制网关解析每个独立Modbus帧

调用示例 #

PumpsComm.SendMessage(1, 3099, 2000);
PumpsComm.ReceiveFullResponse();

PumpsComm.SendMessage(2, 3099, 3000);
PumpsComm.ReceiveFullResponse();

// 依次处理3-6号设备...

内容的提问来源于stack exchange，提问作者ismaquantum