java上传、下载、删除ftp文件

时间：2023-12-04 18:03:02

一共三个类，一个工具类Ftputil.，一个实体类Kmconfig。一个测试类Test

下载地址：http://download.csdn.net/detail/myfmyfmyfmyf/6697107

Ftputil类---------------

  1. package ftpDemo;
  2. import java.io.DataOutputStream;
  3. import java.io.InputStream;
  4. import java.io.OutputStream;
  5. import sun.net.TelnetInputStream;
  6. import sun.net.TelnetOutputStream;
  7. import sun.net.ftp.FtpClient;
  8. public class ftpUtil {
  9. // 上传文件至FTP通用方法
  10. public static void upLoadFileFtp(KmConfig kmConfig,InputStream is, String fileName){
  11. try {
  12. String ftpHost = kmConfig.getFtpHost();
  13. int port = kmConfig.getFtpPort();
  14. String userName = kmConfig.getFtpUser();
  15. String passWord = kmConfig.getFtpPassword();
  16. String path = kmConfig.getFtpPath();
  17. FtpClient ftpClient = new FtpClient(ftpHost, port);// ftpHost为FTP服务器的IP地址，port为FTP服务器的登陆端口,ftpHost为String型,port为int型。
  18. ftpClient.login(userName, passWord);// userName、passWord分别为FTP服务器的登陆用户名和密码
  19. ftpClient.binary();
  20. ftpClient.cd(path);// path为FTP服务器上保存上传文件的路径。
  21. TelnetOutputStream telnetOut = ftpClient.put(fileName);// fileName为上传的文件名
  22. DataOutputStream dataOut = new DataOutputStream(telnetOut);
  23. byte buffer[] = new byte[1024 * 1024];
  24. int count = 0;
  25. while ((count = is.read(buffer)) != -1) {
  26. dataOut.write(buffer, 0, count);
  27. }
  28. telnetOut.close();
  29. dataOut.close();
  30. ftpClient.closeServer();
  31. } catch (Exception e) {
  32. System.out.println("上传文件失败！请检查系统FTP设置,并确认FTP服务启动");
  33. }
  34. }
  35. // 删除文件至FTP通用方法
  36. public static void deleteFileFtp(KmConfig kmConfig,String fileName){
  37. try {
  38. String ftpHost = kmConfig.getFtpHost();
  39. int port = kmConfig.getFtpPort();
  40. String userName = kmConfig.getFtpUser();
  41. String passWord = kmConfig.getFtpPassword();
  42. String path = kmConfig.getFtpPath();
  43. FtpClient ftpClient = new FtpClient(ftpHost, port);// ftpHost为FTP服务器的IP地址，port为FTP服务器的登陆端口,ftpHost为String型,port为int型。
  44. ftpClient.login(userName, passWord);// userName、passWord分别为FTP服务器的登陆用户名和密码
  45. ftpClient.binary();
  46. ftpClient.cd(path);// path为FTP服务器上保存上传文件的路径。
  47. try {
  48. ftpClient.sendServer("dele " + fileName + "\r\n");
  49. } catch (Exception e) {
  50. System.out.println("删除文件失败！请检查系统FTP设置,并确认FTP服务启动");
  51. }
  52. ftpClient.closeServer();
  53. } catch (Exception e) {
  54. System.out.println("删除文件失败！");
  55. }
  56. }
  57. // 下载ftp文件
  58. public static void downloadFileFtp(KmConfig kmConfig,String fileName, String clientFileName, OutputStream outputStream){
  59. try {
  60. String ftpHost = kmConfig.getFtpHost();
  61. int port = kmConfig.getFtpPort();
  62. String userName = kmConfig.getFtpUser();
  63. String passWord = kmConfig.getFtpPassword();
  64. String path = kmConfig.getFtpPath();
  65. FtpClient ftpClient = new FtpClient(ftpHost, port);// ftpHost为FTP服务器的IP地址，port为FTP服务器的登陆端口,ftpHost为String型,port为int型。
  66. ftpClient.login(userName, passWord);// userName、passWord分别为FTP服务器的登陆用户名和密码
  67. ftpClient.binary();
  68. ftpClient.cd(path);// path为FTP服务器上保存上传文件的路径。
  69. try {
  70. TelnetInputStream in = ftpClient.get(fileName);
  71. byte[] bytes = new byte[1024];
  72. int cnt=0;
  73. while ((cnt=in.read(bytes,0,bytes.length)) != -1) {
  74. outputStream.write(bytes, 0, cnt);
  75. }
  76. outputStream.close();
  77. in.close();
  78. } catch (Exception e) {
  79. ftpClient.closeServer();
  80. e.printStackTrace();
  81. }
  82. ftpClient.closeServer();
  83. } catch (Exception e) {
  84. System.out.println("下载文件失败！请检查系统FTP设置,并确认FTP服务启动");
  85. }
  86. }
  87. //在ftp服务器上穿件文件夹
  88. public boolean createDir(String path,FtpClient ftpClient) throws Exception{
  89. //进入到home文件夹下
  90. ftpClient.cd("/home");
  91. //创建远程文件夹
  92. //远程命令包括
  93. //USER    PORT    RETR    ALLO    DELE    SITE    XMKD    CDUP    FEAT<br>
  94. //          PASS    PASV    STOR    REST    CWD     STAT    RMD     XCUP    OPTS<br>
  95. //          ACCT    TYPE    APPE    RNFR    XCWD    HELP    XRMD    STOU    AUTH<br>
  96. //          REIN    STRU    SMNT    RNTO    LIST    NOOP    PWD     SIZE    PBSZ<br>
  97. //          QUIT    MODE    SYST    ABOR    NLST    MKD     XPWD    MDTM    PROT<br>
  98. //               在服务器上执行命令,如果用sendServer来执行远程命令(不能执行本地FTP命令)的话，所有FTP命令都要加上/r/n<br>
  99. //                    ftpclient.sendServer("XMKD /test/bb/r/n"); //执行服务器上的FTP命令<br>
  100. //                    ftpclient.readServerResponse一定要在sendServer后调用<br>
  101. //                    nameList("/test")获取指目录下的文件列表<br>
  102. //                    XMKD建立目录，当目录存在的情况下再次创建目录时报错<br>
  103. //                    XRMD删除目录<br>
  104. //                    DELE删除文件<br>
  105. //通过远程命令 穿件一个files文件夹
  106. ftpClient.sendServer("MKD "+ path + "\r\n");
  107. //这个方法必须在 这两个方法中间调用 否则 命令不管用
  108. ftpClient.binary();
  109. ftpClient.readServerResponse();
  110. return false;
  111. }
  112. /**
  113. * 检查文件夹是否存在
  114. * @param dir
  115. * @param ftpClient
  116. * @return
  117. */
  118. public boolean isDirExist(String dir, FtpClient ftpClient) {
  119. try {
  120. ftpClient.cd(dir);
  121. } catch (Exception e) {
  122. return false;
  123. }
  124. return true;
  125. }
  126. }

Kmconfig类---------------

  1. package ftpDemo;
  2. public class KmConfig {
  3. //主机ip
  4. private String FtpHost = "";
  5. //端口号
  6. private int FtpPort;
  7. //ftp用户名
  8. private String FtpUser = "";
  9. //ftp密码
  10. private String FtpPassword = "";
  11. //ftp中的目录
  12. private String FtpPath = "";
  13. public String getFtpHost() {
  14. return FtpHost;
  15. }
  16. public void setFtpHost(String ftpHost) {
  17. FtpHost = ftpHost;
  18. }
  19. public int getFtpPort() {
  20. return FtpPort;
  21. }
  22. public void setFtpPort(int ftpPort) {
  23. FtpPort = ftpPort;
  24. }
  25. public String getFtpUser() {
  26. return FtpUser;
  27. }
  28. public void setFtpUser(String ftpUser) {
  29. FtpUser = ftpUser;
  30. }
  31. public String getFtpPassword() {
  32. return FtpPassword;
  33. }
  34. public void setFtpPassword(String ftpPassword) {
  35. FtpPassword = ftpPassword;
  36. }
  37. public String getFtpPath() {
  38. return FtpPath;
  39. }
  40. public void setFtpPath(String ftpPath) {
  41. FtpPath = ftpPath;
  42. }
  43. }

Test类---------------

    1. package ftpDemo;
    2. import java.io.File;
    3. import java.io.FileInputStream;
    4. import java.io.FileNotFoundException;
    5. import java.io.InputStream;
    6. public class Test {
    7. public static void main(String[] args) {
    8. //设置ftp
    9. KmConfig km = new KmConfig();
    10. km.setFtpHost("172.20.32.48");
    11. km.setFtpPort(21);
    12. km.setFtpUser("test");
    13. km.setFtpPassword("111111");
    14. km.setFtpPath("KM");
    15. //上传到ftp
    16. ftpUtil util=new ftpUtil();
    17. File file = new File("F:/文章2.jpg");
    18. InputStream in;
    19. try {
    20. in = new FileInputStream(file);
    21. util.upLoadFileFtp(km, in, "更改后的名字.jpg");
    22. } catch (FileNotFoundException e) {
    23. // TODO Auto-generated catch block
    24. e.printStackTrace();
    25. }
    26. //页面访问: ftp://账户:密码@ip地址:端口号/文件夹目录/
    27. //  ftp://test:111111@222.22.22.11:21/image/
    28. }
    29. }

相关文章