Java上传文件到Linux服务器

清疚 2022-10-10 04:40 266阅读 0赞

> 将从数据库中查询出的数据，按照字段排序，数据之间以 "|"分隔，存储到文本文件中，上传到指定的服务器

下面分两种方法来进行实现：SFTP 和 FTP，一般使用 SFTP

> SFTP

SFTP 需要引入包

<dependency>
        <groupId>commons-net</groupId>
        <artifactId>commons-net</artifactId>
        <version>3.8.0</version>
    </dependency>
    
    <dependency>
    	<groupId>com.jcraft</groupId>
    	<artifactId>jsch</artifactId>
    	<version>0.1.55</version>
    </dependency>

public static void main(String[] args) { 
    	// sb 为查询出来的数据转换成的字符串
        ByteArrayInputStream inputStream = new ByteArrayInputStream(sb.toString().getBytes());
        boolean success = uploadFileSFTP("xxx.xxx.xxx.xxx", 22, "root", "root", "/home/data", "/20210626", "test.txt", inputStream);
        log.info("文件上传成功");
    }

/** * 向FTP服务器上传文件 * * @param host FTP服务器ip * @param port FTP服务器端口 * @param username FTP登录账号 * @param password FTP登录密码 * @param basePath FTP服务器基础目录,/home/data * @param filePath FTP服务器文件存放路径 * @param filename 上传到FTP服务器上的文件名 * @param input 输入流 * @return 成功返回true，否则返回false */
    private boolean uploadFileSFTP(String host, int port, String username, String password, String basePath,
                                   String filePath, String filename, InputStream inputStream) { 
        boolean result;
        FTPClient ftp = new FTPClient();
        try { 
            JSch jsch = new JSch();
            // 获取sshSession 账号-ip-端口
            Session sshSession = jsch.getSession(username, host, port);
            // 添加密码
            sshSession.setPassword(password);
            Properties sshConfig = new Properties();
            // 严格主机密钥检查
            sshConfig.put("StrictHostKeyChecking", "no");
            sshSession.setConfig(sshConfig);
            // 开启sshSession链接
            sshSession.connect();
            // 获取sftp通道
            Channel channel = sshSession.openChannel("sftp");
            // 开启
            channel.connect();
            ChannelSftp sftp = (ChannelSftp) channel;
            // 设置为被动模式
            ftp.enterLocalPassiveMode();
            // 设置上传文件的类型为二进制类型
            ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
            // 进入到要上传的目录 然后上传文件
            sftp.cd(basePath + filePath);
            // sftp put为上传，get为下载，之后会出一篇下载的代码
            sftp.put(inputStream, filename);
            inputStream.close();
            result = true;
        } catch (Exception e) { 
            log.error("FTP服务器 文件上传失败 失败原因：{}", e.getMessage(), e);
            result = false;
        } finally { 
            if (ftp.isConnected()) { 
                try { 
                    ftp.disconnect();
                } catch (IOException e) { 
                    log.error("FTP服务器 关闭失败 失败原因：{}", e.getMessage(), e);
                }
            }
        }
        return result;
    }

> FTP

FTP需要引入的包

<dependency>
        <groupId>commons-net</groupId>
        <artifactId>commons-net</artifactId>
        <version>3.8.0</version>
    </dependency>

/** * @param url FTP服务器hostname * @param port FTP服务器端口 * @param username FTP登录账号 * @param password FTP登录密码 * @param path FTP服务器保存目录 * @param filename 文件名 6403_APP_YYYYMMDD_渠道标志_批次号.txt * @param input 输入流 * @return */
    private boolean uploadFileFTP(String url, int port, String username, String password,
                                  String path, String filename, InputStream inputStream) { 
        boolean success;
        FTPClient ftp = new FTPClient();
        try { 
            int reply;
            // 链接 FTP 服务器
            // 如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器
            ftp.connect(url, port);
            // 登录
            ftp.login(username, password);
            // 返回链接码
            reply = ftp.getReplyCode();
            // 设置文件格式为二进制类型
            ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
            if (!FTPReply.isPositiveCompletion(reply)) { 
                ftp.disconnect();
                log.info("FTP服务器 拒绝连接");
                return false;
            }
            // 跳转到指定的目录路径
            ftp.changeWorkingDirectory(path);
            // 存储文件
            ftp.storeFile(filename, inputStream);
            inputStream.close();
            ftp.logout();
            success = true;
        } catch (IOException e) { 
            log.error("FTP服务器 文件上传失败 失败原因：{}", e.getMessage(), e);
            return false;
        } finally { 
            if (ftp.isConnected()) { 
                try { 
                    ftp.disconnect();
                } catch (IOException e) { 
                    log.error("FTP服务器 关闭失败 失败原因：{}", e.getMessage(), e);
                }
            }
        }
        return success;
    }

FTP上传会出现一个

MalformedServerReplyException: Could not parse response code

异常，解决办法可以参考下面的解决办法  
[https://blog.csdn.net/shenju2011/article/details/106614717][https_blog.csdn.net_shenju2011_article_details_106614717]

参考文档：  
[https://blog.csdn.net/a116385895/article/details/107150935/][https_blog.csdn.net_a116385895_article_details_107150935]

[https://blog.csdn.net/hpp1314520/article/details/72875151][https_blog.csdn.net_hpp1314520_article_details_72875151]

[https_blog.csdn.net_shenju2011_article_details_106614717]: https://blog.csdn.net/shenju2011/article/details/106614717
[https_blog.csdn.net_a116385895_article_details_107150935]: https://blog.csdn.net/a116385895/article/details/107150935/
[https_blog.csdn.net_hpp1314520_article_details_72875151]: https://blog.csdn.net/hpp1314520/article/details/72875151