package com.ruoyi.web.controller.tool;
|
|
import com.intelligt.modbus.jlibmodbus.master.ModbusMaster;
|
import com.intelligt.modbus.jlibmodbus.master.ModbusMasterFactory;
|
import com.intelligt.modbus.jlibmodbus.tcp.TcpParameters;
|
import com.ruoyi.common.core.domain.R;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.net.InetAddress;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Api(tags = "modbus测试")
|
@RestController
|
@RequestMapping("/base")
|
public class ModbusExample {
|
|
@ApiOperation(value = "抓取700号段寄存器数据")
|
@GetMapping(value = "/test")
|
public R<List<Map<String, Object>>> test() {
|
// 1. 设置 TCP 参数
|
TcpParameters tcpParameters = new TcpParameters();
|
try {
|
// 这里的 IP 保持你之前的配置，端口 502
|
tcpParameters.setHost(InetAddress.getByName("192.168.40.138"));
|
tcpParameters.setKeepAlive(true);
|
tcpParameters.setPort(502);
|
|
// 2. 创建 Master 实例
|
ModbusMaster master = ModbusMasterFactory.createModbusMasterTCP(tcpParameters);
|
// master.setConnectTimeout(3000); // 设置3秒超时
|
|
try {
|
if (!master.isConnected()) {
|
master.connect();
|
}
|
|
// --- 关键参数修改区 (匹配你的 Modbus Poll 截图) ---
|
int slaveId = 1; // Slave ID: 1
|
int offset = 700; // Address: 700 (对应 PLC 40701)
|
int quantity = 50; // Quantity: 30
|
// ----------------------------------------------
|
|
// 3. 读取保持寄存器
|
int[] registerValues = master.readHoldingRegisters(slaveId, offset, quantity);
|
|
// 4. 解析并封装为 JSON 格式 (List<Map>)
|
List<Map<String, Object>> dataList = new ArrayList<>();
|
for (int i = 0; i < registerValues.length; i++) {
|
Map<String, Object> item = new HashMap<>();
|
int currentAddress = offset + i;
|
int rawValue = registerValues[i];
|
|
item.put("address", currentAddress); // 寄存器物理地址
|
item.put("value", rawValue); // 寄存器原始数值
|
|
// 这里可以根据业务增加转换逻辑，例如：
|
// if(currentAddress == 700) item.put("comment", "设备运行状态");
|
|
dataList.add(item);
|
}
|
|
// 5. 返回带数据的成功响应
|
return R.ok(dataList);
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
return R.fail("Modbus 读取异常: " + e.getMessage());
|
} finally {
|
// 必须断开连接，否则下次请求可能因为连接数占满而失败
|
master.disconnect();
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
return R.fail("网络配置异常: " + e.getMessage());
|
}
|
}
|
|
// 假设 regs[10] = 50880, regs[11] = 45 (这里假设 711 是高位)
|
public static float registersToFloat(int low, int high) {
|
// 1. 将两个 16 位整数合成一个 32 位整数
|
int combined = (high << 16) | (low & 0xFFFF);
|
// 2. 将 32 位整数按 IEEE 754 标准转为浮点数
|
return Float.intBitsToFloat(combined);
|
}
|
|
private static float parseModbusFloat(int reg1, int reg2) {
|
// 尝试 CDAB 顺序 (这是大多数 HMI 如 Delta/台达 屏幕常用的顺序)
|
int bits = (reg1 << 16) | (reg2 & 0xFFFF);
|
|
// 如果结果还是不对，试着把上面这行换成 ABCD:
|
// int bits = (reg2 << 16) | (reg1 & 0xFFFF);
|
|
// int bits = ((reg1 & 0xFF) << 24) | ((reg1 >> 8) << 16) | ((reg2 & 0xFF) << 8) | (reg2 >> 8);
|
return Float.intBitsToFloat(bits);
|
}
|
|
public static void main(String[] args) {
|
// 调用示例
|
float value = parseModbusFloat(50880, 45);
|
// float value = parseModbusFloat(45, 50880);
|
System.out.println("解析后的真实数值: " + value);
|
}
|
|
}
|
