大数据平台文件接收FTP服务接入说明

1、DB15/T 1872 2020附录 D（资料性附录）文件接收FTP服务接入说明D.1文件接收 FTP服务接口文件接收 FTP服务接口见表 D.1 ：表D.1文件接收 FTP服务接口序号接口方法接口说明1publicvoid initFtpClient(Stringhostname,初始化 FTP服务器，参数说明如下：Integerport,Stringusername,Stringhostname： FTP服务器地址；password)prot ： FTP服务器端口username： FTP登录账号；password ： FTP登录密码。2publicboolean uploadFile(S

2、tringpathname,上传文件。参数说明如下：String fileName, InputStream inputStream)pathname： ftp 服务保存地址fileName ：上传到 ftp 的文件名inputStream：输入文件流3publicbooleanCreateDirecroty(String创建文件目录。参数说明如下：remote)remote ：文件目录D.2文件接收 FTP 服务示例管理信息系统在生成好文件后，编写代码实现上传文件到大数据平台的FTP服务中，调用服务示例（ Java ） 见表 D.2：表D.2文件接收 FTP服务示例public void i

3、nitFtpClient(String hostname, Integer port,String username,String password) ftpClient = new FTPClient();ftpClient.setControlEncoding("utf-8");try ftpClient.connect(hostname, port);ftpClient.login(username, password);int replyCode = ftpClient.getReplyCode();if (!FTPReply.isPositiveCompletio

4、n(replyCode) 服务器 :" + this.hostname + ":" + this.port); catch (MalformedURLException e) e.printStackTrace(); catch (IOException e) e.printStackTrace();16DB15/T 1872 2020public boolean uploadFile(String pathname, String fileName, InputStream inputStream) try 开始上传文件 ");initFtpClien

5、t();ftpClient.setFileType(FTP.BINARY_FILE_TYPE);CreateDirecroty(pathname);ftpClient.makeDirectory(pathname);ftpClient.changeWorkingDirectory(pathname);ftpClient.storeFile(fileName, inputStream);inputStream.close();ftpClient.logout();上传文件成功 "); catch (Exception e) 上传文件失败 "); e.printStackTra

6、ce(); finally if (ftpClient.isConnected() try ftpClient.disconnect(); catch (IOException e) e.printStackTrace();if (null != inputStream) try inputStream.close(); catch (IOException e) e.printStackTrace();return true; ;public boolean CreateDirecroty(String remote) throws IOException boolean success =

7、 true;String directory = remote + "/"/ 如果远程目录不存在，则递归创建远程服务器目录if (!directory.equalsIgnoreCase("/") && !changeWorkingDirectory(new String(directory) int start = 0;17DB15/T 1872 2020int end = 0;if (directory.startsWith("/") start = 1; else start = 0;end = directory

8、.indexOf("/", start); String path = ""String paths = ""while (true) String subDirectory = new String(remote.substring(start, end).getBytes("GBK"), "iso-8859-1"); path = path + "/" + subDirectory;if (!existFile(path) if (makeDirectory(subDirectory) changeWorkingDirectory(subDirectory); else 创建目录 " + subDirectory + "失败 ");changeWorkingDirectory(subDirectory); else changeWorkingDirectory(subDirectory);paths = paths + "/"