| | |
| | | public class LedThread implements Runnable, ThreadHandler { |
| | | |
| | | private Slave slave; |
| | | private Bx5GScreenClient screen; |
| | | |
| | | public LedThread(Slave slave) { |
| | | this.slave = slave; |
| | | try { |
| | | Bx5GEnv.initial(3000); |
| | | screen = new Bx5GScreenClient("MyScreen"); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | log.info("led连接构造器错误 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | @SuppressWarnings("InfiniteLoopStatement") |
| | | public void run() { |
| | | connect(); |
| | | while (true) { |
| | |
| | | |
| | | @Override |
| | | public boolean connect() { |
| | | return false; |
| | | boolean connRes = false; |
| | | try { |
| | | connRes = screen.connect(slave.getIp(),slave.getPort()); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | if (connRes) { |
| | | log.info("led连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); |
| | | } else { |
| | | log.error("led连接失败!!! ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); |
| | | } |
| | | return connRes; |
| | | } |
| | | |
| | | @Override |
| | | public void close() { |
| | | |
| | | screen.disconnect(); |
| | | } |
| | | |
| | | |
| | |
| | | Bx5GScreenClient screen = new Bx5GScreenClient("MyScreen"); |
| | | // 创建screen对象,用于对控制器进行访问,串口模式 |
| | | // Bx5GScreenRS screen = new Bx5GScreenRS("MyScreen"); |
| | | |
| | | |
| | | // 在对控制器交互之前,需要先与控制器建立连接 |
| | | screen.connect("192.168.100.199",5005); |