sftp实战

旧城等待， 2021-10-30 02:24 369阅读 0赞

要求读取sftp 目录下的文件解析入库

![925291-20190716175839136-1366916967.png][]

SFTP配置类

// 远程服务器ip
        public static String HOST = "192.168.204.7";
    
        // 远程服务器端口
        public static int PORT = 22;
    
        // 远程服务器用户名
        public static String USERNAME = "teys02";
    
        // 远程服务器密码
        public static String PASSWORD = "9sL";
    
        // 文件临时存放路径
        public static String SAVEPATH = "/opt/saas/isc-dtt/sap/";

存放路径注意权限

注意点：

Vector a = sftp.ls("/path");

定位到文件的目录

ChannelSftp.LsEntry entry = (ChannelSftp.LsEntry) ite.next();
     String filename = entry.getFilename();
     log.info("filename"+filename);

获取文件的名字例如：FTPCN\_PT001S (1).xml

这里读取的时候会连文件夹名称一起读取

![925291-20190716180531611-226115769.png][]

所以加了校验

if(filename.contains("FTPCN")){

下载的文件

String path = FTPConfig.SAVEPATH + filename;
     log.info("本地保存 path = " + path);
    // 下载文件 1下载的路径 2是保存的路径

SftpUtil.download("/path/" + filename, path, sftp);

是下载的相对路径/path/xx.xml

如果路径错误下载的就是空文件

下载完成后，对保存的路径做便利 读取

File file2 = new File(FTPConfig.SAVEPATH);
       if(file2.exists()){
           File[] files = file2.listFiles();
           if (files.length == 0) {
                log.info("文件夹是空的!");
           } else {
          for (File file : files) {
            log.info("#########读取文件  " + file.getAbsolutePath());

查看是否下载到服务器的文件夹内

完整代码（有bug）

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

public void dealData() {
            ChannelSftp sftp = null;
    
            int number = 0;
            try {
                sftp = SftpUtil.getSftpConnect(FTPConfig.HOST, FTPConfig.PORT, FTPConfig.USERNAME,
                    FTPConfig.PASSWORD);
                if (null == sftp) {
                    int timesOfResend = 5;
                    int _connectCount = 1;
                    //SFTP连接失败，尝试重连5次
                    while (timesOfResend > 0 && sftp == null) {
                        //间隔60秒
                        Thread.sleep(60000);
                        sftp = SftpUtil.getSftpConnect(FTPConfig.HOST, FTPConfig.PORT, FTPConfig.USERNAME,
                            FTPConfig.PASSWORD);
                        if(sftp == null){
                            log.info(taskName, "尝试重连 --> " + (_connectCount++) +"次失败,sftp = "+ sftp);
                        }else{
                            log.info(taskName, "尝试重连 --> " + (_connectCount++) +"次成功,sftp = "+ sftp);
                        }
    
                        timesOfResend--;
                    }
                }
    
                if (null == sftp) {
                    log.info("InitSftpConnection", "SFTP尝试重连5次后失败,SFTP==null");
                    //通知LinkWin
                    //return ResultVO.connectionError("SFTP尝试重连5次后失败");
                } else {
                    // 获取文件路径和文件名称
                   /* String pwd = sftp.pwd();
                    log.info("pwd"+pwd);
    */
                    /*Vector b = sftp.ls("/");
                    for(Iterator ite=b.iterator(); ite.hasNext();) {
                        log.info("b==="+ite.next().toString());
                    }*/
    
    
                    Vector a = sftp.ls("/path");
                    for(Iterator ite=a.iterator(); ite.hasNext();) {
                        ChannelSftp.LsEntry entry = (ChannelSftp.LsEntry) ite.next();
                        String filename = entry.getFilename();
                       //s SftpATTRS attrs = entry.getAttrs();
    
                        //log.info("attrs"+attrs);
                        log.info("filename"+filename);
                        if(filename.contains("FTPCN")){
                            String path = FTPConfig.SAVEPATH + filename;
    
                            // 上传到azure
                            //InitaZureConnection.upload(path);
                            log.info("本地保存 path = " + path);
                            // 下载文件 1下载的路径 2是保存的路径
                            SftpUtil.download("/path/" + filename, path, sftp);
    
                            File file2 = new File(FTPConfig.SAVEPATH);
                            if(file2.exists()){
                                File[] files = file2.listFiles();
                                if (files.length == 0) {
                                    log.info("文件夹是空的!");
                                } else {
                                    for (File file : files) {
                                        log.info("#########读取文件  " + file.getAbsolutePath());
                                        Document document = XmlUtils.getDocument(file);
                                        Element rootElement = document.getRootElement();
                                        Element rec = rootElement.element("RECORDSET");
                                        if(file.getAbsolutePath().contains(SapConstants.FTPCN_PT001S)){
                                            log.info("-----createHu");
                                            createHu(rec);
                                        }else if(file.getAbsolutePath().contains(SapConstants.FTPCN_PT002S)){
                                            log.info("-----createObd");
                                            createObd(rec);
                                        }else if(file.getAbsolutePath().contains(SapConstants.FTPCN_PT003S)){
                                            log.info("-----createIbd");
                                            createIbd(rec);
                                        }
                                    }
                                }
                        }
    
    
    
                        }
                    }
                   
                    SftpUtil.exit(sftp);
    
    
                    // 通知linkwin
                    //log.info("InitSftpConnection", "number="+ number);
                }
            }  catch (Exception e) {
                log.info("InitSftpConnection", e);
            } finally {
                if (null != sftp) {
                    SftpUtil.exit(sftp);
                }
            }
            //return null;
        }

上面代码有个BUG，重复读取了文件夹下的文件。
    因为先是iteratrot 然后又file。files（）
    更新版

for(Iterator ite=a.iterator(); ite.hasNext();) {
                        ChannelSftp.LsEntry entry = (ChannelSftp.LsEntry) ite.next();
                        String filename = entry.getFilename();
                       //s SftpATTRS attrs = entry.getAttrs();
    
                        //log.info("attrs"+attrs);
                        log.info("filename"+filename);
                        if(filename.contains("FTPCN")){
                            String path = FTPConfig.SAVEPATH + filename;
    
                            // 上传到azure
                            //InitaZureConnection.upload(path);
                            log.info("本地保存 path = " + path);
                            // 下载文件 1下载的路径 2是保存的路径
                            SftpUtil.download(FTP_FILEPATH+"/" + filename, path, sftp);
    
                            File file = new File(path);
                            log.info("#########读取文件  " + file.getAbsolutePath());
                            Document document = XmlUtils.getDocument(file);
                            Element rootElement = document.getRootElement();
                            Element rec = rootElement.element("RECORDSET");
                            if(file.getAbsolutePath().contains(SapConstants.FTPCN_PT001S)){
                                log.info("-----createHu");
                                createHu(rec);
                            }else if(file.getAbsolutePath().contains(SapConstants.FTPCN_PT002S)){
                                log.info("-----createObd");
                                createObd(rec);
                            }else if(file.getAbsolutePath().contains(SapConstants.FTPCN_PT003S)){
                                log.info("-----createIbd");
                                createIbd(rec);
                            }
                        }
                    }

转载于:https://www.cnblogs.com/lyon91/p/11196606.html

[925291-20190716175839136-1366916967.png]: /images/20211029/c3edaf5e51be4848ab1a265ae3852b2f.png
[925291-20190716180531611-226115769.png]: /images/20211029/8f53adbedec241c98706850c91691239.png
[ContractedBlock.gif]: https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif
[ExpandedBlockStart.gif]: /images/20211029/0f24fe53adb2455b9a735961c06efa60.png