首页 > 代码库 > 使用ServiceLoader辅助责任链模式
使用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
使用ServiceLoader辅助责任链模式
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。