FTP

package com.lhw.ftp;
import java.io.FileInputStream;
import java.io.IOException;
import java.util.StringTokenizer;
import sun.net.TelnetOutputStream;
import sun.net.ftp.FtpClient;
/**
* FTP文件配置远程连接
*/
public class FtpClientUtil {
String localfilename;
String remotefilename;
FtpClient ftpClient;
public FtpClientUtil() {
ftpClient = new FtpClient();
}
/***************************************************************************
* 判断指定ftp服务器是否能够连接，并且指定目录
* @param ip
* @param port
* @param user
* @param password
* @param path
* @throws IOException
*/
public void connectServer(String ip, int port, String user,
String password, String path) throws IOException {
ftpClient.openServer(ip, port);
ftpClient.login(user, password);
System.out.println("login success!");
ftpClient.ascii();
//ftpClient.binary();
}
public void connectServer(String ip, int port, String user, String password)
throws IOException {
ftpClient.openServer(ip, port);
ftpClient.login(user, password);
String currentpath = ftpClient.pwd();
System.out.println(ip + "login success!");
ftpClient.ascii();
//ftpClient.binary();
}
/***************************************************************************
* 指向指定路径，指定文件加，用来放置上传文件，同时制定下载文件的路径， 那么每次上传下载文件，要先做这个操作，指定到某个路径(文件??
*
* @param ftpClient
* @param path
* @throws Exception
*/
public void cdPath(String path) throws Exception {
boolean isexit = false;// 标识文件夹或者文件是否存??
if (path.length() != 0) {
// isexit = isDirExist(path);
// if (isexit == false) {
// createDir(path);
// }
try {
ftpClient.cd(path);
} catch (IOException e) {
throw new Exception(path + ",该路经不存在,或??无权访问该目");
}
}
}
/***************************************************************************
* 用来????ftp服务器能否连接，这里????这么????,我这个直接用ajax来实现，用来
* @param ip
* @param port
* @param user
* @param password
* @return
* @throws IOException
*/
public boolean connectServercheckByIndex(String ip, int port, String user,
String password,String path){
FtpClient ftpCli = new FtpClient();
try {
ftpCli.openServer(ip, port);
ftpCli.login(user, password);
ftpCli.cd(path);
System.out.println("login success!");
} catch (IOException e) {
return false;
} finally {
try {
if (ftpCli.serverIsOpen()) {
ftpCli.closeServer();
System.out.println("disconnect success");
}
} catch (IOException ex) {
System.out.println("not disconnect");
System.out.println(ex);
return false;
}
}
return true;
}

评论

4 楼 aiyalhw 2009-12-16  

/***************************************************************************
* 上传文件，在我们进行上传文件的过程中，我这里????进行的一个问题， 在上传之前，看需不需要指定路径， 如果ftp服务器上没有
* @throws Exception
*/
public void upload() throws Exception {
IniFileClientUtil filecreate = new IniFileClientUtil();
filecreate.createFile("HappyHappy",
"D:/workspace/INFOX-EXPSMSV100R002C02B06/WebContent/TEMPINIFODER/systemconfig2009-10-20-21-07-31.ini");
this.localfilename = "D://aaa.txt";
this.remotefilename = "kkkkk.txt";
TelnetOutputStream os = null;
FileInputStream is = null;
try {
java.io.File file_in = new java.io.File(this.localfilename);
if (!file_in.exists()) {
throw new Exception("此文件或文件夹[" + file_in.getName() + "]有误或不存在!");
}
os = ftpClient.put(this.remotefilename);
is = new FileInputStream(file_in);
byte[] bytes = new byte[1024];
int c;
while ((c = is.read(bytes)) != -1) {
os.write(bytes, 0, c);
}
System.out.println("upload success");
} catch (IOException ex) {
System.out.println("not upload");
System.out.println(ex);
}finally{
try {
if(is!=null){
is.close();
}
if(os!=null){
os.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}

3 楼 aiyalhw 2009-12-16  

/**
* 在当前目录下创建文件??
*
*
* @param dir
* @return
* @throws Exception
* @throws Exception
*/
private void createDir(String dir) throws Exception {
try {
String pathName = "";
ftpClient.ascii();
StringTokenizer s = new StringTokenizer(dir, "/"); // sign
s.countTokens();
while (s.hasMoreElements()) {
pathName = pathName + "/" + (String) s.nextElement();
ftpClient.sendServer("MKD " + pathName + "\r\n");
System.out.println(ftpClient.serverInput.read());
int responsecode = ftpClient.readServerResponse();
}
ftpClient.ascii();
//ftpClient.binary();

} catch (IOException e1) {
throw new Exception("用户提供的路径不存在，创建路经有问题，可能无权限");
}
}

/**
* 验证文件夹在当前目录下是否存?
* @param dir
* @return
*/
private boolean isDirExist(String dir) {
try {
ftpClient.cd(dir);
} catch (Exception e) {
return false;
}
return true;
}

public FtpClient getFtpClient() {
return ftpClient;
}

public void setFtpClient(FtpClient ftpClient) {
this.ftpClient = ftpClient;
}

public static void main(String agrs[]) {
FtpClientUtil fu = new FtpClientUtil();
try {
//FTP检测连接
if(fu.connectServercheck("127.0.0.1", 21, "ROOT", "123456")){
//初始化连接
fu.connectServer("127.0.0.1", 21, "ROOT", "123456",
"testTemp/tppp");
// 这个字符串，????到常量类当中去进行配??
String newName = "/home/smsweb/Documents/aa";
boolean isexit = fu.isDirExist(newName);
System.out.println("isexit=======" + isexit);
if (!fu.isDirExist(newName)) {
fu.createDir(newName);
}
fu.ftpClient.cd(newName);
fu.upload();
}else{
System.out.println("无法获取连接！！！");
}

} catch (Exception e) {
e.printStackTrace();
}
fu.closeConnect();
}

2 楼 aiyalhw 2009-12-16  

/****
* 该方法用来上传文??
* @param localfilename
*            临时文件，可能是多级目录下的文件，需要生成多级目??
* @param remotefilename
*            这个是用来上传到我们ftp服务器上以后显示的名??我这里想知道的呢？就是我这里这些目录的??择，
* 我是不是????用户进行路径配置呢？我这里是有这个路径配置的??其次还有点，就是这个页面的，某个文本框的用户输入都要做限??
* @throws Exception
*/
public void upload(String localfilename, String remotefilename)
throws Exception {
// 如何生成????临时文件路径下生成一个临时文件夹，我应该放到我们的工程上的临时目录上好了??
// 然后上传到对应的这个ftp配置，我本地不需要备份了，查看数据库记录就行了???????
this.localfilename = localfilename;
this.remotefilename = remotefilename;
TelnetOutputStream os = null;
FileInputStream is = null;
java.io.File file_in = null;
try {
os = ftpClient.put(this.remotefilename);
file_in = new java.io.File(this.localfilename);
if (!file_in.exists()) {
throw new Exception("此文件或文件夹[" + file_in.getName() + "]有误或不存在!");
}
is = new FileInputStream(file_in);
byte[] bytes = new byte[1024];
int c;
while ((c = is.read(bytes)) != -1) {
os.write(bytes, 0, c);
}
System.out.println("upload success");

} catch (IOException e) {
// e.printStackTrace();
System.err.println("Exception e in Ftp upload(): " + e.toString());
// return false;
throw new Exception("ini文件上传失败,可能无上传权?");

} finally {
try {
if (is != null) {
is.close();
}
if (os != null) {
os.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}

/**
* 得到当前FTP服务器路径
* @return
*/
public String getCurrentFtpPath() {
String currentFtpPath = "";
try {
currentFtpPath = ftpClient.pwd();
} catch (IOException e) {
e.printStackTrace();
}
return currentFtpPath;
}

1 楼 aiyalhw 2009-12-16  

/***************************************************************************
* 用来????ftp服务器能否连接，这里????这么????,我这个直接用ajax来实现，用来
* @param ip
* @param port
* @param user
* @param password
* @return
* @throws IOException
*/
public void connectServercheck(String ip, int port, String user,
String password,String path) throws Exception {
FtpClient ftpCli = new FtpClient();
try {
ftpCli.openServer(ip, port);
ftpCli.login(user, password);
System.out.println("login success!");
try {
ftpCli.cd(path);
} catch (Exception e) {
// TODO Auto-generated catch block
throw new Exception("登录成功,访问路径失败,请检查路径或者是否有访问权限");
} finally {
try {
if (ftpCli.serverIsOpen()) {
ftpCli.closeServer();
System.out.println("disconnect success");
}
} catch (IOException ex) {
System.out.println("not disconnect");
System.out.println(ex);
}
}
} catch (IOException e) {
throw new Exception("FTP信息登录失败,请检查用户名密码IP或端");
} finally {
try {
if (ftpCli.serverIsOpen()) {
ftpCli.closeServer();
System.out.println("disconnect success");
}

} catch (IOException ex) {
System.out.println("not disconnect");
System.out.println(ex);
}
}
}
/**
* FTP 服务器连接检测
* @param ip
* @param port
* @param user
* @param password
* @return
*/
public boolean connectServercheck(String ip, int port, String user,
String password) {
FtpClient ftpCli = new FtpClient();
try {
ftpCli.openServer(ip, port);
ftpCli.login(user, password);
System.out.println("login success!");
} catch (IOException e) {
System.out.println("Error Information of Ftp,Login fail");
return false;
} finally {
try {
if (ftpCli.serverIsOpen()) {
ftpCli.closeServer();
System.out.println("disconnect success");
}
} catch (IOException ex) {
System.out.println("not disconnect");
System.out.println(ex);
}
}
return true;
}
/**
* 此方法用来，关闭ftp的连??
*
*/
public void closeConnect() {
try {
if (ftpClient.serverIsOpen()) {
ftpClient.closeServer();
System.out.println("disconnect success");
}
} catch (IOException ex) {
System.out.println("not disconnect");
System.out.println(ex);
}

}