java多线程    Java入门    vsftp    ftp    linux配置    centos    FRP教程    HBase    Html5缓存    webp    zabbix    分布式    neo4j图数据库    

apche common-net-3.0.1.jar上传FTP文件

之前用的sun的ftp包,在java7 下面,过时了,不能用,无法引入。觉得还是用Apache的吧。

下载了一个commons-net-3.0.0.jar的包搞了一通以后,发现上传的文件为0大小,郁闷啊。

在百度里翻了半天别人问的这个问题,无正确回答

最后跑google翻出去看外国人说是包有毛病,得用3.0.1的,于是跑去下载个commons-net-3.0.1.jar,就成功了。

伟大的google啊。(真是百度一根毛也找不到)

顺便提供一份commons-net-3.0.1.jar包下载(我快翻遍了百度google,才找到这个。CSDN要积分,我积分消耗完毕了。)

下载jar包, 网盘
链接:https://pan.baidu.com/s/1d04G9XA8rZ4xjjxHm8UK8w 密码:ead2

package com.javaer.commcon;

import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPClientConfig;
import org.apache.commons.net.ftp.FTPReply;

import java.io.*;
import java.net.SocketException;
import java.text.SimpleDateFormat;

public class AFtp {

	private static String userName; // FTP 登录用户名
	private static String password; // FTP 登录密码
	private static String ip; // FTP 服务器地址IP地址
	private static int port; // FTP 端口
	private static FTPClient ftpClient = null; // FTP 客户端代理
	// FTP状态码
	public static int i = 1;

	public static void main(String[] args) {
		setArg("db2","123455","122.111.1.23",21);
		connectServer();
		uploadFile("/a.html" , "/b.html");
		closeConnect();// 关闭连接
	}
	
	/**
	 * 设置参数
	 * 
	 * @param configFile
	 *            --参数的配置文件
	 */
	public  static void setArg(String user,String pwd,String IP,int PORT) {
		// property = new Properties();

		userName = user;
		password = pwd;
		ip = IP;
		port = PORT;


	}

	/**
	 * 上传单个文件,并重命名
	 * 
	 * @param localFile
	 *            --本地文件路径
	 * @param distFolder
	 *            --新的文件名,可以命名为空""
	 * @return true 上传成功,false 上传失败
	 */
	public static boolean uploadFile(String local, final String dist) {
		boolean flag = true;
		try {
			connectServer();
			ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
			ftpClient.enterLocalPassiveMode();
			ftpClient.setFileTransferMode(FTP.STREAM_TRANSFER_MODE);

			ftpClient.setBufferSize(1024 * 2);
			ftpClient.setDataTimeout(2000);
			
			File localFile= new File(local);
			
			InputStream input = new FileInputStream(localFile);
			BufferedInputStream inStream = null;
			inStream = new BufferedInputStream(input);
			
			System.out.println("本地文件名字" + localFile.getName() + " size:" + localFile.length());

			flag = ftpClient.storeFile(dist, inStream);
			inStream.close();
			if (flag) {
				System.out.println("上传文件成功!");
			} else {
				System.out.println("上传文件失败!");
			}
			input.close();
		} catch (IOException e) {
			e.printStackTrace();
			System.out.println("本地文件上传失败!");
		} catch (Exception e) {
			e.printStackTrace();
		}
		return flag;
	}

	/**
	 * 删除一个文件
	 */
	public static boolean deleteFile(String filename) {
		boolean flag = true;
		try {
			connectServer();
			flag = ftpClient.deleteFile(filename);
			if (flag) {
				System.out.println("删除文件成功!");
			} else {
				System.out.println("删除文件失败!");
			}
		} catch (IOException ioe) {
			ioe.printStackTrace();
		}
		return flag;
	}

	/**
	 * 列出服务器上文件和目录
	 * 
	 * @param regStr
	 *            --匹配的正则表达式
	 */
	public static void listRemoteFiles(String regStr) {
		connectServer();
		try {
			String files[] = ftpClient.listNames(regStr);
			if (files == null || files.length == 0)
				System.out.println("没有任何文件!");
			else {
				for (int i = 0; i < files.length; i++) {
					System.out.println(files[i]);
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	/**
	 * 关闭连接
	 */
	public static void closeConnect() {
		try {
			if (ftpClient != null) {
				ftpClient.logout();
				ftpClient.disconnect();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}


	/**
	 * 设置传输文件的类型[文本文件或者二进制文件]
	 * 
	 * @param fileType
	 *            --BINARY_FILE_TYPE、ASCII_FILE_TYPE
	 * 
	 */
	public static void setFileType(int fileType) {
		try {
			connectServer();
			ftpClient.setFileType(fileType);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	/**
	 * 扩展使用
	 * 
	 * @return ftpClient
	 */
	protected static FTPClient getFtpClient() {
		connectServer();
		return ftpClient;
	}

	

	/**
	 * 连接到服务器
	 * 
	 * @return true 连接服务器成功,false 连接服务器失败
	 */
	public static boolean connectServer() {
		boolean flag = true;
		if (ftpClient == null) {
			int reply;
			try {
				ftpClient = new FTPClient();
				ftpClient.setControlEncoding("GBK");
				ftpClient.setDefaultPort(port);
				ftpClient.configure(getFtpConfig());
				ftpClient.connect(ip);
				ftpClient.login(userName, password);
				ftpClient.setDefaultPort(port);
				System.out.print(ftpClient.getReplyString());
				reply = ftpClient.getReplyCode();
				ftpClient.setDataTimeout(120000);

				if (!FTPReply.isPositiveCompletion(reply)) {
					ftpClient.disconnect();
					System.err.println("FTP server refused connection.");
					// System.out.println("FTP 服务拒绝连接!");
					flag = false;
				}
				// System.out.println(i);
				i++;
			} catch (SocketException e) {
				flag = false;
				e.printStackTrace();
				System.err.println("登录ftp服务器 " + ip + " 失败,连接超时!");
			} catch (IOException e) {
				flag = false;
				e.printStackTrace();
				System.err.println("登录ftp服务器 " + ip + " 失败,FTP服务器无法打开!");
			}
		}
		return flag;
	}

	/**
	 * 进入到服务器的某个目录下
	 * 
	 * @param directory
	 */
	public static void changeWorkingDirectory(String directory) {
		try {
			connectServer();
			ftpClient.changeWorkingDirectory(directory);
		} catch (IOException ioe) {
			ioe.printStackTrace();
		}
	}

	/**
	 * 返回到上一层目录
	 */
	public static void changeToParentDirectory() {
		try {
			connectServer();
			ftpClient.changeToParentDirectory();
		} catch (IOException ioe) {
			ioe.printStackTrace();
		}
	}

	/**
	 * 重命名文件
	 * 
	 * @param oldFileName
	 *            --原文件名
	 * @param newFileName
	 *            --新文件名
	 */
	public static void renameFile(String oldFileName, String newFileName) {
		try {
			connectServer();
			ftpClient.rename(oldFileName, newFileName);
		} catch (IOException ioe) {
			ioe.printStackTrace();
		}
	}

	/**
	 * 设置FTP客服端的配置--一般可以不设置
	 * 
	 * @return ftpConfig
	 */
	private static FTPClientConfig getFtpConfig() {
		FTPClientConfig ftpConfig = new FTPClientConfig(
				FTPClientConfig.SYST_UNIX);
		ftpConfig.setServerLanguageCode(FTP.DEFAULT_CONTROL_ENCODING);
		return ftpConfig;
	}

	/**
	 * 转码[ISO-8859-1 -> GBK] 不同的平台需要不同的转码
	 * 
	 * @param obj
	 * @return ""
	 */
	private static String iso8859togbk(Object obj) {
		try {
			if (obj == null)
				return "";
			else
				return new String(obj.toString().getBytes("iso-8859-1"), "GBK");
		} catch (Exception e) {
			return "";
		}
	}

	/**
	 * 在服务器上创建一个文件夹
	 * 
	 * @param dir
	 *            文件夹名称,不能含有特殊字符,如 \ 、/ 、: 、* 、?、 "、 <、>...
	 */
	public static boolean makeDirectory(String dir) {
		connectServer();
		boolean flag = true;
		try {
			flag = ftpClient.makeDirectory(dir);
			if (flag) {
				System.out.println("make Directory " + dir + " succeed");

			} else {

				System.out.println("make Directory " + dir + " false");
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return flag;
	}

}


This entry was posted in JAVA and tagged , , , . Bookmark the permalink.
月小升QQ 2651044202, 技术交流QQ群 178491360
首发地址:月小升博客https://java-er.com/blog/apche-ftp-common-3-0-net/
无特殊说明,文章均为月小升原创,欢迎转载,转载请注明本文地址,谢谢
您的评论是我写作的动力.

Leave a Reply