package com.dev.modbus4j;
|
|
import java.io.IOException;
|
import java.net.Socket;
|
|
import com.serotonin.modbus4j.ModbusMaster;
|
import com.serotonin.modbus4j.ip.IpParameters;
|
import com.serotonin.modbus4j.serial.SerialPortWrapper;
|
|
public class MyModbusMaster {
|
public final static int SLAVEID_DEFAULT = 2;
|
|
public final static int MAX_ERROR_COUNT = 2; //最大连续错误计数
|
public final static int LOSE_CONNECT_COUNT = 10; //通讯中断最大计数
|
|
private ModbusMaster master;
|
private int errcount; //错误计数 错误连续超过三个时重新获取master
|
private int totalerr = 31; //总的错误计数[默认失去连接] 用于判别设备是否掉线
|
private int tolcommcount = 0 ; //总的通讯计数
|
private String target_ip; //目标ip
|
private int slaveId; //设备ID
|
private Socket socket;
|
private int ModbusType = MyModbusFactory.ModBus_TCP;
|
private MyIpParameters params;
|
|
public MyModbusMaster(String target_ip,int slaveId) {
|
this.target_ip = target_ip;
|
this.slaveId = slaveId;
|
this.params = new MyIpParameters(target_ip);
|
this.master = MyModbusFactory.getMaster(params,MyModbusFactory.ModBus_TCP);
|
}
|
|
public MyModbusMaster(Socket socket,int ModbusType,int slaveId) {
|
this.slaveId = slaveId;
|
SerialPortWrapper impl = new SerialPortWrapperImpl(socket);
|
this.params = new MyIpParameters(impl,ModbusType);
|
this.master = MyModbusFactory.getMaster(params,ModbusType);
|
}
|
|
public void addErrorCount() {
|
this.errcount++;
|
if(this.errcount > MAX_ERROR_COUNT) {
|
reConnect();
|
}
|
if(this.totalerr > 99999999) {
|
this.totalerr = 5;
|
}
|
this.totalerr ++;
|
}
|
|
public void addTotalCommCount() {
|
this.tolcommcount++;
|
if(this.tolcommcount > 999999999) {
|
this.tolcommcount = 100;
|
}
|
}
|
|
//清空错误计数
|
public void clearError() {
|
errcount = 0;
|
totalerr = 0;
|
}
|
|
|
|
public int getTolcommcount() {
|
return tolcommcount;
|
}
|
|
public void reConnect() {
|
//System.out.println(target_ip);
|
IpParameters params = new IpParameters();
|
params.setHost(target_ip);
|
if(this.master != null) {
|
//清空上一个master
|
this.master.destroy();
|
}
|
this.errcount = 0;
|
if(MyModbusFactory.ModBus_TCP == ModbusType) {
|
this.master = MyModbusFactory.getMaster(this.params,MyModbusFactory.ModBus_TCP);
|
}
|
}
|
|
/**
|
* 判断获取到的值是否为空
|
* @param target
|
* @param source
|
* @return
|
*/
|
public static Object checkNullData(Object target,Object source) {
|
if(null == target) {
|
return source;
|
}
|
try {
|
if(target instanceof Number) {
|
if(source instanceof Integer) {
|
return ((Number) target).intValue();
|
}else if(source instanceof Float) {
|
return ((Number) target).floatValue();
|
}
|
}
|
if(target instanceof Boolean) {
|
//判断Boolean类型数据
|
if((Boolean)target) {
|
target = 1;
|
}else {
|
target = 0;
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return target;
|
|
}
|
|
public int getConnectState() {
|
if(this.totalerr < LOSE_CONNECT_COUNT) {
|
return 1;
|
}
|
return 0;
|
}
|
|
public int getTotalerr() {
|
return totalerr;
|
}
|
|
public void setTotalerr(int totalerr) {
|
this.totalerr = totalerr;
|
}
|
|
public ModbusMaster getMaster() {
|
return master;
|
}
|
public int getErrcount() {
|
return errcount;
|
}
|
public void setMaster(ModbusMaster master) {
|
this.master = master;
|
}
|
public void setErrcount(int errcount) {
|
this.errcount = errcount;
|
}
|
|
public String getTarget_ip() {
|
return target_ip;
|
}
|
|
public void setTarget_ip(String target_ip) {
|
this.target_ip = target_ip;
|
}
|
|
public int getSlaveId() {
|
return slaveId;
|
}
|
|
public void setSlaveId(int slaveId) {
|
this.slaveId = slaveId;
|
}
|
|
public void destory() {
|
master.destroy();
|
if(null != socket) {
|
try {
|
socket.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
@Override
|
public String toString() {
|
return "MyModbusMaster [SLAVEID_DEFAULT=" + SLAVEID_DEFAULT + ", master=" + master + ", errcount=" + errcount
|
+ ", target_ip=" + target_ip + ", slaveId=" + slaveId + "]";
|
}
|
}
|
