java 通過sftp伺服器上傳下載刪除檔案
阿新 • • 發佈:2020-12-11
import java.io.*; import java.util.*; import com.jcraft.jsch.Channel; import com.jcraft.jsch.ChannelSftp; import com.jcraft.jsch.ChannelSftp.LsEntry; import com.jcraft.jsch.JSch; import com.jcraft.jsch.Session; public class SftpClientUtil { /** * Sftp */ ChannelSftp sftp = null; /** * 主機 */ private String host = ""; /** * 埠 */ private int port = 0; /** * 使用者名稱 */ private String username = ""; /** * 密碼 */ private String password = ""; /** * 建構函式 * * @param host 主機 * @param port 埠 * @param username 使用者名稱 * @param password 密碼 */ public SftpClientUtil(String host, int port, String username,String password) { this.host = host; this.port = port; this.username = username; this.password = password; } /** * 連線sftp伺服器 * * @throws Exception */ public void connect() throws Exception { JSch jsch = new JSch(); Session sshSession = jsch.getSession(this.username, this.host); sshSession.setPassword(password); Properties sshConfig = new Properties(); sshConfig.put("StrictHostKeyChecking", "no"); sshSession.setConfig(sshConfig); sshSession.connect(); Channel channel = sshSession.openChannel("sftp"); channel.connect(); this.sftp = (ChannelSftp) channel; } /** * 關閉連線 * * @throws Exception */ public void disconnect() throws Exception { if (this.sftp != null) { if (this.sftp.isConnected()) { this.sftp.disconnect(); } else if (this.sftp.isClosed()) { } } } /** * 上傳單個檔案 * * @param directory 上傳的目錄 * @param uploadFile 要上傳的檔案 * @throws Exception */ public void upload(String directory, String uploadFile) throws Exception { this.sftp.cd(directory); File file = new File(uploadFile); this.sftp.put(new FileInputStream(file), file.getName()); } /** * 上傳目錄下全部檔案 * * @param directory 上傳的目錄 * @throws Exception */ 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); } } /** * 下載單個檔案 * * @param directory 下載目錄 * @param downloadFile 下載的檔案 * @param saveDirectory 存在本地的路徑 * @throws Exception */ public void download(String directory, String downloadFile, String saveDirectory) throws Exception { String saveFile = saveDirectory + "//" + downloadFile; this.sftp.cd(directory); File file = new File(saveFile); this.sftp.get(downloadFile, new FileOutputStream(file)); } /** * 下載目錄下全部檔案 * * @param directory 下載目錄 * @param saveDirectory 存在本地的路徑 * @throws Exception */ 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); } } /** * 刪除檔案 * * @param directory 要刪除檔案所在目錄 * @param deleteFile 要刪除的檔案 * @throws Exception */ public void delete(String directory, String deleteFile) throws Exception { this.sftp.cd(directory); this.sftp.rm(deleteFile); } /** * 列出目錄下的檔案 * * @param directory 要列出的目錄 * @return list 檔名列表 * @throws Exception */ @SuppressWarnings("unchecked") public List<String> listFiles(String directory) throws Exception { Vector fileList; List<String> fileNameList = new ArrayList<String>(); fileList = this.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; } /** * 更改檔名 * * @param directory 檔案所在目錄 * @param oldFileNm 原檔名 * @param newFileNm 新檔名 * @throws Exception */ public void rename(String directory, String oldFileNm, String newFileNm) throws Exception { this.sftp.cd(directory); this.sftp.rename(oldFileNm, newFileNm); } public void cd(String directory) throws Exception { this.sftp.cd(directory); } public InputStream get(String directory) throws Exception { InputStream streatm = this.sftp.get(directory); return streatm; } }