Flutter UDP Modbus客户端插件modbus_client_udp的使用

Flutter UDP Modbus客户端插件modbus_client_udp的使用

引入

本示例基于 modbus_client 项目开发，提供了Modbus客户端发送请求到远程设备的功能。 包含TCP、UDP和Serial三种协议。

特性

• 自动连接模式：通过设置 ModbusConnectionMode 来自动连接和断开客户端。
• 单位ID：客户端和请求可以指定目标单位ID，适用于多个设备共享一个串口的情况。
• 响应超时：请求中可以设置等待响应的超时时间。
• 服务器发现（仅支持TCP/UDP）：从起始IP地址发现Modbus服务器。
• 连接超时（仅支持TCP/UDP）：设置连接超时时间。
• 延迟后连接（仅支持TCP/UDP）：在连接服务器后应用延迟。
• 元素类型：提供多种元素类型，如 ModbusNumRegister、ModbusBitElement 等。
• 文件记录：支持 File Records 功能码0x14和0x15的不同类型的数值记录。
• 组元素：为了优化请求，可以创建 Group of elements。
• 自定义请求实现：可以通过重写 Request 类来实现自定义请求。
• 日志：Modbus客户端库启用了日志功能，可以通过根日志器或 ModbusAppLogger 实例启用日志。

使用方法

使用 modbus client 是非常简单的的。 您定义元素，创建读或写请求，并使用客户端发送请求。

示例代码

import 'package:modbus_client/modbus_client.dart';
import 'package:modbus_client_udp/modbus_client_udp.dart';

void main() async {
  // 创建一个 modbus 整数16位寄存器元素
  var batteryTemperature = ModbusInt16Register(
      name: "BatteryTemperature",
      type: ModbusElementType.inputRegister,
      address: 22,
      uom: "°C",
      multiplier: 0.1,
      onUpdate: (self) => print(self));

  // 发现 Modbus 服务器
  var serverIp = await ModbusClientUdp.discover("192.168.0.0");
  if (serverIp == null) {
    ModbusAppLogger.shout("No modbus server found!");
    return;
  }

  // 创建 modbus 客户端。
  var modbusClient = ModbusClientUdp(serverIp, unitId: 1);

  // 发送读请求从元素
  await modbusClient.send(batteryTemperature.getReadRequest());

  // 结束这里
  modbusClient.disconnect();
}

读请求

import 'package:modbus_client/modbus_client.dart';
import 'package:modbus_client_udp/modbus_client_udp.dart';

void main() async {
  // 创建一个 modbus 整数16位寄存器元素
  var batteryStatus = ModbusEnumRegister(
      name: "BatteryStatus",
      address: 11,
      type: ModbusElementType.holdingRegister,
      enumValues: BatteryStatus.values,
      onUpdate: (self) => print(self));

  // 发现 Modbus 服务器
  var serverIp = await ModbusClientUdp.discover("192.168.0.0");
  if (serverIp == null) {
    ModbusAppLogger.shout("No modbus server found!");
    return;
  }

  // 创建 modbus 客户端。
  var modbusClient = ModbusClientUdp(serverIp, unitId: 1);

  var req = batteryStatus.getWriteRequest(BatteryStatus.running);
  var res = await modbusClient.send(req);
  print(res.name);

  modbusClient.disconnect();
}

写请求

import 'package:modbus_client/modbus_client.dart';
import 'package:modbus_client_udp/modbus_client_udp.dart';

enum BatteryStatus implements ModbusIntEnum {
  offline(0),
  standby(1),
  running(22),
  fault(3),
  sleepMode(4);

  const BatteryStatus(this.intValue);

  @override
  final int intValue;

  @override
  String toString() {
    return name;
  }
}

void main() async {
  var batteryStatus = ModbusEnumRegister(
      name: "BatteryStatus",
      address: 11,
      type: ModbusElementType.holdingRegister,
      enumValues: BatteryStatus.values);

  // 发现 Modbus 服务器
  var serverIp = await ModbusClientUdp.discover("127.0.0.1");
  if (serverIp == null) {
    ModbusAppLogger.shout("No modbus server found!");
    return;
  }

  // 创建 modbus 客户端。
  var modbusClient = ModbusClientUdp("127.0.0.1", unitId: 1);

  await modbusClient.send(batteryStatus.getReadRequest());
  modbusClient.disconnect();
}

元素组

import 'package:modbus_client/modbus_client.dart';
import 'package:modbus_client_udp/modbus_client_udp.dart';

enum BatteryStatus implements ModbusIntEnum {
  offline(0),
  standby(1),
  running(22),
  fault(3),
  sleepMode(4);

  const BatteryStatus(this.intValue);

  @override
  final int intValue;

  @override
  String toString() {
    return name;
  }
}

void main() async {
  // 创建 modbus 元素组
  var batteryRegs = ModbusElementsGroup([
    ModbusEnumRegister(
        name: "BatteryStatus",
        type: ModbusElementType.holdingRegister,
        address: 37000,
        enumValues: BatteryStatus.values),
    ModbusInt32Register(
        name: "BatteryChargingPower",
        type: ModbusElementType.holdingRegister,
        address: 37001,
        uom: "W",
        description: "> 0: charging - < 0: discharging"),
    ModbusUint16Register(
        name: "BatteryCharge",
        type: ModbusElementType.holdingRegister,
        address: 37004,
        uom: "%",
        multiplier: 0.1),
    ModbusUint16Register(
        name: "BatteryTemperature",
        type: ModbusElementType.holdingRegister,
        address: 37022,
        uom: "°C",
        multiplier: 0.1),
  ]);

  // 创建 modbus 客户端。
  var modbusClient = ModbusClientUdp("127.0.0.1", unitId: 1);

  // 发送读请求从组
  await modbusClient.send(batteryRegs.getReadRequest());
  print(batteryRegs[0]);
  print(batteryRegs[1]);
  print(batteryRegs[2]);
  print(batteryRegs[3]);

  // 结束这里
  modbusClient.disconnect();
}

文件记录