详解sftp实现对远程服务器的文件操作

亦凉 2022-08-08 17:57 244阅读 0赞

**该所有操作依赖的jsch的jar包    ** jsch-0.1.50.jar

以下为本人整理的相关SFTP对服务器文件的相关操作,具体的操作方方法依赖于ChannelSftp对象,刻字机单独进行封装,本处就不贴出完整的工具类了

**1:获得 ChannelSftp对象**

public class SftpUtil {
    	private static final Logger LOG = LogManager.getLogger(SftpUtil.class);
    	private static SftpUtil sftpUtil;
    	private static ChannelSftp sftp;
    	private String host;
    	private int port;
    	private String userName;
    	private String password;
    
    	private SftpUtil(String host, int port, String userName, String password) {
    		this.host = host;
    		this.port = port;
    		this.userName = userName;
    		this.password = password;
    	}
    
    	/**
    	 * 获得Smb连接对象
    	 * 
    	 * @Title: getInstance
    	 * @param url
    	 * @return SmbUtil
    	 * @author wangqinghua
    	 * @date 2015-9-22 下午7:39:41
    	 */
    	public static synchronized SftpUtil getInstance(String host, int port,
    			String userName, String password) {
    		if (sftpUtil == null) {
    			sftpUtil = new SftpUtil(host, port, userName, password);
    		}
    		return sftpUtil;
    	}
    
    	/**
    	 * 连接初始化
    	 * 
    	 * @Title: init void
    	 * @author wangqinghua
    	 * @date 2015-9-22 下午7:40:50
    	 */
    	public ChannelSftp getSftp() {
    		JSch jsch = new JSch();
    		Channel channel = null;
    		try {
    			Session sshSession = jsch.getSession(this.userName, this.host, this.port);
    			sshSession.setPassword(password);
    			Properties sshConfig = new Properties();
    			sshConfig.put("StrictHostKeyChecking", "no");
    			sshSession.setConfig(sshConfig);
    			sshSession.connect(20000);
    			channel = sshSession.openChannel("sftp");
    			channel.connect();
    		} catch (JSchException e) {
    			LOG.info("getSftp exception：", e);
    		}
    		return (ChannelSftp) channel;
    	}
            public void disconnect() throws Exception {
                if (sftp != null) {
                   if (sftp.isConnected()) {
                        sftp.disconnect();
                   } else if (sftp.isClosed()) {
                        System.out.println("Session close...........");
                   }
                }
            }
    }

** 2:SFTP上传单个文件**

/**
    	 * SFTP上传单个文件
    	 * 
    	 * @Title: upload
    	 * @param directory
    	 * @param uploadFile
    	 * @throws Exception
    	 *             void
    	 * @author wangqinghua
    	 * @date 2015-9-24 下午1:49:55
    	 */
    	public void upload(String directory, String uploadFile) throws Exception {
    		sftp.cd(directory);
    		File file = new File(uploadFile);
    		sftp.put(new FileInputStream(file), file.getName());
    	}

**3.上传目录下的所有文件(批量上传)**

/**
    	 * 上传目录下的所有文件(批量上传)
    	 * 
    	 * @Title: uploadByDirectory
    	 * @param directory
    	 * @throws Exception
    	 *             void
    	 * @author wangqinghua
    	 * @date 2015-9-24 下午1:50:53
    	 */
    	public void uploadByDirectory(String directory) throws Exception {
    		String uploadFile = "";
    		List<String> uploadFileList = this.listFiles(directory);
    		Iterator<String> it = uploadFileList.iterator();
    		while (it.hasNext()) {
    			uploadFile = it.next().toString();
    			this.upload(directory, uploadFile);
    		}
    	}

**4:通过SFTP下载文件**

/**
    	 * 通过SFTP下载文件
    	 * 
    	 * @Title: download
    	 * @param directory
    	 * @param downloadFile
    	 * @param saveDirectory
    	 * @throws Exception
    	 *             void
    	 * @author wangqinghua
    	 * @date 2015-9-24 下午1:56:22
    	 */
    	public void download(String directory, String downloadFile,
    			String saveDirectory) throws Exception {
    		String saveFile = saveDirectory + "//" + downloadFile;
    		sftp.cd(directory);
    		File file = new File(saveFile);
    		sftp.get(downloadFile, new FileOutputStream(file));
    	}

**5:批量下载目录下的文件**

/**
    	 * 批量下载目录下的文件
    	 * 
    	 * @Title: downloadByDirectory
    	 * @param directory
    	 * @param saveDirectory
    	 * @throws Exception
    	 *             void
    	 * @author wangqinghua
    	 * @date 2015-9-24 下午1:58:17
    	 */
    	public void downloadByDirectory(String directory, String saveDirectory)
    			throws Exception {
    		String downloadFile = "";
    		List<String> downloadFileList = this.listFiles(directory);
    		Iterator<String> it = downloadFileList.iterator();
    		while (it.hasNext()) {
    			downloadFile = it.next().toString();
    			if (downloadFile.toString().indexOf(".") < 0) {
    				continue;
    			}
    			this.download(directory, downloadFile, saveDirectory);
    		}
    	}

6:删除文件

/**
    	 * 删除文件
    	 * 
    	 * @Title: delete
    	 * @param directory
    	 * @param deleteFile
    	 * @throws Exception
    	 *             void
    	 * @author wangqinghua
    	 * @date 2015-9-24 下午1:58:57
    	 */
    	public void delete(String directory, String deleteFile) throws Exception {
    		sftp.cd(directory);
    		sftp.rm(deleteFile);
    	}

**7:文件重命名**

/**
    	 * 文件重命名
    	 * 
    	 * @Title: rename
    	 * @param directory
    	 * @param oldFileNm
    	 * @param newFileNm
    	 * @throws Exception
    	 *             void
    	 * @author wangqinghua
    	 * @date 2015-9-24 下午2:02:22
    	 */
    	public void rename(String directory, String oldFileNm, String newFileNm)
    			throws Exception {
    		sftp.cd(directory);
    		sftp.rename(oldFileNm, newFileNm);
    	}

**8:获得文件流**

/**
    	 * 获得文件流
    	 * 
    	 * @Title: get
    	 * @param directory
    	 * @return
    	 * @throws Exception
    	 *             InputStream
    	 * @author wangqinghua
    	 * @date 2015-9-24 下午2:03:41
    	 */
    	public InputStream getInputStream(String directory) throws Exception {
    		InputStream streatm = sftp.get(directory);
    		return streatm;
    	}

**9:Servlet结合SFTP实现简单的文件下载**

/**
    	 * Servlet结合SFTP实现简单的文件下载
    	 * @Title: doPost
    	 * @param request
    	 * @param response
    	 * @throws IOException
    	 * @throws ServletException
    	 * void
    	 * @author wangqinghua 
    	 * @date 2015-9-24 下午2:15:40
    	 */
    	public void doPost(HttpServletRequest request, HttpServletResponse response)
    			throws IOException, ServletException {
    		LOG.info("进入下载文件开始..........");
    		String host = "";// 主机地址
    		String port = "";// 主机端口
    		String username = "";// 服务器用户名
    		String password = "";// 服务器密码
    		String planPath = "";// 文件所在服务器路径
    		BufferedInputStream bis = null;
    		BufferedOutputStream bos = null;
    		OutputStream fos = null;
    
    		String fileName = "demo";
    		SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMdd");
    		String currentDate = formatter.format(new Date());
    		// demo20150924.txt
    		String downloadFile = fileName + currentDate + ".zip";
    
    		PrintWriter out = null;
    		SftpUtil sftpUtil = new SftpUtil(host, Integer.parseInt(port),
    				username, password);
    		try {
    			ChannelSftp sftp=sftpUtil.getSftp();
    			String filename = "";
    			// String[] strs=planUrl.split("/");
    			String filePath = planPath;
    			// 列出目录下的文件
    			List<String> listFiles = listFiles(filePath);
    			boolean isExists = listFiles.contains(downloadFile);
    			if (isExists) {
    				sftp.cd(filePath);
    				if (sftp.get(downloadFile) != null) {
    					bis = new BufferedInputStream(sftp.get(downloadFile));
    				}
    				filename = downloadFile;
    				fos = response.getOutputStream();
    				bos = new BufferedOutputStream(fos);
    				response.setCharacterEncoding("UTF-8");
    				response.setContentType("application/x-msdownload;charset=utf-8");
    				final String agent = request.getHeader("User-Agent");
    				String attachment = "attachment;fileName=";
    				String outputFilename = null;
    
    				if (agent.indexOf("Firefox") > 0) {
    					attachment = "attachment;fileName*=";
    					outputFilename = "=?UTF-8?B?"
    							+ (new String(Base64.encodeBase64(filename
    									.getBytes("UTF-8")))) + "?=";
    					;
    				} else {
    					if (agent.indexOf("MSIE") != -1) {
    						outputFilename = new String(filename.getBytes("gbk"),"iso8859-1");
    					} else {
    						outputFilename = new String(filename.getBytes("UTF-8"), "iso8859-1");
    					}
    				}
    				response.setHeader("Content-Disposition", attachment + outputFilename);
    				int bytesRead = 0;
    				// 输入流进行先读，然后用输出流去写，下面用的是缓冲输入输出流
    				byte[] buffer = new byte[8192];
    				while ((bytesRead = bis.read(buffer)) != -1) {
    					bos.write(buffer, 0, bytesRead);
    				}
    				bos.flush();
    				LOG.info("文件下载成功");
    			} else {
    				response.setCharacterEncoding("utf-8");
    				response.setContentType("text/html; charset=UTF-8");
    				out = response.getWriter();
    				out.println("<html >" + "<body>" + "没有找到你要下载的文件" + "</body>"
    						+ "</html>");
    			}
    		} catch (Exception e) {
    			response.setCharacterEncoding("utf-8");
    			response.setContentType("text/html; charset=UTF-8");
    			out = response.getWriter();
    			out.println("<html >" + "<body>" + "没有找到你要下载的文件" + "</body>"
    					+ "</html>");
    		} finally {
    			try {
    				sftp.disconnect();
    				LOG.info("SFTP连接已断开");
    			} catch (Exception e) {
    				e.printStackTrace();
    			}
    
    			if (out != null) {
    				out.close();
    			}
    			LOG.info("out已关闭");
    			if (bis != null) {
    				bis.close();
    			}
    			LOG.info("bis已关闭");
    			if (bos != null) {
    				bos.close();
    			}
    			LOG.info("bos已关闭");
    		}
    	}

10:获得目录下的所有文件名

/**
    	 * 获得目录下的所有文件名
    	 * 
    	 * @Title: listFiles
    	 * @param directory
    	 * @return
    	 * @throws Exception
    	 *             List<String>
    	 * @author wangqinghua
    	 * @date 2015-9-24 下午1:53:40
    	 */
    	@SuppressWarnings("rawtypes")
    	public List<String> listFiles(String directory) throws Exception {
    		Vector fileList;
    		List<String> fileNameList = new ArrayList<String>();
    		fileList = sftp.ls(directory);
    		Iterator it = fileList.iterator();
    		while (it.hasNext()) {
    			String fileName = ((LsEntry) it.next()).getFilename();
    			if (".".equals(fileName) || "..".equals(fileName)) {
    				continue;
    			}
    			fileNameList.add(fileName);
    		}
    		return fileNameList;
    	}

关于sftp内部方法详情 :http://blog.csdn.net/jr\_soft/article/details/18704857