java上传、下载、预览、删除ftp服务器上的文件

简介: java上传、下载、预览、删除ftp服务器上的文件

1、添加依赖

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

2、在properties文件里配置ftp信息(初学者可以放在java类里):

ftp.url=192.168.60.48
ftp.port=21
ftp.username=FTPTest
ftp.password=FTPTest
ftp.path=E

3、代码:

package com.bosssoft.nontax.basicinfo.standard.sfml.domain;

import org.apache.commons.lang3.StringUtils;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

import java.io.IOException;
import java.io.InputStream;

/**
 * @Description TODD
 * @Author sgw
 * @Date 2019/4/2
 * @Version 1.0
 **/
@Component
public class PdfUtilsByFtp {
   

     @Resource
     private FTPClient ftpClient;

     @Value("${ftp.url}")
     public String url;//ftpClient url

     @Value("${ftp.port}")
     public int port;//端口

     @Value("${ftp.username}")
     public String username;//登录用户名

     @Value("${ftp.password}")
     public String password;//登录密码

     @Value("${ftp.path}")
     public String path;//写入/上传文件路径

    //本地字符编码
    private static String LOCAL_CHARSET = "GBK";

    Logger logger = LoggerFactory.getLogger(PdfUtilsByFtp.class);

    /**
     * Description: 向FTP服务器上传文件
     * @param filename 文件名
     * @param path  文件路径
     * @param input  输入流
     * @param url     ftp的地址
     * @param port    ftp的端口
     * @param username  ftp用户名
     * @param password  ftp密码
     * @throws IOException
     */
    public void uploadFile(String filename, String path, InputStream input, String url, int port, String username, String password) throws IOException {
   
        /*try {*/

        int reply;

        /**
         * 连接FTP服务器
         * 如果采用默认端口,可以使用ftp.connect(url)的方式直接连接FTP服务器
         */
        ftpClient.connect(url, port);
        //登录
        ftpClient.login(username, password);
        //ftp连接的返回码:200表示连接成功,其他值表示连接失败
        reply = ftpClient.getReplyCode();
        if (!FTPReply.isPositiveCompletion(reply)) {
   
            ftpClient.disconnect();
            logger.error("FTP上传文件还没开始就断开了");
        }
        /**
         * 这里修改为被动模式
         * 主动模式:客户端开放端口给服务端用;
         * 被动模式:服务端开放端口给客户端用。
         * 由于很多客户端在防火墙内,开放端口给服务器端用比较困难。所以用被动模式的时候比较多。
         */
        ftpClient.enterLocalPassiveMode();

        // 修改工作目录为path指定的目录
        workingDirectory(ftpClient, path);
        // ftpClient.changeWorkingDirectory(path);
        logger.info("FTP判断服务器的编码格式是UTF-8还是GBK");
        //查看服务器的编码格式是UTF-8还是GBK 开启服务器对UTF-8的支持,如果服务器支持就用UTF-8编码,否则就使用本地编码(GBK).
        if (FTPReply.isPositiveCompletion(ftpClient.sendCommand("OPTS UTF8", "ON"))) {
   
            LOCAL_CHARSET = "UTF-8";
        }
        ftpClient.setControlEncoding(LOCAL_CHARSET);
        //ftp上传文件是以文本形式传输的,所以多媒体文件会失真,需要转为二进制形式传输
        ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
        logger.info("FTP进行上传文件");
        //文件名字进行编码转换
        ftpClient.storeFile(utf8TOiso88591(filename, LOCAL_CHARSET), input);
        input.close();
        ftpClient.logout();
        if (ftpClient.isConnected()) {
   
            ftpClient.disconnect();
        }
    }
    public void workingDirectory(FTPClient ftp, String path) {
   
        try {
   
            //切换工作目录为根目录
            ftp.changeWorkingDirectory("/");

            if (StringUtils.isBlank(path) || path.equals("/")) {
   //如果输入的路径为空或者为根路径,则不转换操作目录

            } else {
   //否则创建想要上传文件的目录,并且将操作目录转为新创建的目录
                //循环创建多级目录
                String directory = path.substring(0, path.lastIndexOf("/") + 1);
                if (!directory.equalsIgnoreCase("/") && !ftpClient.changeWorkingDirectory(new String(directory.getBytes("GBK"), "iso-8859-1"))) {
   
                    // 如果远程目录不存在,则递归创建远程服务器目录
                    int start = 0;
                    int end = 0;
                    if (directory.startsWith("/")) {
   
                        start = 1;
                    } else {
   
                        start = 0;
                    }
                    end = directory.indexOf("/", start);
                    while (true) {
   
                        String subDirectory = new String(path.substring(start, end).getBytes("GBK"),
                                "iso-8859-1");
                        if (!ftpClient.changeWorkingDirectory(subDirectory)) {
   
                            if (ftpClient.makeDirectory(subDirectory)) {
   
                                ftpClient.changeWorkingDirectory(subDirectory);

                            } else {
   
                                System.out.println("创建目录失败");
                            }
                        }
                        start = end + 1;
                        end = directory.indexOf("/", start);
                        // 检查所有目录是否创建完毕
                        if (end <= start) {
   
                            break;
                        }
                    }
                }
                //这个创建目录的函数只能创建一级目录,不能创建多级目录
                //boolean b = ftp.makeDirectory(gbkTOiso88591(path));
                //切换当前的工作目录为新建的目录
                ftp.changeWorkingDirectory(gbkTOiso88591(path));
            }
        } catch (Exception e) {
   
            logger.error("FTP上传文件进行创建目录结构的时候出现了异常:" + e.getMessage());
        }
    }

    public String utf8TOiso88591(String filename, String codestyle) {
   
        try {
   
            return new String(filename.getBytes(codestyle), "iso-8859-1");
        } catch (Exception e) {
   
            logger.error("FTP上传文件进行" + codestyle + "转ISO-8859-1的时候出现了异常:" + e.getMessage() + "返回的结果就还是传进来的参数");
            logger.error("FTP上传文件进行" + codestyle + "转ISO-8859-1的时候出现了异常,返回的结果就还是传进来的参数");
            return filename;
        }
    }

    public String gbkTOiso88591(String path) {
   
        try {
   
            return new String(path.getBytes("GBK"), "iso-8859-1");
        } catch (Exception e) {
   
            logger.error("FTP上传文件进行GBK转ISO-8859-1的时候出现了异常:" + e.getMessage());
            logger.error("FTP上传文件进行GBK转ISO-8859-1的时候出现了异常,返回的结果就还是传进来的参数");
            return path;
        }
    }

    public FTPClient getFtpClient() {
   
        return ftpClient;
    }

    public void setFtpClient(FTPClient ftpClient) {
   
        this.ftpClient = ftpClient;
    }

    /**
     * Description: 删除ftp上的文件
     * @param url     ftp的地址
     * @param port    ftp的端口
     * @param username  ftp用户名
     * @param password  ftp密码
     * @param filePath  文件路径(后边跟上了文件名)
     * @throws IOException
     */
    public void deleteFile(String url, int port, String username, String password, String filePath) throws IOException {
   
        int reply;
        ftpClient.connect(url, port);
        //如果采用默认端口,可以使用ftp.connect(url)的方式直接连接FTP服务器
        ftpClient.login(username, password);
        reply = ftpClient.getReplyCode();
        if (!FTPReply.isPositiveCompletion(reply)) {
   
            ftpClient.disconnect();
            logger.error("FTP断开了");
        }
        //修改为被动模式
        ftpClient.enterLocalPassiveMode();
        //删除文件
        ftpClient.deleteFile(filePath);
    }
    /**
     * Description: 下载/浏览器预览  需要的流信息
     * @param url     ftp的地址
     * @param port    ftp的端口
     * @param username  ftp用户名
     * @param password  ftp密码
     * @param filePath  文件路径(后边跟上了文件名)
     * @throws IOException
     */
    public InputStream getStream(String url, int port, String username, String password, String filePath) throws IOException {
   
        int reply;
        ftpClient.connect(url, port);//连接FTP服务器
        //如果采用默认端口,可以使用ftp.connect(url)的方式直接连接FTP服务器
        ftpClient.login(username, password);//登录
        reply = ftpClient.getReplyCode();
        if (!FTPReply.isPositiveCompletion(reply)) {
   
            ftpClient.disconnect();
            logger.error("FTP断开了");
        }
        InputStream inputStream = ftpClient.retrieveFileStream(filePath);
        return inputStream;
    }
}

注意:由于PdfUtilsByFtp类需要加载配置文件里的信息,所以,引用PdfUtilsByFtp类的时候需要用注入的方式,不能new,即:

    @Autowired
    private PdfUtilsByFtp fdfUtilsByFtp;
相关文章
|
20天前
|
Java
有关Java发送邮件信息(支持附件、html文件模板发送)
有关Java发送邮件信息(支持附件、html文件模板发送)
23 1
|
24天前
|
Java
java中替换文件内容
java中替换文件内容
13 1
|
22天前
|
Java 数据库连接 API
Java 学习路线:基础知识、数据类型、条件语句、函数、循环、异常处理、数据结构、面向对象编程、包、文件和 API
Java 是一种广泛使用的、面向对象的编程语言,始于1995年,以其跨平台性、安全性和可靠性著称,应用于从移动设备到数据中心的各种场景。基础概念包括变量(如局部、实例和静态变量)、数据类型(原始和非原始)、条件语句(if、else、switch等)、函数、循环、异常处理、数据结构(如数组、链表)和面向对象编程(类、接口、继承等)。深入学习还包括包、内存管理、集合框架、序列化、网络套接字、泛型、流、JVM、垃圾回收和线程。构建工具如Gradle、Maven和Ant简化了开发流程,Web框架如Spring和Spring Boot支持Web应用开发。ORM工具如JPA、Hibernate处理对象与数
88 3
|
22天前
|
Java 关系型数据库 MySQL
Flink1.18.1和CDC2.4.1 本地没问题 提交任务到服务器 报错java.lang.NoClassDefFoundError: Could not initialize class io.debezium.connector.mysql.MySqlConnectorConfig
【2月更文挑战第33天】Flink1.18.1和CDC2.4.1 本地没问题 提交任务到服务器 报错java.lang.NoClassDefFoundError: Could not initialize class io.debezium.connector.mysql.MySqlConnectorConfig
32 2
|
25天前
|
Java
使用java将字符串写入到指定的文件中
使用java将字符串写入到指定的文件中
11 0
|
21天前
|
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 博客
|
24天前
|
存储 弹性计算 数据可视化
要将ECS中的文件直接传输到阿里云网盘与相册(
【2月更文挑战第31天】要将ECS中的文件直接传输到阿里云网盘与相册(
409 4
|
26天前
|
SQL 弹性计算 安全
购买阿里云活动内云服务器之后设置密码、安全组、增加带宽、挂载云盘教程
当我们通过阿里云的活动购买完云服务器之后,并不是立马就能使用了,还需要我们设置云服务器密码,配置安全组等基本操作之后才能使用,有的用户还需要购买并挂载数据盘到云服务器上,很多新手用户由于是初次使用阿里云服务器,因此并不知道这些设置的操作流程,下面给大家介绍下这些设置的具体操作流程。
购买阿里云活动内云服务器之后设置密码、安全组、增加带宽、挂载云盘教程
|
10天前
|
弹性计算
阿里云ECS使用体验
在申请高校学生免费体验阿里云ECS云服务器后的一些使用体验和感受。
|
27天前
|
弹性计算
阿里云3M带宽云服务器并发多大?阿里云3M带宽云服务器测评参考
在探讨云服务器3M带宽能支持多大并发这一问题时,我们首先要明白一个关键点:并发量并非仅由带宽决定,还与网站本身的大小密切相关。一般来说,一个优化良好的普通网站页面大小可能只有几K,为便于计算,我们可以暂且假定每个页面大小为50K。
790 1