当前位置:   article > 正文

Spring设计模式-实战篇之责任链模式_spring 责任链

spring 责任链

什么是责任链模式?  

        责任链模式是一种行为设计模式,它允许你创建一系列对象,使每个对象都有机会处理请求。在该模式中,请求沿着对象链传递,直到最后一个责任链对象为止,责任链模式包括以下几个要点:

  1. Handler 接口:定义了处理请求的接口,通常包含一个处理请求的方法。

  2. ConcreteHandler 具体处理者类:实现了处理请求的方法,并决定是否自行处理请求或将请求传递给下一个处理者。

  3. Client 客户端:创建责任链,并将请求发送到链中的第一个处理者。

在 Spring 框架中,责任链模式经常被用于实现过滤器、拦截器等功能,例如在 Spring Security 中就有一个基于责任链模式的安全过滤器链。

责任链模式在项目中可以用来做什么?

  1. 校验用户的权限:token权限、URL权限、是否已经被管理员禁用;
  2. 校验短信的数据是否手机号码在黑名单里、参数是否合法、平台的短信功能是否开启

  3. 支付回调验签、订单状态更新、发送通知告知用户支付成功、统计订单支付成功数量、金额。

下面演示一个使用了责任链模式进行支付回调的案例

同样以:验签、订单状态更新、发送通知告知用户支付成功、统计订单支付成功数量、金额这几个步骤进行拆分,每个步骤都是一个链条,具体代码如下:

1、定义支付回调上下文类,用于获取各个阶段的结果,即是否处理成功;

  1. // 支付回调上下文类
  2. @Data
  3. class PaymentCallbackContext {
  4. // 签名是否有效
  5. private boolean signatureValid;
  6. // 订单状态是否更新
  7. private boolean orderStatusUpdated;
  8. // 通知是否发送
  9. private boolean notificationSent;
  10. public boolean isSignatureValid() {
  11. return signatureValid;
  12. }
  13. public boolean isOrderStatusUpdated() {
  14. return orderStatusUpdated;
  15. }
  16. public boolean isNotificationSent() {
  17. return notificationSent;
  18. }
  19. }

2、定义支付回调接口,后面每一个流程都需要实现这个接口

  1. // 支付回调处理
  2. public interface PaymentCallbackHandler {
  3. // 设置下一个责任链
  4. void setNext(PaymentCallbackHandler handler);
  5. // 方法处理
  6. void handle(PaymentCallbackContext context);
  7. }

3、验签处理,一般通过特定的算法和公钥进行加密对比验证

  1. /**
  2. * 验签处理
  3. */
  4. @Data
  5. public class SignatureValidator implements PaymentCallbackHandler {
  6. private PaymentCallbackHandler nextHandler;
  7. @Override
  8. public void setNext(PaymentCallbackHandler handler) {
  9. this.nextHandler = handler;
  10. }
  11. @Override
  12. public void handle(PaymentCallbackContext context) {
  13. System.out.println("验证签名...");
  14. // 验签逻辑
  15. context.setSignatureValid(true);
  16. // 传递给下一个处理器
  17. PaymentCallbackHandler nextHandler = new OrderStatusUpdater();
  18. nextHandler.handle(context);
  19. }
  20. }

4、下一个执行链:更新订单状态处理

  1. /**
  2. * 订单状态更新
  3. */
  4. @Data
  5. public class OrderStatusUpdater implements PaymentCallbackHandler {
  6. private PaymentCallbackHandler nextHandler;
  7. @Override
  8. public void setNext(PaymentCallbackHandler handler) {
  9. this.nextHandler = handler;
  10. }
  11. @Override
  12. public void handle(PaymentCallbackContext context) {
  13. if (context.isSignatureValid()) {
  14. System.out.println("更新订单状态...");
  15. // 更新订单状态逻辑
  16. context.setOrderStatusUpdated(true);
  17. // 传递给下一个处理器
  18. if (nextHandler != null) {
  19. nextHandler.handle(context);
  20. }
  21. } else {
  22. System.out.println("验签未通过,无法更新订单状态。");
  23. }
  24. }
  25. }

5、下一个执行链:发送通知,告知用户支付成功

  1. /**
  2. * 发送通知处理器
  3. */
  4. @Data
  5. public class NotificationSender implements PaymentCallbackHandler {
  6. private PaymentCallbackHandler nextHandler;
  7. @Override
  8. public void setNext(PaymentCallbackHandler handler) {
  9. this.nextHandler = handler;
  10. }
  11. @Override
  12. public void handle(PaymentCallbackContext context) {
  13. if (context.isOrderStatusUpdated()) {
  14. System.out.println("发送支付成功通知...");
  15. // 发送通知逻辑
  16. context.setNotificationSent(true);
  17. } else {
  18. System.out.println("订单状态未更新,无法发送通知。");
  19. }
  20. }
  21. }

6、下一个执行链:统计订单支付成功的数量和金额

  1. /**
  2. * 实现统计处理器
  3. */
  4. @Data
  5. public class StatisticsCollector implements PaymentCallbackHandler {
  6. private PaymentCallbackHandler nextHandler;
  7. @Override
  8. public void setNext(PaymentCallbackHandler handler) {
  9. this.nextHandler = handler;
  10. }
  11. @Override
  12. public void handle(PaymentCallbackContext context) {
  13. if (context.isNotificationSent()) {
  14. System.out.println("统计订单支付成功数量和金额...");
  15. // 统计逻辑
  16. } else {
  17. System.out.println("未发送通知,无法统计订单信息。");
  18. }
  19. }
  20. }

7、最后,进行测试,指定各个链条之间的顺序,调用第一个责任链即可,它就会自动执行后续的责任链,代码如下:

  1. public class test {
  2. public static void main(String[] args) {
  3. new test().startPaymentCallback();
  4. }
  5. private void startPaymentCallback() {
  6. // 创建处理器实例
  7. PaymentCallbackHandler signatureValidator = new SignatureValidator();
  8. PaymentCallbackHandler orderStatusUpdater = new OrderStatusUpdater();
  9. PaymentCallbackHandler notificationSender = new NotificationSender();
  10. PaymentCallbackHandler statisticsCollector = new StatisticsCollector();
  11. // 构建责任链
  12. signatureValidator.setNext(orderStatusUpdater);
  13. orderStatusUpdater.setNext(notificationSender);
  14. notificationSender.setNext(statisticsCollector);
  15. // 执行责任链
  16. signatureValidator.handle(new PaymentCallbackContext());
  17. }
  18. }

总结

将支付回调的各个步骤使用责任链模式进行拆分以后,有很多优点:

  1. 解耦合:你无需关注你的下一个链条是如何实现的,只需要把自己的模块实现好即可,并且链条之间的顺序可以随意切换,在构建责任链时指定Next即可,无需去各个实现类中进行修改代码;
  2. 高可扩展性:当需要新增加或者修改支付回调处理的步骤时,可以通过添加新的处理器来实现,而无需修改已有的代码。
  3. 提高可读性:每一个步骤的实现代码都在独立的类中实现,这样可以更容易地理解和调试代码,不像很多业务代码一样,一大堆业务处理逻辑放在一个方法里面调来调去,很容易搞迷糊。

但是他也有一些注意事项,如下:

  1. 可能造成循环调用: 如果责任链的 setNext() 设置不当,就可能会导致循环调用,栈溢出StackOverFlow;

  2. 不一定适合所有情况: 责任链模式可以提高系统的灵活性和可扩展性,但是会增加代码的复杂性和代码量。在一些简单的场景下,使用责任链模式可能会显得过于复杂,也没必要;

  3. 适合场景:整体的业务流程场景较为复杂,并且每个步骤之间都是有序的,需要根据不同的条件选择不同的处理流程时,责任链模式可以提供一种灵活的解决方案。

ps:以下是我整理的java面试资料,感兴趣的可以看看。最后,创作不易,觉得写得不错的可以点点关注!

链接:https://www.yuque.com/u39298356/uu4hxh?# 《Java面试宝典》 

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/我家小花儿/article/detail/497897
推荐阅读
相关标签
  

闽ICP备14008679号