public interface RasterDataProcessStrategy {
    void rasterDataProcess(SerialPort serialPort, int conveyorAddress, int[] rasterAddress,double stepLength,int frequency);
}

@Component("RasterDataPoll")
public class RasterDataPollStrategy implements RasterDataProcessStrategy {


    @Override
    public void rasterDataProcess(SerialPort serialPort, int conveyorAddress, int[] rasterAddress,double stepLength ,int frequency) {
        // 机器站点一般都不会大于127,这里强转为byte
        ModBusCommandUtil.sendWriteCommand(serialPort, ModBusCommandConstant.FORWARD.getCommand((byte) conveyorAddress));
        sleep(100);
        ModBusCommandUtil.sendWriteCommand(serialPort, ModBusCommandConstant.RUN_CONVEYOR.getCommand((byte) conveyorAddress));
        sleep(100);
        // 读取串口判断命令是否正确被接收执行
        ModBusCommandUtil.sendWriteCommand(serialPort, ModBusCommandConstant.RUN_RASTER.getCommand((byte) rasterAddress[0]));
        ModBusCommandUtil.sendWriteCommand(serialPort, ModBusCommandConstant.RUN_RASTER.getCommand((byte) rasterAddress[1]));
        // 判断传送带是否运行(轮询5次)
        byte[] bytes = ModBusCommandUtil.sendReadCommand(serialPort, ModBusCommandConstant.RUN_CONVEYOR_STATUS.getCommand((byte) conveyorAddress));
        int status = ModBusCommandUtil.toUnsignedInt(bytes);
        int count = 1;
        while (count<=5){
            if (status == 1){
                new Thread(new RasterDataTask(serialPort,conveyorAddress,rasterAddress,stepLength,frequency)).start();
                return;
            }
            sleep(100);
            bytes = ModBusCommandUtil.sendReadCommand(serialPort, ModBusCommandConstant.RUN_CONVEYOR_STATUS.getCommand((byte) conveyorAddress));
            status = ModBusCommandUtil.toUnsignedInt(bytes);
            count++;
        }
        throw new RuntimeException("传送带未启动，请检查设备地址是否正确！");
    }

    private static class RasterDataTask implements Runnable{

        private final int conveyorAddress;
        private final int[] rasterAddress;
        private final SerialPort serialPort;
        private final double stepLength;
        private final int frequency;

        public RasterDataTask(SerialPort serialPort,int conveyorAddress, int[] rasterAddress, double stepLength ,int frequency)  {
            this.conveyorAddress = conveyorAddress;
            this.rasterAddress = rasterAddress;
            this.serialPort = serialPort;
            this.stepLength = stepLength;
            this.frequency = frequency;
        }

        /**
         * 当传送带正确启动后执行光栅数据轮询操作
         * TODO 多线异步优化
         */
        @Override
        public void run() {
            int orderNum = 0;
            IDetailService detailService = SpringUtils.getBean(IDetailService.class);
            WebSocketController webSocketController = SpringUtils.getBean(WebSocketController.class);
            // 将detail对象保存在List集合中，等到传送带运动结束再执行批量插入操作
            List<Detail> details = new LinkedList<>();
            double totalVolume = 0;
            while (true){
                /*
                 * 轮询光栅数据，获取光栅长度
                 * */
                // 判断传送带是否停止
                byte[] bytes = ModBusCommandUtil.sendReadCommand(serialPort, ModBusCommandConstant.RUN_CONVEYOR_STATUS.getCommand((byte) conveyorAddress));
                int status = ModBusCommandUtil.toUnsignedInt(bytes);
                if (status == 0){
                    break;
                }
                byte[] raster0 = ModBusCommandUtil.sendReadCommand(serialPort, ModBusCommandConstant.READ_RASTER.getCommand((byte) rasterAddress[0]));
                byte[] raster1 = ModBusCommandUtil.sendReadCommand(serialPort, ModBusCommandConstant.READ_RASTER.getCommand((byte) rasterAddress[1]));
                double rasterLength0 = ModBusCommandUtil.toUnsignedInt(raster0)*2.5;
                double rasterLength1 = ModBusCommandUtil.toUnsignedInt(raster1)*2.5;
                // 封装长宽数据保存到数据库
                Detail detail = new Detail();
                detail.setOrderNum(orderNum);
                detail.setA(rasterLength0);
                detail.setB(rasterLength1);
                detail.setVolume(rasterLength0*rasterLength1);
                details.add(detail);
                orderNum++;
                double curVolume = rasterLength0 * rasterLength1 * stepLength;
                totalVolume += curVolume;
                // WebSocket上传a,b数据给前端 （WebSocket or UDP传输 or Netty）
                webSocketController.sendVolumeData(rasterLength0,rasterLength1,curVolume);
                sleep(frequency);
            }
            // 异步发送总扫描体积给前端
            // 执行批量插入操作
            detailService.saveBatch(details);
        }
    }
}

@Component("RasterDataListener")
public class RasterDataListenerStrategy implements RasterDataProcessStrategy {
    @Override
    public void rasterDataProcess(SerialPort serialPort, int conveyorAddress, int[] rasterAddress,double stepLength,int frequency) {
        // 将设备注册监听类
        try {
            MySerialPortEventListener listener = new MySerialPortEventListener(serialPort, 1,rasterAddress,conveyorAddress);
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}

@Service
public class RasterDataProcessFactory {

    @Autowired
    Map<String, RasterDataProcessStrategy> map = new ConcurrentHashMap<>();

    /*
    * 根据设备类型选择适配器
    * */
    public RasterDataProcessStrategy getRasterDataProcessAdapter(String deviceType){
        RasterDataProcessStrategy rasterDataProcessAdapter = map.get(deviceType);
        if (rasterDataProcessAdapter == null){
            throw new RuntimeException("设备类型错误");
        }
        return rasterDataProcessAdapter;
    }
}

if (serialPort != null){
            //适配器模式优化
            RasterDataProcessStrategy rasterDataPollStrategy = rasterDataProcessFactory.getRasterDataProcessAdapter("RasterDataPoll");
            rasterDataPollStrategy.rasterDataProcess(serialPort, conveyorAddress, rasterAddress,stepLength, frequency);
        }

public interface Sum extends Library {
 
        //动态库接口
        int sum(int x, int y);
        
        //创建动态库实例 dllPath = src/main/resources/sum.dll
        Sum INSTANCE = (Sum) Native.loadLibrary(dllPath, Sum.class);
    }

Sum.INSTANCE.sum(1,2)