依赖

<dependency><groupId>commons-net</groupId><artifactId>commons-net</artifactId><version>3.4</version></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-lang3</artifactId><version>3.3.2</version></dependency>

节点对象

package per.qiao.utils.ftp;/*** Create by IntelliJ Idea 2018.2** @author: qyp* Date: 2019-07-19 22:14*/import lombok.Data;import java.util.List;@Data
public class Node {private enum TYPE {DIR("DIR"),FILE("FILE");private String type;private TYPE(String type) {this.type = type;}public String getType() {return this.type;}}private String id;private String name;private String path;private TYPE type;private List<Node> childList;private Node() {}private Node(String id, String name, String path, TYPE type) {this.id = id;this.name = name;this.path = path;this.type = type;}public static Node getDirNode(String id, String name, String path) {return new Node(id, name, path, TYPE.DIR);}public static Node getFileNode(String id, String name, String path) {return new Node(id, name, path, TYPE.FILE);}
}

生成节点目录树结构

package per.qiao.utils.ftp;import org.apache.commons.lang3.StringUtils;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import java.io.File;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.UUID;/*** Create by IntelliJ Idea 2018.2** @author: qyp* Date: 2019-07-19 21:27*/public class FtpUtils {private final static Logger logger = LoggerFactory.getLogger(FtpUtils.class);/*** 本地连接* @return*/public static FTPClient localConn() {String server = "127.0.0.1";int port = 21;String username = "test";String password = "test";
//        path = "/FTPStation/";FTPClient ftpClient = null;try {ftpClient = connectServer(server, port, username, password, "/");} catch (IOException e) {e.printStackTrace();}return ftpClient;}/**** @param server* @param port* @param username* @param password* @param path 连接的节点（相对根路径的文件夹）* @return*/public static FTPClient connectServer(String server, int port, String username, String password, String path) throws IOException {path = path == null ? "" : path;FTPClient ftp = new FTPClient();//下面四行代码必须要，而且不能改变编码格式，否则不能正确下载中文文件// 如果使用serv-u发布ftp站点，则需要勾掉“高级选项”中的“对所有已收发的路径和文件名使用UTF-8编码”ftp.setControlEncoding("GBK");FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_NT);conf.setServerLanguageCode("zh");ftp.configure(conf);// 判断ftp是否存在ftp.connect(server, port);ftp.setDataTimeout(2 * 60 * 1000);if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {ftp.disconnect();System.out.println(server + "拒绝连接");}//登陆ftpboolean login = ftp.login(username, password);if (logger.isDebugEnabled()) {if (login) {logger.debug("登陆FTP成功! ip: " + server);} else {logger.debug("登陆FTP失败! ip: " + server);}}//根据输入的路径，切换工作目录。这样ftp端的路径就可以使用相对路径了exchageDir(path, ftp);return ftp;}/*** 切换目录 返回切换的层级数* @param path* @param ftp* @return 切换的层级数* @throws IOException*/private static int exchageDir(String path, FTPClient ftp) {// 切换的次数（层级）,方便回退int level = 0;try {if (StringUtils.isNotBlank(path)) {// 对路径按照 '/' 进行切割，一层一层的进入String[] pathes = path.split("/");for (String onepath : pathes) {if (onepath == null || "".equals(onepath.trim())) {continue;}//文件排除if (onepath.contains(".")) {continue;}boolean flagDir = ftp.changeWorkingDirectory(onepath);if (flagDir) {level ++;logger.info("成功连接ftp目录：" + ftp.printWorkingDirectory());} else {logger.warn("连接ftp目录失败：" + ftp.printWorkingDirectory());}}}} catch (IOException e) {logger.error("切换失败, 路径不存在");e.printStackTrace();throw new IllegalArgumentException("切换失败, 路径不存在");}return level;}/*** 生成目录树* @return*/public static Node getTree(String path) {FTPClient ftp = localConn();exchageDir(path, ftp);String rootNodeName = path.substring(path.lastIndexOf("/") + 1);Node rootNode = Node.getDirNode(getId(), rootNodeName, path);listTree(ftp, path, rootNode);return rootNode;}/*** 遍历树结构* @param ftp* @param rootPath* @param parentNode*/private static void listTree(FTPClient ftp, String rootPath, Node parentNode) {try {FTPFile[] ftpFiles = ftp.listFiles();if (ftpFiles.length <= 0) {return;}for (FTPFile f : ftpFiles) {List<Node> childList = parentNode.getChildList();if (childList == null) {childList = new ArrayList<>();parentNode.setChildList(childList);}Node currentNode = null;if (f.isDirectory()) {currentNode = Node.getDirNode(getId(), f.getName(), rootPath + File.separator + f.getName());if (ftp.changeWorkingDirectory(f.getName()) ) {if (logger.isDebugEnabled()) {logger.debug("进入：", ftp.printWorkingDirectory());}listTree(ftp, rootPath + File.separator + f.getName(), currentNode);}ftp.changeToParentDirectory();if (logger.isDebugEnabled()) {logger.debug("退出: {}", ftp.printWorkingDirectory());}} else {currentNode = Node.getFileNode(getId(), f.getName(), rootPath + File.separator + f.getName());}childList.add(currentNode);}} catch (IOException e) {e.printStackTrace();logger.error("路径不存在");}}private static String getId() {return UUID.randomUUID().toString().replaceAll("-", "");}public static void main(String[] args) {Node rootNode = getTree("/CAD/第一层");System.out.println(rootNode);}}