MyBatis-Flux 是 MyBatis 的一个扩展，它提供了与 Reactor Core 库的集成，使得可以在 MyBatis 中进行 Flux 反应式操作。以下是 MyBatis-Flux 的操作指南：
创建 Flux 查询： 使用 Flux 查询可以通过 MyBatis 的 SqlSession 实例来执行查询，并将结果转换为 Flux 流。例如：
Flux<User> users = Flux.from(SqlSession.selectList("getUserList"));
Flux 操作： 可以使用 Flux 提供的操作符对查询结果进行操作，例如过滤、映射、排序等。例如：
Flux<User> filteredUsers = users.filter(user -> user.getAge() > 18)
.map(user -> new User(user.getName().toUpperCase(), user.getAge()));
订阅 Flux： 最后，可以通过订阅 Flux 来处理查询结果。可以使用 subscribe() 方法来订阅，例如：
filteredUsers.subscribe(user -> System.out.println(user));
错误处理： 在处理 Flux 查询过程中可能会出现错误，可以使用 onError() 方法来处理错误，例如：
filteredUsers.onError(throwable -> System.err.println("Error: " + throwable.getMessage()));
关闭 Flux： 在完成 Flux 查询后，需要手动关闭 Flux 流，以释放资源。可以使用 dispose() 方法来关闭 Flux，例如：
filteredUsers.dispose();
总的来说，MyBatis-Flux 提供了处理查询结果的更灵活的方式，使得可以更方便地进行异步、非阻塞的操作。通过以上指南，可以更好地理解和使用 MyBatis-Flux。
