package com.ruoyi.fuzhou.utils;
|
|
import com.serotonin.modbus4j.ModbusFactory;
|
import com.serotonin.modbus4j.ModbusMaster;
|
import com.serotonin.modbus4j.exception.ErrorResponseException;
|
import com.serotonin.modbus4j.exception.ModbusInitException;
|
import com.serotonin.modbus4j.exception.ModbusTransportException;
|
import com.serotonin.modbus4j.ip.IpParameters;
|
import com.serotonin.modbus4j.locator.BaseLocator;
|
import com.serotonin.modbus4j.msg.*;
|
import org.apache.commons.logging.Log;
|
import org.apache.commons.logging.LogFactory;
|
|
/**
|
* modbus4j写入数据
|
*
|
* @author zhangyy
|
*/
|
public class Modbus4jWriteUtils {
|
|
static Log log = LogFactory.getLog(Modbus4jWriteUtils.class);
|
/**
|
* 工厂。
|
*/
|
static ModbusFactory modbusFactory;
|
|
static {
|
if (modbusFactory == null) {
|
modbusFactory = new ModbusFactory();
|
}
|
}
|
|
/**
|
* 获取tcpMaster
|
*
|
* @return
|
* @throws ModbusInitException
|
*/
|
public static ModbusMaster getMaster(String ip) throws ModbusInitException {
|
IpParameters params = new IpParameters();
|
params.setHost(ip);
|
params.setPort(20108);
|
// params.setHost("10.2.73.22");
|
// params.setPort(502);
|
ModbusMaster tcpMaster = modbusFactory.createTcpMaster(params, false);
|
tcpMaster.init();
|
return tcpMaster;
|
}
|
|
/**
|
* 写 [01 Coil Status(0x)]写一个 function ID = 5
|
*
|
* @param slaveId slave的ID
|
* @param writeOffset 位置
|
* @param writeValue 值
|
* @return 是否写入成功
|
* @throws ModbusTransportException
|
* @throws ModbusInitException
|
*/
|
public static boolean writeCoil(String ip, int slaveId, int writeOffset, boolean writeValue)
|
throws ModbusTransportException, ModbusInitException {
|
// 获取master
|
ModbusMaster tcpMaster = getMaster(ip);
|
// 创建请求
|
WriteCoilRequest request = new WriteCoilRequest(slaveId, writeOffset, writeValue);
|
// 发送请求并获取响应对象
|
WriteCoilResponse response = (WriteCoilResponse) tcpMaster.send(request);
|
if (response.isException()) {
|
return false;
|
} else {
|
return true;
|
}
|
}
|
|
/**
|
* 写[01 Coil Status(0x)] 写多个 function ID = 15
|
*
|
* @param slaveId slaveId
|
* @param startOffset 开始位置
|
* @param bdata 写入的数据
|
* @return 是否写入成功
|
* @throws ModbusTransportException
|
* @throws ModbusInitException
|
*/
|
public static boolean writeCoils(String ip, int slaveId, int startOffset, boolean[] bdata)
|
throws ModbusTransportException, ModbusInitException {
|
// 获取master
|
ModbusMaster tcpMaster = getMaster(ip);
|
// 创建请求
|
WriteCoilsRequest request = new WriteCoilsRequest(slaveId, startOffset, bdata);
|
// 发送请求并获取响应对象
|
WriteCoilsResponse response = (WriteCoilsResponse) tcpMaster.send(request);
|
if (response.isException()) {
|
return false;
|
} else {
|
return true;
|
}
|
|
}
|
|
/***
|
* 写[03 Holding Register(4x)] 写一个 function ID = 6
|
*
|
* @param slaveId
|
* @param writeOffset
|
* @param writeValue
|
* @return
|
* @throws ModbusTransportException
|
* @throws ModbusInitException
|
*/
|
public static boolean writeRegister(String ip, int slaveId, int writeOffset, short writeValue)
|
throws ModbusTransportException, ModbusInitException {
|
// 获取master
|
ModbusMaster tcpMaster = getMaster(ip);
|
// 创建请求对象
|
WriteRegisterRequest request = new WriteRegisterRequest(slaveId, writeOffset, writeValue);
|
WriteRegisterResponse response = (WriteRegisterResponse) tcpMaster.send(request);
|
if (response.isException()) {
|
log.error(response.getExceptionMessage());
|
return false;
|
} else {
|
return true;
|
}
|
|
}
|
|
/**
|
* 写入[03 Holding Register(4x)]写多个 function ID=16
|
*
|
* @param slaveId modbus的slaveID
|
* @param startOffset 起始位置偏移量值
|
* @param sdata 写入的数据
|
* @return 返回是否写入成功
|
* @throws ModbusTransportException
|
* @throws ModbusInitException
|
*/
|
public static boolean writeRegisters(String ip, int slaveId, int startOffset, short[] sdata)
|
throws ModbusTransportException, ModbusInitException {
|
// 获取master
|
ModbusMaster tcpMaster = getMaster(ip);
|
// 创建请求对象
|
WriteRegistersRequest request = new WriteRegistersRequest(slaveId, startOffset, sdata);
|
// 发送请求并获取响应对象
|
ModbusResponse response = tcpMaster.send(request);
|
if (response.isException()) {
|
log.error(response.getExceptionMessage());
|
return false;
|
} else {
|
return true;
|
}
|
}
|
|
/**
|
* 写入数字类型的模拟量（如:写入Float类型的模拟量、Double类型模拟量、整数类型Short、Integer、Long）
|
*
|
* @param slaveId
|
* @param offset
|
* @param value 写入值,Number的子类,例如写入Float浮点类型,Double双精度类型,以及整型short,int,long
|
* @param registerCount ,com.serotonin.modbus4j.code.DataType
|
* @throws ModbusTransportException
|
* @throws ErrorResponseException
|
* @throws ModbusInitException
|
*/
|
public static void writeHoldingRegister(String ip, int slaveId, int offset, Number value, int dataType)
|
throws ModbusTransportException, ErrorResponseException, ModbusInitException {
|
// 获取master
|
ModbusMaster tcpMaster = getMaster(ip);
|
// 类型
|
BaseLocator<Number> locator = BaseLocator.holdingRegister(slaveId, offset, dataType);
|
tcpMaster.setValue(locator, value);
|
}
|
|
}
|
