Spring FTP上傳下載工具類遇到問題小結
更新時間：2017年12月11日 11:59:01 作者：宇的季節(jié)
本文通過實例代碼給大家介紹了Spring FTP上傳下載工具類遇到問題小結，非常不錯，具有參考借鑒價值，需要的朋友參考下吧
前言
最近在項目中需要和ftp服務器進行交互，在網(wǎng)上找了一下關于ftp上傳下載的工具類，大致有兩種。
第一種是單例模式的類。
第二種是另外定義一個Service，直接通過Service來實現(xiàn)ftp的上傳下載。
這兩種感覺都有利弊。
第一種實現(xiàn)了代碼復用，但是配置信息全需要寫在類中，維護比較復雜。
第二種如果是spring框架，可以通過propertis文件，動態(tài)的注入配置信息，但是又不能代碼復用。
所以我打算自己實現(xiàn)一個工具類，來把上面的兩種優(yōu)點進行整合。順便把一些上傳過程中一些常見的問題也給解決了。
因為我使用的是spring框架，如果把工具類聲明為bean給spring管理，他默認就是單例的，所以不需要我再實現(xiàn)單例。并且因為是bean，所以我可以把properties文件的屬性注入bean的屬性中，實現(xiàn)解耦，下面是具體代碼：
package com.cky.util;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
//使用spring自動生成單例對象，
//@Component
public class FtpUtil {
//通過properties文件自動注入
@Value("${ftp.host}")
private String host; //ftp服務器ip
@Value("${ftp.port}")
private int port; //ftp服務器端口
@Value("${ftp.username}")
private String username;//用戶名
@Value("${ftp.password}")
private String password;//密碼
@Value("${ftp.basePath}")
private String basePath;//存放文件的基本路徑
//測試的時候把這個構造函數(shù)打開，設置你的初始值，然后在代碼后面的main方法運行測試
/*public FtpUtil() {
//System.out.println(this.toString());
host="192.168.100.77";
port=21;
username="ftpuser";
password="ftp54321";
basePath="/home/ftpuser/";
}*/
/**
*
* @param path 上傳文件存放在服務器的路徑
* @param filename 上傳文件名
* @param input 輸入流
* @return
*/
public boolean fileUpload(String path,String filename,InputStream input) {
FTPClient ftp=new FTPClient();
try {
ftp.connect(host, port);
ftp.login(username, password);
//設置文件編碼格式
ftp.setControlEncoding("UTF-8");
//ftp通信有兩種模式
//PORT(主動模式)客戶端開通一個新端口(>1024)并通過這個端口發(fā)送命令或傳輸數(shù)據(jù),期間服務端只使用他開通的一個端口，例如21
//PASV(被動模式)客戶端向服務端發(fā)送一個PASV命令，服務端開啟一個新端口(>1024),并使用這個端口與客戶端的21端口傳輸數(shù)據(jù)
//由于客戶端不可控，防火墻等原因，所以需要由服務端開啟端口，需要設置被動模式
ftp.enterLocalPassiveMode();
//設置傳輸方式為流方式
ftp.setFileTransferMode(FTP.STREAM_TRANSFER_MODE);
//獲取狀態(tài)碼，判斷是否連接成功
if(!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
throw new RuntimeException("FTP服務器拒絕連接");
}
//轉(zhuǎn)到上傳文件的根目錄
if(!ftp.changeWorkingDirectory(basePath)) {
throw new RuntimeException("根目錄不存在，需要創(chuàng)建");
}
//判斷是否存在目錄
if(!ftp.changeWorkingDirectory(path)) {
String[] dirs=path.split("/");
//創(chuàng)建目錄
for (String dir : dirs) {
if(null==dir||"".equals(dir)) continue;
//判斷是否存在目錄
if(!ftp.changeWorkingDirectory(dir)) {
//不存在則創(chuàng)建
if(!ftp.makeDirectory(dir)) {
throw new RuntimeException("子目錄創(chuàng)建失敗");
}
//進入新創(chuàng)建的目錄
ftp.changeWorkingDirectory(dir);
}
}
//設置上傳文件的類型為二進制類型
ftp.setFileType(FTP.BINARY_FILE_TYPE);
//上傳文件
if(!ftp.storeFile(filename, input)) {
return false;
}
input.close();
ftp.logout();
return true;
}
} catch (Exception e) {
throw new RuntimeException(e);
}finally {
if(ftp.isConnected()) {
try {
ftp.disconnect();
} catch (IOException e) {
throw new RuntimeException(e);
}
}
}
return false;
}
/**
*
* @param filename 文件名，注意！此處文件名為加路徑文件名，如：/2015/06/04/aa.jpg
* @param localPath 存放到本地第地址
* @return
*/
public boolean downloadFile(String filename,String localPath) {
FTPClient ftp=new FTPClient();
try {
ftp.connect(host, port);
ftp.login(username, password);
//設置文件編碼格式
ftp.setControlEncoding("UTF-8");
//ftp通信有兩種模式
//PORT(主動模式)客戶端開通一個新端口(>1024)并通過這個端口發(fā)送命令或傳輸數(shù)據(jù),期間服務端只使用他開通的一個端口，例如21
//PASV(被動模式)客戶端向服務端發(fā)送一個PASV命令，服務端開啟一個新端口(>1024),并使用這個端口與客戶端的21端口傳輸數(shù)據(jù)
//由于客戶端不可控，防火墻等原因，所以需要由服務端開啟端口，需要設置被動模式
ftp.enterLocalPassiveMode();
//設置傳輸方式為流方式
ftp.setFileTransferMode(FTP.STREAM_TRANSFER_MODE);
//獲取狀態(tài)碼，判斷是否連接成功
if(!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
throw new RuntimeException("FTP服務器拒絕連接");
}
int index=filename.lastIndexOf("/");
//獲取文件的路徑
String path=filename.substring(0, index);
//獲取文件名
String name=filename.substring(index+1);
//判斷是否存在目錄
if(!ftp.changeWorkingDirectory(basePath+path)) {
throw new RuntimeException("文件路徑不存在："+basePath+path);
}
//獲取該目錄所有文件
FTPFile[] files=ftp.listFiles();
for (FTPFile file : files) {
//判斷是否有目標文件
//System.out.println("文件名"+file.getName()+"---"+name);
if(file.getName().equals(name)) {
//System.out.println("找到文件");
//如果找到，將目標文件復制到本地
File localFile =new File(localPath+"/"+file.getName());
OutputStream out=new FileOutputStream(localFile);
ftp.retrieveFile(file.getName(), out);
out.close();
}
}
ftp.logout();
return true;
} catch (Exception e) {
throw new RuntimeException(e);
}finally {
if(ftp.isConnected()) {
try {
ftp.disconnect();
} catch (IOException e) {
throw new RuntimeException(e);
}
}
}
}
//兩個功能其中一個使用的話另一個需要注釋
public static void main(String []args) {
//上傳測試-----------------------------------
/*FileInputStream in;
try {
in=new FileInputStream(new File("C:\\Users\\Administrator\\Desktop\\json.png"));
FtpUtil ftputil=new FtpUtil();
boolean flag=ftputil.fileUpload("/2015/06/04", "aa.jpg", in);
System.out.println(flag);
}catch (Exception e) {
e.printStackTrace();
}finally {
}*/
//下載測試--------------------------------------
String filename="/2015/06/04/aa.jpg";
String localPath="F:\\";
FtpUtil ftputil=new FtpUtil();
ftputil.downloadFile(filename, localPath);
}
//get set方法自己添加
//..............
}
具體使用
第一步：配置spring加載properties文件
applicationContext.xml
<context:property-placeholder location="classpath:*.properties"/> ftp.properties ftp.host=192.168.100.77 ftp.port=21 ftp.username=ftpuser ftp.password=ftp54321 ftp.basePath=/home/ftpuser/
第二步：將工具類聲明為bean
xml方式
<bean id="ftpUtil" class="com.cky.util.FtpUtil">
<property name="host" value="${ftp.host}"></property>
<property name="port" value="${ftp.port}"></property>
<property name="username" value="${ftp.username}"></property>
<property name="password" value="${ftp.password}"></property>
<property name="basePath" value="${ftp.basePath}"></property>
</bean>
注解方式，組件掃描
<context:component-scan base-package="com.cky.util"></context:component-scan>
第三部：注入使用
@Autowired private FtpUtil ftpUtil;
總結
以上所述是小編給大家介紹的Spring FTP上傳下載工具類遇到問題小結，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持！
相關文章
基于kafka實現(xiàn)Spring Cloud Bus消息總線
消息總線是一種通信工具，可以在機器之間互相傳輸消息、文件等，這篇文章主要介紹了如何利用kafka實現(xiàn)SpringCloud Bus消息總線，感興趣的可以學習一下2022-04-04
這篇文章主要介紹了JVM GC 垃圾收集梳理總結，GC是一種自動的存儲管理機制。當一些被占用的內(nèi)存不再需要時，就應該予以釋放，這種存儲資源管理，稱為垃圾回收2022-07-07
SpringBoot中的ImportSelector類動態(tài)加載bean詳解
這篇文章主要介紹了SpringBoot中的ImportSelector類動態(tài)加載bean詳解,ImportSelector接口是spring中導入外部配置的核心接口,根據(jù)給定的條件(通常是一個或多個注釋屬性)判定要導入那個配置類,在spring自動化配置和@EnableXXX中都有它的存在,需要的朋友可以參考下2024-01-01
java中ArrayList 、LinkList的區(qū)別分析
java中ArrayList 、LinkList的區(qū)別分析，需要的朋友可以參考一下2013-05-05
springboot 如何配置多個jndi數(shù)據(jù)源
這篇文章主要介紹了springboot 如何配置多個jndi數(shù)據(jù)源的操作，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-07-07
SpringBoot和Vue實現(xiàn)動態(tài)二維碼的示例代碼
二維碼在現(xiàn)代社交和營銷活動中被廣泛使用,本文主要介紹了SpringBoot和Vue實現(xiàn)動態(tài)二維碼的示例代碼,文中通過示例代碼介紹的非常詳細,需要的朋友們下面隨著小編來一起學習學習吧2024-02-02
java.io.EOFException: Unexpected end of
本文主要介紹了java.io.EOFException: Unexpected end of ZLIB input stream異常解決，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-05-05
裝飾器模式又名包裝(Wrapper)模式。裝飾器模式以對客戶端透明的方式拓展對象的功能，是繼承關系的一種替代方案，本篇文章以虹貓藍兔生動形象的為你帶來詳細講解2022-04-04
mybatis多對多查詢的實現(xiàn)(xml方式和注解方式）
本文主要介紹了mybatis多對多查詢的實現(xiàn),有xml方式和注解方式兩種,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2024-08-08
Java 輕松實現(xiàn)二維數(shù)組與稀疏數(shù)組互轉(zhuǎn)
在某些應用場景中需要大量的二維數(shù)組來進行數(shù)據(jù)存儲，但是二維數(shù)組中卻有著大量的無用的位置占據(jù)著內(nèi)存空間，稀疏數(shù)組就是為了優(yōu)化二維數(shù)組，節(jié)省內(nèi)存空間2022-04-04