import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.net.SocketException;
import java.text.SimpleDateFormat;
import java.util.Properties;
import org.apache.commons.logging.Log;
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;
public class Ftp {
private static Log logger;
private static String UserName;
private static String Password;
private static String Ip;
private static int Port;
private static Properties Property = null;
private static String ConfigFile = "src/com/wwkj/cms/test/ftp/ftpconfig.properties";
private static FTPClient FtpClient = null;
private static SimpleDateFormat dateFormat = new SimpleDateFormat(
"yyyy-MM-dd hh:mm");
private static final String[] FILE_TYPES = { "文件", "目錄", "符號鏈接", "未知類型" };
public static final int BINARY_FILE_TYPE = FTP.BINARY_FILE_TYPE;
public static final int ASCII_FILE_TYPE = FTP.ASCII_FILE_TYPE;
public static int i=1;
public static void main(String[] args) {
connectServer();
setFileType(FTP.BINARY_FILE_TYPE);
closeConnect();
}
public static boolean uploadFile(String localFile, String newFileName) {
boolean flag = true;
try {
connectServer();
FtpClient.setFileType(BINARY_FILE_TYPE);
FtpClient.enterLocalPassiveMode();
FtpClient.setFileTransferMode(FTP.STREAM_TRANSFER_MODE);
File file = new File(localFile);
File newFile = new File(newFileName);
String dir = newFile.getParentFile().getPath();
if (!FtpClient.changeWorkingDirectory(dir)) {
if (!makeDirectory(newFile.getParentFile().getPath())) {
System.out.println("創建文件目錄【"+dir+"】 失敗！");
}
}
changeWorkingDirectory("/");
InputStream input = new FileInputStream(file);
if (input == null) {
System.out.println("本地文件不存在");
logger.debug("本地文件不存在,請重新選擇！");
}
if (newFileName.trim().equals("")) {
newFileName = file.getName();
}
flag = FtpClient.storeFile(newFileName, input);
if (flag) {
System.out.println("upload File succeed");
} else {
System.out.println("upload File false");
}
input.close();
} catch (IOException e) {
e.printStackTrace();
logger.debug("本地文件上傳失敗！", e);
} catch (Exception e) {
e.printStackTrace();
}
return flag;
}
public static void closeConnect() {
try {
if (FtpClient != null) {
FtpClient.logout();
FtpClient.disconnect();
}
} catch (Exception e) {
e.printStackTrace();
}
}
public static void setConfigFile(String configFile) {
Ftp.ConfigFile = configFile;
}
public static void setFileType(int fileType) {
try {
connectServer();
FtpClient.setFileType(fileType);
} catch (Exception e) {
e.printStackTrace();
}
}
protected static FTPClient getFtpClient() {
connectServer();
return FtpClient;
}
private static void setArg(String configFile) {
Property = new Properties();
BufferedInputStream inBuff = null;
try {
File file = new File(configFile);
inBuff = new BufferedInputStream(new FileInputStream(file));
Property.load(inBuff);
UserName = Property.getProperty("username");
Password = Property.getProperty("password");
Ip = Property.getProperty("ip");
Port = Integer.parseInt(Property.getProperty("port"));
} catch (FileNotFoundException e1) {
System.out.println("配置文件 【" +configFile +"】不存在！");
e1.printStackTrace();
} catch (IOException e) {
System.out.println("配置文件 【" +configFile+ "】無法讀取！");
e.printStackTrace();
}
}
public static boolean connectServer() {
boolean flag = true;
if (FtpClient == null) {
int reply;
try {
setArg(ConfigFile);
FtpClient = new FTPClient();
FtpClient.setControlEncoding("GBK");
FtpClient.setDefaultPort(Port);
FtpClient.configure(getFtpConfig());
FtpClient.connect(Ip);
FtpClient.login(UserName, Password);
FtpClient.setDefaultPort(Port);
reply = FtpClient.getReplyCode();
FtpClient.setDataTimeout(120000);
if (!FTPReply.isPositiveCompletion(reply)) {
FtpClient.disconnect();
System.err.println("FTP server refused connection.");
flag = false;
}
} 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;
}
public static void changeWorkingDirectory(String directory) {
try {
connectServer();
FtpClient.changeWorkingDirectory(directory);
} catch (IOException ioe) {
ioe.printStackTrace();
}
}
public static void renameFile(String oldFileName, String newFileName) {
try {
connectServer();
FtpClient.rename(oldFileName, newFileName);
} catch (IOException ioe) {
ioe.printStackTrace();
}
}
private static FTPClientConfig getFtpConfig() {
FTPClientConfig ftpConfig = new FTPClientConfig(
FTPClientConfig.SYST_UNIX);
ftpConfig.setServerLanguageCode(FTP.DEFAULT_CONTROL_ENCODING);
return ftpConfig;
}
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 "";
}
}
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;
}
public static Log getLogger() {
return logger;
}
public static void setLogger(Log logger) {
Ftp.logger = logger;
}
}
