首页 > 其他 > 详细

ServiceLoader

时间:2018-04-30 21:58:49      阅读:234      评论:0      收藏:0      [点我收藏+]

  先从业务场景分析,要完成数据的分析处理功能。根据数据的不同种类,先调用groovy或者python脚本等中的一种处理数据,处理完数据的后需要流程相同。

  要支持处理能力的动态扩展,也就是框架完成后,可以再增加新的处理能力,而不改变原有的代码。如要增加el处理数据的能力。

  这时ServiceLoader可以方便的完成需求。

 

  先看所需的模块。groovy,python模块是具体的处理模块。plat模块使用ServiceLoader调用groovy或者python模块,再完成后续处理。pon模块是一个业务测试模块

  技术分享图片

  先看plat模块中的接口类IService:

package com.service;

public interface IService {
    String getService();

    String handle();
}

  DataProcess类,ServiceLoader调用groovy或者python模块:

package com;

import com.service.IService;
import java.util.ServiceLoader;

public class DataProcess {public IService getService(String name) {
        IService properService = null;
        ServiceLoader<IService> serviceLoader = ServiceLoader.load(IService.class);
        for (IService service : serviceLoader) {
            if (service.getService().equalsIgnoreCase(name)) {
                properService=  service;
            }
        }
        return  properService;
    }

}

  GroovyService,使用groovy处理数据的示例代码:

package com;

import com.service.IService;

public class GroovyService implements IService {

    public String getService() {
        return "groovy";
    }

    public String handle() {
        return "groovy handle data";
    }

}

  groovy模块下的resources下,要有META-INF\services\com.service.IService文件,内容如下:

com.GroovyService

  

  再看业务测试模块pon下的测试类:

package com.pon;

import com.GroovyService;
import com.PythonService;
import com.DataProcess;

public class TestProcess {
    public static void main(String[] args) {
        DataProcess process = new DataProcess();
        GroovyService groovyService = (GroovyService) process.getService("groovy");
        PythonService pythonservice = (PythonService) process.getService("python");
        System.out.println(groovyService.handle());
        System.out.println(pythonservice.handle());
    }
}

  测试的结果为:

技术分享图片

  需要增加el处理能力时,新增el模块,plat模块的处理不需要改变。

 

  ServiceLoader会classpath下的jar包,分析META-INF/services中放置提供者配置文件来标识服务提供者。看看pon模块的依赖。

 技术分享图片

  

  Hadoop FileSystem就是通过这个机制来根据不同文件的scheme来返回不同的FileSystem。

private static void loadFileSystems() {  

  synchronized(FileSystem.class){  

    if(!FILE_SYSTEMS_LOADED) {  

      ServiceLoader<FileSystem> serviceLoader = ServiceLoader.load(FileSystem.class); 

      for(FileSystem fs : serviceLoader) {  

        SERVICE_FILE_SYSTEMS.put(fs.getScheme(),fs.getClass());  

      } 

      FILE_SYSTEMS_LOADED= true; 

    } 

  } 

}

  对应的配置文件:

org.apache.hadoop.fs.LocalFileSystem 

org.apache.hadoop.fs.viewfs.ViewFileSystem 

org.apache.hadoop.fs.s3.S3FileSystem 

org.apache.hadoop.fs.s3native.NativeS3FileSystem 

org.apache.hadoop.fs.kfs.KosmosFileSystem 

org.apache.hadoop.fs.ftp.FTPFileSystem 

org.apache.hadoop.fs.HarFileSystem

  可以看到FileSystem会把所有的FileSystem的实现都以scheme和class来cache,之后就从这个cache中取相应的值。因此,以后可以通过ServiceLoader来实现一些类似的功能,而不用依赖像Spring这样的第三方框架。

  

   

ServiceLoader

原文:https://www.cnblogs.com/lnlvinso/p/8974736.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!