delete

src/test/java/FTPListAllFiles.java

@@ -0,0 +1,142 @@
/**
 * Created by zdm on 2019/5/7.
 */
import java.io.*;
import java.util.ArrayList;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPClientConfig;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Value;
/**
 * 列出FTP服务器上指定目录下面的所有文件
 */
public class FTPListAllFiles {
    private static Logger logger = Logger.getLogger(FTPListAllFiles.class);
    public static FTPClient ftp = new FTPClient();
    public ArrayList<String> arFiles;
    private static final String FAR_SERVER_URL = "172.26.0.220";
    private static final int SERVER_PORT = 21;
    private static final String SERVER_USER = "Telecom";
    private static final String SERVER_PWD = "telecom@jkzl2019";
    private static final String path = "/data/rec2/2019/0507/08/";
    private static final String showPath = "D:\\testFile\\";
    @Value("${file.default_path}")
    private String fileDefaultPath;
    /**
     * 登陆FTP服务器
     *
     * @param host     FTPServer IP地址
     * @param port     FTPServer 端口
     * @param username FTPServer 登陆用户名
     * @param password FTPServer 登陆密码
     * @return 是否登录成功
     * @throws IOException
     */
    public static boolean login(String host, int port, String username, String password) throws IOException {
        ftp.connect(host, port);
        if (FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
            if (ftp.login(username, password)) {
                ftp.setControlEncoding("GBK");
                ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
                //设置linux环境
                FTPClientConfig conf = new FTPClientConfig( FTPClientConfig.SYST_UNIX);
                ftp.configure(conf);
                return true;
            }
        }
        if (ftp.isConnected()) {
            ftp.disconnect();
        }
        return false;
    }
    /**
     * 关闭数据链接
     *
     * @throws IOException
     */
    public void disConnection() throws IOException {
        if (this.ftp.isConnected()) {
            this.ftp.disconnect();
        }
    }
    /**
     * 递归遍历出目录下面所有文件
     *
     * @param pathName 需要遍历的目录，必须以"/"开始和结束
     * @throws IOException
     */
    public static String List(String pathName) throws IOException {
        StringBuffer filename = new StringBuffer();
        if (pathName.startsWith("/") && pathName.endsWith("/")) {
            //更换目录到当前目录
            ftp.changeWorkingDirectory(path);
            //设置访问被动模式
            ftp.enterLocalPassiveMode();
            ftp.setRemoteVerificationEnabled(false);
            //检索ftp目录下所有的文件，利用时间字符串进行过滤
                FTPFile[] files = ftp.listFiles();
                if (files != null) {
                    for (int i = 0; i < files.length; i++) {
                        if (files[i].isFile()) {
                            downloadFileFromFTP(ftp, path+files[i].getName(), showPath,files[i].getName());
                        }
                }
            }
        }
        return filename.toString();
    }
    /**
     * 从FTP下载文件到本地
     * @param ftpClient     已经登陆成功的FTPClient
     * @param ftpFilePath   FTP上的目标文件路径
     * @param localFilePath 下载到本地的文件路径
     */
    public static void downloadFileFromFTP(FTPClient ftpClient, String ftpFilePath, String localFilePath,String fileName) {
        InputStream is = null;
        FileOutputStream fos = null;
        try {
            // 获取ftp上的文件
            is = ftpClient.retrieveFileStream(ftpFilePath);
            fos = new FileOutputStream(new File(localFilePath+fileName));
            // 文件读取方式一
            int i;
            byte[] bytes = new byte[1024];
            while ((i = is.read(bytes)) != -1) {
                fos.write(bytes, 0, i);
            }
            ftpClient.completePendingCommand();
            logger.info("FTP文件下载成功！");
        } catch (Exception e) {
            logger.error("FTP文件下载失败！", e);
        } finally {
            try {
                if (fos != null) {
                    fos.close();
                }
                if (is != null) {
                    is.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    //测试
    public static void main(String[] args) throws IOException {
        login("172.26.0.220",21,"Telecom","telecom@jkzl2019");
        List(path);
    }
}

src/test/java/FtpUtilTest.java

@@ -0,0 +1,185 @@
/**
 * Created by zdm on 2019/5/7.
 */
import java.io.*;
import org.apache.commons.net.ftp.*;
import org.apache.log4j.Logger;
import org.junit.Test;
import org.springframework.boot.test.context.TestComponent;
@TestComponent
public class FtpUtilTest {
    static Logger Log = Logger.getLogger(FtpUtilTest.class);
    private  FTPClient ftpClient;
    private static String ENCODING = "GBK";
    FTPClientConfig ftpConfig = new FTPClientConfig("UNIX");
    /**
     * 连接到ftp
     * @param address ip
     * @param port 端口
     * @param name 用户名
     * @param passwd 密码
     * @return
     */
    public boolean connectServer(String address,int port,String name,String passwd) {
        boolean flag = false;
        try {
            ftpClient = new FTPClient();
            ftpConfig.setServerLanguageCode("ISO-8859-1");
            ftpClient.connect(address, port);
            if(ftpClient.login(name,passwd)){
                if (FTPReply.isPositiveCompletion(ftpClient.sendCommand("OPTS UTF8", "ON"))) {
                    ENCODING = "UTF-8";
                }
                ftpClient.setControlEncoding(ENCODING);
                ftpClient.enterLocalPassiveMode();
                ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
                ftpClient.setFileTransferMode(FTP.STREAM_TRANSFER_MODE);
                ftpClient.setDataTimeout(120000);
            }
            int reply = ftpClient.getReplyCode();
            if (FTPReply.isPositiveCompletion(reply)) {
                flag = true;
                Log.info("FTP connect success!");
            } else {
                Log.warn("FTP refused to connect!");
                ftpClient.disconnect();
            }
        } catch (Exception e) {
            Log.error("Failed to login ftp " + address + ":" + port, e);
        }
        return flag;
    }
    /**
     * 判断服务器上是否存在该文件
     * @param path
     * @return
     * @throws IOException
     */
    public boolean existFile(String path) throws IOException {
        boolean flag = false;
        FTPFile[] ftpFileArr = ftpClient.listFiles(path);
        if (ftpFileArr.length > 0) {
            flag = true;
        }else {
            Log.info("file ‘"+path+ "' does not exist ! ");
        }
        return flag;
    }
    /**
     * 上传文件到服务器
     * @param remoteFilePath 远程文件路径： /data/rec2/2019/0507/08/52.mp3
     * @param uploadFile 待上传文件： D:\testFile\52.mp3
     * @return
     * @throws IOException
     */
    public boolean uploadFile(String remoteFilePath, File uploadFile) throws IOException {
        boolean flag = false;
        InputStream input = null;
        try {
            input = new FileInputStream(uploadFile);
            String remote = new String(remoteFilePath.getBytes(ENCODING), "ISO-8859-1");
            if (ftpClient.appendFile(remote, input)) {
                flag = true;
            }
        } finally {
            input.close();
        }
        Log.info("push file (" + uploadFile.getCanonicalPath() + ") => " + (flag ? "SUCCESS" : "FAILED"));
        return flag;
    }
    /**
     * 关闭服务器连接
     */
    public void closeConnect() {
        try {
            if (ftpClient != null) {
                ftpClient.logout();
                ftpClient.disconnect();
                Log.info("FTP connect closed!");
            }
        } catch (Exception e) {
            Log.info("Failed to close FTP connection!");
            e.printStackTrace();
        }
    }
    /**
     * 下载文件
     * @param remoteFilePath 远程文件：/data/rec2/2019/0507/08/52.mp3
     * @param downloadFile 下载到本地的文件：D:\testFile\52.mp3
     * @return
     * @throws IOException
     */
    public boolean downloadFile(String remoteFilePath, File downloadFile) throws IOException {
        boolean flag = false;
        OutputStream out = null;
        InputStream in=null;
        try {
            //获取文件流
            in = ftpClient.retrieveFileStream(remoteFilePath);
            // 文件读取方式一
            out = new FileOutputStream(downloadFile);
            int i;
            byte[] bytes = new byte[1024];
            while ((i = in.read(bytes)) != -1) {
                out.write(bytes, 0, i);
            }
          out.flush();
        }catch (IOException e){
            Log.info("File download failed :"+e.getMessage());
            e.printStackTrace();
        }finally {
            try {
                if(null!=in){
                    in.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                if(null!=in){
                    out.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        Log.info("File Download Successful");
        return flag;
    }
    public static void main(String[] args) throws Exception{
        FtpUtilTest ftpClient = new FtpUtilTest();
        //截取最后一个"/",获取文件目录
      /*  String remoteFilePath = "/data/rec2/2019/0507/08/52.mp3";
        File downloadFile = new File("D:\\testFile\\52.mp3");
        try {
            if(ftpClient.connectServer("172.26.0.220",21,"Telecom","telecom@jkzl2019")){
                boolean flag = ftpClient.downloadFile(remoteFilePath, downloadFile);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }*/
//       getPath();
        ftpClient.closeConnect();
    }
@Test
    public  void getPath() throws IOException {
        try {
            FtpUtilTest ftpClient = new FtpUtilTest();
            ftpClient.connectServer("172.26.0.220",21,"Telecom","telecom@jkzl2019");
        }catch (Exception e){
            Log.info("File download failed :"+e.getMessage());
            e.printStackTrace();
        }
        Log.info("File Download Successful");
    }
}

target/classes/application.yml

@@ -1,20 +0,0 @@
server:
  port: 8011
spring:
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
---
spring:
  profiles: devtest
  datasource:
    url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&autoReconnect=true
    username: root
    password: root
    type: com.alibaba.druid.pool.DruidDataSource
  jpa:
    hibernate:
      ddl-auto: update
    show-sql: true

target/maven-archiver/pom.properties

@@ -1,5 +0,0 @@
#Generated by Apache Maven
#Mon May 06 18:53:18 CST 2019
version=1.0-SNAPSHOT
groupId=com.yihu.wlyy
artifactId=wlyy-ftp-files

target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst

@@ -1 +0,0 @@
com\yihu\wlyy\Application.class

target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst

@@ -1 +0,0 @@
E:\workSpace\ijk\wlyy-ftp-files\src\main\java\com\yihu\wlyy\Application.java