whyclxw
2025-03-06 eb33c60306f707ec7b30a048388e4de702ca2f15
src/main/java/com/whyc/dto/FTPClientUtil.java
@@ -1,6 +1,7 @@
package com.whyc.dto;
import com.whyc.constant.YamlProperties;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.net.ftp.FTPClient;
import org.springframework.stereotype.Component;
@@ -9,6 +10,7 @@
import java.io.IOException;
@Component
@Slf4j
public class FTPClientUtil {
    public static FTPClient connect(){
@@ -18,14 +20,15 @@
            ftpClient.login(YamlProperties.ftpUserName,YamlProperties.ftpPassword);
            ftpClient.enterLocalPassiveMode();
            ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
            final int bufferSize = 1024 * 1024;
            final int bufferSize = 20*1024 * 1024;
            ftpClient.setBufferSize(bufferSize);
            log.info("---------------FTP Client 连接成功------------------");
            return ftpClient;
        } catch (IOException e) {
            e.printStackTrace();
            log.error("---------------FTP Client 连接失败:"+e.toString()+"------------------");
        }
        return null;
    }
@@ -39,7 +42,7 @@
                ftpClient.storeFile(descFilePath, fileInputStream);
            } catch (IOException e) {
                e.printStackTrace();
                log.error("---------------文件"+ originalFile.getName() +" FTP 传输异常:"+e.toString()+"------------------");
            } finally {
                try {
                    fileInputStream.close();
@@ -48,7 +51,7 @@
                        ftpClient.disconnect();
                    }
                } catch (IOException ex) {
                    ex.printStackTrace();
                    log.error("---------------关流异常:"+ex.toString()+"------------------");
                }
            }
        }