devbox
知新_RL
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

通过FTP交换数据方式上传下载_ftp.getreplycode()

作者：知新_RL | 2024-03-17 10:19:34

赞

踩

ftp.getreplycode()
  1. import java.io.File;
  2. import java.io.FileInputStream;
  3. import java.io.FileOutputStream;
  4. import java.io.IOException;
  5. import java.io.InputStream;
  6. import java.io.OutputStream;
  7. import java.util.ArrayList;
  8. import java.util.HashMap;
  9. import java.util.List;
  10. import java.util.Vector;
  11.  
  12. import org.apache.commons.net.ftp.FTP;
  13. import org.apache.commons.net.ftp.FTPClient;
  14. import org.apache.commons.net.ftp.FTPFile;
  15. import org.apache.commons.net.ftp.FTPReply;
  16.  
  17. public class FtpUtil {
  18. 	public static boolean uploadFile(String url,// FTP服务器hostname
  19. 			int port,// FTP服务器端口
  20. 			String username, // FTP登录账号
  21. 			String password, // FTP登录密码
  22. 			String path, // FTP服务器保存目录
  23. 			String filename, // 上传到FTP服务器上的文件名
  24. 			InputStream input // 输入流
  25. 	) {
  26. 		boolean success = false;
  27. 		FTPClient ftp = new FTPClient();
  28. 		try {
  29. 			int reply;
  30. 			ftp.connect(url, port);// 连接FTP服务器
  31. 			// 如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器
  32. 			ftp.login(username, password);// 登录
  33. 			reply = ftp.getReplyCode();
  34. 			if (!FTPReply.isPositiveCompletion(reply)) {
  35. 				ftp.disconnect();
  36. 				return success;
  37. 			}
  38. 			ftp.enterLocalPassiveMode();
  39. 			ftp.changeWorkingDirectory(path);
  40. 			ftp.setFileType(FTP.ASCII_FILE_TYPE);
  41. 			String FtpFilename = new String(filename.getBytes("GBK"),
  42. 					"iso-8859-1");
  43. 			boolean result = ftp.storeFile(FtpFilename, input);
  44. 			input.close();
  45. 			ftp.logout();
  46. 			success = true;
  47. 		} catch (IOException e) {
  48. 			e.printStackTrace();
  49. 		} finally {
  50. 			if (ftp.isConnected()) {
  51. 				try {
  52. 					ftp.disconnect();
  53. 				} catch (IOException ioe) {
  54. 				}
  55. 			}
  56. 		}
  57. 		return success;
  58. 	}
  59.  
  60. 	/**
  61. 	 * Description: 从FTP服务器下载文件
  62. 	 * 
  63. 	 * @Version1.0
  64. 	 * @param url
  65. 	 *            FTP服务器hostname
  66. 	 * @param port
  67. 	 *            FTP服务器端口
  68. 	 * @param username
  69. 	 *            FTP登录账号
  70. 	 * @param password
  71. 	 *            FTP登录密码
  72. 	 * @param remotePath
  73. 	 *            FTP服务器上的相对路径
  74. 	 * @param fileName
  75. 	 *            要下载的文件名
  76. 	 * @param localPath
  77. 	 *            下载后保存到本地的路径
  78. 	 * @return
  79. 	 */
  80.  
  81. 	public static boolean downFile(String url, // FTP服务器
  82. 			int port,// FTP服务器端口
  83. 			String username, // FTP登录账号
  84. 			String password, // FTP登录密码
  85. 			String remotePath,// FTP服务器上的相对路径
  86. 			String fileName,// 要下载的文件名
  87. 			String localPath// 下载后保存到本地的路径
  88.  
  89. 	) {
  90.  
  91. 		boolean success = false;
  92. 		FTPClient ftp = new FTPClient();
  93. 		try {
  94. 			int reply;
  95. 			ftp.connect(url, port);
  96. 			ftp.enterLocalPassiveMode();
  97. 			// 如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器
  98. 			ftp.login(username, password);// 登录
  99. 			reply = ftp.getReplyCode();
  100. 			if (!FTPReply.isPositiveCompletion(reply)) {
  101. 				ftp.disconnect();
  102. 				return success;
  103. 			}
  104. 			ftp.changeWorkingDirectory(remotePath);// 转移到FTP服务器目录
  105. 			FTPFile[] fs = null;
  106. 			String[] names = null;
  107. 			if (ftp.listFiles() != null) {
  108. 				fs = ftp.listFiles();
  109. 			}
  110. 			if (ftp.listNames().length > 0) {
  111. 				names = ftp.listNames();
  112. 			}
  113. 			if (fs != null && fs.length > 0) {
  114. 				for (FTPFile ff : fs) {
  115. 					String FtpFilename = new String(ff.getName().getBytes(
  116. 							"iso-8859-1"), "GBK");
  117. 					if (FtpFilename.equals(fileName)) {
  118. 						File localFile = new File(localPath + "/" + FtpFilename);
  119. 						if (!localFile.exists()) {
  120. 							OutputStream is = new FileOutputStream(localFile);
  121. 							boolean result = ftp.retrieveFile(ff.getName(), is);
  122. 							is.close();
  123. 						}
  124. 					}
  125. 				}
  126. 			} else {
  127. 				if (names != null) {
  128. 					for (int i = 0, j = names.length; i < j; i++) {
  129. 						if (names[i].equals(fileName)) {
  130. 							File localFile = new File(localPath + "/"
  131. 									+ names[i]);
  132. 							if (!localFile.exists()) {
  133. 								OutputStream is = new FileOutputStream(
  134. 										localFile);
  135. 								boolean result = ftp.retrieveFile(names[i], is);
  136. 								is.close();
  137. 							}
  138. 						}
  139. 					}
  140. 				} else {
  141. 					ftp.logout();
  142. 					success = true;
  143. 					return success;
  144. 				}
  145. 			}
  146. 			ftp.logout();
  147. 			success = true;
  148. 		} catch (IOException e) {
  149. 			e.printStackTrace();
  150. 		} finally {
  151. 			if (ftp.isConnected()) {
  152. 				try {
  153. 					ftp.disconnect();
  154. 				} catch (IOException ioe) {
  155. 				}
  156. 			}
  157. 		}
  158. 		return success;
  159. 	}
  160.  
  161. 	/**
  162. 	 * Description: 从FTP服务器删除文件
  163. 	 * 
  164. 	 * @Version1.0
  165. 	 * @param url
  166. 	 *            FTP服务器hostname
  167. 	 * @param port
  168. 	 *            FTP服务器端口
  169. 	 * @param username
  170. 	 *            FTP登录账号
  171. 	 * @param password
  172. 	 *            FTP登录密码
  173. 	 * @param remotePath
  174. 	 *            FTP服务器上的相对路径
  175. 	 * @param fileName
  176. 	 *            要下载的文件名
  177. 	 * @return
  178. 	 */
  179.  
  180. 	public static boolean deleteFile(String url, // FTP服务器
  181. 			int port,// FTP服务器端口
  182. 			String username, // FTP登录账号
  183. 			String password, // FTP登录密码
  184. 			String remotePath,// FTP服务器上的相对路径
  185. 			String fileName// 要下载的文件名
  186.  
  187. 	) {
  188.  
  189. 		boolean success = false;
  190. 		FTPClient ftp = new FTPClient();
  191. 		try {
  192. 			int reply;
  193. 			ftp.connect(url, port);
  194. 			// 如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器
  195. 			ftp.enterLocalPassiveMode();
  196. 			ftp.login(username, password);// 登录
  197. 			reply = ftp.getReplyCode();
  198. 			if (!FTPReply.isPositiveCompletion(reply)) {
  199. 				ftp.disconnect();
  200. 				return success;
  201. 			}
  202. 			ftp.changeWorkingDirectory(remotePath);// 转移到FTP服务器目录
  203. 			FTPFile[] fs = ftp.listFiles();
  204. 			String[] names = ftp.listNames();
  205.  
  206. 			if (fs != null && fs.length > 0) {
  207. 				for (FTPFile ff : fs) {
  208. 					String FtpFilename = new String(ff.getName().getBytes(
  209. 							"iso-8859-1"), "GBK");
  210. 					if (FtpFilename.equals(fileName)) {
  211. 						ftp.deleteFile(FtpFilename);
  212. 					}
  213. 				}
  214. 			} else {
  215. 				if (names != null) {
  216. 					// System.getProperties().getProperty("os.name").toUpperCase().startsWith("WIN");
  217. 					for (int i = 0, j = names.length; i < j; i++) {
  218. 						if (names[i].equals(fileName)) {
  219. 							ftp.deleteFile(names[i]);
  220. 						}
  221. 					}
  222. 				} else {
  223. 					ftp.logout();
  224. 					success = true;
  225. 					return success;
  226. 				}
  227. 			}
  228. 			ftp.logout();
  229. 			success = true;
  230. 		} catch (IOException e) {
  231. 			e.printStackTrace();
  232. 		} finally {
  233. 			if (ftp.isConnected()) {
  234. 				try {
  235. 					ftp.disconnect();
  236. 				} catch (IOException ioe) {
  237. 				}
  238. 			}
  239. 		}
  240. 		return success;
  241. 	}
  242.  
  243. 	/**
  244. 	 * Description: 从FTP服务器下载文件,上传到ftp服务器
  245. 	 * 
  246. 	 * @Version1.0
  247. 	 * @param url
  248. 	 *            FTP服务器hostname
  249. 	 * @param port
  250. 	 *            FTP服务器端口
  251. 	 * @param username
  252. 	 *            FTP登录账号
  253. 	 * @param password
  254. 	 *            FTP登录密码
  255. 	 * @param remotePath
  256. 	 *            FTP服务器上的相对路径
  257. 	 * @param fileName
  258. 	 *            要下载的文件名
  259. 	 * @param localPath
  260. 	 *            下载后保存到本地的路径
  261. 	 * @return
  262. 	 */
  263.  
  264. 	public static boolean downuploadFile(String url, // 下载FTP服务器
  265. 			int port,// 下载FTP服务器端口
  266. 			String username, // 下载FTP登录账号
  267. 			String password, // 下载FTP登录密码
  268. 			String remotePath,// 下载FTP服务器上的相对路径
  269. 			String fileName,// 要下载的文件名
  270. 			String urlup,// 上传FTP服务器hostname
  271. 			int portup,// 上传FTP服务器端口
  272. 			String usernameup, // 上传FTP登录账号
  273. 			String passwordup, // 上传FTP登录密码
  274. 			String pathup, // 上传FTP服务器保存目录
  275. 			String filenameup // 上传到FTP服务器上的文件名
  276.  
  277. 	) {
  278.  
  279. 		boolean success = false;
  280. 		FTPClient ftp = new FTPClient();
  281. 		try {
  282. 			int reply;
  283. 			ftp.connect(url, port);
  284. 			ftp.enterLocalPassiveMode();
  285. 			// 如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器
  286. 			ftp.login(username, password);// 登录
  287. 			reply = ftp.getReplyCode();
  288. 			if (!FTPReply.isPositiveCompletion(reply)) {
  289. 				ftp.disconnect();
  290. 				return success;
  291. 			}
  292. 			ftp.changeWorkingDirectory(remotePath);// 转移到FTP服务器目录
  293. 			FTPFile[] fs = null;
  294. 			String[] names = null;
  295. 			if (ftp.listFiles() != null) {
  296. 				fs = ftp.listFiles();
  297. 			}
  298. 			if (ftp.listNames().length > 0) {
  299. 				names = ftp.listNames();
  300. 			}
  301. 			if (fs != null && fs.length > 0) {
  302. 				for (FTPFile ff : fs) {
  303. 					String FtpFilename = new String(ff.getName().getBytes(
  304. 							"iso-8859-1"), "GBK");
  305. 					if (FtpFilename.equals(fileName)) {
  306. 						InputStream input=ftp.retrieveFileStream(fileName);
  307. 						
  308. 						int size=input.available();
  309. 				        if(size>0){
  310. 				        	Boolean result = FtpUtil.uploadFile(urlup,
  311. 									portup, usernameup,
  312. 									passwordup, pathup, filenameup,
  313. 										input);
  314. 				        }
  315. 						
  316. 						
  317. 					}
  318. 				}
  319. 			} else {
  320. 				if (names != null) {
  321. 					for (int i = 0, j = names.length; i < j; i++) {
  322. 						if (names[i].equals(fileName)) {
  323. 							InputStream input=ftp.retrieveFileStream(fileName);
  324. 							int size=input.available();
  325. 					        if(size>0){
  326. 					        	Boolean result = FtpUtil.uploadFile(urlup,
  327. 										portup, usernameup,
  328. 										passwordup, pathup, filenameup,
  329. 											input);
  330. 					        }
  331. 						}
  332. 					}
  333. 				} else {
  334. 					ftp.logout();
  335. 					success = true;
  336. 					return success;
  337. 				}
  338. 			}
  339. 			ftp.logout();
  340. 			success = true;
  341. 		} catch (IOException e) {
  342. 			e.printStackTrace();
  343. 		} finally {
  344. 			if (ftp.isConnected()) {
  345. 				try {
  346. 					ftp.disconnect();
  347. 				} catch (IOException ioe) {
  348. 				}
  349. 			}
  350. 		}
  351. 		return success;
  352. 	}
  353. 	
  354. 	
  355. 	public static void main(String[] args) throws Exception {
  356. //      从ftp下载文件
  357. //		Boolean result = FtpUtil.downFile("192.xxx.xxx.01",
  358. //				21,"xx@outlook.com",
  359. //				"qaz041366","/ftp", "log.txt",
  360. //				"E:/iso/");
  361. //		File file = new File("E:\\iso\\xx.txt");
  362. //		if (file.exists()) {
  363. //			return;
  364. //		}
  365.         //本地上传到FTP服务器
  366. //		 Boolean result = FtpUtil.uploadFile("192.xxx.xxx.01",
  367. //		 21, "xx@outlook.com",
  368. //			"qaz0413xx", "/ftp", "xx.log",
  369. //			(InputStream) (new FileInputStream(new File("E:\\iso\\xx.log"))));
  370. //		if (!result) {
  371. //			// file.delete();
  372. //		}
  373. 		//从一个ftp下载并上传到另一个
  374. 		Boolean result = FtpUtil.downuploadFile("192.xxx.xxx.01",
  375. 				 21, "xxx@outlook.com",
  376. 					"qaz041366", "/ftp", "gioi_log.log","192.xxx.xxx.02",
  377. 					 21, "xxx@outlook.com",
  378. 						"qaz041366", "/ftp", "xx.log");
  379. 	}
  380. }

 

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/知新_RL/article/detail/255512?site
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号