如果您对java.util.ServiceLoader使用感兴趣，那么本文将是一篇不错的选择，我们将为您详在本文中，您将会了解到关于java.util.ServiceLoader使用的详细内容，我们还

如果您对java.util.ServiceLoader 使用感兴趣，那么本文将是一篇不错的选择，我们将为您详在本文中，您将会了解到关于java.util.ServiceLoader 使用的详细内容，我们还将为您解答java.util.locale的相关问题，并且为您提供关于'java.lang.NoClassDefFoundError 由 java.lang.ClassNotFoundException 引起的 Ljava/util/Base64 解析失败 未找到类“java.util.Base64”、android – 解压缩zip文件给出“java.util.zip.ZipException：无法读取版本”或“java.util.ZipException无法读取本地标题版本45”、com.intellij.util.ReflectionUtil 对方法 java.util.ResourceBundle.setParent(java.util.ResourceBundle) 的非法反射访问、CompletableFuture 源码详解之 java.util.concurrent.CompletableFuture#supplyAsync (java.util.function.Suppl...的有价值信息。

• java.util.ServiceLoader 使用（java.util.locale）
• 'java.lang.NoClassDefFoundError 由 java.lang.ClassNotFoundException 引起的 Ljava/util/Base64 解析失败 未找到类“java.util.Base64”
• android – 解压缩zip文件给出“java.util.zip.ZipException：无法读取版本”或“java.util.ZipException无法读取本地标题版本45”
• com.intellij.util.ReflectionUtil 对方法 java.util.ResourceBundle.setParent(java.util.ResourceBundle) 的非法反射访问
• CompletableFuture 源码详解之 java.util.concurrent.CompletableFuture#supplyAsync (java.util.function.Suppl...

java.util.ServiceLoader 使用（java.util.locale）

近期在项目中需要实现能在配置文件中定义多个统一接口类型的类，可以在程序中获取到所有配置的类，刚开始打算配置到 properties 中，然后去程序读取，感觉这种方式不太灵活，于是，研究研究 java 中有没有这种支持，最终确认 ServiceLoader 可以实现这种功能，下面讲解如何使用 ServiceLoader 类。

首先定义一个接口程序的定义如下：

public interface IShareniuService {
public String sayHello();
 
public String getScheme();
}
public class ShareniuserverImp1 implements IShareniuService {
 
public String sayHello() {
return "shareniu1sayHello";
}
 
public String getScheme() {
return "shareniu1getScheme";
}
 
}
public String sayHello() {
return "shareniu2sayHello";
}
 
public String getScheme() {
return "shareniu2getScheme";
}

需要在 META-INF/services 下以 IShareniuService 这个类的全名来新建立一个文件，文件中的内容为两个实现类的全名，如下：

所有的实现和配置都已经完成，下面写一个测试类来看一下结果:

ServiceLoader<IShareniuService> serviceLoader = ServiceLoader  
                .load(IShareniuService.class);  
        for (IShareniuService service : serviceLoader) {  
            System.out.println(service.getScheme()+"="+service.sayHello());  
        }

具体的输出来如下:

shareniu2getScheme=shareniu2sayHello

shareniu1getScheme=shareniu1sayHello

可以看到 ServiceLoader 可以根据 IShareniuService 把定义的两个实现类找出来，返回一个 ServiceLoader 的实现，而 ServiceLoader 实现了 Iterable 接口，所以可以通过 ServiceLoader 来遍历所有在配置文件中定义的类的实例

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

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;  
    }  
  }  
} 

FileSystem 对应的配置如下：

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 

通过之前的测试类输出对应的 scheme 和 class 如下：

file=class org.apache.hadoop.fs.LocalFileSystem  
viewfs=class org.apache.hadoop.fs.viewfs.ViewFileSystem  
s3=class org.apache.hadoop.fs.s3.S3FileSystem  
s3n=class org.apache.hadoop.fs.s3native.NativeS3FileSystem  
kfs=class org.apache.hadoop.fs.kfs.KosmosFileSystem  
ftp=class org.apache.hadoop.fs.ftp.FTPFileSystem  
har=class org.apache.hadoop.fs.HarFileSystem  
hdfs=class org.apache.hadoop.hdfs.DistributedFileSystem  
hftp=class org.apache.hadoop.hdfs.HftpFileSystem  
hsftp=class org.apache.hadoop.hdfs.HsftpFileSystem  
webhdfs=class org.apache.hadoop.hdfs.web.WebHdfsFileSystem 

可以看到 FileSystem 会把所有的 FileSystem 的实现都以 scheme 和 class 来 cache，之后就从这个 cache 中取相应的值。

因此，以后可以通过 ServiceLoader 来实现一些类似的功能。而不用依赖像 Spring 这样的第三方框架。

'java.lang.NoClassDefFoundError 由 java.lang.ClassNotFoundException 引起的 Ljava/util/Base64 解析失败 未找到类“java.util.Base64”

private File downloadpath = new File(Environment.getExternalStorageDirectory() + "/Test/file.zip");
private File unzipLoc = new File(Environment.getExternalStorageDirectory() + "/Test/");
        FileInputStream fin = new FileInputStream(downloadpath); 
        ZipInputStream zin = new ZipInputStream(fin);
        ZipEntry ze = null; 
        while ((ze = zin.getNextEntry()) != null) 
        { 
            FileOutputStream fout = new FileOutputStream(unzipLoc + ze.getName()); 
            for (int c = zin.read(); c != -1; c = zin.read()) 
            { 
                fout.write(c); 
            } 

            zin.closeEntry(); 
            fout.close(); 
        } 
        zin.close(); 

public void readCSV(String fileName) {
    fileLocation = fileName;
    File csvFile = new File(fileName);
    Scanner sfile;
//    noOfColumns = 0;
//    noOfRows = 0;
    data = new ArrayList<ArrayList>();
    int colCounter = 0;
    int rowCounter = 0;
    
    try {
        sfile = new Scanner(csvFile);
        
        while (sfile.hasNextLine()) {
            String aLine = sfile.nextLine();
            Scanner sline = new Scanner(aLine);
            sline.useDelimiter(",");
            colCounter = 0;
            while (sline.hasNext()) {
                if (rowCounter == 0) 
                    data.add(new ArrayList<String>());
                
                
                data.get(colCounter).add(sline.next());
                colCounter++;
            }
            rowCounter++;
            sline.close();
        }
//        noOfColumns = colCounter;
//        noOfRows = rowCounter;
        sfile.close();
    } catch (FileNotFoundException e) {
        System.out.println("File to read " + csvFile + " not found!");
    }
} 

fun main() {
println("Hello world")
}

/**
     * Returns a new CompletableFuture that is asynchronously completed
     * by a task running in the {@link ForkJoinPool#commonPool()} with
     * the value obtained by calling the given Supplier.
     *
     * @param supplier a function returning the value to be used
     * to complete the returned CompletableFuture
     * @param <U> the function''s return type
     * @return the new CompletableFuture
     */
    public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier) {
        return asyncSupplyStage(asyncPool, supplier);
    }

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

/**
 * 测试类
 * @author yangchangkui
 */
public class TestMy {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        long start = System.currentTimeMillis();
        CompletableFuture<String> completableFuture = CompletableFuture.supplyAsync(() -> {
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "hello";
        });
        //判断是否已经完成
        System.out.println("耗时："+(System.currentTimeMillis()-start)+"，isDone:"+completableFuture.isDone());
        //阻塞获取结果
        String result = completableFuture.get();
        System.out.println("耗时："+(System.currentTimeMillis()-start)+"，result:"+result);
        //判断是否已经完成
        System.out.println("耗时："+(System.currentTimeMillis()-start)+"，isDone:"+completableFuture.isDone());

    }
}