java pipeline

java pipeline是什么，让我们一起了解一下？

pipeline又称为管道，是一种在计算机普遍使用的技术。在分布式处理领域，由于管道模式是数据驱动，而目前流行的Spark分布式处理平台也是数据驱动的，两者非常合拍，于是在spark的新的api里面pipeline模式得到了广泛的应用。还有java web中的struct的filter、netty的pipeline，无处不见pipeline模式。

管道模式设计其实和责任链模式很像，都是按照顺序往下执行不同的方法，管道只是负责顺序执行，不管是否执行不同方法。

管道入口：

Map context = new HashMap<>();
                context.put("BusinessType", BusinessType.CREDIT_FLOW.getBusinessType());
                context.put("CheckType", CertificateBusinessTypeEnum.THREE_ELEMENTS.name());
                context.put("ZaUser", user);
                context.put("RequestParam", relavants);
                //管道入口
                context = certificateElementService.checkAdmittance(context);
                JSONObject jsonObject = (JSONObject) context.get("ResponseParam");

AaaThreeElementsCheckValve 的实现：

@Component("aaaThreeElementsCheckValve")
public class AaaThreeElementsCheckValve extends AbstractLogableValve {
 
    @Autowired
    private ICodeLibraryService codeLibraryService;
    @Autowired
    private IJunYuCertificateService junYuCertificateService;
 
    @Override
    public void handle(Map context, ValveChain chain) throws I18NSupportException {
        String checkType = context.get("CheckType").toString();
        //aaa的校验不通过,直接执行下一个
        if (!Objects.equals(CertificateBusinessTypeEnum.THREE_ELEMENTS.name(), checkType)) {
            chain.handleNext(context);
        }
        //执行aaa的代码逻辑
         if (Objects.equals(CertificateResponseLevelEnum.FORBIDDEN.getCode(), finalLevel)) {
            //aaa处理了请求,返回
                return;
          }
            //放开,让bbb去处理
            chain.handleNext(context);
        } catch (Exception e) {
            logger.error("骏聿三要素接口异常：", e);
            I18NSupportException.Builder builder = new I18NSupportException.Builder();
            builder.setTargetObject(this);
            builder.setMessage(e.getMessage());
            throw builder.build();
        }
    }
}

BbbThreeElementsCheckValve 的实现：

@Component("bbbThreeElementsCheckValve")
public class BbbThreeElementsCheckValve extends AbstractLogableValve {
 
    @Autowired
    private ICodeLibraryService codeLibraryService;
    @Autowired
    private IShuJuBaoCreditService shuJuBaoCreditService;
 
    @Override
    public void handle(Map context, ValveChain chain) throws I18NSupportException {
 
        JSONObject jsonObject = (JSONObject) context.get("ResponseParam");
        if (Objects.equals(Integer.valueOf(jsonObject.get(WebUtil.JSON_RESULT_STATUS_CODE).toString()), WebUtil.ERROR)) {
            //aaa三要素接口已强控，因此不继续调用bbb三要素接口,也不调用后续阀门进行校验
        } else {
            ZaUser user = (ZaUser) context.get("ZaUser");
            Object requestParam = context.get("RequestParam");
            List relavants = JSON.parseArray(JSON.toJSONString(requestParam), CustomerCreditRelavant.class);
            CodeLibrary codeLibrary = codeLibraryService.queryLibraryNoException("shujubaoCompanyIdAndCobankId", user.getCompanyId() + "-" + relavants.get(0).getInquryBankId());
            if (Objects.nonNull(codeLibrary)) {
                String s = shuJuBaoCreditService.sjbThreeElmentVerify(relavants);
                if (StringUtils.isNotBlank(s)) {
                    jsonObject.put(WebUtil.JSON_RESULT_STATUS_CODE, WebUtil.ERROR);
                    jsonObject.put(WebUtil.JSON_RESULT_DATA, JSONObject.toJSONString(s));
                }
            }else{
                //bbb三要素校验通过，调用后续阀门进行校验
                chain.handleNext(context);
            }
        }
    }
}

以上就是小编今天的分享了，希望可以帮助到大家。