今天就带大家一步一步地感受泛型和函数式编程的优雅所在案例分析2.1 结构化的代码以分页为例子来感受一下什么是结构化的代码。特别说明一下分页还需当前页数、页大小以及校验等本案例忽略代码主要逻辑查询分页条数如果为 0 则不用查询列表详情直接返回如果分页条数大于 0 则查询列表详情。代码一、返回总数和分页详情查询 Book 表public PageData queryBook(BookRequest request) { // 1. 创建分页对象 PageData pageData new PageData(); // 2. 计算满足的记录数 int count bookMapper.queryBookCount(request); // 3. 为 0则表示没有符合的数据直接返回 if (count 0) { pageData.setCount(0); return pageData; } // 4. 不为 0计算记录详情 ListBookDO bookList bookMapper.queryBookList(request); // 5. 封装记录总数和 pageData.setCount(count); pageData.setResult(bookList); return pageData; }代码二、返回总数和分页详情查询 Pencil 表public PageData queryPencil(PencilRequest request) { // 1. 创建分页对象 PageData pageData new PageData(); // 2. 计算满足的记录数 int count pencilMapper.queryPencilCount(request); // 3. 为 0则表示没有符合的数据直接返回 if (count 0) { pageData.setCount(0); return pageData; } // 4. 不为 0计算记录详情 ListPencilDO pencilList pencilMapper.queryPencilList(request); // 5. 封装记录总数和 pageData.setCount(count); pageData.setResult(pencilList); return pageData; }将两段代码进行对比bookpencil得出结论结构相似外形语义相似分页语义一致先查询 count然后再根据 count 是否查询 List 详情如果再有其他实体对象的分页那么 CV 一下改改我上面的红框的地方即可。基于上面这个案例我们再深度思考一下。2.2 重复代码的考量在系统里面这样结构化的代码随处可见。那么这两个方法代码有重复代码吗好像并没有(IDEA没有提示)因为很难找到大块重复的代码也很难抽取出来一个具体的方法然后被调用就像下面图中展示的那样选中重复代码然后抽取一个新的方法对重复代码进行替换下面的这种操作就是我早期进行代码重构的核心技能image.png虽然很难找到大块重复代码但是上面的代码从“外形骨架”上看却极其相似难道这种相似不应该也是一种重复吗这种结构化式的重复曾经困扰了我很久我很难像抽取重复代码一样去抽取这种相似的结构遇到这样结构化的代码我也不得不加入 CV 大军并自我PUA这样的代码并不是重复的代码随着对代码的思考和深入一种独特的组合彻底解决这种结构化的重复那便是泛型函数式编程泛型 函数式编程我认为它们的组合是天生解决这种结构化的3.1 泛型特性泛型,一切皆行泛型在于它的普适性、通用性。太多工具类都使用了泛型当然我也喜欢用泛型因为它很优雅下面是一个代码片段。对请求返回结果进行包装特别适用于 RPC 远程调用结果等场景。针对不同的返回实体可以使用T 类型来表示。非常通用T 代表一切实体success 是否请求成功errorCode、errorMsg 出错时提供错误码和错误消息public class ServiceResultT { /** * 请求是否成 */ private Boolean success; /** * 错误码 */ private String errorCode ; /** * 错误信息 */ private String errorMsg; /** * 返回内容 */ private T content; ...... }除了上面这个案例以外在很多工具类库中都十分常见。例如下面是 hutool 包中的一个工具类。一个 set 集合如果为 null则创建一个空的集合对象否则返回原来的集合对象image.png泛型为简化重复代码而生泛型的适用的场景太多比如下面场景工具类中使用抽象类模板方法构建标准步骤中使用顶层接口类中使用甚至使用 Object 的场景都可以考虑使用泛化来替代......接下来再聊聊从 JDK8 开始的新特性(语法糖)函数式编程。3.2 函数式编程在函数式编程中可将方法作为参数进行传递调用灵活性不言而喻下面这几行代码是基于 guava 的 ListenableFuture 封装的一个异步回调。Callable 可以代表所有的方法。匿名内部类public static V ListenableFutureV invokeWithFuture( CallableV callable) { return gPool.submit(callable); }使用如下Test public void invokeWithFuture() throws Execution { ListenableFutureString result AsyncInvoke.invokeWithFuture(() - hello); System.out.println(result.get()); }() - hello作为一个代码块被传入到了方法中。是的将代码块作为参数传递函数式编程的好处让代码变得如此的灵活。困扰我多年的问题终于有了解法了。华丽转身泛型解决通用性函数式编程将代码块用函数作为参数进行传递于是基于分页的结构化问题使用泛型 函数式编程进行解决分页总数使用 countFunction 计算分页详情使用 listFunction 获取如下所示SneakyThrows public static T PageData buildPageData( CallableInteger countFunction, CallableListT listFunction) { // 1. 创建分页对象 PageData pageData new PageData(); // 2. 计算满足的记录数 int count countFunction.call(); // 3. 为 0则表示没有符合的数据直接返回 if (count 0) { pageData.setCount(0); return pageData; } // 4. 不为 0计算记录详情 ListT resultList listFunction.call(); // 5. 封装记录总数和 pageData.setCount(count); pageData.setResult(resultList); return pageData; }补充分页对象代码Data static class PageDataT { private int count; private T result; }使用情况Test public void testBuildPageData(String[] args) { buildPageData(()- 1, () - Arrays.asList(1)); }第一个参数是求记录数的方法第二个参数是求详情的方法从那时起结构化的代码我不再进行 CV 了。泛型和函数式的编程让我的代码重复率又下降一个水位小秘诀将变动的部分以函数方式进行变量替换从而保留骨架达到泛化和通用。就像下面这张图一样“骨肉分离”肉是细节代码骨是结构框架。image.png更多案例我开始大量实践后这样的代码也越来越多。接着再分析一个详细的案例。下面是一个异步回调的工具类。首先定义异步回调的任务接口所有目标对象需要实现该接口才能作为异步回调的参数进行调用public interface CallbackTaskR { R execute(); default void onSuccess(R r) { } default void onFailure(Throwable t) { } }方法理解execute 主方法目标任务需要具体实现方法执行成功后回调 onSuccess 方法方法执行失败后回调 onFailure 方法下面是具体实现通过 CompletableFuture 来实现异步回调调用执行链路逻辑supplyAsync 异步执行任务whenComplete 异步执行结束回调不管失败成功都会调用因此我做了一下判断exceptionally 失败场景回调/** * 借助 CompletableFuture 来实现异步行为。 * 不会抛出异常在 onFailure 中处理异常 * * param executeTask * param R * return */ private static R CompletableFutureR doInvoker( CallbackTaskR executeTask) { CompletableFutureR invoke CompletableFuture .supplyAsync(() - { try { return executeTask.execute(); } catch (Exception exception) { throw new BizException( ASYNC_INVOKER_ERROR.getErrorCode(), exception.getMessage()); } }, gPool) .whenComplete((result, throwable) - { // 不管成功与失败whenComplete 都会执行 // 通过 throwable null 跳过执行 if (throwable null) { executeTask.onSuccess(result); } }) .exceptionally(throwable - { executeTask.onFailure(throwable); // todo 给一个默认值或者使用 Optional包装一下否者异常会出现NPE return null; }); return invoke; }上面代码是整个骨架 实现了异步回调。下面是具体使用:CompletableFutureInteger result AsyncInvoke.doInvoker(new CallbackTaskInteger() { public Integer execute() { int result 1 1; return result; } Override public void onSuccess(Integer integer) { System.out.println(on success result: integer); } Override public void onFailure(Throwable t) { System.out.println(error t.getMessage()); } });result#get 可以获取异步结果执行成功后调用 onSuccess失败会调用 onFailure还有很多其他场景都可以使用泛型 函数式编程来解决针对每个方法限流针对每个方法重试......它解决了重复让代码看起来优雅虽然如此但这样的组合也会带来一些不足。不足之处泛型和函数式编程不方便调试出问题的时候比较显著理解有成本尤其方法不熟悉的时候同时降低一定的可读性