Java责任链模式:优雅解耦系统处理流程,实现高效灵活的请求处理与分发(下)

简介: Java责任链模式:优雅解耦系统处理流程,实现高效灵活的请求处理与分发

3.4 优化方式:使用AOP实现责任链模式

如前所述,在传统的责任链模式实现中,每个处理节点的实现都需要定义一个独立的类,从而增加了代码量和维护难度。为了简化实现,可以使用面向切面编程(AOP)来实现责任链模式。

在AOP中,可以使用切面来定义责任链模式中每个节点的处理逻辑,并将这些切面连接成一个链式结构。当需要进行请求处理时,只需要按顺序将这些切面逐个执行,就可以实现责任链模式的功能。

使用AOP可以避免定义大量的类文件,简化代码实现,同时也提高了代码的执行效率。此外,AOP还提供了更加灵活的配置方式,可以根据业务需求对责任链结构进行动态配置,支持动态增加、删除节点对象。由此,AOP实现的责任链模式具有更高的可扩展性和灵活性。

示例代码:

// 定义切面,定义每个节点的处理逻辑  
@Aspect  
public class Responsibilities {  
    // 定义处理请求的切入点  
    @Pointcut("execution(* com.example.Application.*(..))")  
    public void handleRequest() {  
        // 声明需要执行的切面方法  
        @Before("handleRequest()")  
        public void beforeHandleRequest(JoinPoint joinPoint) {  
            // 获取请求对象  
            Request request = (Request) joinPoint.getArgs()[0];  
            // 执行前置处理逻辑  
            beforeHandleRequest(request);  
            // 执行处理逻辑  
            handleRequest(request);  
            // 执行后置处理逻辑  
            afterHandleRequest(request);  
        }  
    }  
    // 定义处理前置处理逻辑的切面方法  
    @Before("handleRequest()")  
    public void beforeHandleRequest(Request request) {  
        // 执行前置处理逻辑  
        // ...  
    }  
    // 定义处理后置处理逻辑的切面方法  
    @After("handleRequest()")  
    public void afterHandleRequest(Request request) {  
        // 执行后置处理逻辑  
        // ...  
    }  
}
// 定义请求处理类,实现责任链模式  
public class Request {  
    // 处理请求的逻辑  
    public void handleRequest() {  
        // 执行处理逻辑  
        // ...  
    }  
    // 前置处理逻辑  
    public void beforeHandleRequest(Request request) {  
        // 执行前置处理逻辑  
        // ...  
    }  
    // 后置处理逻辑  
    public void afterHandleRequest(Request request) {  
        // 执行后置处理逻辑  
        // ...  
    }  
}
// 应用上下文,声明需要执行的责任链  
@ApplicationContext  
public class ApplicationContext {  
    // 声明需要执行的责任链  
    @Autowired  
    private ResponsibilitiesResponsibilities;  
    // 处理请求的方法  
    public void handleRequest(Request request) {  
        Responsibilities.beforeHandleRequest(request);  
        request.handleRequest();  
        Responsibilities.afterHandleRequest(request);  
    }  
}

在上面的示例代码中,Responsibilities类是切面类,它定义了每个节点的处理逻辑。handleRequest()方法是请求处理类实现的处理方法,它实现了责任链模式的核心功能。beforeHandleRequest()afterHandleRequest()方法是前置处理逻辑和后置处理逻辑,它们被注入到请求处理类中,以便在请求处理类中调用。

四、责任链模式的注意事项

4.1 存在循环调用的风险

在实现责任链模式时,需要注意节点之间的循环调用,避免出现死循环的情况。

循环调用的风险通常出现在两种情况下:一是责任链节点自身会对请求进行多次处理,从而形成死循环;二是责任链节点之间相互调用,出现互相调用的情况。

为了避免循环调用的风险,需要对责任链节点的处理逻辑进行严格的控制和规范,确保节点的处理逻辑只能一次性地对请求进行处理,并且不会出现相互调用的情况。

另外,可以通过设置最大处理次数或者设置超时时间等机制来防止出现死循环,从而避免对系统的影响。

4.2 确定责任链顶端和底端

在实现责任链模式时,需要确定责任链的顶端和底端,以确保请求能够被正确地传递和处理。

责任链的顶端一般是由客户端发起请求的地方,底端则是链的末尾,即最后一个节点的处理逻辑。

在确定责任链的顶端和底端时,需要考虑业务需求和系统结构,避免出现环状结构或节点缺失的情况。

如果责任链没有明确的顶端和底端,则会出现请求无法被正确处理的情况,从而影响系统的正常运行。因此,在实现责任链模式时,需要对节点的逻辑和业务流程进行仔细的分析和设计,并合理地确定责任链的顶端和底端。

五、责任链模式的例子

5.1 实例:多个银行卡支付问题

假设有一个在线支付系统,用户可以选择使用多个银行卡中的任意一张,但是每个银行卡都有不同的支付限制,如下所示:

  • 银行卡A支付限制:每次支付金额不超过500元;
  • 银行卡B支付限制:每日支付金额不超过2000元;
  • 银行卡C支付限制:每月支付金额不超过10000元。

如果用户选择的银行卡支付限制不符合要求,则无法完成支付。为了解决这个问题,可以使用责任链模式,创建一个银行卡支付处理链,根据银行卡的支付限制依次进行处理,直到找到可以完成支付的银行卡。

代码实现:

首先,定义银行卡处理器接口和抽象类。银行卡处理器接口包含一个处理方法,用于判断当前银行卡是否可以完成支付;抽象类实现了银行卡处理器接口,并提供了一个链式处理器的引用,以及一个设置下一个处理器的方法。

public interface BankCardHandler {
    boolean canPay(int amount);
}
public abstract class AbstractBankCardHandler implements BankCardHandler {
    private BankCardHandler nextHandler;
    public BankCardHandler setNextHandler(BankCardHandler handler) {
        this.nextHandler = handler;
        return nextHandler;
    }
    public boolean canPay(int amount) {
        if (check(amount)) {
            return true;
        } else if (nextHandler != null) {
            return nextHandler.canPay(amount);
        } else {
            return false;
        }
    }
    protected abstract boolean check(int amount);
}

然后,创建三个具体的银行卡处理器类,分别处理上述三个场景:

public class BankCardAHandler extends AbstractBankCardHandler {
    protected boolean check(int amount) {
        return amount <= 500;
    }
}
public class BankCardBHandler extends AbstractBankCardHandler {
    private int dailyLimit;
    public BankCardBHandler(int dailyLimit) {
        this.dailyLimit = dailyLimit;
    }
    protected boolean check(int amount) {
        return amount <= dailyLimit;
    }
}
public class BankCardCHandler extends AbstractBankCardHandler {
    private int monthlyLimit;
    public BankCardCHandler(int monthlyLimit) {
        this.monthlyLimit = monthlyLimit;
    }
    protected boolean check(int amount) {
        return amount <= monthlyLimit;
    }
}

最后,组合银行卡处理器类,形成一个处理链:

public class BankCardPayment {
    private BankCardHandler handlerChain;
    public BankCardPayment() {
        handlerChain = new BankCardAHandler();
        handlerChain.setNextHandler(new BankCardBHandler(2000))
            .setNextHandler(new BankCardCHandler(10000));
    }
    public boolean pay(int amount) {
        return handlerChain.canPay(amount);
    }
}

在客户端代码中,创建一个银行卡支付实例,根据用户输入的支付金额进行支付操作:

BankCardPayment payment = new BankCardPayment();
if (payment.pay(300)) {
    System.out.println("支付成功!");
} else {
    System.out.println("支付失败,金额超过所有银行卡的限制!");
}

5.2 实例:Java Web过滤器

Java Web过滤器用于拦截Web请求并对它们进行相应的处理,它可以对特定的请求进行过滤、修改它们的参数、检查用户权限等。下面是一个简单的Java Web过滤器示例,对其代码进行详细说明:

首先,我们需要创建一个实现Filter接口的Java类:

public class MyFilter implements Filter {
  @Override
  public void init(FilterConfig filterConfig) throws ServletException {
    // 初始化代码
  }
  @Override
  public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
    // 过滤代码
    chain.doFilter(request, response); // 继续执行其他过滤器或Servlet
  }
  @Override
  public void destroy() {
    // 清理资源代码
  }
}

上面的代码中,我们实现了Filter接口中的三个方法:

  • init方法:在过滤器被初始化时被调用。在这个方法中,我们可以进行一些初始化工作(例如读取配置文件或建立数据库连接等)。
  • doFilter方法:这是过滤器最重要的方法,它会对请求进行过滤处理。我们可以在这个方法中检查请求参数、修改请求或响应数据、检查用户权限等。如果需要,我们还可以使用FilterChain的doFilter方法,将请求传递给链中的下一个过滤器或最终的Servlet。
  • destroy方法:在过滤器被销毁时被调用。在这个方法中,我们可以进行一些清理操作(例如释放资源或关闭数据库连接等)。

在doFilter方法中,我们可以根据需要对请求进行处理。例如,以下代码将检查请求参数中是否包含名为"username"的参数:

@Override
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
  String username = request.getParameter("username");
  if (username != null) {
    // 对于包含username参数的请求,我们可以进行相应的处理
  }
  chain.doFilter(request, response); // 继续执行其他过滤器或Servlet
}

在实际使用中,我们需要将这个过滤器注册到我们的Web应用程序中。以下是一个简单的web.xml配置示例:

<web-app>
  <filter>
    <filter-name>myFilter</filter-name>
    <filter-class>com.example.MyFilter</filter-class>
  </filter>
  <filter-mapping>
    <filter-name>myFilter</filter-name>
    <url-pattern>/*</url-pattern>
  </filter-mapping>
</web-app>

以上示例将我们的过滤器注册到应用程序中,并将其映射到所有的URL上。这样,每当有请求访问我们的Web应用程序时,过滤器就会被自动调用。

以上是一个简单的Java Web过滤器的实例和说明。尽管这个示例非常简单,但它可以作为你编写更复杂的过滤器的参考。

六、总结与结论

责任链模式是一种行为型设计模式,用于将多个请求处理器对象连接成一条链,可以让请求沿着这条链不断地传递,直到有一个请求处理器处理完成为止。在责任链模式中,每个请求处理器都可以选择将请求进行处理,或将请求转发给下一个请求处理器,从而将系统中的请求处理逻辑进行解耦,使得请求的发送者和接收者之间的关系更加灵活。

责任链模式的实现方式有单向链表实现和集合迭代器实现,优化方式可以使用函数式编程和AOP来简化实现和提高可扩展性。在使用责任链模式时需要注意存在循环调用的风险和确定责任链的顶端和底端。

在实际应用中,责任链模式可以用于银行卡支付、Java Web过滤器等场景。通过使用责任链模式,可以避免代码耦合度过高,增加代码的可维护性和可扩展性,提高系统的效率和灵活性。

目录
相关文章
|
1月前
|
监控 Java API
如何使用Java语言快速开发一套智慧工地系统
使用Java开发智慧工地系统,采用Spring Cloud微服务架构和前后端分离设计,结合MySQL、MongoDB数据库及RESTful API,集成人脸识别、视频监控、设备与环境监测等功能模块,运用Spark/Flink处理大数据,ECharts/AntV G2实现数据可视化,确保系统安全与性能,采用敏捷开发模式,提供详尽文档与用户培训,支持云部署与容器化管理,快速构建高效、灵活的智慧工地解决方案。
|
16天前
|
JSON Java 数据格式
java操作http请求针对不同提交方式(application/json和application/x-www-form-urlencoded)
java操作http请求针对不同提交方式(application/json和application/x-www-form-urlencoded)
67 25
java操作http请求针对不同提交方式(application/json和application/x-www-form-urlencoded)
|
6天前
|
安全 Java API
java如何请求接口然后终止某个线程
通过本文的介绍,您应该能够理解如何在Java中请求接口并根据返回结果终止某个线程。合理使用标志位或 `interrupt`方法可以确保线程的安全终止,而处理好网络请求中的各种异常情况,可以提高程序的稳定性和可靠性。
37 6
|
21天前
|
缓存 监控 Java
Java线程池提交任务流程底层源码与源码解析
【11月更文挑战第30天】嘿,各位技术爱好者们,今天咱们来聊聊Java线程池提交任务的底层源码与源码解析。作为一个资深的Java开发者,我相信你一定对线程池并不陌生。线程池作为并发编程中的一大利器,其重要性不言而喻。今天,我将以对话的方式,带你一步步深入线程池的奥秘,从概述到功能点,再到背景和业务点,最后到底层原理和示例,让你对线程池有一个全新的认识。
50 12
|
21天前
|
设计模式 消息中间件 搜索推荐
Java 设计模式——观察者模式:从优衣库不使用新疆棉事件看系统的动态响应
【11月更文挑战第17天】观察者模式是一种行为设计模式,定义了一对多的依赖关系,使多个观察者对象能直接监听并响应某一主题对象的状态变化。本文介绍了观察者模式的基本概念、商业系统中的应用实例,如优衣库事件中各相关方的动态响应,以及模式的优势和实际系统设计中的应用建议,包括事件驱动架构和消息队列的使用。
|
1月前
|
运维 自然语言处理 供应链
Java云HIS医院管理系统源码 病案管理、医保业务、门诊、住院、电子病历编辑器
通过门诊的申请,或者直接住院登记,通过”护士工作站“分配患者,完成后,进入医生患者列表,医生对应开具”长期医嘱“和”临时医嘱“,并在电子病历中,记录病情。病人出院时,停止长期医嘱,开具出院医嘱。进入出院审核,审核医嘱与住院通过后,病人结清缴费,完成出院。
90 3
|
1月前
|
小程序 前端开发 算法
|
1月前
|
Java 数据库连接 数据库
深入探讨Java连接池技术如何通过复用数据库连接、减少连接建立和断开的开销,从而显著提升系统性能
在Java应用开发中,数据库操作常成为性能瓶颈。本文通过问题解答形式,深入探讨Java连接池技术如何通过复用数据库连接、减少连接建立和断开的开销,从而显著提升系统性能。文章介绍了连接池的优势、选择和使用方法,以及优化配置的技巧。
39 1
|
1月前
|
Java API 开发者
Java如何实现企业微信审批流程
大家好,我是V哥。本文分享如何在企业微信中实现审批流程,通过调用企业微信的开放API完成。主要内容包括获取Access Token、创建审批模板、发起审批流程和查询审批结果。提供了一个Java示例代码,帮助开发者快速上手。希望对你有帮助,关注V哥爱编程,编码路上同行。
|
1月前
|
JavaScript Java 项目管理
Java毕设学习 基于SpringBoot + Vue 的医院管理系统 持续给大家寻找Java毕设学习项目(附源码)
基于SpringBoot + Vue的医院管理系统,涵盖医院、患者、挂号、药物、检查、病床、排班管理和数据分析等功能。开发工具为IDEA和HBuilder X,环境需配置jdk8、Node.js14、MySQL8。文末提供源码下载链接。
下一篇
DataWorks