From 6c1764f1e65a55a914b8d894101b5b555958f093 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9E=97=E9=92=9F=E4=B8=80=E5=85=AD?= <1477007136@qq.com> Date: Tue, 4 Jun 2024 22:15:20 +0800 Subject: [PATCH 1/2] fix: fix and close #I9V10O --- .../com/mybatisflex/core/util/ClassUtil.java | 22 +++++-------------- 1 file changed, 5 insertions(+), 17 deletions(-) diff --git a/mybatis-flex-core/src/main/java/com/mybatisflex/core/util/ClassUtil.java b/mybatis-flex-core/src/main/java/com/mybatisflex/core/util/ClassUtil.java index a964a367..515a7930 100644 --- a/mybatis-flex-core/src/main/java/com/mybatisflex/core/util/ClassUtil.java +++ b/mybatis-flex-core/src/main/java/com/mybatisflex/core/util/ClassUtil.java @@ -285,23 +285,11 @@ public class ClassUtil { } Method[] declaredMethods = clazz.getDeclaredMethods(); - if (clazz.isInterface()) { - for (Method method : declaredMethods) { - // 接口类只需要获取 default 方法 - if (method.isDefault() && (predicate == null || predicate.test(method))) { - methods.add(method); - if (firstOnly) { - break; - } - } - } - } else { - for (Method method : declaredMethods) { - if (predicate == null || predicate.test(method)) { - methods.add(method); - if (firstOnly) { - break; - } + for (Method method : declaredMethods) { + if (predicate == null || predicate.test(method)) { + methods.add(method); + if (firstOnly) { + break; } } } From e901997a82784b9589626708e9507ea598bc2751 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9E=97=E9=92=9F=E4=B8=80=E5=85=AD?= <1477007136@qq.com> Date: Sun, 11 Aug 2024 13:43:22 +0800 Subject: [PATCH 2/2] =?UTF-8?q?docs:=20=E5=A2=9E=E5=8A=A0=E4=BA=86?= =?UTF-8?q?=E5=BC=80=E6=BA=90=E9=A1=B9=E7=9B=AE=20Mybatis-Flex-Reactor=20?= =?UTF-8?q?=E7=9A=84=E4=BB=8B=E7=BB=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- docs/zh/awesome-things.md | 72 +++++++++++++++++++++++++++++++++++++++ 1 file changed, 72 insertions(+) diff --git a/docs/zh/awesome-things.md b/docs/zh/awesome-things.md index dc67fba4..7dbd4537 100644 --- a/docs/zh/awesome-things.md +++ b/docs/zh/awesome-things.md @@ -159,3 +159,75 @@ MyBatis-Flex-Kotlin 基于 Mybatis-Flex 的 Kotlin 扩展模块，方便 Kotlin **开源地址：** https://gitee.com/mybatis-flex/mybatis-flex-kotlin + +## Mybatis-Flex-Reactor + +MybatisFlex Reactor 为 MybatisFlex 的“响应式”拓展模块，以 Flux 封装了 Cursor 操作。方便了流式查询开发以及大数据体量项目响应数据。 + +### 特点 + +1. 无需在现有 MybatisFlex 项目增加兼容性改动，仅需将原有的 `ServiceImpl` 改为 `ReactorServiceImpl` 即可，或者直接再新建一个 `XxxReactorService` 继承于 `ReactorServiceImpl` 即可。 +2. 不强绑定 Spring，也不必须在 Spring WebFlux 框架下开发。完全可以单用 MybatisFlex Reactor 以解决一些传统项目中的性能与内存占用问题。 +3. 与 MybatisFlex 中的 `IService` 逻辑基本保持一致，几乎 0 学习成本即可上手。 +4. 异步非堵塞，对于写入日志等重要级别较低的数据库操作，我们完全可以让步于主线程逻辑，等所有逻辑处理完以后再执行次要逻辑，加快了系统的响应速度。 + +### 一个解决内存占用过高问题的示例 + +很多人从 POI 换成 EasyExcel 的原因除了简单易用以外，还有个就是内存占用低。在 POI 会内存爆满写入失败的情况，EasyExcel 却可以写入成功，但是内存占用依然不低。如果后续项目中数据量持续增加，简单的换成 EasyExcel 也不再管用，因为你依然会将所有数据直接读到内存当中。当然，你也可以使用多次分页查询等方式解决这个问题，但是我们是否可以更优雅些呢？ + +```kotlin +class UserService : ReactorServiceImpl() { + // 在 WebFlux 中，可以将此方法直接作为 Controller 的返回值，供 WebFlux 进行调度，返回数据给前端 + fun writeAllToExcel(): Mono { + // 目标文件 + val tempFile = File.createTempFile("user", ".xlsx") + // 创建 EasyExcel 的 writer 与目标 sheet + val writer = EasyExcel.write(tempFile, UserExportVo::class.java) + // 自动列宽 + .registerWriteHandler(LongestMatchColumnWidthStyleStrategy()) + .build() + val sheet = EasyExcel.writerSheet(1).build() + // 调用响应式的 listAs 方法 + return listAs(QueryWrapper.create(), UserExportVo::class.java) + // 这里可以预处理数据 + .doOnNext { it.name = "${it.id} ${it.name}" } + // 选择缓存大小，即多少条数据一起写入 Excel + .buffer(100) + // 写入到 Excel + .doOnNext { writer.write(it, sheet) } + // 做结尾操作，使用 then 只接收信号而不接收数据 + .then() + // 结束后关闭 writer + .doOnTerminate { writer.finish() } + // 返回文件路径 + .thRerturn(tempFile.absolutePath) + // 即使出错也会关闭 writer，防止可能的资源泄漏 + .doOnError { + writer.finish() + it.printStackTrace() + } + } +} +``` + +看完上面代码，你会发现你再也不需要关注内部实现细节与逻辑，仅需像“配置代码”一样，填写几个参数就实现了我们的需求。与原来 `IService` 一样的查询调用方法简单易懂。 + +在非 Webflux 项目中如何调用返回值为 `Mono` 或 `Flux` 的方法呢？MybatisFlex Reactor 提供了两个方法解决这个问题： + +```kotlin +// 异步调用 +ReactorUtils.runAsync(Mono) // 返回 任务生命周期对象 Disposable +// 同步 / 堵塞 调用 +ReactorUtils.runBlock(Mono) // 返回 T + +// 对于返回值为 Flux 的方法，我们可以将其转换为 Mono 即可 +// 直接将所有结果集中到一个 List 中 +Flux.collectList() // 返回 Mono> +// 以自定义 Collector 汇总数据 +Flux.collect(Collectors.joining(", ")) // 返回 String，每个数据直接用“，”链接 +``` + +### 开源地址 +[Gitee（仅同步项目）](https://gitee.com/goxiaogle/mybatis-flex-reactor) + +[Github](https://github.com/Goxiaogle/mybatis-flex-reactor)