webFlux 解析16进制的modbus字符串，传入回调，监听解析过程

在WebFlux中，您可以使用Java的内置类库来解析16进制的modbus字符串，并且在解析过程中传入回调函数，以便监听解析过程。以下是一个示例代码：

public interface ModbusDataListener {
    void onDataParsed(ModbusData data);
}

public class ModbusDataParser {
    private ModbusDataListener listener;

    public ModbusDataParser(ModbusDataListener listener) {
        this.listener = listener;
    }

    public void parse(String modbusString) {
        Flux.fromArray(modbusString.split("\\s"))
            .map(hex -> Integer.parseInt(hex, 16))
            .collectList()
            .map(list -> {
                int address = list.get(1);
                int numRegisters = list.get(3);
                byte[] dataBytes = new byte[numRegisters * 2];
                for (int i = 0; i < numRegisters * 2; i++) {
                    dataBytes[i] = list.get(4 + i).byteValue();
                }
                return new ModbusData(address, numRegisters, dataBytes);
            })
            .subscribe(modbusData -> {
                // 在这里处理解析后的Modbus数据，并回调listener
                listener.onDataParsed(modbusData);
            });
    }
}

在这个示例中，我们首先定义了一个接口`ModbusDataListener`，它包含一个回调函数`onDataParsed()`，用于在解析过程中传入解析后的Modbus数据。接着，我们定义了一个`ModbusDataParser`类，它包含一个`ModbusDataListener`类型的成员变量`listener`。在`ModbusDataParser`的构造方法中，我们将传入的`listener`赋值给成员变量`listener`。然后，我们定义了一个`parse()`方法，它接受一个16进制的modbus字符串作为参数。在`parse()`方法中，我们使用与之前相同的方式来解析16进制的modbus字符串。但是，这次我们在`subscribe()`方法中调用了回调函数`onDataParsed()`，并将解析后的`ModbusData`对象作为参数传入。在解析过程中，每当解析出一个`ModbusData`对象时，回调函数`onDataParsed()`就会被调用，并传入解析后的`ModbusData`对象。这样，我们就可以在解析过程中监听解析的结果，并在回调函数中进行进一步的处理。