javaweb实现Sftp文件上传下载

思路

1.首先连接ftp服务器

2.连接到服务器之后如何上传文件

3.上传后如何获取文件

4.文件格式是图片如何展示到客户端浏览器

5.服务端代码如何接收客户端的文件以及如何返回响应信息给浏览器

 主要jar包依赖文件

      com.jcraft
      jsch
      0.1.54
 
        

      com.jcraft
      jzlib
      1.1.1
 

public class SftpUtils {

   private static final Logger log &＃61; LoggerFactory.getLogger(SftpUtils.class);
   private static ChannelSftp sftp;
   public static Properties properties &＃61; LoadProperties.getProperties("/config/sftp.properties");
   private static Channel channel;
   private static Session sshSession;

    /**
     * 登陆SFTP服务器
     * &＃64;return
     */
    public static boolean getConnect() throws Exception{
        log.info("进入SFTP&＃61;&＃61;&＃61;&＃61;");
        boolean result &＃61; false;
        JSch jsch &＃61; new JSch();
        //获取sshSession  账号-ip-端口&＃xff0c;从properties文件中获取连接ftp服务器的相关信息
        sshSession  &＃61;jsch.getSession(properties.getProperty("user"), properties.getProperty("ip"), Integer.parseInt(properties.getProperty("port")));
        //添加密码
        sshSession.setPassword(properties.getProperty("password"));
        Properties sshConfig &＃61; new Properties();
        //严格主机密钥检查
        sshConfig.put("StrictHostKeyChecking", "no");

        sshSession.setConfig(sshConfig);
        //开启sshSession链接
        sshSession.connect();
        //获取sftp通道
        channel &＃61; sshSession.openChannel("sftp");
        //开启
        channel.connect();
        sftp &＃61; (ChannelSftp) channel;
        result &＃61; true;
        return result;
    }
    
    /**
             * 文件上传
     * &＃64;param inputStream 上传的文件输入流
     * &＃64;param fileCategory 存储文件目录分类
     * &＃64;return
     */
    public static String upload(InputStream inputStream, String fileCategory, String fileName) throws Exception{
        String destinationPath &＃61; properties.getProperty("destinationPath")&＃43;fileCategory;
        try {
            sftp.cd(destinationPath);
            //获取随机文件名
            fileName  &＃61; UUID.randomUUID().toString().replace("-", "") &＃43; fileName;
            //文件名是 随机数加文件名的后5位
            sftp.put(inputStream, fileName);
        }finally {
            sftp.disconnect();
        }
        return fileName;
    }
 
    /**
         * 下载文件
    *
    * &＃64;param downloadFilePath 下载的文件完整目录
    * &＃64;param saveFile     保存在本地的文件路径
    * &＃64;return 返回的是文件
    */
    public static File download(String downloadFilePath, String saveFile) {
        FileOutputStream fileOutputStream &＃61; null;
        try {
            int i &＃61; downloadFilePath.lastIndexOf(&＃39;/&＃39;);
            if (i &＃61;&＃61; -1)
                return null;
            sftp.cd(downloadFilePath.substring(0, i));
            File file &＃61; new File(saveFile);
            fileOutputStream &＃61; new FileOutputStream(file);
            sftp.get(downloadFilePath.substring(i &＃43; 1), fileOutputStream);
            return file;
        } catch (Exception e) {
            log.error(e.getMessage());
            return null;
        }finally {
            sftp.disconnect();
            try {
                fileOutputStream.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    
    
    /**
         * 获取ftp服务器    (图片)文件流
     * &＃64;param downloadFilePath ftp文件上的文件全路径&＃xff0c;包括具体文件名 a/b/c.png
     * &＃64;return 返回的是文件流
     */
    public static InputStream download(String downloadFilePath) {
        int i &＃61; downloadFilePath.lastIndexOf(&＃39;/&＃39;);
        InputStream inputStream &＃61; null;
        if (i &＃61;&＃61; -1)
            return null;
        try {
            sftp.cd(downloadFilePath.substring(0, i));
            inputStream &＃61; sftp.get(downloadFilePath.substring(i &＃43; 1));
        } catch (SftpException e) {
            log.error("获取ftp服务文件流发生异常!");
            e.printStackTrace();
        }
        return inputStream;
    }
    
    /* * 断开SFTP Channel、Session连接
     * &＃64;throws Exception
     *
     */
    public static void disconnect() {
        if (SftpUtils.sftp !&＃61; null) {
            if (sftp.isConnected()) {
                sftp.disconnect();
                log.info("sftp is closed already");
            }
        }
        if (SftpUtils.sshSession !&＃61; null) {
            if (SftpUtils.sshSession.isConnected()) {
                SftpUtils.sshSession.disconnect();
                log.info("sshSession is closed already");
            }
        }
    }
    
    /**
     * 文件流转为base64字节码
     * &＃64;param in
     * &＃64;return
     */
    public static String inputStreamtoBase64(InputStream in) throws Exception{
        byte[] bytes &＃61; IOUtils.toByteArray(in);
        String base64str &＃61; Base64.getEncoder().encodeToString(bytes);
        return base64str;
    }

    /** 删除sftp文件
     * &＃64;param directPath 需要删除的文件目录
     * &＃64;param fileName 需要删除的文件
     * &＃64;return
     **/
    public static void deleteFile(String directPath, String fileName) throws Exception{
        //进入需要删除的文件目录下 
        sftp.cd(directPath);
        sftp.rm(fileName);
    }
    
   
    /**
         * 列出某目录下的文件名
     * &＃64;param directory 需要列出的文件目录(sftp服务器目录下的)
     * &＃64;return  List 返回的文件名列表
     * &＃64;throws Exception
     */
    public static List listFiles(String directory) throws Exception {
        Vector fileList;
        List fileNameList &＃61; new ArrayList();
        fileList &＃61; sftp.ls(directory);
        Iterator it &＃61; fileList.iterator();
        while(it.hasNext())
        {
            String fileName &＃61; ((LsEntry)it.next()).getFilename();
            if(".".equals(fileName) || "..".equals(fileName)){
            continue;
            }
            fileNameList.add(fileName);

        }
        return fileNameList;
        }

总结&＃xff1a;上面是一个ftp工具类&＃xff0c;包括ftp连接&＃xff0c;文件上传&＃xff0c;文件下载&＃xff0c;ftp服务硬盘目录下的文件查询

二,服务端后台代码

/**
     * 上传文件
     * &＃64;param multipartFile 客户端上传的文件
     * &＃64;param request
     * &＃64;param response
     * &＃64;return
     */
    &＃64;PostMapping("uploadFile")
    &＃64;ResponseBody
    public String uploadFile(&＃64;RequestParam("multipartFile") MultipartFile multipartFile, HttpServletRequest request, HttpServletResponse response) {
        //连接sftp服务
        String fileName &＃61; null;
        try {
            SftpUtils.getConnect();
            //上传的文件所属类型 banner, mobile, pc, share四种
            //如果未明确默认存放在ftp服务器的share文件目录下
            String fileCategory &＃61; request.getParameter("fileCategory")&＃61;&＃61; null ? "share" : request.getParameter("fileCategory");
            //上传的文件名
            fileName &＃61; multipartFile.getOriginalFilename();
            int index &＃61; fileName.lastIndexOf(".");
            String nameSuffix &＃61; fileName.substring(index, fileName.length());
            //禁止上传.exe文件
            if(".exe".equalsIgnoreCase(nameSuffix)) {
                return renderResult(Global.FALSE, text("上传的文件格式不支持!")); 
            }
            InputStream inputStream &＃61; multipartFile.getInputStream();
            String filePath &＃61; SftpUtils.upload(inputStream, fileCategory, fileName);
            SftpUtils.disconnect();
            //需要保存到数据库的文件名称
            fileName &＃61; fileCategory&＃43;"/"&＃43;filePath;
        } catch (Exception e) {
            e.printStackTrace();
            logger.error("文件上传过程中发生异常!");
            return renderResult(Global.FALSE, text("上传失败!"));
        }
            return renderResult(Global.TRUE, text(fileName));
    }
    
    /**
     * 下载文件
     * &＃64;param request
     * &＃64;param response
     * &＃64;return
     */
    &＃64;RequestMapping("downLoad")
    &＃64;ResponseBody
    public Map downLoad(HttpServletRequest request, HttpServletResponse response) {
        Map paraMap &＃61; new HashMap();
        paraMap.put("result", "true");
        paraMap.put("msg", "文件下载成功");
        //获取需要下载的文件名称
        //正式情况下是从表中获取&＃xff0c;文件格式,文件名称,存入数据库中
        //测试某文件名称
        String fileName &＃61; "share/eae3b1a4a6fe4bb48af11381add03c59textJGY.jpg";
        //判断需要下载的文件是否是图片格式&＃xff0c;如果是图片则传Base64格式给浏览器
        String fileType &＃61; "jpg";
        String oldName &＃61; "JGY.jpg";
        String [] imagesTypes &＃61; {"jpg", "JPG", "png", "PNG", "bmp", "BMP", "gif", "GIF"};
        boolean flag &＃61; false;
        for (int i &＃61; 0; i             if(fileType.equalsIgnoreCase(imagesTypes[i])) {
                flag &＃61; true;
                break;
            }
        }
        try {
            SftpUtils.getConnect();
        } catch (Exception ftpexp) {
            logger.error("ftp连接时发生异常!");
            ftpexp.printStackTrace();
            paraMap.put("result", "false");
            paraMap.put("msg", "ftp连接时发生异常!");
            return paraMap;
        }
        //获取properties文件中ftp服务器存放的路径
        String direct &＃61; SftpUtils.properties.getProperty("destinationPath");
        //获取下载文件的文件流            
        String downloadFilePath &＃61; direct&＃43;fileName;
        InputStream inputStream &＃61; SftpUtils.download(downloadFilePath);
        //图片转为base64
        if(flag) {
            try {
                //文件流转为base64
                String base64String &＃61; SftpUtils.inputStreamtoBase64(inputStream);
                paraMap.put("base64", base64String);
            } catch (Exception e) {
                logger.error("文件下载出现异常!");
                e.printStackTrace();
                paraMap.put("result", "false");
                paraMap.put("msg", "文件下载失败!");
                return paraMap;
            }
            //非图片文件就直接浏览器下载
        } else {
             String agent &＃61; request.getHeader("user-agent");
             try {
                 if(StringUtils.contains(agent, "MSIE")||StringUtils.contains(agent,"Trident")){//IE浏览器
                     oldName &＃61; URLEncoder.encode(oldName,"UTF8");
                     System.out.println("IE浏览器");
                 }else if(StringUtils.contains(agent, "Mozilla")) {//google,火狐浏览器
                     oldName &＃61; new String(oldName.getBytes(), "ISO8859-1");
                 }else {
                     oldName &＃61; URLEncoder.encode(oldName,"UTF8");//其他浏览器
                 }
                 response.reset();//重置 响应头
                 response.setContentType("application/x-download");//告知浏览器下载文件&＃xff0c;而不是直接打开&＃xff0c;浏览器默认为打开
                 response.addHeader("Content-Disposition" ,"attachment;filename&＃61;\"" &＃43;oldName&＃43; "\"");//下载文件的名称
                 byte[] b &＃61; new byte[1024];
                 int len;
                 while((len &＃61; inputStream.read(b)) > 0) {
                     response.getOutputStream().write(b, 0, len);;
                 }
             }catch (Exception e) {
                e.printStackTrace();
                paraMap.put("result", "false");
                paraMap.put("msg", "文件下载失败!");
                return paraMap;
             }finally {
                 try {
                    response.getOutputStream().close();
                } catch (IOException e) {
                    logger.error("文件输出流关闭发生异常!");
                    e.printStackTrace();
                }
                 SftpUtils.disconnect();
            }
        }
        return paraMap;
    }