自定义ServicesLoader来实现根据配置使用不通的SPI实现从而实现项目扩展

一 、  都知道Java中的SPI技术，也是dubbo中实验的，

通过这个案例可以快速的了解spi是什么？https://my.oschina.net/lenglingx/blog/879292

这个案例就是直接简单使用的spi，都说dubbo是也是使用spi来做扩展的，去看了一下dubbo的介绍，了解到了：ExtensionLoader.java

且dubbo使用是通过配置来的，如注册协议有，redis,和zookeeper。

这里我们就介绍如何实现通过配置来和spi结合实现dubbo这样的。

二、  这个项目介绍，log-parent,为整体项目，内部有4个项目。

log为api的接口项目

alog为ALog实现

blog为BLog实现

logTest为这个 log的测试项目

log项目的Log接口

package com.tspi.log;public interface Logger {public void debug(String logger);public void info(String logger);public void warn(String logger);public void error(String logger);}

CustomServiceLoader自定义serviceLoader

package com.tspi.log;import java.net.URL;
import java.util.Enumeration;
import java.util.HashMap;
import java.util.Map;import org.apache.commons.io.IOUtils;public class CustomServiceLoader {public static final String MAPPING_CONFIG_PREFIX = "META-INF/services";public static Map mservices;public static <S> Map<String, Class<S>> loade(Class<S> service) throws Exception {String mappingConfigFile = MAPPING_CONFIG_PREFIX + "/log/" + service.getName();// 由于一个接口的实现类可能存在多个jar包中的META-INF目录下，所以下面使用getResources返回一个URL数组System.out.println("configFile:" + mappingConfigFile);Enumeration<URL> configFileUrls = CustomServiceLoader.class.getClassLoader().getResources(mappingConfigFile);if (configFileUrls == null) {return null;}//List<S> services = new LinkedList<S>();mservices = new HashMap<String, Class<S>>();while (configFileUrls.hasMoreElements()) {URL configFileUrl = configFileUrls.nextElement();String configContent = IOUtils.toString(configFileUrl.openStream());System.out.println("configContent:");System.out.println(configContent);System.out.println("configContent  --end");String[] serviceNames = configContent.split("\n");for (String serviceName : serviceNames) {System.out.println("serviceName: " + serviceName);String[] tempServiceName = serviceName.split("=");System.out.println("tmpServiceName:" + tempServiceName[0] + "," +tempServiceName[1]);ClassLoader classLoader = CustomServiceLoader.class.getClassLoader();System.out.println("classloader:" + classLoader);Class class1 = classLoader.loadClass(tempServiceName[1]);System.out.println("class1" + class1);Object serviceInstance = class1.newInstance();Logger log = (Logger)serviceInstance;log.warn("TEST!!!");//services.add((S) serviceInstance);mservices.put(tempServiceName[0],  serviceInstance);}}System.out.println("-----");System.out.println("mservices:" + mservices.toString());return mservices;}public static Object getType(String type) {System.out.println("type:" + type);System.out.println("-----");System.out.println("mservices:" + mservices.toString());return mservices.get(type);}}

alog项目：

ALogger实现：

package com.tspi.alog;import com.tspi.log.Logger;public class ALogger implements Logger{public ALogger() {}public void debug(String logger) {System.out.println("ALogger-->debug: " + logger);}public void info(String logger) {System.out.println("ALogger-->info: " + logger);   }public void warn(String logger) {System.out.println("ALogger-->warn: " + logger);}public void error(String logger) {System.out.println("ALogger-->error: " + logger);}}

同时在resources目录下添加

META-INF/services/log/com.tspi.log.Logger  这个文件。

内容为

alog=com.tspi.alog.ALogger

blog项目同alog 项目已样：

package com.tspi.blog;import com.tspi.log.Logger;public class BLogger implements Logger{public BLogger() {}public void debug(String logger) {System.out.println("BLogger-->debug: " + logger);}public void info(String logger) {System.out.println("BLogger-->info: " + logger);  }public void warn(String logger) {System.out.println("BLogger-->warn: " + logger);}public void error(String logger) {System.out.println("BLogger-->error: " + logger);}
}

同样在resources目录下添加

META-INF/services/log/com.tspi.log.Logger  这个文件。

内容为

blog=com.tspi.blog.BLogger

logTest项目：

App.java

package com.tspi.logtest;import java.util.ResourceBundle;import com.tspi.log.CustomServiceLoader;
import com.tspi.log.Logger;/*** Hello world!**/
public class App {public static void main(String[] args) {System.out.println("Hello World!");ResourceBundle log = ResourceBundle.getBundle("log");String logString = log.getString("logType");System.out.println("logType:" + logString);CustomServiceLoader customServiceLoader = new CustomServiceLoader();try {customServiceLoader.loade(Logger.class);} catch (Exception e) {e.printStackTrace();}System.out.println("logString:" + logString);Logger logger = (Logger) customServiceLoader.getType(logString);logger.info("我爱你。。。");}
}

这个项目依赖着前面三个项目，在这个项目的resources这个目录下新建log.properties文件，内容如下：

logType=blog

可以是alog或者blog。配置不同，将调用不同的实现。

运行如下：

Hello World!
logType:blog
configFile:META-INF/services/log/com.tspi.log.Logger
configContent:
alog=com.tspi.alog.ALogger
configContent  --end
serviceName: alog=com.tspi.alog.ALogger
tmpServiceName:alog,com.tspi.alog.ALogger
classloader:sun.misc.Launcher$AppClassLoader@73d16e93
class1class com.tspi.alog.ALogger
ALogger-->warn: TEST!!!
configContent:
blog=com.tspi.blog.BLogger
configContent  --end
serviceName: blog=com.tspi.blog.BLogger
tmpServiceName:blog,com.tspi.blog.BLogger
classloader:sun.misc.Launcher$AppClassLoader@73d16e93
class1class com.tspi.blog.BLogger
BLogger-->warn: TEST!!!
-----
mservices:{blog=com.tspi.blog.BLogger@14ae5a5, alog=com.tspi.alog.ALogger@7f31245a}
logString:blog
type:blog
-----
mservices:{blog=com.tspi.blog.BLogger@14ae5a5, alog=com.tspi.alog.ALogger@7f31245a}
BLogger-->info: 我爱你。。。

如果配置的是alog，

最后打印将会是ALogger-->info: 我爱你。。。

三、  后记

这基本就是一个很简单的自定义servicesLoader的实现。基本实现了读配置来觉得调不通的SPI的实现

就像使用dubbo注册时你配置的是的redis就使用了redis注册中心，zookeeper就使用了zookeeper注册中心，我们这是配置alog就使用了ALogger实现，配置blog就使用了BLogger实现一样。

这个例子的地址：https://git.oschina.net/lenglingx-163/log-parent.git