之前用的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;
}
}