package cn.com.wwh;
/**
 * 
 * @FileName Logger.java
 * @version:1.0
 * @Description: 服務(wù)提供者接口
 * @author: wwh
 * @date: 2022年9月19日 上午10:31:53
 */
public interface Logger {
    
    /**
     * 
     * @Description:(功能描述)
     * @param msg
     */
    public void info(String msg);
    
    /**
     * 
     * @Description:(功能描述)
     * @param msg
     */
    public void debug(String msg);
}

package cn.com.wwh;

import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.ServiceLoader;

/**
 * 
 * @FileName LoggerService.java
 * @version:1.0
 * @Description: 為服務(wù)的調(diào)用者提供特定的功能，是SPI的核心功能
 * @author: wwh
 * @date: 2022年9月19日 上午10:33:30
 */
public class LoggerService {

    private static final LoggerService INSTANCE = new LoggerService();

    private final Logger logger;                          

    private final List<Logger> loggers = new ArrayList<>();

    private LoggerService() {
　　　　　//ServiceLoader是實現(xiàn)SPI的核心類
        ServiceLoader<Logger> sl = ServiceLoader.load(Logger.class);
        Iterator<Logger> it = sl.iterator();
        while (it.hasNext()) {
            loggers.add(it.next());
        }

        if (!loggers.isEmpty()) {
            logger = loggers.get(0);
        } else {
            logger = null;
        }
    }

    /**
     * @Description:(功能描述)
     * @return
     */
    public static LoggerService getLoggerService() {
        return INSTANCE;
    }

    /**
     * 
     * @Description:(功能描述)
     * @param msg
     */
    public void info(String msg) {
        if (logger == null) {
            System.err.println("在info方法中沒有找到Logger的實現(xiàn)類...");
        } else {
            logger.info(msg);
        }
    }

    /**
     * 
     * @Description:(功能描述)
     * @param msg
     */
    public void debug(String msg) {
        if (logger == null) {
            System.err.println("在debug方法中沒有找到Logger的實現(xiàn)類...");
        } else {
            logger.info(msg);
        }
    }
}

package cn.com.wwh;

import cn.com.pep.Logger;

/**
 * 
 * @FileName Logback.java
 * @version:1.0
 * @Description: 服務(wù)接口的實現(xiàn)類
 * @author: wwh
 * @date: 2022年9月19日 上午10:50:31
 */
public class Logback implements Logger {

    @Override
    public void debug(String msg) {
        System.err.println("調(diào)用Logback的debug方法，輸出的日志為：" + msg);
    }

    @Override
    public void info(String msg) {
        System.err.println("調(diào)用Logback的info方法，輸出的日志為：" + msg);
    }

}

package cn.com.wwh;

import cn.com.pep.LoggerService;

/**
 * 
 * @FileName SpiTest.java
 * @version:1.0
 * @Description: 
 * @author: wwh
 * @date: 2022年9月19日 上午10:56:31
 */
public class SpiTest {
    
    public static void main(String[] args) {
        LoggerService logger = LoggerService.getLoggerService();
        logger.info("我是中國人");
        logger.debug("白菜多少錢一斤");
    }
}

public Iterator<S> iterator() {
        //通過匿名內(nèi)部類方式提供了一個迭代器
        return new Iterator<S>() {
            //獲取緩存的服務(wù)實現(xiàn)者的迭代器
            Iterator<Map.Entry<String, S>> knownProviders = providers.entrySet().iterator();

            //判斷迭代器中是否還有元素
            public boolean hasNext() {
                //緩存的服務(wù)實現(xiàn)者的迭代器中已經(jīng)沒有元素了
                if (knownProviders.hasNext())
                    return true;
                return lookupIterator.hasNext();//判斷延遲加載的迭代器中是否還有元素
            }

            //獲取迭代其中的下一個元素
            public S next() {
                if (knownProviders.hasNext())
                    return knownProviders.next().getValue();
                return lookupIterator.next();//獲取延遲加載的迭代器中的下一個元素
            }

            public void remove() {
                throw new UnsupportedOperationException();
            }
        };
   }

public boolean hasNext() {
        if (nextName != null) {//存在下一個元素
            return true;
        }
        if (configs == null) {//配置文件為空
            try {
                String fullName = PREFIX + service.getName();//獲取配置文件路徑
                if (loader == null)
                    configs = ClassLoader.getSystemResources(fullName);
                else
                    configs = loader.getResources(fullName);//加載配置文件
            } catch (IOException x) {
                fail(service, "Error locating configuration files", x);
            }
        }
        //遍歷配置文件內(nèi)容
        while ((pending == null) || !pending.hasNext()) {
            if (!configs.hasMoreElements()) {
                return false;
            }
            pending = parse(service, configs.nextElement());//配置文件內(nèi)容解析
        }
        nextName = pending.next();//獲取服務(wù)實現(xiàn)類的全路徑名
        return true;
    }

public S next() {
        if (!hasNext()) {
            throw new NoSuchElementException();
        }
        String cn = nextName;//文件中保存的服務(wù)接口實現(xiàn)類的全路徑名
        nextName = null;
        Class<?> c = null;
        try {
            //獲取全限定名的Class對象
            c = Class.forName(cn, false, loader);
        } catch (ClassNotFoundException x) {
            fail(service, "Provider " + cn + " not found");
        }
            //判斷實現(xiàn)類和服務(wù)接口是否是同一類型
        if (!service.isAssignableFrom(c)) {
            fail(service, "Provider " + cn + " not a subtype");
        }
        try {
            //通過反射生成服務(wù)接口的實現(xiàn)類，并判斷這個實例是否是接口的實現(xiàn)
            S p = service.cast(c.newInstance());
            //將服務(wù)接口的實現(xiàn)緩存起來，并返回
            providers.put(cn, p);
            return p;
        } catch (Throwable x) {
            fail(service, "Provider " + cn + " could not be instantiated", x);
        }
        throw new Error(); // This cannot happen
    }