/**
?? ? * 測(cè)試上傳
?? ? * @param map 從數(shù)據(jù)庫獲取到的文件信息 （包含文件路徑FILE_PATH 文件類型FILE_TYPE等信息）
?? ? */
?? ? public void testUpdFtpFile(Map<String,Object> map){
?? ??? ? /*上傳附件到FTP*/
?? ??? ? FileInputStream inputStream = null;
?? ??? ? try {
?? ??? ? ? ?//找到要上傳的文件?
?? ??? ? ?? ?String originfilename = "E:\\work\\files\\"+map.get("FILE_PATH").toString();
?? ??? ? ?? ?//轉(zhuǎn)成流
?? ??? ? ?? ?inputStream = new FileInputStream(originfilename);
?? ??? ? ? ?//上傳后的文件名+文件類型?? ??? ??? ??? ??? ??? ?
?? ??? ? ? ?String ftpName = "上傳到FTP后的文件名."+map.get("FILE_TYPE");
?? ??? ? ?? ?boolean updFtpFile = FtpClientFile.uploadFile(ftpName,inputStream);
?? ??? ? ?? ?if(updFtpFile){
?? ??? ? ?? ??? ?//打印下日志
?? ??? ? ?? ??? ?System.out.println(("=======文件已上傳到FTP========"));
?? ??? ? ?? ?}
?? ??? ? } catch (Exception e) {
?? ??? ? ?? ?throw new BusinessException("附件上傳失?。?);
?? ??? ? }
?? ? }

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
?
import com.google.gson.JsonArray;
?
/**
?* ftp 上傳文件
?* FTPClient commons.net 3.0.1版本
?* @author Lenovo
?*
?*/
public class FtpClientFile {
?? ?
?? ?private static final String hostname = "10.xx.xx.xx" ;//FTP IP
?? ?
?? ?private static final int port = 21;//FTP 端口號(hào)
?? ?
?? ?private static final String username = "ftpName";//FTP 登錄賬號(hào)
? ?
?? ?private static final String password = "ftpPsd"; //FTP 登錄密碼
?? ?
?? ?private static final String pathname = "/";//FTP 工作路徑
?? ?
?? ?
?? ?/**
?? ? * 上傳文件（可供Action/Controller層使用）
?? ? * @param fileName 上傳到FTP服務(wù)器后的文件名稱
?? ? * @param inputStream 輸入文件流
?? ? * @return
?? ? */
?? ? public static boolean uploadFile(String fileName,FileInputStream inputStream){
?? ??? ??
?? ? boolean flag = false;
?? ? FTPClient ftpClient = new FTPClient();
?? ? //設(shè)置超時(shí)
?? ? ftpClient.setConnectTimeout(60*60*1000);
?? ? //設(shè)置編碼
?? ? ftpClient.setControlEncoding("UTF-8");
?? ? try {
?? ??? ? //連接FTP服務(wù)器
?? ??? ? ftpClient.connect(hostname, port);
?? ??? ? //登錄FTP服務(wù)器
?? ??? ? ftpClient.login(username, password);
?? ??? ? //是否成功登錄FTP服務(wù)器?? ?
?? ??? ? int replyCode = ftpClient.getReplyCode();
?? ??? ? if(!FTPReply.isPositiveCompletion(replyCode)){
?? ??? ??? ? return flag;
?? ? ?? ??? ?}
?? ??? ? System.out.println("===========登錄FTP成功了==========");
?? ??? ? ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
?? ??? ? //切換路徑 創(chuàng)建路徑
?? ??? ? ftpClient.makeDirectory(pathname);
?? ??? ? ftpClient.changeWorkingDirectory(pathname);
?? ??? ? ftpClient.enterLocalPassiveMode();
?? ??? ? //設(shè)置緩沖
?? ??? ? ftpClient.setBufferSize(1024 * 1024 * 20);
?? ??? ? //保持連接
?? ??? ? ftpClient.setKeepAlive(true);
?? ??? ? boolean a = ftpClient.storeFile(new String(fileName.getBytes("utf-8"),"iso-8859-1"), inputStream);
?? ??? ? if(a){
?? ??? ??? ? System.out.println("===========創(chuàng)建文件成功=============="+a);
?? ??? ??? ??? ? String fileName2 = fileName+"AAA";
?? ??? ??? ??? ? boolean status = ftpClient.rename(fileName, fileName2);
?? ??? ??? ??? ? if(status)
?? ??? ??? ??? ? System.out.println("===========修改文件名稱成功=============="+status);
?? ??? ??? ? }
?? ??? ? inputStream.close();
?? ??? ? ftpClient.logout();
?? ??? ? flag = true;
?? ? ?? ?} catch (Exception e) {
?? ? ?? ??? ?e.printStackTrace();
?? ? ?? ?} finally{
?? ? ?? ??? ?if(ftpClient.isConnected()){
?? ? ?? ??? ??? ?try {
?? ? ?? ??? ??? ??? ?ftpClient.disconnect();
?? ? ?? ??? ??? ?} catch (IOException e) {
?? ? ?? ??? ??? ??? ?e.printStackTrace();
?? ? ?? ??? ??? ?}
?? ? ?? ??? ?}
?? ? ?? ?}
?? ? ?? ?return flag;
?? ? ?? ?
?? ? }
?? ?
?? ??
?? ? ?? ?
?? ?/* public static void main(String[] args) {
?? ??? ? String originfilename = "C:\\Users\\Lenovo\\Desktop\\xx.txt";
?? ??? ? FileInputStream inputStream;
?? ??? ? try {
?? ??? ??? ?inputStream = new FileInputStream(new File(originfilename));
?? ??? ??? ?boolean a = uploadFile("xx.txt","/104/",inputStream);
?? ??? ??? ?System.out.println("上傳文件成功============"+a);
?? ??? ? } catch (FileNotFoundException e) {
?? ??? ??? ?e.printStackTrace();
?? ??? ? }
?? ?}*/
?? ??
?? ??
}