FTP测试工具类

在进入正文前，先给大家分享一款比较好用的服务器连接工具： IIS7服务器管理工具是一款windows全系下用于连接并操控基于windows和linux系统的VPS、VNC、FTP等远程服务器、云服务器的管理工具。 界面简单明了，操作易上手，功能强大，支持批量导入服务器，并批量打开，多窗口化管理，除此之外，加载本地硬盘、硬盘映射、加载服务器的声音，远程声卡读取等功能也一应俱全，完全实现了各类场景使用，对于FTP连接界面，其中FTP文件的定时上传，定时下载（也可以说定时上传下载、定时备份）功能，对于经常使用FTP的小伙伴来说，也是非常适用的。 工具支持自动更新，压缩包只有7.62M，方便简洁，一步到位。 下载地址：IIS7服务器管理工具 简单的使用步骤可以看下面的截图，做了详细标注：

下面开始我们文章的内容

因项目现场无法部署IDE工具联调FTP服务器，开发个简单的小工具，打成jar部署联调测。一下是该工具的源代码。

package cn.org.july.ftp; import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPFile; import org.apache.commons.net.ftp.FTPReply; import java.io.*; import java.net.SocketException; import java.util.Scanner; public class FtpTest { private static String address = ""; private static int port = 21; private static String userName; private static String pwd; private static FTPClient ftpClient; private static String userDir = System.getProperty("user.dir"); public static void init() { Scanner scan = new Scanner(System.in); System.out.println("please enter the FTP service address: (请输入FTP服务地址：)"); address = scan.nextLine(); System.out.println("ftp address is ".concat(address)); System.out.println("please enter the FTP service port:(请输入FTP服务端口：)"); port = Integer.valueOf(scan.nextLine()); System.out.println("ftp port is ".concat(port + "")); System.out.println("please enter the FTP service user: (请输入FTP服务用户：)"); userName = scan.nextLine(); System.out.println("ftp user is ".concat(userName)); System.out.println("please enter the FTP service pwd: (请输入FTP服务用户密码：)"); pwd = scan.nextLine(); System.out.println("ftp pwd is ".concat(pwd)); } public static void connect() { try { ftpClient = new FTPClient(); ftpClient.setConnectTimeout(60000); ftpClient.connect(address, port);// 连接FTP服务器 if (FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) { if (ftpClient.login(userName, pwd)) {// 登陆FTP服务器 if (FTPReply.isPositiveCompletion(ftpClient.sendCommand( "OPTS UTF8", "ON"))) {// 开启服务器对UTF-8的支持，如果服务器支持就用UTF-8编码，否则就使用本地编码（GBK）. ftpClient.setControlEncoding("UTF-8"); } else { ftpClient.setControlEncoding("GBK"); } ftpClient.enterLocalPassiveMode();// 设置被动模式 ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);// 设置传输的模式，以二进制流的方式读取 ftpClient.enterLocalPassiveMode(); System.out.println("FTP服务连接成功！"); } else { System.out.println("FTP服务用户名或密码错误！"); disConnection(); } } else { System.out.println("连接到FTP服务失败！"); disConnection(); } } catch (SocketException e) { e.printStackTrace(); disConnection(); System.out.println("FTP的IP地址可能错误，请正确配置。"); } catch (IOException e) { e.printStackTrace(); disConnection(); System.out.println("FTP的端口错误,请正确配置。"); } } /** * 关闭FTP服务链接 * * @throws IOException */ public static void disConnection() { try { if (ftpClient.isConnected()) { ftpClient.disconnect(); } } catch (IOException e) { e.printStackTrace(); } } /** * 获取文件夹下的所有文件信息 * * @param path 文件路径 */ public static void getFTPDirectoryFiles(String path) { FTPFile[] files = null; try { ftpClient.changeWorkingDirectory(path); files = ftpClient.listFiles(); for (FTPFile file : files) { System.out.println(file.getName()); } } catch (Exception e) { e.printStackTrace(); System.out.println("FTP读取数据异常！"); } finally { //关闭连接 disConnection(); } } /** * 获取文件夹下的所有文件信息 * * @param path 文件路径 */ public static void getFTPFile(String path, String fileName) { InputStream in = null; try { ftpClient.changeWorkingDirectory(path); FTPFile[] files = ftpClient.listFiles(); if (files.length > 0) { in = ftpClient.retrieveFileStream(new String(fileName.getBytes(), "ISO-8859-1")); } writeToLocal("ftpFile".concat(File.separator).concat(System.currentTimeMillis() + "").concat(fileName), in); } catch (Exception e) { e.printStackTrace(); System.out.println("FTP读取数据异常！"); } finally { //关闭连接 disConnection(); } } /** * 将InputStream写入本地文件 * * @param destination 写入本地目录 * @param input 输入流 * @throws IOException IOException */ public static void writeToLocal(String destination, InputStream input) throws IOException { int index; byte[] bytes = new byte[1024]; String downPath = userDir.concat(File.separator).concat(destination); File file = new File(downPath); if (!file.exists()) { if (!file.getParentFile().exists()) { file.getParentFile().mkdir(); } file.createNewFile(); } FileOutputStream downloadFile = new FileOutputStream(downPath); while ((index = input.read(bytes)) != -1) { downloadFile.write(bytes, 0, index); downloadFile.flush(); } input.close(); downloadFile.close(); System.out.println("文件下载路径：" + downPath); } public static void operation() throws FileNotFoundException { System.out.println("1:下载操作。2：上传操作。3：遍历目录下文件"); Scanner scan = new Scanner(System.in); String exit = scan.nextLine(); if ("1".equals(exit)) { System.out.println("ftp download path (下载路径：)"); String path = scan.nextLine(); System.out.println("ftp download path is ".concat(path)); System.out.println("ftp download fileName(下载文件名称：) "); String fileName = scan.nextLine(); System.out.println("ftp download fileName is ".concat(fileName)); getFTPFile(path, fileName); } else if ("2".equals(exit)) { System.out.println("please enter the local file path（请输入本地文件路径E:/test.pdf）"); String localPath = scan.nextLine(); System.out.println("local file path is ".concat(localPath)); System.out.println("please enter the ftp file path (请输入ftp文件路径)"); String ftpPath = scan.nextLine(); System.out.println("ftp path is ".concat(ftpPath)); System.out.println("please enter ftp file name (请输入ftp文件名称)"); String fileName = scan.nextLine(); System.out.println("ftp file name is ".concat(fileName)); boolean b = uploadFile(ftpPath, fileName, new FileInputStream(new File(localPath))); if (b) { System.out.println("file upload success"); } else { System.out.println("file upload fail"); } } else if ("3".equals(exit)) { System.out.println("please enter ftp path:(请输入FTP文件路径)"); String path = scan.nextLine(); getFTPDirectoryFiles(path); } else { System.out.println("操作类型错误。"); } } /** * Description: 向FTP服务器上传文件 * * @param ftpPath FTP服务器中文件所在路径 格式： ftptest/aa * @param fileName ftp文件名称 * @param input 文件流 * @return 成功返回true，否则返回false */ public static boolean uploadFile(String ftpPath, String fileName, InputStream input) { boolean success = false; try { int reply; reply = ftpClient.getReplyCode(); if (!FTPReply.isPositiveCompletion(reply)) { ftpClient.disconnect(); return success; } ftpClient.setControlEncoding("UTF-8"); // 中文支持 ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE); ftpClient.enterLocalPassiveMode(); if (!ftpClient.changeWorkingDirectory(ftpPath)) { System.err.println("不存在"); boolean makeDirectory = ftpClient.makeDirectory(ftpPath); boolean changeWorkingDirectory = ftpClient.changeWorkingDirectory(ftpPath); System.err.println(ftpPath + "创建：" + makeDirectory + ";切换：" + changeWorkingDirectory); } else { ftpClient.changeWorkingDirectory(ftpPath); } ftpClient.storeFile(fileName, input); input.close(); ftpClient.logout(); success = true; } catch (IOException e) { e.printStackTrace(); } finally { if (ftpClient.isConnected()) { try { ftpClient.disconnect(); } catch (IOException ioe) { } } } return success; } public static void main(String[] args) { init(); connect(); try { operation(); } catch (FileNotFoundException e) { e.printStackTrace(); } } }