JSch实现SFTP文件上传

引入jar包

<!--tomcat上传到服务器工具  -->
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-ftp</artifactId>
            <version>2.13.2</version>
        </dependency>
           

代码

package cn.nhb.upload.util;

import com.jcraft.jsch.*;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

@Service
public class SftpJschUtil {
    @Value("${sftp.host}")
    private String host;
    @Value("${sftp.port}")
    private int port;
    @Value("${sftp.username}")
    private String username;
    @Value("${sftp.password}")
    private String password;
    @Value("${sftp.directory}")
    private String directory;
    @Value("${sftp.nginxUrl}")
    private String nginxUrl;

    private static final Logger logger = LoggerFactory.getLogger(SftpJschUtil.class);

    //获取连接
    public ChannelSftp getConnection() {
        JSch jsch = new JSch();
        try {
            Session session = jsch.getSession(username, host, port);
            session.setPassword(password);
            //配置取消验证hostkey
            Properties config = new Properties();
            config.put("StrictHostKeyChecking", "no");
            session.setConfig(config);
            session.connect();

            //获取sftp通道
            ChannelSftp channelSftp = (ChannelSftp) session.openChannel("sftp");
            //连接
            channelSftp.connect();

            return channelSftp;
        } catch (JSchException e) {
            logger.error("连接sftp服务器失败", e);
        }
        return null;
    }

    //文件上传
    public String fileUpload(MultipartFile file, String path) throws SftpException, IOException {
        ChannelSftp sftp = getConnection();
        try {
            sftp.cd(directory + path);
        } catch (SftpException e) {
            logger.error("未找到此文件夹,正在创建中...");
            sftp.mkdir(directory + path);
            sftp.cd(directory + path);
        }
        String fileName = file.getOriginalFilename();
        String newFileName = NoUtil.getInstance().getOrderID() + fileName.substring(fileName.lastIndexOf("."));
        InputStream in = file.getInputStream();
        sftp.put(in, newFileName);
        return nginxUrl + path + fileName;
    }

    //删除文件
    public boolean deleteFile(String path) {
        ChannelSftp sftp = getConnection();
        try {
            sftp.cd(directory);
            sftp.rm(path.substring(nginxUrl.length()));
            return true;
        } catch (SftpException e) {
            return false;
        }
    }
}