java中使用FTP進行圖片的上傳
阿新 • • 發佈：2018-08-18
let pack ddn true download ati eno exce list
使用ftp需要引入兩個jar包（commons-net、commons-fileupload）
1、添加ftp服務器配置文件
#FTP FTP_ADDRESS=192.168.25.133 //目標服務器ip FTP_PORT=21 //ftp默認端口21 FTP_USERNAME=ftpuser //用戶名 FTP_PASSWORD=ftpuser //密碼 FTP_BASE_PATH=/home/ftpuser/www/images //上傳路徑 #picServerBaseUrl IMAGE_BASE_URL=http://192.168.25.133/images //基礎路徑
2、使用@Value 註解獲取ftp上傳文件的配置文件中的屬性值
@Value("${FTP_ADDRESS}")
private String host;
@Value("${FTP_PORT}")
private int port;
@Value("${FTP_USERNAME}")
private String username;
@Value("${FTP_PASSWORD}")
private String password;
@Value("${FTP_BASE_PATH}")
private String basePath;
@Value(
3、ftp上傳下載文件工具類
package com.taotao.common.utils; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; 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; /** * ftp上傳下載工具類 * <p>Title: FtpUtil</p> * <p>Description: </p> * <p>Company: www.itcast.com</p> * @author 入雲龍 * @date 2015年7月29日下午8:11:51 * @version 1.0 */ public class FtpUtil { /** * Description: 向FTP服務器上傳文件 * @param host FTP服務器hostname * @param port FTP服務器端口 * @param username FTP登錄賬號 * @param password FTP登錄密碼 * @param basePath FTP服務器基礎目錄 * @param filePath FTP服務器文件存放路徑。例如分日期存放：/2015/01/01。文件的路徑為basePath+filePath * @param filename 上傳到FTP服務器上的文件名 * @param input 輸入流 * @return 成功返回true，否則返回false */ public static boolean uploadFile(String host, int port, String username, String password, String basePath, String filePath, String filename, InputStream input) { boolean result = false; FTPClient ftp = new FTPClient(); try { int reply; ftp.connect(host, port);// 連接FTP服務器 // 如果采用默認端口，可以使用ftp.connect(host)的方式直接連接FTP服務器 ftp.login(username, password);// 登錄 reply = ftp.getReplyCode(); if (!FTPReply.isPositiveCompletion(reply)) { ftp.disconnect(); return result; } //切換到上傳目錄 if (!ftp.changeWorkingDirectory(basePath+filePath)) { //如果目錄不存在創建目錄 String[] dirs = filePath.split("/"); String tempPath = basePath; for (String dir : dirs) { if (null == dir || "".equals(dir)) continue; tempPath += "/" + dir; if (!ftp.changeWorkingDirectory(tempPath)) { if (!ftp.makeDirectory(tempPath)) { return result; } else { ftp.changeWorkingDirectory(tempPath); } } } } //設置上傳文件的類型為二進制類型 ftp.setFileType(FTP.BINARY_FILE_TYPE); //上傳文件 if (!ftp.storeFile(filename, input)) { return result; } input.close(); ftp.logout(); result = true; } catch (IOException e) { e.printStackTrace(); } finally { if (ftp.isConnected()) { try { ftp.disconnect(); } catch (IOException ioe) { } } } return result; } /** * Description: 從FTP服務器下載文件 * @param host FTP服務器hostname * @param port FTP服務器端口 * @param username FTP登錄賬號 * @param password FTP登錄密碼 * @param remotePath FTP服務器上的相對路徑 * @param fileName 要下載的文件名 * @param localPath 下載後保存到本地的路徑 * @return */ public static boolean downloadFile(String host, int port, String username, String password, String remotePath, String fileName, String localPath) { boolean result = false; FTPClient ftp = new FTPClient(); try { int reply; ftp.connect(host, port); // 如果采用默認端口，可以使用ftp.connect(host)的方式直接連接FTP服務器 ftp.login(username, password);// 登錄 reply = ftp.getReplyCode(); if (!FTPReply.isPositiveCompletion(reply)) { ftp.disconnect(); return result; } ftp.changeWorkingDirectory(remotePath);// 轉移到FTP服務器目錄 FTPFile[] fs = ftp.listFiles(); for (FTPFile ff : fs) { if (ff.getName().equals(fileName)) { File localFile = new File(localPath + "/" + ff.getName()); OutputStream is = new FileOutputStream(localFile); ftp.retrieveFile(ff.getName(), is); is.close(); } } ftp.logout(); result = true; } catch (IOException e) { e.printStackTrace(); } finally { if (ftp.isConnected()) { try { ftp.disconnect(); } catch (IOException ioe) { } } } return result; } public static void main(String[] args) { try { FileInputStream in=new FileInputStream(new File("D:\\temp\\image\\gaigeming.jpg")); boolean flag = uploadFile("192.168.25.133", 21, "ftpuser", "ftpuser", "/home/ftpuser/www/images","/2015/01/21", "gaigeming.jpg", in); System.out.println(flag); } catch (FileNotFoundException e) { e.printStackTrace(); } } }
4、圖片上傳業務層代碼
//圖片上傳結果json數據格式，成功結果:error=0,url="圖片上傳成功後目標路徑"；失敗error=1,message="上傳文件失敗"
/** * 圖片上傳 */ public Map<String, Object> uploadPic(MultipartFile multipartFile) { Map<String, Object> resultMap = new HashMap<>(); try { //將圖片重新命名 //獲取原始圖片名稱 String oddName = multipartFile.getOriginalFilename(); //獲取原始圖片擴展名 String kzm = oddName.substring(oddName.lastIndexOf(".")); //重新命名圖片 String newName = IDUtils.genImageName() + kzm; //圖片上傳 String filepath = new DateTime().toString("/yyyy/MM/dd"); boolean flag = FtpUtil.uploadFile(host, port, username, password, basePath, filepath , newName, multipartFile.getInputStream()); if (flag) { resultMap.put("error", 0); resultMap.put("url", IMAGE_BASE_URL + filepath + "/" + newName); }else { resultMap.put("error", 1); resultMap.put("message", "圖片上傳失敗！"); } } catch (IOException e) { e.printStackTrace(); resultMap.put("error", 1); resultMap.put("message", "圖片上傳發生異常！"); } return resultMap; }
5、圖片上傳表現層代碼
/** * 圖片上傳 * @param uploadFile * @return String */ @RequestMapping("/pic/upload") @ResponseBody public String uploadFile(MultipartFile uploadFile){ Map<String, Object> result = pictureServer.uploadPic(uploadFile); //為保證此上傳功能在不同瀏覽器正常運行，需要將返回結果轉換為json格式數據 String resultJson = JsonUtils.objectToJson(result); return resultJson; }
5中需要的JsonUtils工具類
package com.taotao.common.utils; import java.util.List; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.JavaType; import com.fasterxml.jackson.databind.ObjectMapper; /** * 淘淘商城自定義響應結構 */ public class JsonUtils { // 定義jackson對象 private static final ObjectMapper MAPPER = new ObjectMapper(); /** * 將對象轉換成json字符串。 * <p>Title: pojoToJson</p> * <p>Description: </p> * @param data * @return */ public static String objectToJson(Object data) { try { String string = MAPPER.writeValueAsString(data); return string; } catch (JsonProcessingException e) { e.printStackTrace(); } return null; } /** * 將json結果集轉化為對象 * * @param jsonData json數據 * @param clazz 對象中的object類型 * @return */ public static <T> T jsonToPojo(String jsonData, Class<T> beanType) { try { T t = MAPPER.readValue(jsonData, beanType); return t; } catch (Exception e) { e.printStackTrace(); } return null; } /** * 將json數據轉換成pojo對象list * <p>Title: jsonToList</p> * <p>Description: </p> * @param jsonData * @param beanType * @return */ public static <T>List<T> jsonToList(String jsonData, Class<T> beanType) { JavaType javaType = MAPPER.getTypeFactory().constructParametricType(List.class, beanType); try { List<T> list = MAPPER.readValue(jsonData, javaType); return list; } catch (Exception e) { e.printStackTrace(); } return null; } }
java中使用FTP進行圖片的上傳