| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311 |
- package com.goafanti.common.utils;
- import java.io.File;
- import java.io.FileInputStream;
- import java.io.FileOutputStream;
- import java.io.IOException;
- import java.io.InputStream;
- import java.io.OutputStream;
- import java.net.MalformedURLException;
- import org.apache.commons.net.ftp.FTPClient;
- import org.apache.commons.net.ftp.FTPFile;
- import org.apache.commons.net.ftp.FTPReply;
- public class FtpUtils {
- //ftp服务器地址
- public static final String HOSTNAME = "118.190.205.7";
- //ftp服务器端口号默认为21
- public static final Integer PORT = 21 ;
- //ftp登录账号
- public static final String USERNAME = "video";
- //ftp登录密码
- public static final String PASSWORD = "aft2018";
-
- public FTPClient ftpClient = null;
- /**
- * 初始化ftp服务器
- */
- public void initFtpClient() {
- ftpClient = new FTPClient();
- ftpClient.setControlEncoding("utf-8");
- try {
- System.out.println("connecting...ftp服务器:"+ HOSTNAME+":"+ PORT);
- ftpClient.connect(HOSTNAME, PORT); //连接ftp服务器
- ftpClient.login(USERNAME, PASSWORD); //登录ftp服务器
- int replyCode = ftpClient.getReplyCode(); //是否成功登录服务器
- if(!FTPReply.isPositiveCompletion(replyCode)){
- System.out.println("connect failed...ftp服务器:"+ HOSTNAME+":"+ PORT);
- }
- System.out.println("connect successfu...ftp服务器:"+ HOSTNAME+":"+ PORT);
- }catch (MalformedURLException e) {
- e.printStackTrace();
- }catch (IOException e) {
- e.printStackTrace();
- }
- }
-
- /**
- * 上传文件
- * @param pathname ftp服务保存地址
- * @param fileName 上传到ftp的文件名
- * @param originfilename 待上传文件的名称(绝对地址) *
- * @return
- */
- public boolean uploadFile( String pathname, String fileName,String originfilename){
- boolean flag = false;
- InputStream inputStream = null;
- try{
- System.out.println("开始上传文件");
- inputStream = new FileInputStream(new File(originfilename));
- System.out.println(inputStream==null?"null":"notnull");
- initFtpClient();
- ftpClient.setFileType(ftpClient.BINARY_FILE_TYPE);
- CreateDirecroty(pathname);
- System.out.println("11111ftp服务保存地址"+pathname);
- System.out.println("22222上传到ftp的文件名"+fileName);
- System.out.println("33333待上传文件的名称"+originfilename);
- System.out.println("44444创建指定文件夹");
- System.out.println("55555===" + ftpClient.makeDirectory(pathname));
- System.out.println("66666/*/*" + ftpClient.changeWorkingDirectory(pathname));
- ftpClient.enterLocalPassiveMode();
- System.out.println("77777#####"+ftpClient.storeFile(fileName, inputStream));
- inputStream.close();
- ftpClient.logout();
- System.out.println("888888注销ftp");
- flag = true;
- System.out.println("上传文件成功");
- }catch (Exception e) {
- System.out.println("上传文件失败");
- e.printStackTrace();
- }finally{
- System.out.println("finally处理");
- if(ftpClient.isConnected()){
- try{
- ftpClient.disconnect();
- }catch(IOException e){
- e.printStackTrace();
- }
- }
- if(null != inputStream){
- try {
- inputStream.close();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- }
- return true;
- }
- /**
- * 上传文件
- * @param pathname ftp服务保存地址
- * @param fileName 上传到ftp的文件名
- * @param inputStream 输入文件流
- * @return
- */
- public boolean uploadFile( String pathname, String fileName,InputStream inputStream){
- boolean flag = false;
- try{
- System.out.println("开始上传文件");
- initFtpClient();
- ftpClient.setFileType(ftpClient.BINARY_FILE_TYPE);
- CreateDirecroty(pathname);
- ftpClient.makeDirectory(pathname);
- ftpClient.changeWorkingDirectory(pathname);
- ftpClient.storeFile(fileName, inputStream);
- inputStream.close();
- ftpClient.logout();
- flag = true;
- System.out.println("上传文件成功");
- }catch (Exception e) {
- System.out.println("上传文件失败");
- e.printStackTrace();
- }finally{
- if(ftpClient.isConnected()){
- try{
- ftpClient.disconnect();
- }catch(IOException e){
- e.printStackTrace();
- }
- }
- if(null != inputStream){
- try {
- inputStream.close();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- }
- return true;
- }
- //改变目录路径
- public boolean changeWorkingDirectory(String directory) {
- boolean flag = true;
- try {
- flag = ftpClient.changeWorkingDirectory(directory);
- if (flag) {
- System.out.println("进入文件夹" + directory + " 成功!");
- } else {
- System.out.println("进入文件夹" + directory + " 失败!开始创建文件夹");
- }
- } catch (IOException ioe) {
- ioe.printStackTrace();
- }
- return flag;
- }
- //创建多层目录文件,如果有ftp服务器已存在该文件,则不创建,如果无,则创建
- public boolean CreateDirecroty(String remote) throws IOException {
- boolean success = true;
- String directory = remote + "/";
- // 如果远程目录不存在,则递归创建远程服务器目录
- if (!directory.equalsIgnoreCase("/") && !changeWorkingDirectory(new String(directory))) {
- int start = 0;
- int end = 0;
- if (directory.startsWith("/")) {
- start = 1;
- } else {
- start = 0;
- }
- end = directory.indexOf("/", start);
- String path = "";
- String paths = "";
- while (true) {
- String subDirectory = new String(remote.substring(start, end).getBytes("GBK"), "iso-8859-1");
- path = path + "/" + subDirectory;
- if (!existFile(path)) {
- if (makeDirectory(subDirectory)) {
- changeWorkingDirectory(subDirectory);
- } else {
- System.out.println("创建目录[" + subDirectory + "]失败");
- changeWorkingDirectory(subDirectory);
- }
- } else {
- changeWorkingDirectory(subDirectory);
- }
- paths = paths + "/" + subDirectory;
- start = end + 1;
- end = directory.indexOf("/", start);
- // 检查所有目录是否创建完毕
- if (end <= start) {
- break;
- }
- }
- }
- return success;
- }
- //判断ftp服务器文件是否存在
- public boolean existFile(String path) throws IOException {
- boolean flag = false;
- FTPFile[] ftpFileArr = ftpClient.listFiles(path);
- if (ftpFileArr.length > 0) {
- flag = true;
- }
- return flag;
- }
- //创建目录
- public boolean makeDirectory(String dir) {
- boolean flag = true;
- try {
- flag = ftpClient.makeDirectory(dir);
- if (flag) {
- System.out.println("创建文件夹" + dir + " 成功!");
- } else {
- System.out.println("创建文件夹" + dir + " 失败!");
- }
- } catch (Exception e) {
- e.printStackTrace();
- }
- return flag;
- }
-
- /** * 下载文件 *
- * @param pathname FTP服务器文件目录 *
- * @param filename 文件名称 *
- * @param localpath 下载后的文件路径 *
- * @return */
- public boolean downloadFile(String pathname, String filename, String localpath){
- boolean flag = false;
- OutputStream os=null;
- try {
- System.out.println("开始下载文件");
- initFtpClient();
- //切换FTP目录
- ftpClient.changeWorkingDirectory(pathname);
- FTPFile[] ftpFiles = ftpClient.listFiles();
- for(FTPFile file : ftpFiles){
- if(filename.equalsIgnoreCase(file.getName())){
- File localFile = new File(localpath + "/" + file.getName());
- os = new FileOutputStream(localFile);
- ftpClient.retrieveFile(file.getName(), os);
- os.close();
- }
- }
- ftpClient.logout();
- flag = true;
- System.out.println("下载文件成功");
- } catch (Exception e) {
- System.out.println("下载文件失败");
- e.printStackTrace();
- } finally{
- if(ftpClient.isConnected()){
- try{
- ftpClient.disconnect();
- }catch(IOException e){
- e.printStackTrace();
- }
- }
- if(null != os){
- try {
- os.close();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- }
- return flag;
- }
-
- /** * 删除文件 *
- * @param pathname FTP服务器保存目录 *
- * @param filename 要删除的文件名称 *
- * @return */
- public boolean deleteFile(String pathname, String filename){
- boolean flag = false;
- try {
- System.out.println("开始删除文件");
- initFtpClient();
- //切换FTP目录
- ftpClient.changeWorkingDirectory(pathname);
- ftpClient.dele(filename);
- ftpClient.logout();
- flag = true;
- System.out.println("删除文件成功");
- } catch (Exception e) {
- System.out.println("删除文件失败");
- e.printStackTrace();
- } finally {
- if(ftpClient.isConnected()){
- try{
- ftpClient.disconnect();
- }catch(IOException e){
- e.printStackTrace();
- }
- }
- }
- return flag;
- }
-
- public static void main(String[] args) {
- FtpUtils ftp =new FtpUtils();
- ftp.uploadFile("ftpFile/data", "aaa.avi", "F:\\BaiduNetdiskDownload\\day63_project_OA_day12_JBPM04\\video\\aaa.avi");
- System.out.println("ok");
- }
-
- }
|