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

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

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

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

[java] view plaincopy

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类---------------

[java] view plaincopy

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类---------------

[java] view plaincopy

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:[email protected]:21/image/
28. }
29. }