|  |  | 
 |  |  | import com.core.common.SpringUtils; | 
 |  |  | import com.zy.asrs.entity.BasDevp; | 
 |  |  | import com.zy.asrs.service.BasDevpService; | 
 |  |  | import com.zy.asrs.service.DeviceErrorService; | 
 |  |  | import com.zy.core.Slave; | 
 |  |  | import com.zy.core.ThreadHandler; | 
 |  |  | import com.zy.core.cache.OutputQueue; | 
 |  |  | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public boolean connect() { | 
 |  |  |  | 
 |  |  |         try { | 
 |  |  |             close();  //1.主动释放连接 //2.某些服务器对指定ip有链路数限制 | 
 |  |  |             socket = new Socket(); | 
 |  |  | 
 |  |  |             dataOutputStream = new DataOutputStream(socket.getOutputStream()); | 
 |  |  |             dataInputStream = new DataInputStream(socket.getInputStream()); | 
 |  |  | //            log.info("条码扫描仪连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); | 
 |  |  |             DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class); | 
 |  |  |             deviceErrorService.deleteDeviceError("scale", slave.getId()); | 
 |  |  |         } catch (Exception e) { | 
 |  |  |             socket = null; | 
 |  |  |             log.error("磅秤连接失败!!! ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); | 
 |  |  |             DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class); | 
 |  |  |             deviceErrorService.addDeviceError("scale", slave.getId(), "磅秤连接失败"); | 
 |  |  |             return false; | 
 |  |  |         } | 
 |  |  |         return true; |