模版模式的应用实际举例

目录

基本理解与应用举例

业务应用

业务失败重试机制

基本模版代码

具体业务处理

使用及测试展示

使用框架实现业务失败重试机制

业务前置检查流程模版

基本代码依赖

模版代码准备

业务应用前置检查

业务实现

测试及结果展示

Thrift远程调用处理模版

基本常规业务处理模版

分页处理模版

滚动处理模版

业务使用模版定义

业务模拟服务

具体模拟业务

测试及展示

干货分享，感谢您的阅读！模版模式应该是工作中最常用的设计模式之一，直白的讲就是如果的一些处理方式是有一定的模版流程处理的，那么在应用中使用该模式在合适不过了。对于其基本的业务应用，我简单写了以下三个基本的通用模版（业务失败重试机制、业务前置检查流程模版、Thrift远程调用处理模版）来展示，有问题的可以留言纠正，谢谢！

基本理解与应用举例

GoF《设计模式》一书中，定义如下：

      Define the skeleton of an algorithm in an operation, deferring some steps to subclasses. Template Method lets subclasses redefine certain steps of an algorithm without changing the algorithm’s structure.

基本结合业务使用可以翻译为：模板方法模式在一个方法中定义一个算法骨架，并将某些步骤推迟到子类中实现。模板方法模式可以让子类在不改变算法整体结构的情况下，重新定义算法中的某些步骤。算法骨架，其实就是指的我们定义的业务处理流程模版。

应用举例平时在看源码的时候基本都可以看到，比方说以下的几个举例：

  • spring 中 Hibernate 比如开启事务、获取 Session、关闭 Session 等规范化流程的设计和实现；
  • HttpServlet的service()模板方法，定义了整个HTTP请求的执行流程，doGet()、doPost()是模板中可以由子类来定制的部分；
  • Java IO类库中，比如InputStream、OutputStream、Reader、Writer的设计都使用了模板模式

业务应用

实际中只有业务上有很固定的流程基本都可以使用模版模式进行定义和解决问题，这边的就我自身来看，具体的业务的一定不方便拿出来举例，所以暂时想了以下三个业务场景较为公用的拿出来与大家分享，有需要纠正的请大家留言纠正。

业务失败重试机制

我们在实际业务处理中经常会遇到调用远程方法如果因为超时或一些其他原因失败的话，最好在进行重试调用一次，而重试简单的来看主要的模版流程基本有按业务实际调用失败后规定休眠一段时间后再次重试一次，如果超过重试次数则返回报错，如果中间重试成功则按成功的处理，所以我们可以简单的写一个业务失败重试机制的模版

基本模版代码

  1. package org.zyf.javabasic.designpatterns.strategy.template.retry;
  2.  
  3. import lombok.extern.log4j.Log4j2;
  4.  
  5. /**
  6.  * @author yanfengzhang
  7.  * @description 模板方式处理重试逻辑
  8.  * @date 2022/3/15  00:13
  9.  */
  10. @Log4j2
  11. public abstract class RetryTemplate {
  12.     /**
  13.      * 默认重试次数
  14.      */
  15.     private static final int DEFAULT_RETRY_TIME = 1;
  16.     /**
  17.      * 定义重试次数
  18.      */
  19.     private int retryTime = DEFAULT_RETRY_TIME;
  20.     /**
  21.      * 重试的睡眠时间
  22.      */
  23.     private int sleepMills = 0;
  24.  
  25.     /**
  26.      * 业务处理的睡眠时间
  27.      *
  28.      * @return 睡眠时间
  29.      */
  30.     public int getSleepMills() {
  31.         return sleepMills;
  32.     }
  33.  
  34.     /**
  35.      * 获取重试次数
  36.      *
  37.      * @return 重试次数
  38.      */
  39.     public int getRetryTime() {
  40.         return retryTime;
  41.     }
  42.  
  43.     /**
  44.      * 规定业务处理的睡眠时间
  45.      *
  46.      * @param sleepMills 睡眠时间（毫秒）
  47.      * @return 重试模版
  48.      */
  49.     public RetryTemplate setSleepMills(int sleepMills) {
  50.         if (sleepMills < 0) {
  51.             throw new IllegalArgumentException("sleepMills should equal or bigger than 0");
  52.         }
  53.  
  54.         this.sleepMills = sleepMills;
  55.         return this;
  56.     }
  57.  
  58.     /**
  59.      * 规定业务处理的重试次数
  60.      *
  61.      * @param retryTime 业务处理的重试次数
  62.      * @return 重试模版
  63.      */
  64.     public RetryTemplate setRetryTime(int retryTime) {
  65.         if (retryTime <= 0) {
  66.             throw new IllegalArgumentException("retryTime should bigger than 0");
  67.         }
  68.  
  69.         this.retryTime = retryTime;
  70.         return this;
  71.     }
  72.  
  73.     /**
  74.      * 重试的业务执行代码
  75.      * 失败时请抛出一个异常
  76.      */
  77.     protected abstract Object doBiz() throws Exception;
  78.  
  79.     /**
  80.      * 重试的主要业务逻辑
  81.      *
  82.      * @return 实际业务处理返回内容
  83.      * @throws InterruptedException 中断异常
  84.      */
  85.     public R execute() throws InterruptedException {
  86.         for (int i = 0; i < retryTime; i++) {
  87.             try {
  88.                 return (R) doBiz();
  89.             } catch (Exception e) {
  90.                 log.warn("业务执行出现异常，e: ", e);
  91.                 Thread.sleep(sleepMills);
  92.             }
  93.         }
  94.         return null;
  95.     }
  96. }

具体业务处理

  1. package org.zyf.javabasic.designpatterns.strategy.template.retry;
  2.  
  3. import com.google.common.collect.Maps;
  4. import lombok.extern.slf4j.Slf4j;
  5. import org.apache.commons.lang3.StringUtils;
  6. import org.springframework.stereotype.Service;
  7.  
  8. import java.util.Map;
  9. import java.util.Random;
  10.  
  11. /**
  12.  * @author yanfengzhang
  13.  * @description
  14.  * @date 2022/3/15  00:20
  15.  */
  16. @Service
  17. @Slf4j
  18. public class RetryBizService {
  19.  
  20.     private static Map aphorisms = Maps.newHashMap();
  21.  
  22.     static {
  23.         aphorisms.put(1, "知人者智，自知者明。胜人者有力，自胜者强。——老子");
  24.         aphorisms.put(2, "要知道对好事的称颂过于夸大，也会招来人们的反感轻蔑和嫉妒。——培根");
  25.         aphorisms.put(5, "业精于勤，荒于嬉；行成于思，毁于随。——韩愈");
  26.         aphorisms.put(7, "最大的骄傲于最大的自卑都表示心灵的最软弱无力。——斯宾诺莎");
  27.         aphorisms.put(9, "知之者不如好之者，好之者不如乐之者。——孔子");
  28.     }
  29.  
  30.     /**
  31.      * 获取名言警句
  32.      *
  33.      * @return 名言警句
  34.      */
  35.     public String getAphorisms() throws Exception {
  36.         int randomNumber = new Random().nextInt(10);
  37.         String rersult = aphorisms.get(randomNumber);
  38.         if (StringUtils.isBlank(rersult)) {
  39.             throw new Exception("抱歉！系统异常，暂无数据可进行返回！randomNumber=" + randomNumber);
  40.         }
  41.  
  42.         return rersult;
  43.     }
  44. }

使用及测试展示

测试代码

  1. package org.zyf.javabasic.designpatterns.strategy.template.retry;
  2.  
  3. import com.github.rholder.retry.RetryException;
  4. import com.github.rholder.retry.Retryer;
  5. import com.github.rholder.retry.RetryerBuilder;
  6. import com.github.rholder.retry.StopStrategies;
  7. import com.github.rholder.retry.WaitStrategies;
  8. import lombok.extern.slf4j.Slf4j;
  9. import org.apache.commons.lang3.StringUtils;
  10. import org.junit.Test;
  11. import org.junit.runner.RunWith;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.boot.test.context.SpringBootTest;
  14. import org.springframework.test.context.junit4.SpringRunner;
  15. import org.zyf.javabasic.ZYFApplication;
  16.  
  17. import java.util.Objects;
  18. import java.util.concurrent.Callable;
  19. import java.util.concurrent.ExecutionException;
  20. import java.util.concurrent.TimeUnit;
  21.  
  22. /**
  23.  * @author yanfengzhang
  24.  * @description
  25.  * @date 2022/3/2022/3/15  00:23
  26.  */
  27. @RunWith(SpringRunner.class)
  28. @SpringBootTest(classes = ZYFApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
  29. @Slf4j
  30. public class RetryTemplateTest {
  31.  
  32.     @Autowired
  33.     private RetryBizService retryBizService;
  34.  
  35.     @Test
  36.     public void testRetryBizService() {
  37.         String aphorisms = null;
  38.         try {
  39.             aphorisms = (String) new RetryTemplate() {
  40.                 @Override
  41.                 protected Object doBiz() throws Exception {
  42.                     return retryBizService.getAphorisms();
  43.                 }
  44.             }.setRetryTime(3).setSleepMills(200).execute();
  45.         } catch (Exception e) {
  46.             log.warn("[RetryBizService名言警句展示] 系统系统进行重试调用失败！");
  47.         }
  48.         if (StringUtils.isEmpty(aphorisms)) {
  49.             log.error("[RetryBizService名言警句展示异常，请稍后重试]");
  50.             return;
  51.         }
  52.         log.info("测试成功，得到的名言警句为：{}", aphorisms);
  53.     }
  54. }

测试结果展示

使用框架实现业务失败重试机制

但是实际中，以上的实现还是较为简单，比如像高并发等场景基本没有进行考虑，所以实际应用中我建议使用guava的重试模版进行处理比较好

引入pom

  1.         
  2.         
  3.             com.github.rholder
  4.             guava-retrying
  5.             2.0.0
  6.

使用及测试展示

  1. package org.zyf.javabasic.designpatterns.strategy.template.retry;
  2.  
  3. import com.github.rholder.retry.RetryException;
  4. import com.github.rholder.retry.Retryer;
  5. import com.github.rholder.retry.RetryerBuilder;
  6. import com.github.rholder.retry.StopStrategies;
  7. import com.github.rholder.retry.WaitStrategies;
  8. import lombok.extern.slf4j.Slf4j;
  9. import org.apache.commons.lang3.StringUtils;
  10. import org.junit.Test;
  11. import org.junit.runner.RunWith;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.boot.test.context.SpringBootTest;
  14. import org.springframework.test.context.junit4.SpringRunner;
  15. import org.zyf.javabasic.ZYFApplication;
  16.  
  17. import java.util.Objects;
  18. import java.util.concurrent.Callable;
  19. import java.util.concurrent.ExecutionException;
  20. import java.util.concurrent.TimeUnit;
  21.  
  22. /**
  23.  * @author yanfengzhang
  24.  * @description
  25.  * @date 2022/3/2022/3/15  00:23
  26.  */
  27. @RunWith(SpringRunner.class)
  28. @SpringBootTest(classes = ZYFApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
  29. @Slf4j
  30. public class RetryTemplateTest {
  31.  
  32.     @Autowired
  33.     private RetryBizService retryBizService;
  34.  
  35.     @Test
  36.     public void testGuavaRetrying() {
  37.         Callable callable = () -> {
  38.             /*业务逻辑*/
  39.             return retryBizService.getAphorisms();
  40.         };
  41.  
  42.         /*定义重试器*/
  43.         Retryer retryer = RetryerBuilder.newBuilder()
  44.                 /*如果结果为空则重试*/
  45.                 .retryIfResult(Objects::isNull)
  46.                 /*发生IO异常则重试*/
  47.                 .retryIfExceptionOfType(Exception.class)
  48.                 /*发生运行时异常则重试*/
  49.                 .retryIfRuntimeException()
  50.                 /*等待*/
  51.                 .withWaitStrategy(WaitStrategies.incrementingWait(100, TimeUnit.MILLISECONDS,
  52.                         100, TimeUnit.MILLISECONDS))
  53.                 /*允许执行4次（首次执行 + 最多重试3次）*/
  54.                 .withStopStrategy(StopStrategies.stopAfterAttempt(4))
  55.                 .build();
  56.  
  57.         try {
  58.             /*执行*/
  59.             String aphorisms = retryer.call(callable);
  60.             if (StringUtils.isEmpty(aphorisms)) {
  61.                 log.error("[RetryBizService名言警句展示异常，请稍后重试]");
  62.                 return;
  63.             }
  64.             log.info("测试成功，得到的名言警句为：{}", aphorisms);
  65.         } catch (RetryException | ExecutionException e) {
  66.             /*重试次数超过阈值或被强制中断*/
  67.             log.warn("[RetryBizService名言警句展示] 系统系统进行重试调用失败！");
  68.         }
  69.     }
  70. }

业务前置检查流程模版

平时我们对于业务的基本入参可能会有一些指定的业务检查流程需要检查，比方依次有基础参数检查、业务逻辑检查、冲突关联检查、验证码校验、二次弹窗校验等，于是将其整合一下即可有业务前置检查流程模版。

基本代码依赖

  1. package org.zyf.javabasic.designpatterns.strategy.template.check;
  2.  
  3. import lombok.Builder;
  4. import lombok.Data;
  5.  
  6. /**
  7.  * @author yanfengzhang
  8.  * @description 校验基本返回结构
  9.  * @date 2022/3/16  23:29
  10.  */
  11. @Data
  12. @Builder
  13. public class CheckResponse {
  14.     /**
  15.      * 成功标志：true-校验通过，false-校验未通过
  16.      */
  17.     private boolean pass;
  18.     /**
  19.      * 校验码
  20.      */
  21.     private Integer code;
  22.     /**
  23.      * 未通过原因
  24.      */
  25.     private String errorMsg;
  26. }

模版代码准备

  1. package org.zyf.javabasic.designpatterns.strategy.template.check;
  2.  
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.springframework.stereotype.Service;
  5.  
  6. /**
  7.  * @author yanfengzhang
  8.  * @description 业务数据校验模版
  9.  * @date 2022/3/16  23:35
  10.  */
  11. @Slf4j
  12. @Service
  13. public abstract class BizCheckTemplate
     {
  14.  
  15.     /**
  16.      * 校验全流程模版
  17.      *
  18.      * @param param 基本入参
  19.      * @return 校验结果
  20.      * @throws Exception 业务异常
  21.      */
  22.     public CheckResponse checkProcess(P param) {
  23.         /*1.基础参数校验*/
  24.         CheckResponse checkResponse = checkParam(param);
  25.         if (!checkResponse.isPass()) {
  26.             return checkResponse;
  27.         }
  28.  
  29.         /*2.业务逻辑校验*/
  30.         checkResponse = checkBiz(param);
  31.         if (!checkResponse.isPass()) {
  32.             return checkResponse;
  33.         }
  34.  
  35.         /*3.冲突关联校验*/
  36.         checkResponse = checkConflict(param);
  37.         if (!checkResponse.isPass()) {
  38.             return checkResponse;
  39.         }
  40.  
  41.         /*4.验证码校验*/
  42.         checkResponse = checkVerifyCode(param);
  43.         if (!checkResponse.isPass()) {
  44.             return checkResponse;
  45.         }
  46.  
  47.         /*5.二次弹窗校验*/
  48.         checkResponse = checkTwicePopup(param);
  49.         if (!checkResponse.isPass()) {
  50.             return checkResponse;
  51.         }
  52.  
  53.         return checkResponse;
  54.     }
  55.  
  56.     protected abstract CheckResponse checkParam(P param);
  57.  
  58.     protected abstract CheckResponse checkBiz(P param);
  59.  
  60.     protected abstract CheckResponse checkTwicePopup(P param);
  61.  
  62.     protected abstract CheckResponse checkVerifyCode(P param);
  63.  
  64.     protected abstract CheckResponse checkConflict(P param);
  65. }

业务应用前置检查

假如有一个申诉的业务系统，其需要进行以上前置的检查处理，我们定义其基本检查的实现类如下：

申诉提交检查

  1. package org.zyf.javabasic.designpatterns.strategy.template.check;
  2.  
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.stereotype.Service;
  6.  
  7. /**
  8.  * @author yanfengzhang
  9.  * @description 申诉内容创建检查
  10.  * @date 2022/3/16  20:24
  11.  */
  12. @Service
  13. @Slf4j
  14. public class AppealCreateCheck extends BizCheckTemplate {
  15.  
  16.     @Autowired
  17.     private AppealCheckService appealCheckService;
  18.  
  19.     /**
  20.      * 申诉内容参数检查
  21.      *
  22.      * @param param 请求参数信息
  23.      * @return 校验结果
  24.      */
  25.     @Override
  26.     protected CheckResponse checkParam(AppealMatters param) {
  27.         if (!param.getType().equals(1)) {
  28.             /*为了用于测试*/
  29.             return CheckResponse.builder().pass(false).errorMsg("新增申诉内容类型不符合要求！").build();
  30.         }
  31.         return CheckResponse.builder().pass(true).build();
  32.     }
  33.  
  34.     /**
  35.      * 申诉内容业务逻辑检查
  36.      *
  37.      * @param param 请求参数信息
  38.      * @return 校验结果
  39.      */
  40.     @Override
  41.     protected CheckResponse checkBiz(AppealMatters param) {
  42.         /*业务检查1：申诉的内容编码是唯一的，当前重复申诉*/
  43.         /*业务检查2：申诉的内容项不得包含非法指定的相关内容*/
  44.         /*业务检查3：申诉人对应的申诉项中和申诉人当前享有的权益不匹配*/
  45.         return CheckResponse.builder().pass(true).build();
  46.     }
  47.  
  48.     /**
  49.      * 申诉二次弹窗检查（不涉及直接返回通过）
  50.      *
  51.      * @param param 请求参数信息
  52.      * @return 校验结果
  53.      */
  54.     @Override
  55.     protected CheckResponse checkTwicePopup(AppealMatters param) {
  56.         return CheckResponse.builder().pass(true).build();
  57.     }
  58.  
  59.     /**
  60.      * 申诉验证码校验（不涉及直接返回通过）
  61.      *
  62.      * @param param 请求参数信息
  63.      * @return 校验结果
  64.      */
  65.     @Override
  66.     protected CheckResponse checkVerifyCode(AppealMatters param) {
  67.         return CheckResponse.builder().pass(true).build();
  68.     }
  69.  
  70.     /**
  71.      * 申诉关联冲突校验
  72.      *
  73.      * @param param 请求参数信息
  74.      * @return 校验结果
  75.      */
  76.     @Override
  77.     protected CheckResponse checkConflict(AppealMatters param) {
  78.         return appealCheckService.checkConflict(param);
  79.     }
  80. }

申诉修改检查

  1. package org.zyf.javabasic.designpatterns.strategy.template.check;
  2.  
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.stereotype.Service;
  6.  
  7. /**
  8.  * @author yanfengzhang
  9.  * @description 申诉内容修改检查
  10.  * @date 2022/3/16  23:43
  11.  */
  12. @Service
  13. @Slf4j
  14. public class AppealUpdateCheck extends BizCheckTemplate {
  15.  
  16.     @Autowired
  17.     private AppealCheckService appealCheckService;
  18.  
  19.     /**
  20.      * 申诉内容参数检查
  21.      *
  22.      * @param param 请求参数信息
  23.      * @return 校验结果
  24.      */
  25.     @Override
  26.     protected CheckResponse checkParam(AppealMatters param) {
  27.         if (!param.getType().equals(2)) {
  28.             /*为了用于测试*/
  29.             return CheckResponse.builder().pass(false).errorMsg("修改申诉内容类型不符合要求！").build();
  30.         }
  31.         return CheckResponse.builder().pass(true).build();
  32.     }
  33.  
  34.     /**
  35.      * 申诉内容业务逻辑检查
  36.      *
  37.      * @param param 请求参数信息
  38.      * @return 校验结果
  39.      */
  40.     @Override
  41.     protected CheckResponse checkBiz(AppealMatters param) {
  42.         /*业务检查1：申诉的内容编码不能修改*/
  43.         /*业务检查2：申诉的内容项已进行处理的不能在修改，新增的申诉项不得包含非法指定的相关内容*/
  44.         /*业务检查3：新增的申诉项中，申诉人对应的申诉项中和申诉人当前享有的权益不匹配*/
  45.         return CheckResponse.builder().pass(true).build();
  46.     }
  47.  
  48.     /**
  49.      * 申诉二次弹窗检查
  50.      *
  51.      * @param param 请求参数信息
  52.      * @return 校验结果
  53.      */
  54.     @Override
  55.     protected CheckResponse checkTwicePopup(AppealMatters param) {
  56.         /*二次弹窗检查检查1：申诉的内容存在修改次数，请确认是否修改*/
  57.         return CheckResponse.builder().pass(true).build();
  58.     }
  59.  
  60.     /**
  61.      * 申诉验证码校验
  62.      *
  63.      * @param param 请求参数信息
  64.      * @return 校验结果
  65.      */
  66.     @Override
  67.     protected CheckResponse checkVerifyCode(AppealMatters param) {
  68.         /*验证码校验检查1：修改操作需本人进行验证码确认*/
  69.         return CheckResponse.builder().pass(true).build();
  70.     }
  71.  
  72.     /**
  73.      * 申诉关联冲突校验
  74.      *
  75.      * @param param 请求参数信息
  76.      * @return 校验结果
  77.      */
  78.     @Override
  79.     protected CheckResponse checkConflict(AppealMatters param) {
  80.         return appealCheckService.checkConflict(param);
  81.     }
  82. }

申诉删除检查

  1. package org.zyf.javabasic.designpatterns.strategy.template.check;
  2.  
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.stereotype.Service;
  6.  
  7. /**
  8.  * @author yanfengzhang
  9.  * @description 申诉内容删除检查
  10.  * @date 2022/3/16  23:44
  11.  */
  12. @Service
  13. @Slf4j
  14. public class AppealDeleteCheck extends BizCheckTemplate {
  15.     @Autowired
  16.     private AppealCheckService appealCheckService;
  17.  
  18.     /**
  19.      * 申诉内容参数检查
  20.      *
  21.      * @return 校验结果
  22.      * @id id 请求参数信息
  23.      */
  24.     @Override
  25.     protected CheckResponse checkParam(Long id) {
  26.         if (!checkPosInteger(id)) {
  27.             return CheckResponse.builder().pass(false).errorMsg("申诉内容id不合法！").build();
  28.         }
  29.         /*id必须为有效ID*/
  30.         return CheckResponse.builder().pass(true).build();
  31.     }
  32.  
  33.     /**
  34.      * 申诉内容业务逻辑检查
  35.      *
  36.      * @return 校验结果
  37.      * @id id 请求参数信息
  38.      */
  39.     @Override
  40.     protected CheckResponse checkBiz(Long id) {
  41.         /*业务检查1：申诉的内容必须存在*/
  42.         /*业务检查2：申诉的内容项全部处理完成的不能删除*/
  43.         /*业务检查3：申诉人当前享有的权益存在需要进行续费的暂时不能删除申诉内容*/
  44.         return CheckResponse.builder().pass(true).build();
  45.     }
  46.  
  47.     /**
  48.      * 申诉二次弹窗检查
  49.      *
  50.      * @return 校验结果
  51.      * @id id 请求参数信息
  52.      */
  53.     @Override
  54.     protected CheckResponse checkTwicePopup(Long id) {
  55.         /*二次弹窗检查检查1：申请确认是否删除*/
  56.         /*二次弹窗检查检查2：相关未享受的权益删除后不再享有，申请确认是否删除*/
  57.         return CheckResponse.builder().pass(true).build();
  58.     }
  59.  
  60.     /**
  61.      * 申诉验证码校验
  62.      *
  63.      * @return 校验结果
  64.      * @id id 请求参数信息
  65.      */
  66.     @Override
  67.     protected CheckResponse checkVerifyCode(Long id) {
  68.         /*验证码校验检查1：修改操作需本人进行验证码确认*/
  69.         return CheckResponse.builder().pass(true).build();
  70.     }
  71.  
  72.     /**
  73.      * 申诉关联冲突校验（不涉及直接返回通过）
  74.      *
  75.      * @return 校验结果
  76.      * @id id 请求参数信息
  77.      */
  78.     @Override
  79.     protected CheckResponse checkConflict(Long id) {
  80.         return CheckResponse.builder().pass(true).build();
  81.     }
  82.  
  83.     /**
  84.      * ID信息合法性:必须为正整数
  85.      *
  86.      * @param id id信息
  87.      * @return true-合法；false-非法
  88.      */
  89.     public static boolean checkPosInteger(Long id) {
  90.         return null != id && id > 0L;
  91.     }
  92. }

公用检查

  1. package org.zyf.javabasic.designpatterns.strategy.template.check;
  2.  
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.apache.commons.lang3.StringUtils;
  5. import org.springframework.stereotype.Service;
  6.  
  7. import java.util.Objects;
  8.  
  9. /**
  10.  * @author yanfengzhang
  11.  * @description 申诉基本校验检查（公用）
  12.  * @date 2022/3/16  23:40
  13.  */
  14. @Service
  15. @Slf4j
  16. public class AppealCheckService {
  17.  
  18.     /**
  19.      * 公用的创建和修改必要参数检查
  20.      *
  21.      * @param param 必要参数信息
  22.      * @return 检查结果
  23.      */
  24.     public CheckResponse checkParam(AppealMatters param) {
  25.         if (Objects.isNull(param)) {
  26.             return CheckResponse.builder().pass(false).errorMsg("创建消息不能为空！").build();
  27.         }
  28.  
  29.         if (StringUtils.isBlank(param.getCode())) {
  30.             return CheckResponse.builder().pass(false).errorMsg("申诉编码不能为空！").build();
  31.         }
  32.  
  33.         if (Objects.isNull(param.getType())) {
  34.             return CheckResponse.builder().pass(false).errorMsg("申诉类型不能为空且必须为规定的类型！").build();
  35.         }
  36.  
  37.         return CheckResponse.builder().pass(true).build();
  38.     }
  39.  
  40.     /**
  41.      * 公用的创建和修改关联冲突校验
  42.      *
  43.      * @param param 请求参数信息
  44.      * @return 检查结果
  45.      */
  46.     public CheckResponse checkConflict(AppealMatters param) {
  47.         /*关联冲突检查1：申诉的内容对应的申诉类型在当前系统指定暂停办理中，请进行替换*/
  48.         /*关联冲突检查2：申诉的内容项直接存在相同申诉问题，请重新归类提交*/
  49.         /*关联冲突检查3：申诉的内容项与实际享有权益存在冲突，请确认避免后续被系统锁定*/
  50.         /*关联冲突检查4：申诉人当前存在其他非法内容，则本次提交需解决之前的内容*/
  51.         return CheckResponse.builder().pass(true).build();
  52.     }
  53. }

业务实现

  1. package org.zyf.javabasic.designpatterns.strategy.template.check;
  2.  
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.stereotype.Service;
  6.  
  7. /**
  8.  * @author yanfengzhang
  9.  * @description 申诉相关业务逻辑
  10.  * @date 2022/3/16  22:02
  11.  */
  12. @Service
  13. @Slf4j
  14. public class AppealService {
  15.  
  16.     @Autowired
  17.     private AppealCheckService appealCheckService;
  18.     @Autowired
  19.     private AppealCreateCheck appealCreateCheck;
  20.     @Autowired
  21.     private AppealUpdateCheck appealUpdateCheck;
  22.     @Autowired
  23.     private AppealDeleteCheck appealDeleteCheck;
  24.  
  25.     /**
  26.      * 申诉内容留档
  27.      *
  28.      * @param appealMatters 申诉内容
  29.      */
  30.     public void saveAppealMatters(AppealMatters appealMatters) throws Exception {
  31.         /*1.基本必要参数检查*/
  32.         CheckResponse checkResponse = appealCheckService.checkParam(appealMatters);
  33.         if (!checkResponse.isPass()) {
  34.             throw new Exception(checkResponse.getErrorMsg());
  35.         }
  36.  
  37.         /*2.实际业务操作*/
  38.         if (checkPosInteger(appealMatters.getId())) {
  39.             checkResponse = appealCreateCheck.checkProcess(appealMatters);
  40.             if (!checkResponse.isPass()) {
  41.                 throw new Exception(checkResponse.getErrorMsg());
  42.             }
  43.             /*业务处理，省略*/
  44.         }
  45.         checkResponse = appealUpdateCheck.checkProcess(appealMatters);
  46.         if (!checkResponse.isPass()) {
  47.             throw new Exception(checkResponse.getErrorMsg());
  48.         }
  49.         /*业务处理，省略*/
  50.     }
  51.  
  52.     /**
  53.      * 申诉内容留档
  54.      *
  55.      * @param appealMattersId 申诉内容id
  56.      */
  57.     public void deleteAppealMatters(Long appealMattersId) throws Exception {
  58.         /*1.基本必要参数检查*/
  59.         CheckResponse checkResponse = appealDeleteCheck.checkProcess(appealMattersId);
  60.         if (!checkResponse.isPass()) {
  61.             throw new Exception(checkResponse.getErrorMsg());
  62.         }
  63.         /*业务处理，省略*/
  64.     }
  65.  
  66.     /**
  67.      * ID信息合法性:必须为正整数
  68.      *
  69.      * @param id id信息
  70.      * @return true-合法；false-非法
  71.      */
  72.     public static boolean checkPosInteger(Long id) {
  73.         return null != id && id > 0L;
  74.     }
  75. }

测试及结果展示

  1. package org.zyf.javabasic.designpatterns.strategy.template.check;
  2.  
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.junit.Test;
  5. import org.junit.runner.RunWith;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.boot.test.context.SpringBootTest;
  8. import org.springframework.test.context.junit4.SpringRunner;
  9. import org.zyf.javabasic.ZYFApplication;
  10.  
  11. import java.util.Arrays;
  12. import java.util.List;
  13.  
  14. /**
  15.  * @author yanfengzhang
  16.  * @description
  17.  * @date 2022/3/17  00:15
  18.  */
  19. @RunWith(SpringRunner.class)
  20. @SpringBootTest(classes = ZYFApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
  21. @Slf4j
  22. public class BizCheckTemplateTest {
  23.  
  24.     @Autowired
  25.     private AppealService appealService;
  26.  
  27.     @Test
  28.     public void testAppealService() throws Exception {
  29.         List appealItems = Arrays.asList("隔壁搬来的邻居真他妈的吵！", "小区的健身房器械就不能在多一些练腿的？");
  30.         AppealMatters appealMatters = AppealMatters.builder()
  31.                 .code("shvhf2736gbbnvhbb")
  32.                 .declarant("zyf")
  33.                 .type(2)
  34.                 .appealItems(appealItems).build();
  35.  
  36.         log.info("测试新建");
  37.         appealService.saveAppealMatters(appealMatters);
  38.  
  39.         log.info("测试更新");
  40.         appealMatters.setId(7L);
  41.         appealMatters.setType(2);
  42.         appealService.saveAppealMatters(appealMatters);
  43.  
  44.         log.info("测试删除");
  45.         appealService.deleteAppealMatters(7L);
  46.     }
  47. }

结果展示

Thrift远程调用处理模版

平时可能在使用调用thrift接口的时候往往会使用分页获取调用或者使用滚动的方式进行处理，我们针对这样的业务场景页也共用的定义一套业务模版去处理，具体如下：

基本常规业务处理模版

  1. package org.zyf.javabasic.designpatterns.strategy.template.thrift;
  2.  
  3. import com.google.common.collect.Lists;
  4. import lombok.Data;
  5. import lombok.extern.slf4j.Slf4j;
  6.  
  7. import java.util.List;
  8. import java.util.Objects;
  9.  
  10. /**
  11.  * @author yanfengzhang
  12.  * @description 业务thrift调用基本类
  13.  * * TC : thrift请求
  14.  * * TR : thrift返回
  15.  * * FR : 业务实际真正要的处理结果
  16.  * @date 2022/3/18  23:18
  17.  */
  18. @Data
  19. @Slf4j
  20. public abstract class ThriftInvokeCommand {
  21.     /**
  22.      * thrift请求
  23.      */
  24.     protected TC command;
  25.     /**
  26.      * 每个命令最多翻滚多少页
  27.      */
  28.     private int maxPageCount = ConfigUtils.getThriftScrollMaxPageLimit();
  29.     /**
  30.      * 每个命令的最大重试个数
  31.      */
  32.     private int maxRetryCount = ConfigUtils.getThriftMaxInvokeRetryCount();
  33.     /**
  34.      * 每个命令的休眠时间
  35.      */
  36.     private int sleepMs = ConfigUtils.getThriftScrollRate();
  37.     /**
  38.      * 每个命令的查询页数
  39.      */
  40.     private int pageSize = ConfigUtils.getThriftScrollPageSize();
  41.  
  42.     public ThriftInvokeCommand(TC command) {
  43.         this.command = command;
  44.     }
  45.  
  46.     /**
  47.      * 核心处理逻辑：获取指定结果
  48.      */
  49.     public List getResult() {
  50.         /*执行的页数*/
  51.         int currPageNo = 0;
  52.         /*command 设置 pageSize*/
  53.         setPageSize(command, pageSize);
  54.         /*调用接口的失败次数*/
  55.         int errorCount = 0;
  56.  
  57.         TR thriftResult = null;
  58.         List rList = Lists.newArrayList();
  59.         while (true) {
  60.             try {
  61.                 /*1.前置处理*/
  62.                 preHandle();
  63.                 /*2.业务转发调用*/
  64.                 thriftResult = invoke(command);
  65.                 /*3.从thriftResult提取结果并转换为实际需要的*/
  66.                 rList.addAll(convertThriftResult(thriftResult));
  67.                 /*4.后置处理*/
  68.                 afterHandle(thriftResult);
  69.             } catch (Exception e) {
  70.                 log.error("", e);
  71.                 errorCount++;
  72.             }
  73.             /*thrift调用无结果则直接停止循转*/
  74.             if (Objects.isNull(thriftResult) || 0 == getResultSize(thriftResult)) {
  75.                 break;
  76.             }
  77.             if (errorCount >= maxRetryCount || currPageNo >= maxPageCount) {
  78.                 String msg = errorCount >= maxRetryCount ? "重试次数过多,已达最大尝试次数：" + maxRetryCount : "循环次数过多,已达最大尝试次数：" + maxPageCount;
  79.                 log.warn("ThriftInvokeCommand 处理警告：{}", msg);
  80.                 break;
  81.             }
  82.             currPageNo++;
  83.             /*5.停顿，降低调用频率*/
  84.             sleepInvoke();
  85.         }
  86.         return rList;
  87.     }
  88.  
  89.     /**
  90.      * thrift调用前置处理
  91.      */
  92.     protected abstract void preHandle();
  93.  
  94.     /**
  95.      * thrift调用后置处理
  96.      *
  97.      * @param thriftResult thrift调用结果
  98.      */
  99.     protected abstract void afterHandle(TR thriftResult);
  100.  
  101.     /**
  102.      * 核心逻辑， 通过命令获取结果
  103.      *
  104.      * @param command thrift调用请求
  105.      * @return thrift调用结果
  106.      */
  107.     protected abstract TR invoke(TC command) throws Exception;
  108.  
  109.     /**
  110.      * command 设置 pageSize
  111.      */
  112.     protected abstract void setPageSize(TC command, int pageSize);
  113.  
  114.  
  115.     /**
  116.      * 从 thriftResult 获取 结果长度，若是 0 ，那么 break 退出
  117.      */
  118.     protected abstract int getResultSize(TR thriftResult);
  119.  
  120.     /**
  121.      * 从 thriftResult 提取结果
  122.      */
  123.     protected abstract List convertThriftResult(TR thriftResult);
  124.  
  125.     /**
  126.      * 休眠调整处理
  127.      */
  128.     private void sleepInvoke() {
  129.         if (sleepMs <= 0) {
  130.             return;
  131.         }
  132.         try {
  133.             Thread.sleep(sleepMs);
  134.         } catch (InterruptedException ignored) {
  135.         }
  136.  
  137.     }
  138.  
  139.     public ThriftInvokeCommand setPageSize(int pageSize) {
  140.         this.pageSize = pageSize;
  141.         return this;
  142.     }
  143.  
  144.     public ThriftInvokeCommand setSleepMs(int sleepMs) {
  145.         this.sleepMs = sleepMs;
  146.         return this;
  147.     }
  148. }

分页处理模版

  1. package org.zyf.javabasic.designpatterns.strategy.template.thrift;
  2.  
  3. /**
  4.  * @author yanfengzhang
  5.  * @description 用于利用分页形式滚动调用thrift
  6.  * @date 2022/3/18  23:25
  7.  */
  8. public abstract class ThriftInvokePageCommand extends ThriftInvokeCommand {
  9.     private int pageNo = 1;
  10.  
  11.     public ThriftInvokePageCommand(TC command) {
  12.         super(command);
  13.     }
  14.  
  15.     @Override
  16.     public void preHandle() {
  17.         /*command 设置 pageNo*/
  18.         setPageNo(command, pageNo);
  19.     }
  20.  
  21.     @Override
  22.     public void afterHandle(TR thriftResult) {
  23.         /*页数加 1*/
  24.         pageNo++;
  25.     }
  26.  
  27.     /**
  28.      * command 设置 pageNo
  29.      */
  30.     protected abstract void setPageNo(TC command, int pageNo);
  31. }

滚动处理模版

  1. package org.zyf.javabasic.designpatterns.strategy.template.thrift;
  2.  
  3. /**
  4.  * @author yanfengzhang
  5.  * @description 用于利用scroll形式滚动调用thrift
  6.  * @date 2022/3/18  23:23
  7.  */
  8. public abstract class ThriftInvokeScrollCommand extends ThriftInvokeCommand {
  9.     private Long scrollId = 0L;
  10.  
  11.     public ThriftInvokeScrollCommand(TC command) {
  12.         super(command);
  13.     }
  14.  
  15.     @Override
  16.     public void preHandle() {
  17.         /*command 设置 ScrollId*/
  18.         setScrollId(command, scrollId);
  19.     }
  20.  
  21.     @Override
  22.     public void afterHandle(TR thriftResult) {
  23.         /*从 thriftResult 获取 scrollId*/
  24.         scrollId = getNextScrollId(thriftResult);
  25.     }
  26.  
  27.     /**
  28.      * command 设置 ScrollId
  29.      */
  30.     protected abstract void setScrollId(TC command, Long scrollId);
  31.  
  32.     /**
  33.      * 从 thriftResult 获取 scrollId
  34.      */
  35.     protected abstract Long getNextScrollId(TR thriftResult);
  36. }

业务使用模版定义

假设获取电影资源thrift有两套模版基本如下

获取电影thrift接口分页处理

  1. package org.zyf.javabasic.designpatterns.strategy.template.thrift;
  2.  
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.apache.commons.collections.CollectionUtils;
  5. import org.assertj.core.util.Lists;
  6.  
  7. import java.util.List;
  8. import java.util.Objects;
  9. import java.util.stream.Collectors;
  10.  
  11. /**
  12.  * @author yanfengzhang
  13.  * @description 获取电影thrift接口分页处理
  14.  * @date 2022/3/18  23:32
  15.  */
  16. @Slf4j
  17. public class GetMoviesByConditionPage extends ThriftInvokePageCommand {
  18.     /**
  19.      * 实际thrift接口（此处只做模拟）
  20.      * 实际该处应该类似为：private MoviesInfoThriftService.Iface moviesInfoThriftService;
  21.      */
  22.     private MoviesInfoThriftService moviesInfoThriftService;
  23.  
  24.     /**
  25.      * 实际分页调用构造器
  26.      *
  27.      * @param moviesConditions        请求查询分页请求
  28.      * @param moviesInfoThriftService 实际分页调用电影ThriftService
  29.      */
  30.     public GetMoviesByConditionPage(MoviesConditions moviesConditions, MoviesInfoThriftService moviesInfoThriftService) {
  31.         super(moviesConditions);
  32.         this.moviesInfoThriftService = moviesInfoThriftService;
  33.     }
  34.  
  35.     /**
  36.      * 设置实际页号
  37.      *
  38.      * @param moviesConditions 请求查询分页请求
  39.      * @param pageNo           页号
  40.      */
  41.     @Override
  42.     protected void setPageNo(MoviesConditions moviesConditions, int pageNo) {
  43.         if (Objects.isNull(moviesConditions)) {
  44.             return;
  45.         }
  46.         moviesConditions.setPageNo(pageNo);
  47.     }
  48.  
  49.     /**
  50.      * 设置实际页大小
  51.      *
  52.      * @param moviesConditions 请求查询分页请求
  53.      * @param pageSize         页大小
  54.      */
  55.     @Override
  56.     protected void setPageSize(MoviesConditions moviesConditions, int pageSize) {
  57.         if (Objects.isNull(moviesConditions)) {
  58.             return;
  59.         }
  60.         moviesConditions.setPageSize(pageSize);
  61.     }
  62.  
  63.     /**
  64.      * 获取实际数据大小
  65.      *
  66.      * @param moviesResult 请求查询分页请求
  67.      * @return 实际数据大小
  68.      */
  69.     @Override
  70.     protected int getResultSize(MoviesResult moviesResult) {
  71.         if (Objects.isNull(moviesResult)) {
  72.             return 0;
  73.         }
  74.         return moviesResult.getMovieInfos().size();
  75.     }
  76.  
  77.     /**
  78.      * 实际业务调用thrift接口
  79.      *
  80.      * @param moviesConditions 请求查询分页请求
  81.      * @return 实际业务调用thrift接口返回
  82.      * @throws Exception 业务异常
  83.      */
  84.     @Override
  85.     protected MoviesResult invoke(MoviesConditions moviesConditions) throws Exception {
  86.         if (Objects.isNull(moviesConditions)) {
  87.             return null;
  88.         }
  89.         return moviesInfoThriftService.getMoviesByConditionPage(moviesConditions);
  90.     }
  91.  
  92.     /**
  93.      * 获取实际业务需要的结果（进行实际的转换）
  94.      *
  95.      * @param moviesResult 实际业务调用thrift接口返回
  96.      * @return 实际业务需要的电影基本信息
  97.      */
  98.     @Override
  99.     protected List convertThriftResult(MoviesResult moviesResult) {
  100.         if (Objects.isNull(moviesResult) || CollectionUtils.isEmpty(moviesResult.getMovieInfos())) {
  101.             return Lists.newArrayList();
  102.         }
  103.  
  104.         return moviesResult.getMovieInfos().stream().map(movieInfo -> MovieBasicInfo.builder()
  105.                 .id(movieInfo.getId())
  106.                 .name(movieInfo.getName())
  107.                 .desc(movieInfo.getDesc())
  108.                 .director(movieInfo.getDirector())
  109.                 .actor(movieInfo.getActor())
  110.                 .duration(movieInfo.getDuration())
  111.                 .year(movieInfo.getYear())
  112.                 .score(movieInfo.getScore()).build()).collect(Collectors.toList());
  113.     }
  114. }

获取电影thrift接口滚动处理

  1. package org.zyf.javabasic.designpatterns.strategy.template.thrift;
  2.  
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.apache.commons.collections.CollectionUtils;
  5. import org.assertj.core.util.Lists;
  6.  
  7. import java.util.List;
  8. import java.util.Objects;
  9. import java.util.stream.Collectors;
  10.  
  11. /**
  12.  * @author yanfengzhang
  13.  * @description 获取电影thrift接口滚动处理
  14.  * @date 2022/3/20  17:37
  15.  */
  16. @Slf4j
  17. public class GetMoviesByConditionScroll extends ThriftInvokeScrollCommand {
  18.     /**
  19.      * 实际thrift接口（此处只做模拟）
  20.      * 实际该处应该类似为：private MoviesInfoThriftService.Iface moviesInfoThriftService;
  21.      */
  22.     private MoviesInfoThriftService moviesInfoThriftService;
  23.  
  24.     /**
  25.      * 实际分页调用构造器
  26.      *
  27.      * @param moviesConditions        请求查询分页请求
  28.      * @param moviesInfoThriftService 实际分页调用电影ThriftService
  29.      */
  30.     public GetMoviesByConditionScroll(MoviesConditions moviesConditions, MoviesInfoThriftService moviesInfoThriftService) {
  31.         super(moviesConditions);
  32.         this.moviesInfoThriftService = moviesInfoThriftService;
  33.     }
  34.  
  35.     /**
  36.      * @param moviesConditions 请求查询分页请求
  37.      * @param scrollId         当前滚动ID
  38.      */
  39.     @Override
  40.     protected void setScrollId(MoviesConditions moviesConditions, Long scrollId) {
  41.         if (Objects.isNull(moviesConditions)) {
  42.             return;
  43.         }
  44.         moviesConditions.setScrollId(scrollId);
  45.     }
  46.  
  47.     /**
  48.      * @param thriftResult 请求查询分页请求
  49.      * @return 下一个滚动ID
  50.      */
  51.     @Override
  52.     protected Long getNextScrollId(MoviesResult thriftResult) {
  53.         if (Objects.isNull(thriftResult)) {
  54.             return 0L;
  55.         }
  56.         return thriftResult.getNextScrollId();
  57.     }
  58.  
  59.     /**
  60.      * 设置实际页大小
  61.      *
  62.      * @param moviesConditions 请求查询分页请求
  63.      * @param pageSize         页大小
  64.      */
  65.     @Override
  66.     protected void setPageSize(MoviesConditions moviesConditions, int pageSize) {
  67.         if (Objects.isNull(moviesConditions)) {
  68.             return;
  69.         }
  70.         moviesConditions.setPageSize(pageSize);
  71.     }
  72.  
  73.     /**
  74.      * 获取实际数据大小
  75.      *
  76.      * @param moviesResult 请求查询分页请求
  77.      * @return 实际数据大小
  78.      */
  79.     @Override
  80.     protected int getResultSize(MoviesResult moviesResult) {
  81.         if (Objects.isNull(moviesResult)) {
  82.             return 0;
  83.         }
  84.         return moviesResult.getMovieInfos().size();
  85.     }
  86.  
  87.     /**
  88.      * 实际业务调用thrift接口
  89.      *
  90.      * @param moviesConditions 请求查询分页请求
  91.      * @return 实际业务调用thrift接口返回
  92.      * @throws Exception 业务异常
  93.      */
  94.     @Override
  95.     protected MoviesResult invoke(MoviesConditions moviesConditions) throws Exception {
  96.         if (Objects.isNull(moviesConditions)) {
  97.             return null;
  98.         }
  99.         return moviesInfoThriftService.getMoviesByConditionScroll(moviesConditions);
  100.     }
  101.  
  102.     /**
  103.      * 获取实际业务需要的结果（进行实际的转换）
  104.      *
  105.      * @param moviesResult 实际业务调用thrift接口返回
  106.      * @return 实际业务需要的电影基本信息
  107.      */
  108.     @Override
  109.     protected List convertThriftResult(MoviesResult moviesResult) {
  110.         if (Objects.isNull(moviesResult) || CollectionUtils.isEmpty(moviesResult.getMovieInfos())) {
  111.             return Lists.newArrayList();
  112.         }
  113.  
  114.         return moviesResult.getMovieInfos().stream().map(movieInfo -> MovieBasicInfo.builder()
  115.                 .id(movieInfo.getId())
  116.                 .name(movieInfo.getName())
  117.                 .desc(movieInfo.getDesc())
  118.                 .director(movieInfo.getDirector())
  119.                 .actor(movieInfo.getActor())
  120.                 .duration(movieInfo.getDuration())
  121.                 .year(movieInfo.getYear())
  122.                 .score(movieInfo.getScore()).build()).collect(Collectors.toList());
  123.     }
  124. }

业务模拟服务

前置准备数据

查询电影资源条件集合

  1. package org.zyf.javabasic.designpatterns.strategy.template.thrift;
  2.  
  3. import lombok.Builder;
  4. import lombok.Data;
  5.  
  6. /**
  7.  * @author yanfengzhang
  8.  * @description 查询电影资源条件集合
  9.  * @date 2022/3/18  23:33
  10.  */
  11. @Data
  12. @Builder
  13. public class MoviesConditions {
  14.     /**
  15.      * 综合排序类型：1-热播榜，2-好评榜，3-新上线，4-爱奇艺自制（热播），5-腾讯自制（热播），6-优酷自制（热播）
  16.      */
  17.     private int sortType;
  18.     /**
  19.      * 播放类型：1-剧情，2-喜剧，3-动作，4-爱情，5-惊悚，6-犯罪，7-悬疑，8-战争，9-科幻，10-动画，11-恐怖
  20.      * 12-家庭，13-传记，14-冒险，15-奇幻，16-武侠，17-历史，18-运动，19-歌舞，20-音乐，21-记录
  21.      * 22-伦理，23-西部
  22.      */
  23.     private int playType;
  24.     /**
  25.      * 电影产地归类：1-内地，2-中国香港，3-美国，4-欧洲，5-日本，6-韩国，7-英国，8-法国，9-德国，10-泰国
  26.      * 11-印度，12-意大利，13-西班牙，14-加拿大，15-澳大利亚，16-中国台湾，17-拉丁美洲，18-越南
  27.      * 19-俄罗斯，20-其他
  28.      */
  29.     private int productPlace;
  30.     /**
  31.      * 电影源：1-院线，2-蓝光，3-奥斯卡，4-自制电影，5-独播，6-烂片，7-网络电影，8-巨制
  32.      */
  33.     private int source;
  34.     /**
  35.      * 付费类型：1-免费，2-付费，3-VIP
  36.      */
  37.     private int paymentType;
  38.     /**
  39.      * 年份归类：1-2022年，2-2021年，3-2020年，4-2019年，5-20211-2018年
  40.      * 6-2000-2010年，7-90年代，8-80年代，9-更早
  41.      */
  42.     private int years;
  43.     /**
  44.      * 页号
  45.      */
  46.     private int pageNo;
  47.     /**
  48.      * 页大小
  49.      */
  50.     private int pageSize;
  51.     /**
  52.      * 当前滚动ID
  53.      */
  54.     private Long scrollId;
  55. }

电影资源信息（只是样板）

  1. package org.zyf.javabasic.designpatterns.strategy.template.thrift;
  2.  
  3. import lombok.Builder;
  4. import lombok.Data;
  5.  
  6. import java.util.List;
  7.  
  8. /**
  9.  * @author yanfengzhang
  10.  * @description 电影资源信息（只是样板）
  11.  * @date 2022/3/18  23:33
  12.  */
  13. @Data
  14. @Builder
  15. public class MovieInfo {
  16.     /**
  17.      * ID编号
  18.      */
  19.     private Long id;
  20.     /**
  21.      * 电影名称
  22.      */
  23.     private String name;
  24.     /**
  25.      * 电影简介
  26.      */
  27.     private String desc;
  28.     /**
  29.      * 电影导演
  30.      */
  31.     private String director;
  32.     /**
  33.      * 电影演员
  34.      */
  35.     private String actor;
  36.     /**
  37.      * 电影综合评分
  38.      */
  39.     private Integer score;
  40.     /**
  41.      * 电影时长
  42.      */
  43.     private Integer duration;
  44.     /**
  45.      * 归属排序：1-热播榜，2-好评榜，3-新上线，4-爱奇艺自制（热播），5-腾讯自制（热播），6-优酷自制（热播）
  46.      */
  47.     private int belong;
  48.     /**
  49.      * 播放类型：1-剧情，2-喜剧，3-动作，4-爱情，5-惊悚，6-犯罪，7-悬疑，8-战争，9-科幻，10-动画，11-恐怖
  50.      * 12-家庭，13-传记，14-冒险，15-奇幻，16-武侠，17-历史，18-运动，19-歌舞，20-音乐，21-记录
  51.      * 22-伦理，23-西部
  52.      */
  53.     private List playTypes;
  54.     /**
  55.      * 电影产地归类：1-内地，2-中国香港，3-美国，4-欧洲，5-日本，6-韩国，7-英国，8-法国，9-德国，10-泰国
  56.      * 11-印度，12-意大利，13-西班牙，14-加拿大，15-澳大利亚，16-中国台湾，17-拉丁美洲，18-越南
  57.      * 19-俄罗斯，20-其他
  58.      */
  59.     private int productPlace;
  60.     /**
  61.      * 电影源：1-院线，2-蓝光，3-奥斯卡，4-自制电影，5-独播，6-烂片，7-网络电影，8-巨制
  62.      */
  63.     private List sources;
  64.     /**
  65.      * 付费类型：1-免费，2-付费，3-VIP
  66.      */
  67.     private int paymentType;
  68.     /**
  69.      * 上映年份
  70.      */
  71.     private int year;
  72. }

基本电影信息

  1. package org.zyf.javabasic.designpatterns.strategy.template.thrift;
  2.  
  3. import lombok.Builder;
  4. import lombok.Data;
  5.  
  6. /**
  7.  * @author yanfengzhang
  8.  * @description 基本电影信息
  9.  * @date 2022/3/18  23:35
  10.  */
  11. @Data
  12. @Builder
  13. public class MovieBasicInfo {
  14.     /**
  15.      * ID编号
  16.      */
  17.     private Long id;
  18.     /**
  19.      * 电影名称
  20.      */
  21.     private String name;
  22.     /**
  23.      * 电影简介
  24.      */
  25.     private String desc;
  26.     /**
  27.      * 电影导演
  28.      */
  29.     private String director;
  30.     /**
  31.      * 电影演员
  32.      */
  33.     private String actor;
  34.     /**
  35.      * 电影综合评分
  36.      */
  37.     private Integer score;
  38.     /**
  39.      * 电影时长
  40.      */
  41.     private Integer duration;
  42.     /**
  43.      * 上映年份
  44.      */
  45.     private int year;
  46. }

获取的电影集合

  1. package org.zyf.javabasic.designpatterns.strategy.template.thrift;
  2.  
  3. import lombok.Builder;
  4. import lombok.Data;
  5.  
  6. import java.util.List;
  7.  
  8. /**
  9.  * @author yanfengzhang
  10.  * @description 获取的电影集合
  11.  * @date 2022/3/18  23:35
  12.  */
  13. @Data
  14. @Builder
  15. public class MoviesResult {
  16.     /**
  17.      * 总数目
  18.      */
  19.     private long total;
  20.     /**
  21.      * 具体电影信息
  22.      */
  23.     public List movieInfos;
  24.     /**
  25.      * 电影ID集合
  26.      */
  27.     public List movieIdList;
  28.     /**
  29.      * 下一个滚动ID
  30.      */
  31.     private Long nextScrollId;
  32. }

具体模拟业务

  1. package org.zyf.javabasic.designpatterns.strategy.template.thrift;
  2.  
  3. import com.google.common.collect.Maps;
  4. import lombok.extern.slf4j.Slf4j;
  5. import org.assertj.core.util.Lists;
  6. import org.springframework.stereotype.Service;
  7.  
  8. import java.util.List;
  9. import java.util.Map;
  10. import java.util.Random;
  11.  
  12. /**
  13.  * @author yanfengzhang
  14.  * @description 模拟实际电影thrift接口
  15.  * @date 2022/3/18  23:39
  16.  */
  17. @Service
  18. @Slf4j
  19. public class MoviesInfoThriftService {
  20.  
  21.     private static Map descWords = Maps.newHashMap();
  22.  
  23.     static {
  24.         descWords.put(1, "人生若无悔，那该多无趣啊。——《一代宗师》");
  25.         descWords.put(2, "冬天冷，是因为为了让我们懂得周围人的温暖，是多么的珍贵。——《熔炉》");
  26.         descWords.put(3, "你要尽全力保护你的梦想。那些嘲笑你梦想的人，他们注定失败，他们想把你变成和他们一样。我坚信，只要心中有梦想，我就会与众不同。你也是。——《当幸福来敲门》");
  27.         descWords.put(5, "成功的含义不在于得到什么，而是在于你从那个奋斗的起点走了多远。——《心灵捕手》");
  28.         descWords.put(6, "让朋友低估你的优点，让敌人高估你的缺点。——《教父》");
  29.         descWords.put(7, "所有大人都曾是小孩，虽然只有少数人记得。——《小王子》");
  30.         descWords.put(8, "记住，希望是好事，也许是人间至善，而美好的事物永不消逝。——《肖申克的救赎》");
  31.         descWords.put(9, "当你不能再拥有的时候，唯一可以做的，就是令自己不要忘记。——《东邪西毒》");
  32.         descWords.put(10, "我们要学会珍惜我们生活的每一天，因为，这每一天的开始，都将是我们余下生命之中的第一天。除非我们即将死去。——《美国美人》");
  33.     }
  34.  
  35.     public MoviesResult getMoviesByConditionPage(MoviesConditions moviesConditions) {
  36.         if (!checkPosInteger(moviesConditions.getPageSize())) {
  37.             return null;
  38.         }
  39.  
  40.         List movieInfos = Lists.newArrayList();
  41.         List movieIdList = Lists.newArrayList();
  42.         /*模拟数据，返回第一页数据和指定的页面大小*/
  43.         if (moviesConditions.getPageNo() == 1) {
  44.             for (int i = 1; i <= moviesConditions.getPageSize(); i++) {
  45.                 movieIdList.add((long) i);
  46.                 movieInfos.add(MovieInfo.builder()
  47.                         .id((long) i)
  48.                         .name("张彦峰喜欢的电影" + i)
  49.                         .desc(descWords.get(i))
  50.                         .actor("张彦峰")
  51.                         .director("张彦峰")
  52.                         .belong(2)
  53.                         .score(new Random().nextInt(10) % (10 - i + 1) + i).build());
  54.             }
  55.         }
  56.         if (moviesConditions.getPageNo() == 2) {
  57.             for (int i = 6; i <= moviesConditions.getPageSize() + 5; i++) {
  58.                 movieIdList.add((long) i);
  59.                 movieInfos.add(MovieInfo.builder()
  60.                         .id((long) i)
  61.                         .name("张彦峰喜欢的电影" + i)
  62.                         .desc(descWords.get(i))
  63.                         .actor("张彦峰")
  64.                         .director("张彦峰")
  65.                         .belong(2)
  66.                         .score(new Random().nextInt(10) % (10 - i + 1) + i).build());
  67.             }
  68.         }
  69.         return MoviesResult.builder().total(5).movieIdList(movieIdList).movieInfos(movieInfos).build();
  70.     }
  71.  
  72.     public MoviesResult getMoviesByConditionScroll(MoviesConditions moviesConditions) {
  73.         if (!checkPosInteger(moviesConditions.getPageSize()) || moviesConditions.getScrollId() < 0) {
  74.             return null;
  75.         }
  76.  
  77.         List movieInfos = Lists.newArrayList();
  78.         List movieIdList = Lists.newArrayList();
  79.         /*模拟数据，返回第一页数据和指定的页面大小*/
  80.         if (moviesConditions.getScrollId() == 0) {
  81.             for (int i = 1; i <= moviesConditions.getPageSize(); i++) {
  82.                 movieIdList.add((long) i);
  83.                 movieInfos.add(MovieInfo.builder()
  84.                         .id((long) i)
  85.                         .name("张彦峰喜欢的电影" + i)
  86.                         .desc(descWords.get(i))
  87.                         .actor("张彦峰")
  88.                         .director("张彦峰")
  89.                         .belong(2)
  90.                         .score(new Random().nextInt(10) % (10 - i + 1) + i).build());
  91.             }
  92.             return MoviesResult.builder().total(5).movieIdList(movieIdList).movieInfos(movieInfos).nextScrollId(1L).build();
  93.         }
  94.         if (moviesConditions.getScrollId() == 1) {
  95.             for (int i = 6; i <= moviesConditions.getPageSize() + 5; i++) {
  96.                 movieIdList.add((long) i);
  97.                 movieInfos.add(MovieInfo.builder()
  98.                         .id((long) i)
  99.                         .name("张彦峰喜欢的电影" + i)
  100.                         .desc(descWords.get(i))
  101.                         .actor("张彦峰")
  102.                         .director("张彦峰")
  103.                         .belong(2)
  104.                         .score(new Random().nextInt(10) % (10 - i + 1) + i).build());
  105.             }
  106.         }
  107.         return MoviesResult.builder().total(5).movieIdList(movieIdList).movieInfos(movieInfos).nextScrollId(-1L).build();
  108.     }
  109.  
  110.     /**
  111.      * ID信息合法性:必须为正整数
  112.      *
  113.      * @param id id信息
  114.      * @return true-合法；false-非法
  115.      */
  116.     public static boolean checkPosInteger(Integer id) {
  117.         return null != id && id > 0L;
  118.     }
  119.  
  120.  
  121. }

测试及展示

测试代码

  1. package org.zyf.javabasic.designpatterns.strategy.template.thrift;
  2.  
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.junit.Test;
  5. import org.junit.runner.RunWith;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.boot.test.context.SpringBootTest;
  8. import org.springframework.test.context.junit4.SpringRunner;
  9. import org.zyf.javabasic.ZYFApplication;
  10.  
  11. import java.util.List;
  12.  
  13. /**
  14.  * @author yanfengzhang
  15.  * @description 测试按页获取远程数据
  16.  * @date 2022/3/20  17:21
  17.  */
  18. @RunWith(SpringRunner.class)
  19. @SpringBootTest(classes = ZYFApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
  20. @Slf4j
  21. public class ThriftInvokeCommandTest {
  22.  
  23.     @Autowired
  24.     private MoviesInfoThriftService moviesInfoThriftService;
  25.  
  26.     @Test
  27.     public void testGetMoviesByCondition() {
  28.         log.info("测试分页获取数据：");
  29.         MoviesConditions moviesConditions1 = MoviesConditions.builder()
  30.                 .pageNo(1)
  31.                 .pageSize(2)
  32.                 .build();
  33.         List movieBasicInfos1 = new GetMoviesByConditionPage(moviesConditions1, moviesInfoThriftService)
  34.                 .setPageSize(5)
  35.                 .setSleepMs(100)
  36.                 .getResult();
  37.  
  38.         log.info("按实际条件返回的基本结果为：{}", movieBasicInfos1);
  39.  
  40.         log.info("测试滚动获取数据：");
  41.         MoviesConditions moviesConditions2 = MoviesConditions.builder()
  42.                 .pageNo(1)
  43.                 .pageSize(2)
  44.                 .scrollId(0L)
  45.                 .build();
  46.         List movieBasicInfos2 = new GetMoviesByConditionScroll(moviesConditions2, moviesInfoThriftService)
  47.                 .setPageSize(5)
  48.                 .setSleepMs(100)
  49.                 .getResult();
  50.  
  51.         log.info("按实际条件返回的基本结果为：{}", movieBasicInfos2);
  52.     }
  53. }
文章知识点与官方知识档案匹配，可进一步学习相关知识
Java技能树首页概览148946 人正在系统学习中
注：本文转载自blog.csdn.net的张彦峰ZYF的文章"https://zyfcodes.blog.csdn.net/article/details/123619576"。版权归原作者所有，此博客不拥有其著作权，亦不承担相应法律责任。如有侵权，请联系我们删除。
复制链接
相关推荐
发表评论

评论记录：

未查询到任何数据！