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

ftp代码编写时遇到的坑_ftpreply.ispositivecompletion

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

赞

踩

ftpreply.ispositivecompletion

目录

1.上传服务器上的文件中文名乱码

2.读取ftp路径下的文件

3.配置ftp下载时的编码转换

4.ftp的maven依赖

5.ftp工具类

1.上传服务器上的文件中文名乱码

解决：需要设置linux服务器的编码问题 

首先判断服务器是否支持中文，使用echo $LANG 命令测试

如果不是中文，需要修改如下：(临时)

1、locale

2.临时更换系统语言

LANG="zh_CN.UTF-8"

3.修改系统默认语言

2.读取ftp路径下的文件

首先需要下载到指定的目录中，然后才能解析读取

3.配置ftp下载时的编码转换

4.ftp的maven依赖

  1. <dependency>
  2.     <groupId>commons-net</groupId>
  3.     <artifactId>commons-net</artifactId>
  4.     <version>1.4.1</version>
  5. </dependency>

5.ftp工具类

详细代码：看github

  1. import lombok.extern.slf4j.Slf4j;
  2. import org.apache.commons.net.ftp.FTPClient;
  3. import org.apache.commons.net.ftp.FTPFile;
  4. import org.apache.commons.net.ftp.FTPReply;
  5. import org.apache.poi.hssf.usermodel.HSSFSheet;
  6. import org.apache.poi.hssf.usermodel.HSSFWorkbook;
  7. import org.springframework.stereotype.Component;
  8. import java.io.*;
  9. import java.net.SocketException;
  10. import java.text.SimpleDateFormat;
  11. import java.util.*;
  12.  
  13. @Component
  14. @Slf4j
  15. public class FTPUtil {
  16.  
  17.     /**
  18.      * 打开FTP服务链接
  19.      * @param ftpHost
  20.      * @param ftpPort
  21.      * @param ftpUserName
  22.      * @param ftpPassword
  23.      */
  24.     public static FTPClient getFTPClient(String ftpHost, Integer ftpPort, String ftpUserName, String ftpPassword){
  25.         FTPClient ftpClient = null;
  26.         try {
  27.             ftpClient = new FTPClient();
  28.             ftpClient.setConnectTimeout(60000);
  29.             if(ftpPort != null){
  30.                 ftpClient.connect(ftpHost, ftpPort);// 连接FTP服务器
  31.             }else {
  32.                 ftpClient.connect(ftpHost);// 连接FTP服务器
  33.             }
  34.             if (FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {
  35.                 if (ftpClient.login(ftpUserName, ftpPassword)) {// 登陆FTP服务器
  36.                     if (FTPReply.isPositiveCompletion(ftpClient.sendCommand(
  37.                             "OPTS UTF8", "ON"))) {// 开启服务器对UTF-8的支持，如果服务器支持就用UTF-8编码，否则就使用本地编码（GBK）.
  38.                         ftpClient.setControlEncoding("UTF-8");
  39.                     }else {
  40.                         ftpClient.setControlEncoding("GBK");
  41.                     }
  42.                     ftpClient.enterLocalPassiveMode();// 设置被动模式
  43.                     ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);// 设置传输的模式，以二进制流的方式读取
  44.                     ftpClient.enterLocalPassiveMode();
  45.                     System.out.println("FTP服务连接成功！");
  46.                 }else {
  47.                     System.out.println("FTP服务用户名或密码错误！");
  48.                     disConnection(ftpClient);
  49.                 }
  50.             }else {
  51.                 System.out.println("连接到FTP服务失败！");
  52.                 disConnection(ftpClient);
  53.             }
  54.         } catch (SocketException e) {
  55.             e.printStackTrace();
  56.             disConnection(ftpClient);
  57.             System.out.println("FTP的IP地址可能错误，请正确配置。");
  58.         } catch (IOException e) {
  59.             e.printStackTrace();
  60.             disConnection(ftpClient);
  61.             System.out.println("FTP的端口错误,请正确配置。");
  62.         }
  63.         return ftpClient;
  64.     }
  65.  
  66.     /**
  67.      * 关闭FTP服务链接
  68.      * @throws IOException
  69.      */
  70.     public static void disConnection(FTPClient ftpClient){
  71.         try {
  72.             if(ftpClient.isConnected()){
  73.                 ftpClient.disconnect();
  74.             }
  75.         } catch (IOException e) {
  76.             e.printStackTrace();
  77.         }
  78.     }
  79.  
  80.     /**
  81.      * 获取文件夹下的所有文件信息
  82.      * @param path 文件路径
  83.      */
  84.     public static FTPFile[] getFTPDirectoryFiles(FTPClient ftpClient,String path){
  85.         FTPFile[] files = null;
  86.         try {
  87.             ftpClient.changeWorkingDirectory(path);
  88.             files = ftpClient.listFiles();
  89.             log.info(files.toString());
  90.         }catch (Exception e){
  91.             e.printStackTrace();
  92.             //关闭连接
  93.             disConnection(ftpClient);
  94.             System.out.println("FTP读取数据异常！");
  95.         }
  96.         return files;
  97.     }
  98.  
  99.  
  100.     /**
  101.      * 获取文件夹下的所有文件信息
  102.      * @param path 文件路径
  103.      */
  104.     public static InputStream getFTPFile(FTPClient ftpClient,String path,String fileName){
  105.         InputStream in = null;
  106.         try {
  107.             ftpClient.changeWorkingDirectory(path);
  108.             FTPFile[] files = ftpClient.listFiles();
  109.             if(files.length > 0){
  110.                 in  = ftpClient.retrieveFileStream(fileName);
  111.             }
  112.         }catch (Exception e){
  113.             e.printStackTrace();
  114.             System.out.println("FTP读取数据异常！");
  115.         }finally {
  116.             //关闭连接
  117.             disConnection(ftpClient);
  118.         }
  119.         return in;
  120.     }
  121.  
  122.     /**
  123.      * 下载ftp服务器文件方法
  124.      * @param ftpClient FTPClient对象
  125.      * @param newFileName 新文件名
  126.      * @param fileName 原文件（路径＋文件名）
  127.      * @param downUrl  下载路径
  128.      * @return
  129.      * @throws IOException
  130.      */
  131.     public static boolean downFile(FTPClient ftpClient, String newFileName, String fileName, String downUrl) throws IOException {
  132.         boolean isTrue = false;
  133.         OutputStream os=null;
  134.         File localFile = new File(downUrl + "/" + newFileName);
  135.         if (!localFile.getParentFile().exists()){//文件夹目录不存在创建目录
  136.             localFile.getParentFile().mkdirs();
  137.             localFile.createNewFile();
  138.         }
  139.         os = new FileOutputStream(localFile);
  140.         isTrue =ftpClient.retrieveFile(new String(fileName.getBytes("utf-8"),"iso-8859-1"), os);
  141.         os.close();
  142.         return isTrue;
  143.     }
  144.  
  145.     public static void main(String args[]){
  146.         InputStream in = null;
  147.         BufferedReader br = null;
  148.         FTPClient ftpClient1 = null;
  149.         try{
  150.             String path = "/var/ftp/aaa/";//设置ftp文件所在的目录
  151.             //读取单个文件
  152.             /*FTPClient ftpClient = getFTPClient("159.226.16.187",21,"zxd","1a2b3c");
  153.             String fileName = "person.txt";
  154.             in = getFTPFile(ftpClient,path,fileName);
  155.             if(in != null){
  156.                 br = new BufferedReader(new InputStreamReader(in,"GBK"));
  157.                 String data = null;
  158.                 while ((data = br.readLine()) != null) {
  159.                     String[] empData = data.split(";");
  160.                     System.out.println(empData[0]+" "+empData[1]);
  161.                 }
  162.             }*/
  163.  
  164.             SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMmDDHHmmss");
  165.             String dateStr = sdf.format(new Date());
  166.  
  167.             //读取文件夹下的所有文件
  168.             ftpClient1 = getFTPClient("159.226.16.187",21,"zxd","1a2b3c");
  169.             FTPFile[] files = getFTPDirectoryFiles(ftpClient1,path);
  170.  
  171.             //List<String> list = new ArrayList<String>();
  172.             if(files != null && files.length > 0){
  173.                 for (int i = 0; i < files.length; i++) {
  174.                     if(files[i].isFile()){
  175.  
  176.                         //in = ftpClient1.retrieveFileStream(remotePath);
  177.                        // br = new BufferedReader(new InputStreamReader(in,"GBK"));
  178.                         //只读取文件后缀名为.docx的文件
  179.                         if(files[i].getName().indexOf(".docx")>=0 &&files[i].getName().length() == (files[i].getName().lastIndexOf(".docx") + ".docx".length())){
  180.                             /*System.out.println("获取的文件名：>>>>>>>>>>>>>>>>>>>>"+files[i].getName());
  181.                             String NewfileName="ddd"+dateStr+".docx";
  182.                             boolean flag =downFile(ftpClient1,NewfileName,path+files[i].getName(),"D:\\file\\");
  183.                             System.out.println(flag);//flag=true说明下载成功
  184.                             WebLoophole bean = new WebLoophole();*/
  185.                             try {
  186.                                 /*String remotePath="D:\\file\\"+NewfileName;
  187.                                 log.info("文件路径输出>>>>>>>>>>>>>>>>>>>>>>>>>>=========>"+remotePath);
  188.                                 List<String> list = POIUtil.readWord("D:\\file\\");
  189.                                 if( list !=null){
  190.                                     bean.setWebName(list.get(5));
  191.                                     DateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
  192.                                     String replace = list.get(13).replace("年", "-").replace("月", "-").replace("日", "-");
  193.                                     bean.setScanTime(sdf1.parse(replace));
  194.                                     bean.setLoopholeTotal(Integer.parseInt(list.get(35).split(" ")[1]));
  195.                                     bean.setDomain(list.get(22).split("\t")[1]);
  196.                                     bean.setWebUrl(list.get(21).split("\t")[1]);
  197.                                     String [] numArray = list.get(33).split("\t");
  198.                                     bean.setCritical(Integer.parseInt(numArray[0]));
  199.                                     bean.setHigh(Integer.parseInt(numArray[1]));
  200.                                     bean.setMiddle(Integer.parseInt(numArray[2]));
  201.                                     bean.setLow(Integer.parseInt(numArray[3]));
  202.                                     log.info("数据输出=========>"+bean);
  203.                                     //searchDataMapper.insertWebLoopholeLog(bean);
  204.                                 }*/
  205.  
  206.                             } catch (Exception e) {
  207.                                 log.error("{}",e);
  208.                             }finally {
  209.                                 /*Process process =null;
  210.                                 //读取完文件内容，执行脚本命令清空
  211.                                 String command1 ="rm "+" "+filePath;
  212.                                 try {
  213.                                     Runtime.getRuntime().exec(command1 ).waitFor();
  214.                                 } catch (IOException e1) {
  215.                                     log.error("{}",e1);
  216.                                 }catch (InterruptedException e) {
  217.                                     log.error("{}",e);
  218.                                 }*/
  219.                             }
  220.  
  221.                         }else{
  222.                             System.out.println("获取的文件名：>>>>>>>>>>>>>>>>>>>>"+files[i].getName());
  223.                             String filePath="D:\\file1\\";
  224.                             boolean flag =downFile(ftpClient1,files[i].getName(),path+files[i].getName(),filePath);
  225.                             System.out.println(flag);//flag=true说明下载成功*/
  226.                             File[] dirFiles = new File(filePath).listFiles();
  227.                             String fileName = null;
  228.                             List<Map<String,Object>> list = null;
  229.                             InputStream is = null;
  230.                             for(File temp : dirFiles){
  231.                                 //获取文件路径，包含文件名
  232.                                 filePath = temp.getAbsolutePath();
  233.                                 //获取文件名
  234.                                 fileName = temp.getName();
  235.                                 System.out.println(temp.isFile() + " " + temp.getAbsolutePath());
  236.                                 // 创建输入流，读取Excel
  237.                                 try {
  238.                                     File file1 = new File(filePath);
  239.                                     System.out.println(file1.getAbsolutePath());
  240.                                     is = new FileInputStream(file1.getAbsolutePath());
  241.                                     list = new ArrayList<Map<String,Object>>();
  242.                                     // jxl提供的Workbook类
  243.                                     HSSFWorkbook workbook =  new HSSFWorkbook(is);
  244.                                     Map<String,Object> map = null;
  245.                                     for (int n = 0; n < workbook.getNumberOfSheets(); n++) {
  246.                                         if(workbook.getNumberOfSheets() == 0){
  247.                                             System.out.println("输出为空>>>>>>>>>>>>>>>");
  248.                                             //return list;
  249.                                         }
  250.                                         HSSFSheet sheet = workbook.getSheetAt(i);
  251.                                         System.out.println(sheet.getLastRowNum());
  252.                                         for (int j = 1; j <= sheet.getLastRowNum(); j++) {
  253.                                             if(j == 1){
  254.                                                 continue;
  255.                                             }
  256.                                             map = new HashMap<String,Object>();
  257.                                             String ip = sheet.getRow(j).getCell(0)==null?"":sheet.getRow(j).getCell(0).toString().trim();
  258.                                             String machinName = sheet.getRow(j).getCell(1)==null?"":sheet.getRow(j).getCell(1).toString().trim();
  259.                                             String name = sheet.getRow(j).getCell(2)==null?"":sheet.getRow(j).getCell(2).toString().trim();
  260.                                             String riskLevel = sheet.getRow(j).getCell(3)==null?"":sheet.getRow(j).getCell(3).toString().trim();
  261.                                             String stagery = sheet.getRow(j).getCell(4)==null?"":sheet.getRow(j).getCell(4).toString().trim();
  262.                                             String status = sheet.getRow(j).getCell(5)==null?"":sheet.getRow(j).getCell(5).toString().trim();
  263.                                             String descript = sheet.getRow(j).getCell(6)==null?"":sheet.getRow(j).getCell(6).toString().trim();
  264.                                             Date createTime = sheet.getRow(j).getCell(7).getDateCellValue();
  265.                                             map.put("ip", ip);
  266.                                             map.put("machinName", machinName);
  267.                                             map.put("name", name);
  268.                                             map.put("riskLevel", riskLevel);
  269.                                             map.put("stagery", stagery);
  270.                                             map.put("status", status);
  271.                                             map.put("descript", descript);
  272.                                             //Date date = new SimpleDateFormat("yyyy/mm/dd hh:mm:ss").parse(createTime);
  273.                                             map.put("createTime", createTime);
  274.                                             list.add(map);
  275.                                             //searchDataMapper.insertHostLog(list);
  276.                                         }
  277.                                     }
  278.                                 } catch (Exception e) {
  279.                                     e.printStackTrace();
  280.                                 }
  281.  
  282.                             }
  283.                             // return list;
  284.                         }
  285.                     }
  286.                 }
  287.             }
  288.         }catch (Exception e){
  289.             e.printStackTrace();
  290.         }finally {
  291.             try{
  292.                 //关闭连接
  293.                 disConnection(ftpClient1);
  294.                 //关闭流
  295.                 if (br != null)
  296.                     br.close();
  297.                 if (in != null)
  298.                     in.close();
  299.             }catch (IOException e){
  300.                 e.printStackTrace();
  301.             }
  302.         }
  303.     }
  304. }

 

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

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

  

闽ICP备14008679号