瀏覽代碼

ftp上传内存泄露问题

QuietShadow 3 年之前
父節點
當前提交
05899bf361
共有 1 個文件被更改,包括 11 次插入11 次删除
  1. 11 11
      src/main/java/com/steerinfo/ftp/uploadfile/utils/FtpFileUtil.java

+ 11 - 11
src/main/java/com/steerinfo/ftp/uploadfile/utils/FtpFileUtil.java

@@ -138,9 +138,9 @@ public class FtpFileUtil {
         boolean result;
         try {
             //建立连接
-            connectToServer();
+            this.connectToServer();
             ftpClient.changeWorkingDirectory("/");
-            setFileType(FTP.BINARY_FILE_TYPE);
+            this.setFileType(FTP.BINARY_FILE_TYPE);
             int reply = ftpClient.getReplyCode();
             if (!FTPReply.isPositiveCompletion(reply)) {
                 ftpClient.disconnect();
@@ -195,9 +195,9 @@ public class FtpFileUtil {
         InputStream inputStream;
         String data = fileName + "预览失败";
         try {
-            connectToServer();
+            this.connectToServer();
             // 设置传输二进制文件
-            setFileType(FTP.BINARY_FILE_TYPE);
+            this.setFileType(FTP.BINARY_FILE_TYPE);
             ftpClient.enterLocalPassiveMode();
             int reply = ftpClient.getReplyCode();
             if(!FTPReply.isPositiveCompletion(reply)){
@@ -271,10 +271,10 @@ public class FtpFileUtil {
     public boolean download(HttpServletResponse response, String fileName, String filePath) {
         boolean flag = false;
         try{
-            connectToServer();
+            this.connectToServer();
             // 设置传输二进制文件
-            setFileType(FTP.BINARY_FILE_TYPE);
-            ftpClient.enterLocalPassiveMode();
+            this.setFileType(FTP.BINARY_FILE_TYPE);
+            this.ftpClient.enterLocalPassiveMode();
             int reply = ftpClient.getReplyCode();
             if(!FTPReply.isPositiveCompletion(reply)){
                 ftpClient.disconnect();
@@ -317,9 +317,9 @@ public class FtpFileUtil {
     public ByteArrayOutputStream download(String fileName, String filePath) {
         ByteArrayOutputStream os = new ByteArrayOutputStream();
         try{
-            connectToServer();
+            this.connectToServer();
             // 设置传输二进制文件
-            setFileType(FTP.BINARY_FILE_TYPE);
+            this.setFileType(FTP.BINARY_FILE_TYPE);
             ftpClient.enterLocalPassiveMode();
             int reply = ftpClient.getReplyCode();
             if(!FTPReply.isPositiveCompletion(reply)){
@@ -350,9 +350,9 @@ public class FtpFileUtil {
         boolean result;
         try {
             //建立连接
-            connectToServer();
+            this.connectToServer();
             ftpClient.changeWorkingDirectory("/");
-            setFileType(FTP.BINARY_FILE_TYPE);
+            this.setFileType(FTP.BINARY_FILE_TYPE);
             int reply = ftpClient.getReplyCode();
             if (!FTPReply.isPositiveCompletion(reply)) {
                 ftpClient.disconnect();