pipeline设计模式

管道是用链表实现的，注意头结点设为null，这样做是为了方便插入节点。

这种思想在很多地方都有体现，如AbstractQueuedSynchronizer（抽象的队列同步器）。缩写aqs，它是JUC的基础。

每个任务都有handler来执行一个handler方法来执行这个任务。
pipeline模式将各个业务之间解耦了，每个handler只需要关注它自己的任务即可，不需要关注上一个任务的执行过程。
如果再增加一个任务，只需要再增加一个handler即可。

注意事项

阀⻔的实现分两种，即普通阀⻔和尾阀⻔。普通阀⻔在处理完⾃⼰的事情之后，必须调⽤
getNext.exec(s)⽅法，也就是交给下⼀个阀⻔处理；⽽尾阀⻔不⽤调⽤这个⽅法，因为它是结束
的那个阀⻔。
流⽔线实现类的主要逻辑在addFirst和addLast，它持有⼀个头阀⻔和⼀个尾阀⻔，它按照添加阀
⻔顺序的⽅式构造阀⻔链表，按照队列的形式，决定调⽤的先后顺序
Pipeline的深度:Pipeline中handler的个数被称作Pipeline的深度。所以我们在⽤Pipeline的深度与
JVM宿主机的CPU个数间的关系。如果Pipeline实例所处的任务多属于CPU密集⾏，那么深度最好
不超过Ncpu。如果Pipeline所处理的任务多属于I/O密集型，那么Pipeline的深度最好不要超过
2*Ncpu。

总结⼀下Pipeline模式的优点，如下：
1、降低耦合度。它将请求的发送者和接收者解耦。
2、简化了Handler处理器。使得处理器不需要知道链的结构。也就是Handler处理器可以是⽆状态的。
与责任链（流⽔线）相关的状态，交给了Context去维护。
3、增强给对象指派职责的灵活性。通过改变链内的成员或者调动它们的次序，允许动态地新增或者删
除责任。
4、增加新的请求处理器很⽅便。

来看一下pipeline设计模式在订单模块中的应用:
TransOutboundInvoker（管道接口）：

package com.mall.order.biz;import com.mall.order.biz.context.TransHandlerContext;/***  ciggar* create-date: 2019/8/2-下午9:58*/
public interface TransOutboundInvoker {/*** 启动流程.<br/>**/void start();/*** 终止流程.<br/>**/void shutdown();/*** 用于获取返回值<br/>** @return*/<T extends TransHandlerContext> T getContext();
}

TransPipeline：

package com.mall.order.biz.handler;/*** Created by ciggar on 2019/8/2.*/import com.mall.order.biz.TransOutboundInvoker;/***  ciggar* create-date: 2019/8/2-下午9:58*/
public interface TransPipeline extends TransOutboundInvoker {/**** @param handlers*/void addFirst(TransHandler... handlers);/**** @param handlers*/void addLast(TransHandler ... handlers);
}

DefaultTransPipeline（管道对象的实现）：

package com.mall.order.biz.handler;/*** Created by ciggar on 2019/8/2.*/import com.mall.order.biz.context.TransHandlerContext;
import lombok.extern.slf4j.Slf4j;/***  ciggar* create-date: 2019/8/2-下午10:37*/
@Slf4j
public class DefaultTransPipeline implements TransPipeline{private TransHandlerNode tail;private TransHandlerNode head = new TransHandlerNode();private TransHandlerContext context = null;public DefaultTransPipeline(TransHandlerContext context) {setContext(context);tail = head;}@Overridepublic void addFirst(TransHandler... handlers) {TransHandlerNode pre = head.getNext();for (TransHandler handler : handlers) {if(handler == null) {continue;}TransHandlerNode node = new TransHandlerNode();node.setHandler(handler);node.setNext(pre);pre = node;}head.setNext(pre);}@Overridepublic void addLast(TransHandler... handlers) {TransHandlerNode next = tail;for (TransHandler handler : handlers) {if(handler == null) {continue;}TransHandlerNode node = new TransHandlerNode();node.setHandler(handler);next.setNext(node);next = node;}tail = next;}@Overridepublic void start() {try {head.getNext().exec(getContext());} catch (Exception ex) {log.error("pipeline系统运行异常.", ex);throw ex;}}@Overridepublic void shutdown() {;}@Overridepublic <T extends TransHandlerContext> T getContext() {return (T)context;}public void setContext(TransHandlerContext context) {this.context = context;}
}

在创建订单的时候使用到了pipeline模式：
OrderServiceImpl：

 public CreateOrderResponse createOrder(CreateOrderRequest request) {CreateOrderResponse response = new CreateOrderResponse();try {//创建pipeline对象TransOutboundInvoker invoker = orderProcessPipelineFactory.build(request);//启动pipelineinvoker.start(); //启动流程（pipeline来处理）//获取处理结果AbsTransHandlerContext context = invoker.getContext();//把处理结果转换为responseresponse = (CreateOrderResponse) context.getConvert().convertCtx2Respond(context);response.setCode(OrderRetCode.SUCCESS.getCode());response.setMsg("success");} catch (Exception e) {log.error("OrderCoreServiceImpl.createOrder Occur Exception :" + e);ExceptionProcessorUtils.wrapperHandlerException(response, e);response.setCode(OrderRetCode.DB_EXCEPTION.getCode());return response;}return response;}

对照pdf一起看。

pipeline设计模式相关推荐

[设计模式] Pipeline 设计模式
深析Pipeline设计模式 - 知乎目标通过提供初始输入并传递处理后的输出以供下一阶段使用,从而允许在一系列阶段中进行数据处理. 解释Pipeline模式为管道模式,也称为流水线模式.通过预先设定好 ...
Pipeline 设计模式的优缺点和实践案例
作者:明明如月学长, CSDN 博客专家,蚂蚁集团高级 Java 工程师,<性能优化方法论>作者.<解锁大厂思维:剖析<阿里巴巴Java开发手册>>.<再学经 ...
Laravel 中管道设计模式的使用 —— 中间件实现原理探究
所谓管道(Pipeline)设计模式就是将会数据传递到一个任务序列中,管道扮演者流水线的角色,数据在这里被处理然后传递到下一个步骤. 使用管道使用很多好处的,尤其是在单个任务中编写复杂处理代码时管道为 ...
十二种常见设计模式代码详解
零:设计模式分类设计模式有创建型模式.结构型模式与行为型模式创建型:单例模式.工厂模式(简单工厂,工厂方法,抽象工厂) 结构型:适配器模式.门面模式.装饰器模式.注册树模式.代理模式.管道模式行 ...
腾讯新闻基于Flink PipeLine模式的实践
本文作者:腾讯新闻商业化数据高级工程师罗强摘要随着社会消费模式以及经济形态的发展变化,将催生新的商业模式.腾讯新闻作为一款集游戏.教育.电商等一体的新闻资讯平台.服务亿万用户,业务应用多.数 ...
腾讯新闻基于 Flink PipeLine 模式的实践
摘要: 随着社会消费模式以及经济形态的发展变化,将催生新的商业模式.腾讯新闻作为一款集游戏.教育.电商等一体的新闻资讯平台.服务亿万用户,业务应用多.数据量大.加之业务增长.场景更加复杂,业务对 ...
Netty 源码（ChannelHandler 死磕）
精进篇:netty源码死磕5 - 揭开 ChannelHandler 的神秘面纱目录 1. 前言 2. Handler在经典Reactor中的角色 3. Handler在Netty中的坐标位置 4 ...
揭开netty神秘面纱_Netty 源码（ChannelHandler 死磕）
疯狂创客圈经典图书 : <Netty Zookeeper Redis 高并发实战> 面试必备 + 面试必备 + 面试必备疯狂创客圈经典图书 : <SpringC ...
八戒科技服务技术负责人鸿鹄真人：做好技术负责人的4个关键特质
作者简介猪八戒网后端技术委员成员&八戒科技服务技术负责人,中国商业联合会互联网协会智库顾问.国家软考高级系统架构师.国家软考高级系统分析师.TOGAF企业架构认证.国家软考系统集成项目经理. ...

pipeline设计模式

pipeline设计模式相关推荐

最新文章

热门文章