场景描述
我们将要模拟指定一个文件目录，将该目录的所有所有的文件上传到ftp服务器上
我们知道获取ftp连接与读取目录中所有文件都是比较耗时的，如果可以同时进行是最好的，我们可以使用多线程来获取连接，但两个线程哪个快无法保证，如何保证当连接创建成功后才开始执行上传文件呢，就可以使用承诺模式
一. FTPConnectionUtil
调用者可以通过getPromise()方法获取Ftp连接承诺者对象FutureTask<FTPConnectionUtil>，我们假设获取连接时间为5秒
public class FTPConnectionUtil {
private Exception exception;
private FTPConnectionUtil(){
//防止通过暴力反射破坏单例
if(InFTPConnectionUtil.connectionUtil != null){
throw new RuntimeException("单例已经存在！");
}
}
public static FTPConnectionUtil newInstance(){
return InFTPConnectionUtil.connectionUtil;
}
/**
* 内部类单例，只有调用时才会加载，既避免了懒汉式浪费资源，又避免了饿汉式安全问题
*/
private static class InFTPConnectionUtil{
private final static FTPConnectionUtil connectionUtil = new FTPConnectionUtil();
}
/**
* 构造方法私有，根据此方法获取FutureTask承诺，通过多线程建立连接，然后通过FutureTask.get()方法获取泛型<T>，
* 可以通过isDone方法判断多线程是否执行完毕
* 可以在泛型实体里接受异常属性，通过获取属性判断建立连接过程是否正常</>
* @return
*/
public static FutureTask<FTPConnectionUtil> getPromise(){
Callable<FTPConnectionUtil> callable = new Callable() {
@Override
public Object call() throws Exception {
FTPConnectionUtil ftpConnectionUtil = FTPConnectionUtil.newInstance();
return ftpConnectionUtil.doFtpConnection(ftpConnectionUtil);
}
};
FutureTask<FTPConnectionUtil> futureTask = new FutureTask<>(callable);
new Thread(futureTask).start();
return futureTask;
}
private FTPConnectionUtil doFtpConnection(FTPConnectionUtil util){
try {
System.out.println("---------建立连接开始");
for (int i = 1; i <= 5; i++) {
Thread.sleep(1000);
System.out.println("-----建立连接"+i+"秒！");
}
System.out.println("---------建立连接完成");
}catch (Exception e){
util.exception = e;
}
return util;
}
public void upload(File file){
System.out.println(file.getName() + "上传完成！");
}
public Exception getException() {
return exception;
}
private void setException(Exception exception) {
this.exception = exception;
}
public void closeConnection(){
System.out.println("关闭连接！");
}
}
二. 上传方法服务
我们假设读取文件瞬间完成，又因建立连接需要5秒时间，此时应该等待获取连接后依次上传文件，所以我们通过无限循环调用承诺者对象FtpPromise.isDone()判断是否完成连接，如果连接完成开始上传文件。此处我们可以通过次数或时间来限制最大等待时间
public class UploadToFTP {
FutureTask<FTPConnectionUtil> FtpPromise = FTPConnectionUtil.getPromise();
System.out.println("读取文件开始！");
ArrayList<File> files = new ArrayList<>();
files.add(new File("file1"));
files.add(new File("file2"));
files.add(new File("file3"));
System.out.println("读取文件结束！");
FTPConnectionUtil ftpConnectionUtil = null;
while (true) {
Thread.sleep(1000);
if(FtpPromise.isDone()){
ftpConnectionUtil = FtpPromise.get();
if (ftpConnectionUtil.getException() != null) {
throw ftpConnectionUtil.getException();
}
for (File file : files) {
ftpConnectionUtil.upload(file);
}
break;
}else{
System.out.println("等待");
}
}
ftpConnectionUtil.closeConnection();
}
}
三. 测试方法
public class Run {
public static void main(String[] args) throws Exception {
UploadToFTP uploadToFTP = new UploadToFTP();
uploadToFTP.upload();
}
}
四. 测试结果
读取文件开始！
读取文件结束！
-----建立连接开始
等待
-----建立连接1秒！
等待
-----建立连接2秒！
等待
-----建立连接3秒！
等待
-----建立连接4秒！
等待
-----建立连接5秒！
-----建立连接结束
file1上传完成！
file2上传完成！
file3上传完成！
关闭连接！
