New file |
| | |
| | | package com.dy.testServer.forRmi; |
| | | |
| | | import com.alibaba.fastjson2.JSON; |
| | | |
| | | public class MwConfigVo { |
| | | //模拟客户的RtuAddr起始号 |
| | | public Long rtuAddrStart = 0L ; |
| | | //模拟客户的RtuAddr截止号 |
| | | public Long rtuAddrEnd = 0L ; |
| | | //通信中间件IP |
| | | public String tcpServerIp = "" ; |
| | | //通信中间件端口 |
| | | public Integer tcpServerPort = 0 ; |
| | | //发送数据数据间隔 |
| | | public Integer sendInterval = 2 ;//秒 |
| | | //每一轮次发送数据,其中包括心跳发送次数 |
| | | public Integer heartbeatTimes = 3 ; |
| | | //发送数据次数 |
| | | public Integer sendTimes = 0 ; |
| | | //发送完数据后,是否关闭TCP连接,1是,0否 |
| | | public Integer sendOverThenCloseConnect = 0 ; |
| | | |
| | | /** |
| | | * 对象转成json |
| | | * @return 返回 json |
| | | * @throws Exception 异常 |
| | | */ |
| | | public String toJson()throws Exception{ |
| | | try{ |
| | | return JSON.toJSONString(this) ; |
| | | //return new JSONSerializer().exclude(new String[]{"class", "*.class"}).deepSerialize(this); |
| | | }catch(Exception e){ |
| | | throw new Exception(e.getMessage() , e ) ; |
| | | } |
| | | } |
| | | /** |
| | | * json转成对象 |
| | | * @param json 参数 |
| | | * @return 返回对象 |
| | | * @throws Exception 异常 |
| | | */ |
| | | public static MwConfigVo jsonToObject(String json)throws Exception{ |
| | | try{ |
| | | return JSON.parseObject(json, MwConfigVo.class) ; |
| | | //return new JSONDeserializer<ResConfigVo>().deserialize(json, ResConfigVo.class) ; |
| | | }catch(Exception e){ |
| | | throw new Exception(e.getMessage() , e ) ; |
| | | } |
| | | } |
| | | |
| | | public Long getRtuAddrStart() { |
| | | return rtuAddrStart; |
| | | } |
| | | |
| | | public void setRtuAddrStart(Long rtuAddrStart) { |
| | | this.rtuAddrStart = rtuAddrStart; |
| | | } |
| | | |
| | | public Long getRtuAddrEnd() { |
| | | return rtuAddrEnd; |
| | | } |
| | | |
| | | public void setRtuAddrEnd(Long rtuAddrEnd) { |
| | | this.rtuAddrEnd = rtuAddrEnd; |
| | | } |
| | | |
| | | public String getTcpServerIp() { |
| | | return tcpServerIp; |
| | | } |
| | | |
| | | public void setTcpServerIp(String tcpServerIp) { |
| | | this.tcpServerIp = tcpServerIp; |
| | | } |
| | | |
| | | public Integer getTcpServerPort() { |
| | | return tcpServerPort; |
| | | } |
| | | |
| | | public void setTcpServerPort(Integer tcpServerPort) { |
| | | this.tcpServerPort = tcpServerPort; |
| | | } |
| | | |
| | | public Integer getSendInterval() { |
| | | return sendInterval; |
| | | } |
| | | |
| | | public void setSendInterval(Integer sendInterval) { |
| | | this.sendInterval = sendInterval; |
| | | } |
| | | |
| | | public Integer getHeartbeatTimes() { |
| | | return heartbeatTimes; |
| | | } |
| | | |
| | | public void setHeartbeatTimes(Integer heartbeatTimes) { |
| | | this.heartbeatTimes = heartbeatTimes; |
| | | } |
| | | |
| | | public Integer getSendTimes() { |
| | | return sendTimes; |
| | | } |
| | | |
| | | public void setSendTimes(Integer sendTimes) { |
| | | this.sendTimes = sendTimes; |
| | | } |
| | | |
| | | public Integer getSendOverThenCloseConnect() { |
| | | return sendOverThenCloseConnect; |
| | | } |
| | | |
| | | public void setSendOverThenCloseConnect(Integer sendOverThenCloseConnect) { |
| | | this.sendOverThenCloseConnect = sendOverThenCloseConnect; |
| | | } |
| | | } |