From e163b7b3e4d5acc63cfda2fec2dd9034864ccf7a Mon Sep 17 00:00:00 2001
From: whyclj <1525436766@qq.com>
Date: 星期六, 17 十月 2020 12:01:49 +0800
Subject: [PATCH] 水冷添加历史实时数据记录功能
---
WaterSystem_MonitorServer/src/com/modbus/data/MyModbusFactory.java | 83 ++++++++++++++++++++++-------------------
1 files changed, 44 insertions(+), 39 deletions(-)
diff --git a/WaterSystem_MonitorServer/src/com/modbus/data/MyModbusFactory.java b/WaterSystem_MonitorServer/src/com/modbus/data/MyModbusFactory.java
index 0ba33ea..7eb2a84 100644
--- a/WaterSystem_MonitorServer/src/com/modbus/data/MyModbusFactory.java
+++ b/WaterSystem_MonitorServer/src/com/modbus/data/MyModbusFactory.java
@@ -1,39 +1,44 @@
-package com.modbus.data;
-
-import com.serotonin.modbus4j.ModbusFactory;
-import com.serotonin.modbus4j.ModbusMaster;
-import com.serotonin.modbus4j.exception.ModbusInitException;
-import com.serotonin.modbus4j.ip.IpParameters;
-
-public class MyModbusFactory {
- private static final int SERVER_PORT = 502; //服务端口
-
- static ModbusFactory modbusFactory;
-
- static {
- if (modbusFactory == null) {
- modbusFactory = new ModbusFactory();
- }
- }
-
- /**
- * 获取master
- *
- * @return
- * @throws ModbusInitException
- */
- public static ModbusMaster getMaster(IpParameters params){
- // modbusFactory.createRtuMaster(wapper); //RTU 协议
- // modbusFactory.createUdpMaster(params); //UDP 协议
- // modbusFactory.createAsciiMaster(wrapper); //ASCII 协议
- params.setPort(SERVER_PORT);
- ModbusMaster master = modbusFactory.createTcpMaster(params, false);// TCP 协议
- try {
- master.setTimeout(2000);
- master.init();
- } catch (ModbusInitException e) {
- e.printStackTrace();
- }
- return master;
- }
-}
+package com.modbus.data;
+
+import com.serotonin.modbus4j.ModbusFactory;
+import com.serotonin.modbus4j.ModbusMaster;
+import com.serotonin.modbus4j.exception.ModbusInitException;
+import com.serotonin.modbus4j.ip.IpParameters;
+
+public class MyModbusFactory {
+ private static final int SERVER_PORT = 502; //服务端口
+
+ static ModbusFactory modbusFactory;
+
+ static {
+ if (modbusFactory == null) {
+ modbusFactory = new ModbusFactory();
+ }
+ }
+
+ /**
+ * 获取master
+ *
+ * @return
+ * @throws ModbusInitException
+ */
+ public static ModbusMaster getMaster(IpParameters params){
+ // modbusFactory.createRtuMaster(wapper); //RTU 协议
+ // modbusFactory.createUdpMaster(params); //UDP 协议
+ // modbusFactory.createAsciiMaster(wrapper); //ASCII 协议
+ params.setPort(SERVER_PORT);
+ //false:短连接 true:长连接
+ ModbusMaster master = modbusFactory.createTcpMaster(params, true);// TCP 协议
+ try {
+ //设置超时时间
+ master.setTimeout(2000);
+ //设置重连次数
+ master.setRetries(3);
+ //初始化
+ master.init();
+ } catch (ModbusInitException e) {
+ //e.printStackTrace();
+ }
+ return master;
+ }
+}
--
Gitblit v1.9.1