| | |
| | | try { |
| | | write("T".getBytes(), "T".length()); |
| | | byte[] read = read(11, 1000); |
| | | barcode = new String(read); |
| | | if (null != read) { |
| | | barcode = new String(read); |
| | | } |
| | | Thread.sleep(1000); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | |
| | | } |
| | | |
| | | public void write(byte[] msg, int len) throws IOException { |
| | | log.trace("dataOutputStream.write"); |
| | | dataOutputStream.write(msg, 0, len); |
| | | log.trace("dataOutputStream.flush"); |
| | | dataOutputStream.flush(); |
| | | if (null != dataInputStream) |
| | | { |
| | | dataOutputStream.write(msg, 0, len); |
| | | dataOutputStream.flush(); |
| | | } |
| | | } |
| | | |
| | | public byte[] read(int bufferSize, int timeOut) throws IOException { |
| | | if (socket == null) { |
| | | return null; |
| | | } |
| | | socket.setSoTimeout(timeOut * 1000); |
| | | byte[] bytes = new byte[bufferSize]; |
| | | log.trace("dataInputStream.read"); |
| | |
| | | result = true; |
| | | log.info("输送线plc连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); |
| | | } else { |
| | | log.info("输送线plc连接失败!!! ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); |
| | | log.error("输送线plc连接失败!!! ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); |
| | | } |
| | | siemensS7Net.ConnectClose(); |
| | | return result; |
| | |
| | | # 输送线 |
| | | devp[0]: |
| | | id: 1 |
| | | ip: 192.168.1.125 |
| | | ip: 192.168.2.125 |
| | | port: 102 |
| | | rack: 0 |
| | | slot: 1 |