java编写ftp下载工具.docx

《java编写ftp下载工具.docx》由会员分享，可在线阅读，更多相关《java编写ftp下载工具.docx（12页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、java编写ftp下载工具需要用到java写一个ftp的工具，因为只有一点点java基础，但是由于好几年不用， 几乎算是不会了，只好一点点来搞，还好能捡起来。不过因为是在Linux下使用javac编译，不是在WIN下使用IDE来做这些事情，所以在 运行和编译上又费了一些时间，不过正是因为这样对JAVA的一些编译、运行的知识又了解 了一些。对于ftp下载工具，代码如下：复制代码代码如下：import java. io. File;import java. io. FilelnputStream;import java. io. FileNotFoundException;import java.

2、 io. FileOutputStream;import java. io. lOException;import java. io. InputStream;import java. io. OutputStream;import java. net. SocketException;import org. apache, commons, net. ftp.FTPCIient;import org. apache, commons, net. ftp.FTPReply;public class FtpClient private String host;private int port;p

3、rivate String username;复制代码代码如下: import org. apache, commons. net. ftp. FTPCIient;这个包在apache的网站上直接下载就行，解压后找到对应的jar包，在编译的时候进行 引用：复制代码代码如下：export FTPPATH=$ 路径/xxx. jarjavac -classpath $CLASSPATH:$FTPPATH FtpClient. java同样，在运行的时候也要指定classpath：复制代码代码如下：java -classpath $CLASSPATH:$FTPPATH FtpClient建议不要把$

4、FTPPATH包含在CLASSPATH中，用什么包就引用什么环境变量就行了，没必要 一股脑都添加进去，就像我们没必要import所有的包一样。private String password;private boolean binaryTransfer = true;private boolean passiveMode = true;private String encoding = UTF-8；private int clientTimeout = 3000;private boolean flag=true;private FTPCIient ftpClient = null;public

5、 String getHost() return host;public void setHost(String host) this.host = host;)public int getPort() return port;)public void setPort (int port) this, port = port;)public String getUsername() return username;)public void setUsername(String username) this, username = username;public String getPasswo

6、rd() return password;)public void setPassword(String password) this, password = password;)public boolean isBinaryTransfer() return binaryTransfer;)public void setBinaryTransfer(boolean binaryTransfer) this. binaryTransfer = binaryTransfer;)public boolean isPassiveMode() return passiveMode;public voi

7、d setPassiveMode(boolean passiveMode) this. passiveMode = passiveMode;public String getEncodingO return encoding;)public void setEncoding(String encoding) this, encoding = encoding;public int getClientTimeout() return clientTimeout;)public void setClientTimeout(int clientTimeout) this. clientTimeout

8、 = clientTimeout;)public FtpClient(String Host) this. username =anonymous”;this, encoding = utf-8；this. binaryTransfer = true;this. binaryTransfer = true;this.port = 21;this, host = Host;try this. ftpClient = getFTPClient(); catch (Exception e) System, out. printin (z，Create FTPCIient error!z，);)pri

9、vate FTPCIient getFTPClient () throws lOExceptionFTPCIient ftpClient = new FTPCIient();ftpClient. setControlEncoding(encoding);connect(ftpClient);if (passiveMode) ftpClient. enterLocalPassiveMode();setFileType(ftpClient);try (ftpClient. setSoTimeout(clientTimeout); catch (SocketException e) throw ne

10、w lOException(/zSet timeout error. ，e);)return ftpClient;)private void setFileType(FTPClient ftpClient) throws lOException try if (binaryTransfer) ftpClient. setFileType(FTPCIient. BINARY_FILE_TYPE); else ftpClient. setFileType(FTPClient.ASCII_FILE_TYPE); catch (lOException e) throw new lOException(

11、Could not to set file type.，e);)public boolean connect (FTPCIient ftpClient) throws lOException try ftpClient. connect (host, port);int reply = ftpClient. getReplyCode ();if (FTPReply. isPositiveCompletion(reply) if (ftpClient. login (username, password) setFileType(ftpClient);return true;) else thi

12、s. ftpClient. disconnect ();throw new lOException(/ZFTP server refused connection. /z);) catch (lOException e) if (this. ftpClient. isConnected() try this. ftpClient. disconnect (); catch (lOException el) throw new lOException(Could not disconnect from server. ，e);throw new lOException(z，Could not c

13、onnect to server. z，, e);)return false;)private void disconnect() throws lOException try this. ftpClient. logout (); catch (lOException e) System, out. printin (logout may timeout!/z);if (this. ftpClient. isConnected() this.ftpClient. disconnect();)public InputStream getStream(String serverFile) thr

14、ows lOException InputStream inStream = null;try (inStream = this. ftpClient. retrieveFileStream(serverFile);System, out. printin(inStream get over!”);return inStream; catch (lOException e) System, out. printin (，zget stream exception);return null;)public boolean writeStream(InputStream input, String

15、 localFile) throws lOExcept ion FileOutputStream fout = new FileOutputStream(localFile);int ch = 0;if(input 二二 null) System, out. printin (z，input is null);return false;)ch = input, read ();while(ch != -1) font.write(ch); ch = input. read();)System. out. printin (write over!，z);return flag; catch (l

16、OException e) throw new lOException(，/Couldn，t get file from server. z，, e);)public boolean isExist(String remoteFilePath)throws lOException try File file=new File(remoteFilePath);String remotePath=remoteFilePath. substring(0, (remoteFilePath. indexOf(file. getNa me ()-1);String listNames = this. ft

17、pClient. listNames(remotePath);System, out. printIn(remoteFilePath);for(int i=0;ilistNames. length;i+) System. out. println(listNamesi);if (remoteFilePath. equals(listNa.mesi) flag=true;System, out. printin(file:+file getName()+ existed);break;else flag=false;) catch (lOException e) throw new lOExce

18、ption (Z，FILE EXCEPT 10N，z, e);)return flag;)/main for testingpublic static void main(String args) throws lOException String hostname = z/cp01-testing-ps7130. cpOl. baidu. com，z;String serverFile=，/home/work/check_disk. sh;String localFile=，/home/work/workspace/project/dhc2-0/dhc/base/ftp/taskget”;FtpClient ftp = new FtpClient(hostname);System. out. println(ftp. isExist(serverFile);ftp. writeStream(ftp. getStream(serverFile), localFile);ftp. disconnect ();)这个工具是为了配合另外一个Hadoop工具做 集群上传用的，所以里面的把input和ou tput流分开了，也是为了方便另外一个工具使用。补充一点,如何在linux配置运行:如果这样的代码需要在linux下环境运行，首先要配置好响应的包，例如