怎么在java中利用SFTP上传文件到资源服务器?很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。
首先得创建连接sftp服务器的公共类MySftp.java:
package cn.test.util; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.text.SimpleDateFormat; import java.util.Date; import java.util.Properties; import java.util.Vector; import javax.servlet.http.HttpServletRequest; import com.jcraft.jsch.Channel; import com.jcraft.jsch.ChannelSftp; import com.jcraft.jsch.JSch; import com.jcraft.jsch.Session; import com.jcraft.jsch.SftpException; public class MySFTP { /** * 连接sftp服务器 * @param host 主机 * @param port 端口 * @param username 用户名 * @param password 密码 */ public ChannelSftp connect(String host, int port, String username, String password) { ChannelSftp sftp = null; try { JSch jsch = new JSch(); jsch.getSession(username, host, port); Session sshSession = jsch.getSession(username, host, port); sshSession.setPassword(password); Properties sshConfig = new Properties(); sshConfig.put("StrictHostKeyChecking", "no"); sshSession.setConfig(sshConfig); sshSession.connect(); Channel channel = sshSession.openChannel("sftp"); channel.connect(); sftp = (ChannelSftp) channel; } catch (Exception e) { } return sftp; } /** * 上传文件 * * @param directory * 上传的目录 * @param uploadFile * 要上传的文件 * @param sftp */ public void upload(String directory, String uploadFile, ChannelSftp sftp) { try { sftp.cd(directory); File file = new File(uploadFile); sftp.put(new FileInputStream(file), file.getName()); } catch (Exception e) { e.printStackTrace(); } } /** * 下载文件 * * @param directory * 下载目录 * @param downloadFile * 下载的文件 * @param saveFile * 存在本地的路径 * @param sftp */ public void download(String directory, String downloadFile, String saveFile, ChannelSftp sftp) { try { sftp.cd(directory); File file = new File(saveFile); sftp.get(downloadFile, new FileOutputStream(file)); } catch (Exception e) { e.printStackTrace(); } } /** * 删除文件 * * @param directory * 要删除文件所在目录 * @param deleteFile * 要删除的文件 * @param sftp */ public void delete(String directory, String deleteFile, ChannelSftp sftp) { try { sftp.cd(directory); sftp.rm(deleteFile); } catch (Exception e) { e.printStackTrace(); } } public void uploadSFTP(HttpServletRequest request,String[] uploadFiles) throws Exception { MySFTP mySFTP = new MySFTP(); SFTPUtil sFTPUtil =new SFTPUtil(); ChannelSftp sftp = null; Session session = null; try { sftp = mySFTP.connect(SystemConstants.SFTP_host, Integer.parseInt(SystemConstants.SFTP_port), SystemConstants.SFTP_username, SystemConstants.SFTP_password); for (int i = 0; i < uploadFiles.length; i++) { Date uploadTime = new Date(); String url=request.getSession().getServletContext().getRealPath("").replaceAll("\\\\", "/"); String uploadFile =url.substring(0, url.lastIndexOf("/"))+uploadFiles[i]; // String saveFile=""; SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd"); String ymd = sdf.format(uploadTime); String relativePath = ymd + "/"; String directory = SystemConstants.SFTP_directory+ relativePath; sFTPUtil.createDir(directory, sftp); mySFTP.upload(directory, uploadFile, sftp); sftp.cd(directory); } } catch (Exception e) { e.printStackTrace(); }finally{ try { if(sftp != null) { sftp.disconnect(); } } catch (Exception e) { e.printStackTrace(); } try { if(session != null) { session.disconnect(); } } catch (Exception e) { e.printStackTrace(); } } } /** * 列出目录下的文件 * * @param directory * 要列出的目录 * @param sftp * @return * @throws SftpException */ @SuppressWarnings("rawtypes") public Vector listFiles(String directory, ChannelSftp sftp) throws SftpException { return sftp.ls(directory); } }
上传图片时,调用SFTPUtil类中的uploadMultipartFile方法即可。
package cn.test.util; import java.text.SimpleDateFormat; import java.util.Date; import java.util.Random; import org.springframework.web.multipart.MultipartFile; import com.jcraft.jsch.ChannelSftp; import com.jcraft.jsch.Session; import com.jcraft.jsch.SftpATTRS; import com.jcraft.jsch.SftpException; /**文件上传工具类*/ public class SFTPUtil { /** * spring文件上传方法 * */ public static String uploadMultipartFile(MultipartFile file,String fileExt) { SFTPUtil sFTPUtil =new SFTPUtil(); String originalFilename = file.getOriginalFilename(); //生成文件名 Date uploadTime = new Date(); SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd"); String ymd = sdf.format(uploadTime); String relativePath = ymd+"/"; SimpleDateFormat df = new SimpleDateFormat("yyyyMMddHHmmss"); String fileName = df.format(uploadTime) + "_" + new Random().nextInt(1000) + "." + fileExt; // String fileName = String.valueOf(new Date().getTime())+ new Random().nextInt(10000)+"."+originalFilename.substring(originalFilename.lastIndexOf(".") + 1); String directory=SystemConstants.SFTP_directory+relativePath; ChannelSftp sftp =null; Session session = null; try { MySFTP mySFTP = new MySFTP(); sftp = mySFTP.connect(SystemConstants.SFTP_host, Integer.parseInt(SystemConstants.SFTP_port), SystemConstants.SFTP_username, SystemConstants.SFTP_password); session = sftp.getSession(); sFTPUtil.createDir(directory, sftp); sftp.cd(directory); sftp.put(file.getInputStream(), fileName); sftp.disconnect(); sftp.getSession().disconnect(); } catch (Exception e) { System.out.println("文件[" + originalFilename + "]上传失败,堆栈轨迹如下:"); e.printStackTrace(); }finally{ try { if(sftp != null) { sftp.disconnect(); } } catch (Exception e) { e.printStackTrace(); } try { if(session != null) { session.disconnect(); } } catch (Exception e) { e.printStackTrace(); } } String reName=SystemConstants.SFTP_httpBaseUrl+relativePath+fileName; return reName; } /** * 创建目录 * @throws Exception */ public void createDir(String createpath, ChannelSftp sftp) throws Exception { try { if (isDirExist(sftp, createpath)) { sftp.cd(createpath); } String pathArry[] = createpath.split("/"); StringBuffer filePath = new StringBuffer("/"); for (String path : pathArry) { if (path.equals("")) { continue; } filePath.append(path + "/"); if (isDirExist(sftp, filePath.toString())) { sftp.cd(filePath.toString()); } else { // 建立目录 sftp.mkdir(filePath.toString()); // 进入并设置为当前目录 sftp.cd(filePath.toString()); } } sftp.cd(createpath); } catch (SftpException e) { throw new Exception(e.getMessage()); } } /** * 判断目录是否存在 */ public boolean isDirExist(ChannelSftp sftp,String directory) { boolean isDirExistFlag = false; try { SftpATTRS sftpATTRS = sftp.lstat(directory); isDirExistFlag = true; return sftpATTRS.isDir(); } catch (Exception e) { if (e.getMessage().toLowerCase().equals("no such file")) { isDirExistFlag = false; } } return isDirExistFlag; } }
看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注亿速云行业资讯频道,感谢您对亿速云的支持。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。