zoukankan      html  css  js  c++  java
  • 使用ServiceLoader辅助责任链模式

     在项目中,常常会遇到这么一种场景,即对一批/一种/一堆数据,进行链式的处理。举个栗子,拿到一个task后,需要对这个task进行校验处理、状态变更处理、计算并回填数据处理等等各种处理,这种情况下,最适合的编码方式就是使用责任链了:

    定义一个taskprocessor接口:

    public interface TaskProcessor {
    
        boolean process(Task task, TaskConfigDTO config);
    
    }
    

    然后,再定义诸多的实现类,来进行处理,可以使代码更加优雅和便于扩展。下一点要考虑的就是在代码中,怎么加载/注入这些实现类呢 ?

    (1)使用spring配置,对List<TaskProcessor> processors这个field字段使用XML注入list。

    (2)使用java.util.ServiceLoader

    在第二种方式下,由于不依赖于任何第三方,更加干净,且个人认为也更加优雅一点点。代码如下:

    @Service
    public class RetryTaskProcessorManager {
    
        private ServiceLoader<TaskProcessor> processors = ServiceLoader.load(TaskProcessor.class);
    
        public void process(Task task, TaskConfigDTO config) {
            for (TaskProcessor processor : processors) {
                boolean result = processor.process(task, config);
                if (!result) {
                    break;
                }
            }
        }
    
    }
    

    同时,需要在resources/META-INF/services/接口全路径名的文件中,输入接口实现类的所有全路径名。如此,也能保证processor的处理顺序。

    com.dianping.vc.retry.service.domain.impl.processor.task.TaskStatusProcessor
    com.dianping.vc.retry.service.domain.impl.processor.task.MaxRetryCountProcessor
    com.dianping.vc.retry.service.domain.impl.processor.task.NextExecuteTimeProcessor
    
  • 相关阅读:
    杭电 1548 A strange lift(广搜)
    JAVA数组的定义及用法
    WPF之Binding深入探讨
    FBReaderJ源代码编译配置
    【剑指offer】合并两有序单链表
    对HGE游戏引擎的一次封装
    WAV文件格式分析
    Ubuntu9.04更新源
    内核及内核模块
    java实现第七届蓝桥杯愤怒小鸟
  • 原文地址:https://www.cnblogs.com/dosmile/p/6560421.html
Copyright © 2011-2022 走看看