package FTPDemo;<\/p>\n
import java.io.File;
\nimport java.io.FileInputStream;
\nimport java.io.FileOutputStream;
\nimport java.io.IOException;
\nimport java.io.OutputStream;
\nimport java.util.logging.Logger;<\/p>\n
import org.apache.commons.net.ftp.FTPClient;
\nimport org.apache.commons.net.ftp.FTPFile;
\nimport org.apache.commons.net.ftp.FTPReply;<\/p>\n
public class FtpUtil { <\/p>\n
private static FTPClient ftp;<\/p>\n
\/**
\n * \u83b7\u53d6ftp\u8fde\u63a5
\n * @param f
\n * @return
\n * @throws Exception
\n *\/
\npublic static boolean connectFtp(FtpConfig f) throws Exception{
\n ftp=new FTPClient();
\n boolean flag=false;
\n if (f.getFtpPort()==null) {
\n ftp.connect(f.getFtpHost(),21);
\n }else{
\n ftp.connect(f.getFtpHost(),f.getFtpPort());
\n }
\n ftp.login(f.getFtpUser(), f.getFtpPassword());
\n ftp.enterLocalPassiveMode(); \/\/\u88ab\u52a8\u6a21\u5f0f
\n int reply = ftp.getReplyCode();
\n if (!FTPReply.isPositiveCompletion(reply)) {
\n ftp.disconnect();
\n return flag;
\n }
\n ftp.changeWorkingDirectory(f.getFtpPath());
\n flag = true;
\n return flag;
\n}<\/p>\n
\/**
\n * \u5173\u95edftp\u8fde\u63a5
\n *\/
\npublic static void closeFtp(){
\n try {
\n if (ftp!=null && ftp.isConnected()) {
\n ftp.logout();
\n ftp.disconnect();
\n }
\n }catch (IOException e){
\n e.printStackTrace();
\n }
\n}<\/p>\n
\/**
\n * ftp\u4e0a\u4f20\u6587\u4ef6
\n * @param f
\n * @throws Exception
\n *\/
\npublic static void upload(File f) throws Exception{
\n if (f.isDirectory()) {
\n ftp.makeDirectory(f.getName());
\n ftp.changeWorkingDirectory(f.getName());
\n String[] files=f.list();
\n for(String fstr : files){
\n File file1=new File(f.getPath()+File.separator+fstr);
\n if (file1.isDirectory()) {
\n upload(file1);
\n ftp.changeToParentDirectory();
\n }else{
\n File file2=new File(f.getPath()+File.separator+fstr);
\n FileInputStream input=new FileInputStream(file2);
\n ftp.storeFile(file2.getName(),input);
\n input.close();
\n }
\n }
\n }else{
\n File file2=new File(f.getPath());
\n FileInputStream input=new FileInputStream(file2);
\n ftp.storeFile(file2.getName(),input);
\n input.close();
\n }
\n}<\/p>\n
\/**
\n * \u4e0b\u8f7d\u94fe\u63a5\u914d\u7f6e
\n * @param f
\n * @param localBaseDir \u672c\u5730\u76ee\u5f55
\n * @param remoteBaseDir \u8fdc\u7a0b\u76ee\u5f55
\n * @throws Exception
\n *\/
\npublic static void startDownDir(FtpConfig f,String localBaseDir,String remoteBaseDir) throws Exception{
\n if (FtpUtil.connectFtp(f)) {
\n try {
\n FTPFile[] files = null;
\n boolean changedir = ftp.changeWorkingDirectory(remoteBaseDir);
\n if (changedir) {
\n ftp.setControlEncoding(“UTF-8”);
\n files = ftp.listFiles();
\n for (int i = 0; i < files.length; i++) { \n downloadFile(files[i], localBaseDir, remoteBaseDir); \n } \n }else{\n System.out.println(\"\u4e0d\u5b58\u5728\u7684\u76f8\u5bf9\u8def\u5f84\uff01\");\n } \n } catch (Exception e) { \n e.printStackTrace();\n } \n }else{\n System.out.println(\"\u8fde\u63a5\u5931\u8d25\");\n }\n\n}\n\npublic static void startDownFile(FtpConfig f,String localBaseDir,String remoteFilePath) throws Exception{\n if (FtpUtil.connectFtp(f)) {\n try { \n FileOutputStream outputStream = new FileOutputStream(localBaseDir + remoteFilePath); \n ftp.retrieveFile(remoteFilePath, outputStream);\n outputStream.flush();\n outputStream.close();\n } catch (Exception e) { \n e.printStackTrace();\n } \n }else{\n System.out.println(\"\u8fde\u63a5FTP\u670d\u52a1\u5668\u5931\u8d25\");\n }\n\n}\n\n\n\/** \n * \n * \u4e0b\u8f7dFTP\u6587\u4ef6 \n * \u5f53\u4f60\u9700\u8981\u4e0b\u8f7dFTP\u6587\u4ef6\u7684\u65f6\u5019\uff0c\u8c03\u7528\u6b64\u65b9\u6cd5 \n * \u6839\u636e\u83b7\u53d6\u7684\u6587\u4ef6\u540d\uff0c\u672c\u5730\u5730\u5740\uff0c\u8fdc\u7a0b\u5730\u5740<\/b>\u8fdb\u884c\u4e0b\u8f7d
\n *
\n * @param ftpFile
\n * @param relativeLocalPath \u4e0b\u8f7d\u5230\u672c\u5730\u7684\u7edd\u5bf9\u8def\u5f84
\n * @param relativeRemotePath \u8981\u4e0b\u8f7d\u7684\u8fdc\u7a0bftp\u670d\u52a1\u5668\u76f8\u5bf9\u8def\u5f84
\n *\/
\nprivate static void downloadFile(FTPFile ftpFile, String relativeLocalPath,String relativeRemotePath) {
\n if (ftpFile.isFile()) {
\n if (ftpFile.getName().indexOf(“?”) == -1) {
\n OutputStream outputStream = null;
\n try {
\n File locaFile= new File(relativeLocalPath+ ftpFile.getName());
\n \/\/\u5224\u65ad\u6587\u4ef6\u662f\u5426\u5b58\u5728\uff0c\u5b58\u5728\u5219\u8fd4\u56de or \u76f4\u63a5\u8986\u76d6
\n if(locaFile.exists()){
\n return;
\n }else{
\n outputStream = new FileOutputStream(relativeLocalPath+ ftpFile.getName());
\n ftp.retrieveFile(ftpFile.getName(), outputStream);
\n outputStream.flush();
\n }
\n } catch (Exception e) {
\n e.printStackTrace();
\n } finally {
\n try {
\n if (outputStream != null){
\n outputStream.close();
\n }
\n } catch (IOException e) {
\n e.printStackTrace();
\n }
\n }
\n }
\n } else {
\n String newlocalRelatePath = relativeLocalPath + ftpFile.getName();
\n String newRemote = relativeRemotePath + ftpFile.getName().toString();
\n File fl = new File(newlocalRelatePath);
\n if (!fl.exists()) {
\n fl.mkdirs();
\n }
\n try {
\n newlocalRelatePath = newlocalRelatePath+File.separator;
\n newRemote = newRemote+File.separator;
\n String currentWorkDir = ftpFile.getName().toString();
\n \/\/System.out.println(currentWorkDir);
\n boolean changedir = ftp.changeWorkingDirectory(currentWorkDir);
\n if (changedir) {
\n FTPFile[] files = null;
\n files = ftp.listFiles();
\n for (int i = 0; i < files.length; i++) { \n downloadFile(files[i], newlocalRelatePath, newRemote); \n } \n } \n if (changedir){\n ftp.changeToParentDirectory(); \n } \n } catch (Exception e) { \n e.printStackTrace();\n } \n } \n} \n\n\npublic static void main(String[] args) throws Exception{ \n FtpConfig f=new FtpConfig();\n f.setFtpHost(\"192.168.3.100\");\n f.setFtpPort(21);\n f.setFtpUser(\"anonymous\");\n f.setFtpPassword(\"\");\n \/\/ f.setFtpPath(\"\/data1\/\");\/\/\u76f8\u5bf9\u8def\u5f84\n FtpUtil.connectFtp(f);\n File file = new File(\"E:\\\\data1\\\\physics.txt\");\n\n \/\/FtpUtil.upload(file);\/\/\u628a\u6587\u4ef6\u4e0a\u4f20\u5728ftp\u4e0a\n \/\/ FtpUtil.startDownFile(f, \"E:\/\", \"physics.txt\");\n FtpUtil.startDownDir(f, \"E:\/data1\/\", \"\/data1\/\");\n\n } \n}\n<\/p>\n","protected":false},"excerpt":{"rendered":"
package FTPDemo; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.OutputStream; import java.util.logging.Logger; import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPFile; import org.apache.commons.net.ftp.FTPReply; public class FtpUtil { private static FTPClient ftp; \/** * \u83b7\u53d6ftp\u8fde\u63a5 * @param f * @return * @throws Exception *\/ public static boolean connectFtp(FtpConfig f) throws Exception{ ftp=new FTPClient(); boolean flag=false; if (f.getFtpPort()==null) { ftp.connect(f.getFtpHost(),21); … Read more<\/a><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[7],"tags":[],"class_list":["post-545","post","type-post","status-publish","format-standard","hentry","category-java"],"_links":{"self":[{"href":"http:\/\/22pig.com\/index.php?rest_route=\/wp\/v2\/posts\/545","targetHints":{"allow":["GET"]}}],"collection":[{"href":"http:\/\/22pig.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/22pig.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/22pig.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/22pig.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=545"}],"version-history":[{"count":0,"href":"http:\/\/22pig.com\/index.php?rest_route=\/wp\/v2\/posts\/545\/revisions"}],"wp:attachment":[{"href":"http:\/\/22pig.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=545"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/22pig.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=545"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/22pig.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=545"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}