这篇文章主要介绍了Java负载均衡服务器实现上传文件同步,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
负载服务器Z，应用服务器A 和B ，从A上传的附件，如何在B上下载下来？
这个问题我的解决思路如下（后来被一个装逼的面试官给批评了这种做法，不过我瞧不起他）
服务器A、B 上传附件的时候，将这个附件备份到服务器Z ，当A、B下载文件的时候，首先会在自己服务器的目录下寻找，如果找不到，就会从服务器Z 上下载一份到当前服务器。
服务器之间的文件备份通过sftp，参考：https://www.0133.cn/article/196008.htm（下文中的SftpCustom 类就是这个链接里的 “SFTP上传下载文件例子” 中的类）
这里主要介绍一下重写上传、下载的方法时应该添加的代码
上传文件，异步操作
new Thread(() -> { SftpCustom fu = new SftpCustom(); fu.upload(file.getAbsolutePath(), getFileName(fileDescr)); fu.closeChannel(); }).start();下载文件，先从当前服务器寻找
String tmpPath = roots[0].getPath() + '/' + getFileName(fileDescr); File file2 = new File(tmpPath); if (file2.exists()) { return FileUtils.openInputStream(file2); } SftpCustom fu = new SftpCustom(); fu.download(getFileName(fileDescr), tmpPath); file2 = new File(tmpPath); inputStream = FileUtils.openInputStream(file2); fu.closeChannel(); return inputStream;cuba 框架中重写上传文件类FileStorage.java 的代码如下：
package com.haulmont.cuba.core.app.custom; import com.google.common.util.concurrent.ThreadFactoryBuilder; import com.haulmont.cuba.core.app.FileStorageAPI; import com.haulmont.cuba.core.app.ServerConfig; import com.haulmont.cuba.core.entity.FileDescriptor; import com.haulmont.cuba.core.global.*; import com.haulmont.cuba.core.sys.AppContext; import com.haulmont.cuba.core.sys.SecurityContext; import org.apache.commons.io.FileUtils; import org.apache.commons.io.IOUtils; import org.apache.commons.lang.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import javax.annotation.PostConstruct; import javax.annotation.PreDestroy; import javax.inject.Inject; import java.io.*; import java.nio.charset.StandardCharsets; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Calendar; import java.util.List; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import static com.haulmont.bali.util.Preconditions.checkNotNullArgument; public class FileStorage implements FileStorageAPI { private final Logger log = LoggerFactory.getLogger(FileStorage.class); @Inject protected UserSessionSource userSessionSource; @Inject protected TimeSource timeSource; @Inject protected Configuration configuration; protected boolean isImmutableFileStorage; protected ExecutorService writeExecutor = Executors.newFixedThreadPool(5, new ThreadFactoryBuilder().setNameFormat("FileStorageWriter-%d").build()); protected volatile File[] storageRoots; @PostConstruct public void init() { this.isImmutableFileStorage = configuration.getConfig(ServerConfig.class).getImmutableFileStorage(); } /** * INTERNAL. Don't use in application code. */ public File[] getStorageRoots() { if (storageRoots == null) { String conf = configuration.getConfig(ServerConfig.class).getFileStorageDir(); if (StringUtils.isBlank(conf)) { String dataDir = configuration.getConfig(GlobalConfig.class).getDataDir(); File dir = new File(dataDir, "filestorage"); dir.mkdirs(); storageRoots = new File[]{dir}; } else { List list = new ArrayList<>(); for (String str : conf.split(",")) { str = str.trim(); if (!StringUtils.isEmpty(str)) { File file = new File(str); if (!list.contains(file)) list.add(file); } } storageRoots = list.toArray(new File[list.size()]); } } return storageRoots; } @Override public long saveStream(final FileDescriptor fileDescr, final InputStream inputStream) throws FileStorageException { checkFileDescriptor(fileDescr); File[] roots = getStorageRoots(); // Store to primary storage checkStorageDefined(roots, fileDescr); checkPrimaryStorageAccessible(roots, fileDescr); File dir = getStorageDir(roots[0], fileDescr); dir.mkdirs(); checkDirectoryExists(dir); final File file = new File(dir, getFileName(fileDescr)); checkFileExists(file); long size = 0; OutputStream os = null; try { os = FileUtils.openOutputStream(file); size = IOUtils.copyLarge(inputStream, os); os.flush(); writeLog(file, false); new Thread(() -> { SftpCustom fu = new SftpCustom(); fu.upload(file.getAbsolutePath(), getFileName(fileDescr)); fu.closeChannel(); }).start(); } catch (IOException e) { IOUtils.closeQuietly(os); FileUtils.deleteQuietly(file); throw new FileStorageException(FileStorageException.Type.IO_EXCEPTION, file.getAbsolutePath(), e); } finally { IOUtils.closeQuietly(os); } // Copy file to secondary storages asynchronously final SecurityContext securityContext = AppContext.getSecurityContext(); for (int i = 1; i 以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持html中文网。
以上就是Java负载均衡服务器实现上传文件同步的详细内容，更多请关注0133技术站其它相关文章！
