| | |
|---|
| | | */ |
|---|
| | | public static ModbusMaster getMaster(String ip, int port) throws ModbusInitException, InterruptedException { |
|---|
| | | String key = ip; |
|---|
| | | ModbusMaster modbusMaster = masterMap.get(key); |
|---|
| | | if (modbusMaster == null || !modbusMaster.isConnected()) { |
|---|
| | | // ModbusMaster modbusMaster = masterMap.get(key); |
|---|
| | | // if (modbusMaster == null || !modbusMaster.isConnected()) { |
|---|
| | | IpParameters ipParameters = new IpParameters(); |
|---|
| | | ipParameters.setHost(ip); |
|---|
| | | ipParameters.setPort(port); |
|---|
| | | modbusMaster = modbusFactory.createTcpMaster(ipParameters, true); |
|---|
| | | ModbusMaster modbusMaster = modbusFactory.createTcpMaster(ipParameters, false); |
|---|
| | | modbusMaster.init(); |
|---|
| | | |
|---|
| | | //初始化之后等待，避免出现连接未创建 |
|---|
| | | Thread.sleep(2500); |
|---|
| | | |
|---|
| | | masterMap.put(key, modbusMaster); |
|---|
| | | // masterMap.put(key, modbusMaster); |
|---|
| | | |
|---|
| | | return modbusMaster; |
|---|
| | | } |
|---|
| | | return modbusMaster; |
|---|
| | | // } |
|---|
| | | // return modbusMaster; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
