SpringBoot读取Linux服务器某路径下文件读取项目Resource下文件

Posted 2020-11-23 Rainyn

// SpringBoot读取Linux服务器某路径下文件
    public String messageToRouted() {
            File file = null;
            try {
                file = ResourceUtils.getFile("/home/admin/logs/test/routed.txt");
                // 获取文件输入流
                InputStream inputStream = new FileInputStream(file);
                List<String> fileList = IOUtils.readLines(inputStream);
                log.info("fileList:{}", fileList);
                fileList.forEach(rd -> {
                    RoutedPO routedPO = new RoutedPO();
                    routedPO.setFulfillmentOrderName(rd.trim());
                    routedPO.setRoutedTo("test");
                    // 通知分单结果
                    routedService.notifyRoutedResult(routedPO, OfcRoutedOperate.INSERT);
                });
            } catch (FileNotFoundException e) {
                log.info("文件不存在！");
                return "文件不存在！";
            } catch (IOException e) {
                log.info("文件读取异常！");
                return "文件读取异常！";
            }
        return "success!";
    }

// SpringBoot读取Resource下文件
    public String messageToRouted(){
        try {
            ClassPathResource classPathResource = new ClassPathResource("routed.txt");
            // 判断文件是否存在
            boolean exists = classPathResource.exists();
            if(!exists){
                log.info("文件不存在！");
                return "文件不存在！";
            }
            try {
                // 获取文件输入流
                InputStream inputStream = classPathResource.getInputStream();
                List<String> fileList = IOUtils.readLines(inputStream);
                log.info("fileList:{}",fileList);
                fileList.forEach(rd ->{
                    RoutedPO routedPO = new RoutedPO();
                    routedPO.setFulfillmentOrderName(rd.trim());
                    routedPO.setRoutedTo("test");
                    // 通知分单结果
                    routedService.notifyRoutedResult(routedPO, OfcRoutedOperate.INSERT);
                });
            } catch (IOException e) {
                log.info(e.getMessage());
            }
        } catch (RuntimeException e) {
            log.info(e.getMessage());
        }
        return "success!";
    }