FTP服务器上传下载

简介: windows下FTP服务器可以使用3CDaemon,下载后点击FTP服务器设置进行相关设置:使用jar包坐标如下: <dependency> <groupId>commons-net</groupId> <artifactId>commons-net</artifactId> <version>3.6</version> </dependency>使用java连接服务器并进行操作,登录FTP后默认在FTP根目录下,如果操作文件需要切换到待操作目录。

windows下FTP服务器可以使用3CDaemon,下载后点击FTP服务器设置进行相关设置:

QQ_20190507174117

使用jar包坐标如下:

        <dependency>
            <groupId>commons-net</groupId>
            <artifactId>commons-net</artifactId>
            <version>3.6</version>
        </dependency>

使用java连接服务器并进行操作,登录FTP后默认在FTP根目录下,如果操作文件需要切换到待操作目录。

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

import com.btzh.exception.BusinessException;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.springframework.util.StringUtils;

/**
 * FTP工具类
 *
 * @author faith
 */
public class FtpUtil {
 
    public final static String HOSTNAME = "127.0.0.1";
    public final static Integer PORT = 21;
    public final static String USERNAME = "admin";
    public final static String PASSWORD = "666666";
    public static FTPClient FTP_CLIENT;

    public static void main(String[] args) {
        FtpUtil.uploadFileByPath("/upload/img/", "test.jpg", "D:\\timg.jpg");
        FtpUtil.downloadFile("/upload/img/", "test.jpg", "D:\\ftp");
        FtpUtil.deleteFile("upload/img", "test.jpg");
    }

    /**
     * 上传文件by文件名
     * @param pathName
     * @param fileName
     * @param originFileName
     */
    public static void uploadFileByPath(String pathName, String fileName, String originFileName) {
        InputStream inputStream = null;
        FTP_CLIENT = getFtpClient();

        try {
            FTP_CLIENT.setFileType(FTP.BINARY_FILE_TYPE);

            createIfNotExsit(pathName);
            FTP_CLIENT.storeFile(fileName, inputStream = new FileInputStream(new File(originFileName)));
        } catch (Exception e) {
            throw new RuntimeException("上传文件失败: " + e);
        } finally {
            closeIOResource(FTP_CLIENT, inputStream, null);
        }
    }

    /**
     * 上传文件by流
     * @param pathname
     * @param fileName
     * @param inputStream
     */
    public static void uploadFileByStream(String pathname, String fileName, InputStream inputStream) {
        FTP_CLIENT = getFtpClient();

        try {
            FTP_CLIENT.setFileType(FTP.BINARY_FILE_TYPE);

            createIfNotExsit(pathname);
            FTP_CLIENT.storeFile(fileName, inputStream);
        } catch (Exception e) {
            throw new RuntimeException("上传文件失败");
        } finally {
            closeIOResource(FTP_CLIENT, inputStream, null);
        }
    }
 
    /**
     * 下载文件 
     * @param pathname
     * @param filename
     * @param localPath
     * @return
     */
    public static void downloadFile(String pathname, String filename, String localPath) {
        OutputStream outputStream = null;
        FTP_CLIENT = getFtpClient();

        try {
            FTP_CLIENT.changeWorkingDirectory(pathname);

            FTPFile[] ftpFiles = FTP_CLIENT.listFiles();
            for (FTPFile ftpFile : ftpFiles) {
                if (ftpFile.getName().equalsIgnoreCase(filename)) {
                    FTP_CLIENT.retrieveFile(ftpFile.getName(), outputStream = new FileOutputStream(new File(localPath + "/" + ftpFile.getName())));
                    return;
                }
            }

            throw new BusinessException("未找到文件:" + pathname + "/" + filename);
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            closeIOResource(FTP_CLIENT, null, outputStream);
        }
    }

    /**
     * 删除文件
     * @param pathName
     * @param fileName
     */
    public static void deleteFile(String pathName, String fileName) {
        FTP_CLIENT = getFtpClient();

        try {
            FTP_CLIENT.changeWorkingDirectory(pathName);
            FTP_CLIENT.dele(fileName);
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            closeIOResource(FTP_CLIENT, null, null);
        }
    }

    /**
     * 改变工作目录
     * @param directory
     * @return
     */
    public static boolean changeWorkingDirectory(String directory) {
        try {
            return FTP_CLIENT.changeWorkingDirectory(directory);
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * 创建目录
     * @param directory
     */
    public static void createIfNotExsit(String directory) {
        if (directory.equalsIgnoreCase("/")) {
            return;
        }

        while (directory.startsWith("/") || directory.endsWith("/")) {
            directory = directory.substring(directory.startsWith("/") ? 1 : 0, directory.endsWith("/") ? directory.length() - 1 : directory.length());
            if (directory.equalsIgnoreCase("/")) {
                return;
            }
        }

        String[] filePaths = StringUtils.delimitedListToStringArray(directory, "/");
        for (String filePath : filePaths) {
            if (!existFilePath(filePath)) {
                makeDirectory(filePath);
            }
            changeWorkingDirectory(filePath);
        }
    }

    /**
     * 判断文件是否存在
     * @param filePath
     * @return
     */
    public static boolean existFilePath(String filePath) {
        try {
            return FTP_CLIENT.listFiles(filePath).length > 0;
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * 创建文件目录
     * @param directory
     * @return
     */
    public static boolean makeDirectory(String directory) {
        try {
            return FTP_CLIENT.makeDirectory(directory);
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * 连接FTP服务器
     */
    public static FTPClient getFtpClient() {
        FTP_CLIENT = new FTPClient();
        FTP_CLIENT.setControlEncoding("UTF-8");

        try {
            FTP_CLIENT.connect(HOSTNAME, PORT);

            if (!FTP_CLIENT.login(USERNAME, PASSWORD)) {
                throw new RuntimeException("ftp登录失败");
            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        }

        return FTP_CLIENT;
    }

    /**
     * 关闭使用的资源
     * @param ftpClient
     * @param inputStream
     */
    private static void closeIOResource(FTPClient ftpClient, InputStream inputStream, OutputStream outputStream) {
        if (ftpClient.isConnected()) {
            try {
                ftpClient.logout();
                ftpClient.disconnect();
            } catch (IOException e) {
            }
        }
        if (null != inputStream) {
            try {
                inputStream.close();
            } catch (IOException e) {
            }
        }
        if (null != outputStream) {
            try {
                outputStream.close();
            } catch (IOException e) {
            }
        }
    }
}
目录
相关文章
|
1月前
|
SQL 分布式计算 DataWorks
DataWorks常见问题之dataworks连接FTP服务器失败如何解决
DataWorks是阿里云提供的一站式大数据开发与管理平台,支持数据集成、数据开发、数据治理等功能;在本汇总中,我们梳理了DataWorks产品在使用过程中经常遇到的问题及解答,以助用户在数据处理和分析工作中提高效率,降低难度。
|
1月前
|
缓存 网络协议 数据可视化
WinSCP下载安装并实现远程SSH本地服务器上传文件
WinSCP下载安装并实现远程SSH本地服务器上传文件
|
3月前
|
存储 运维 程序员
快速搭建一个FTP服务器
快速搭建一个FTP服务器
56 0
|
1月前
|
Shell Python Windows
通过Python实现win11环境下FTP的上传与下载
通过Python实现win11环境下FTP的上传与下载
|
1月前
|
存储 网络协议 安全
如何搭建外网可访问的Serv-U FTP服务器,轻松远程共享文件!
如何搭建外网可访问的Serv-U FTP服务器,轻松远程共享文件!
|
1月前
|
数据可视化 网络安全 Windows
下载安装MobaXterm并链接服务器的操作方法
【2月更文挑战第13天】本文介绍在Windows电脑中,下载、配置MobaXterm软件,从而连接、操作远程服务器的方法~
下载安装MobaXterm并链接服务器的操作方法
|
2月前
|
Java
java上传、下载、预览、删除ftp服务器上的文件
java上传、下载、预览、删除ftp服务器上的文件
|
2月前
|
弹性计算 缓存 负载均衡
ECS配置问题之FTP密码修改失败如何解决
ECS配置指的是对阿里云Elastic Compute Service(弹性计算服务)实例的硬件和软件资源进行设置的过程;本合集将详述如何选择合适的ECS配置、调整资源配比以及优化实例性能,以满足不同应用场景的需求。
|
2月前
|
Linux
本地下载使用证书登陆的linux服务器的文件的命令
本地下载使用证书登陆的linux服务器的文件的命令
|
27天前
|
Ubuntu JavaScript 关系型数据库
在阿里云Ubuntu 20.04服务器中搭建一个 Ghost 博客
在阿里云Ubuntu 20.04服务器上部署Ghost博客的步骤包括创建新用户、安装Nginx、MySQL和Node.js 18.x。首先,通过`adduser`命令创建非root用户,然后安装Nginx和MySQL。接着,设置Node.js环境,下载Nodesource GPG密钥并安装Node.js 18.x。之后,使用`npm`安装Ghost-CLI,创建Ghost安装目录并进行安装。配置过程中需提供博客URL、数据库连接信息等。最后,测试访问前台首页和后台管理页面。确保DNS设置正确,并根据提示完成Ghost博客的配置。
在阿里云Ubuntu 20.04服务器中搭建一个 Ghost 博客