从Servlet、Dubbo、Mybatis聊聊责任链究竟怎么用
作者:atheva
来源:https://dwz.cn/1TtgW7Ud
责任链模式的定义:使多个对象都有机会处理请求,从而避免请求的发送者和接受者之间的耦合关系, 将这个对象连成一条链,并沿着这条链传递该请求,直到有一个对象处理他为止。这里就不再过多的介绍什么是责任链模式,主要来说说java中如何编写。主要从下面3个框架中的代码中介绍。
servlet中的filter
dubbo中的filter
mybatis中的plugin
servlet中的Filter
servlet中分别定义了一个 Filter和FilterChain的接口,核心代码如下:
public final class ApplicationFilterChain implements FilterChain {private int pos = 0; //当前执行filter的offsetprivate int n; //当前filter的数量private ApplicationFilterConfig[] filters; //filter配置类,通过getFilter()方法获取Filterprivate Servlet servlet@Overridepublic void doFilter(ServletRequest request, ServletResponse response) {if (pos < n) {ApplicationFilterConfig filterConfig = filters[pos++];Filter filter = filterConfig.getFilter();filter.doFilter(request, response, this);} else {// filter都处理完毕后,执行servletservlet.service(request, response);}}}
代码还算简单,结构也比较清晰,定义一个Chain,里面包含了Filter列表和servlet,达到在调用真正servlet之前进行各种filter逻辑。
Dubbo中的Filter
Dubbo在创建Filter的时候是另外一个方法,通过把Filter封装成 Invoker的匿名类,通过链表这样的数据结构来完成责任链,核心代码如下:
private static <T> Invoker<T> buildInvokerChain(final Invoker<T> invoker, String key, String group) {Invoker<T> last = invoker;//只获取满足条件的FilterList<Filter> filters = ExtensionLoader.getExtensionLoader(Filter.class).getActivateExtension(invoker.getUrl(), key, group);if (filters.size() > 0) {for (int i = filters.size() - 1; i >= 0; i --) {final Filter filter = filters.get(i);final Invoker<T> next = last;last = new Invoker<T>() {...public Result invoke(Invocation invocation) throws RpcException {return filter.invoke(next, invocation);}...};}}return last;
}
Dubbo的责任链就没有类似FilterChain这样的类吧Filter和调用Invoker结合起来,而是通过创建一个链表,调用的时候我们只知道第一个节点,每个节点包含了下一个调用的节点信息。 这里的虽然Invoker封装Filter没有显示的指定next,但是通过java匿名类和final的机制达到同样的效果。
Mybatis中的Plugin
Mybatis可以配置各种Plugin,无论是官方提供的还是自己定义的,Plugin和Filter类似,就在执行Sql语句的时候做一些操作。Mybatis的责任链则是通过动态代理的方式,使用Plugin代理实际的Executor类。(这里实际还使用了组合模式,因为Plugin可以嵌套代理),核心代码如下:
public class Plugin implements InvocationHandler{private Object target;private Interceptor interceptor;@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable { if (满足代理条件) {return interceptor.intercept(new Invocation(target, method, args));}return method.invoke(target, args); }//对传入的对象进行代理,可能是实际的Executor类,也可能是Plugin代理类public static Object wrap(Object target, Interceptor interceptor) {Class<?> type = target.getClass();Class<?>[] interfaces = getAllInterfaces(type, signatureMap);if (interfaces.length > 0) {return Proxy.newProxyInstance(type.getClassLoader(),interfaces,new Plugin(target, interceptor, signatureMap));}return target;}
}
简单的示意图如下:
总结
这里简单介绍了Servlet、Dubbo、Mybatis对责任链模式的不同实现手段,其中Servlet是相对比较清晰,又易于实现的方式,而Dubbo和Mybatis则适合在原有代码基础上,增加责任链模式代码改动量最小的。
热门内容:
从零开始搭建创业公司后台技术栈
基于SpringBoot开发一个Restful服务,实现增删改查功能
开发者说:基于 Nacos 的网关灰度路由和服务权重灰度
如何在微服务架构中实现安全性?
Spring Cloud Alibba教程:Sentinel的使用
你的Redis怎么持久化的
Spring Cloud Alibba教程:如何使用Nacos作为配置中心
Spring Cloud Alibaba教程:使用Nacos作为服务注册中心
感谢搓一下“在看”
从Servlet、Dubbo、Mybatis聊聊责任链究竟怎么用相关推荐
- Java 设计模式之责任链模式实现的三种方式
点击上方 "程序员小乐"关注, 星标或置顶一起成长 每天凌晨00点00分, 第一时间与你相约 每日英文 The worst way to miss someone is to be ...
- 面试官:什么是责任链模式?
前言 只有光头才能变强. 文本已收录至我的GitHub精选文章,欢迎Star:https://github.com/ZhongFuCheng3y/3y 最近在看项目代码的时候发现「责任链模式」,于是想 ...
- 用三国演义解读:责任链模式
故事 前两天,没事又刷了一遍三国演义,看到关羽身在曹营心在汉,听说刘备在袁绍那里,然后就上演了"过五关,斩六将". 关羽过五关斩六将主要内容: 第一关,东岭关,斩守将孔秀.东岭关, ...
- 设计模式 - 责任链模式
故事 前两天,没事又刷了一遍三国演义,看到关羽身在曹营心在汉,听说刘备在袁绍那里,然后就上演了"过五关,斩六将". 关羽过五关斩六将主要内容: 第一关,东岭关,斩守将孔秀. 东岭关 ...
- Java设计模式(十七):责任链设计模式
1. 应用场景 一场足球赛,A队的2个组成队a.b.a队踢上半场,踢完后交给b队踢下半场,一起完成这场球赛. 吃一条鱼:妈妈吃鱼头,吃完让儿子吃鱼身体,吃完给爸爸吃鱼尾巴. Servlet容器的过滤器 ...
- 设计模式 | 责任链模式及典型应用
本文的主要内容: 介绍责任链模式 请假流程示例 责任链模式总结 源码分析Tomcat Filter中的责任链模式 责任链模式 一个事件需要经过多个对象处理是一个挺常见的场景,譬如采购审批流程,请假流程 ...
- 巧用『责任链模式』来优化 参数多重校验,非常优雅!
点击上方"芋道源码",选择"设为星标" 管她前浪,还是后浪? 能浪的浪,才是好浪! 每天 10:33 更新文章,每天掉亿点点头发... 源码精品专栏 原创 | ...
- 三国演义:责任链模式
故事 前两天,没事又刷了一遍三国演义,看到关羽身在曹营心在汉,听说刘备在袁绍那里,然后就上演了"过五关,斩六将". 关羽过五关斩六将主要内容: 第一关,东岭关,斩守将孔秀. 东岭关 ...
- 责任链模式在王者荣耀中的应用,妙啊!
点击上方"Java基基",选择"设为星标" 做积极的人,而不是积极废人! 每天 14:00 更新文章,每天掉亿点点头发... 源码精品专栏 原创 | Java ...
最新文章
- 工具推荐:Astah Community 绘制图形
- C++——虚函数(Virtual Member Functions) 【functions语意学】
- 在Win10 Anaconda中安装Tensorflow
- 如何利用云原生技术构建现代化应用?
- 在Linux下使用iconv转换字符串编码
- spark BlockManager如何实现Broadcast广播
- 题目1003:A+B(字符串转数字)
- antd 下拉框怎么联动_Antd的Table组件嵌套Table以及选择框联动操作
- do{}while(0)只执行一次无意义?你可能真的没理解!
- pycharm 远程调试图文_pycharm远程调试openstack的图文教程
- ORACLE LATERAL-SQL-INJECTION 个人见解
- Tomcat源码下载地址
- oracle 模拟 mysql,mysql通过表和function模拟oracle的sequence
- Codevs 3100 蜗牛的旅行
- 水文勘测工比赛计算机基本应用,水文勘测工技能大赛参赛感言
- BPDU网桥协议数据单元和STP生成树协议
- js文字转图片,使用画布绘制
- win10 linux分区大小调整大小,如何在windows系统中调整分区大小(包括windows10/8/7)...
- Linux解压rar压缩文件的详细方法
- java spark 遍历rdd_Spark入门(四):RDD基本操作
热门文章
- 详解javascript: void(0);
- FPGA研发之道(25)-管脚
- [luoguP2618] 数字工程(DP)
- Android Studio 快捷键
- http://bbs.phome.net/showthread-13-45519-0.html
- 创建ASP.NET WEB自定义控件——例程2
- 如何利用 C# 爬取「京东 - 计算机与互联网图书销量榜」!
- 英特尔第三代 Ice Lake 发布正面与 AMD EPYC PK,结果令人大跌眼镜!
- 希捷发布CORTX对象存储软件与开源社区,普惠超大规模数据存储
- 当谈论迭代器时,我谈些什么?