| | |
| | | } |
| | | |
| | | private void handleClient(DeviceConfig device) throws IOException { |
| | | StringBuffer sb = new StringBuffer(); |
| | | try { |
| | | Socket socket = fakeServerMap.get(String.valueOf(SlaveType.Shuttle) + device.getDeviceNo()); |
| | | if (socket == null) { |
| | |
| | | // 获取输入流 |
| | | BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream)); |
| | | // 读取服务器的响应 |
| | | StringBuffer sb = new StringBuffer(); |
| | | char[] chars = new char[2048];//缓冲区 |
| | | while (true) { |
| | | reader.read(chars); |
| | |
| | | // log.info("收到Client Data: {}", JSON.toJSONString(result)); |
| | | processCommand(result, device); |
| | | } catch (Exception e) { |
| | | log.error("handleClient deviceNo:{},recevie:{}", device.getDeviceNo(), sb); |
| | | e.printStackTrace(); |
| | | } |
| | | } |