SFTP工具类

  1 import java.io.File;
  2 import java.io.FileInputStream;
  3 import java.io.FileOutputStream;
  4 import java.io.IOException;
  5 import java.io.InputStream;
  6 import java.util.ArrayList;
  7 import java.util.Iterator;
  8 import java.util.List;
  9 import java.util.Properties;
 10 import java.util.Vector;
 11 
 12 import com.jcraft.jsch.Channel;
 13 import com.jcraft.jsch.ChannelSftp;
 14 import com.jcraft.jsch.ChannelSftp.LsEntry;
 15 import com.jcraft.jsch.JSch;
 16 import com.jcraft.jsch.JSchException;
 17 import com.jcraft.jsch.Session;
 18 import com.jcraft.jsch.SftpException;
 19 
 20 /**
 21  * 提供SFTP处理文件服务
 22  * 
 23  * @author krm-hehongtao
 24  * @date 2016-02-29
 25  * 
 26  */
 27 public class SFTPUtil {
 28     private JSch jSch = null;
 29     private ChannelSftp sftp = null;// sftp主服务
 30     private Channel channel = null;
 31     private Session session = null;
 32 
 33     private String hostName = "192.168.0.177";// 远程服务器地址
 34     private int port = 22;// 端口
 35     private String userName = "weblogic";// 用户名
 36     private String password = "weblogic";// 密码
 37 
 38     public SFTPUtil(String hostName, int port, String userName, String password) {
 39         this.hostName = hostName;
 40         this.port = port;
 41         this.userName = userName;
 42         this.password = password;
 43     }
 44 
 45     /**
 46      * 连接登陆远程服务器
 47      * 
 48      * @return
 49      */
 50     public boolean connect() throws Exception {
 51         try {
 52             jSch = new JSch();
 53             session = jSch.getSession(userName, hostName, port);
 54             session.setPassword(password);
 55 
 56             session.setConfig(this.getSshConfig());
 57             session.connect();
 58 
 59             channel = session.openChannel("sftp");
 60             channel.connect();
 61 
 62             sftp = (ChannelSftp) channel;
 63             System.out.println("登陆成功:" + sftp.getServerVersion());
 64 
 65         } catch (JSchException e) {
 66             System.err.println("SSH方式连接FTP服务器时有JSchException异常!");
 67             System.err.println(e.getMessage());
 68             throw e;
 69         }
 70         return true;
 71     }
 72 
 73     /**
 74      * 关闭连接
 75      * 
 76      * @throws Exception
 77      */
 78     private void disconnect() throws Exception {
 79         try {
 80             if (sftp.isConnected()) {
 81                 sftp.disconnect();
 82             }
 83             if (channel.isConnected()) {
 84                 channel.disconnect();
 85             }
 86             if (session.isConnected()) {
 87                 session.disconnect();
 88             }
 89         } catch (Exception e) {
 90             throw e;
 91         }
 92     }
 93 
 94     /**
 95      * 获取服务配置
 96      * 
 97      * @return
 98      */
 99     private Properties getSshConfig() throws Exception {
100         Properties sshConfig = null;
101         try {
102             sshConfig = new Properties();
103             sshConfig.put("StrictHostKeyChecking", "no");
104 
105         } catch (Exception e) {
106             throw e;
107         }
108         return sshConfig;
109     }
110 
111     /**
112      * 下载远程sftp服务器文件
113      * 
114      * @param remotePath
115      * @param remoteFilename
116      * @param localFilename
117      * @return
118      */
119     public boolean downloadFile(String remotePath, String remoteFilename, String localFilename)
120             throws SftpException, IOException, Exception {
121         FileOutputStream output = null;
122         boolean success = false;
123         try {
124             if (null != remotePath && remotePath.trim() != "") {
125                 sftp.cd(remotePath);
126             }
127 
128             File localFile = new File(localFilename);
129             // 有文件和下载文件重名
130             if (localFile.exists()) {
131                 System.err.println("文件: " + localFilename + " 已经存在!");
132                 return success;
133             }
134             output = new FileOutputStream(localFile);
135             sftp.get(remoteFilename, output);
136             success = true;
137             System.out.println("成功接收文件,本地路径：" + localFilename);
138         } catch (SftpException e) {
139             System.err.println("接收文件时有SftpException异常!");
140             System.err.println(e.getMessage());
141             return success;
142         } catch (IOException e) {
143             System.err.println("接收文件时有I/O异常!");
144             System.err.println(e.getMessage());
145             return success;
146         } finally {
147             try {
148                 if (null != output) {
149                     output.close();
150                 }
151                 // 关闭连接
152                 disconnect();
153             } catch (IOException e) {
154                 System.err.println("关闭文件时出错!");
155                 System.err.println(e.getMessage());
156             }
157         }
158         return success;
159     }
160 
161     /**
162      * 上传文件至远程sftp服务器
163      * 
164      * @param remotePath
165      * @param remoteFilename
166      * @param localFileName
167      * @return
168      */
169     public boolean uploadFile(String remotePath, String remoteFilename, String localFileName)
170             throws SftpException, Exception {
171         boolean success = false;
172         FileInputStream fis = null;
173         try {
174             // 更改服务器目录
175             if (null != remotePath && remotePath.trim() != "") {
176                 sftp.cd(remotePath);
177             }
178             File localFile = new File(localFileName);
179             fis = new FileInputStream(localFile);
180             // 发送文件
181             sftp.put(fis, remoteFilename);
182             success = true;
183             System.out.println("成功发送文件,本地路径：" + localFileName);
184         } catch (SftpException e) {
185             System.err.println("发送文件时有SftpException异常!");
186             e.printStackTrace();
187             System.err.println(e.getMessage());
188             throw e;
189         } catch (Exception e) {
190             System.err.println("发送文件时有异常!");
191             System.err.println(e.getMessage());
192             throw e;
193         } finally {
194             try {
195                 if (null != fis) {
196                     fis.close();
197                 }
198                 // 关闭连接
199                 disconnect();
200             } catch (IOException e) {
201                 System.err.println("关闭文件时出错!");
202                 System.err.println(e.getMessage());
203             }
204         }
205         return success;
206     }
207 
208     /**
209      * 上传文件至远程sftp服务器
210      * 
211      * @param remotePath
212      * @param remoteFilename
213      * @param input
214      * @return
215      */
216     public boolean uploadFile(String remotePath, String remoteFilename, InputStream input)
217             throws SftpException, Exception {
218         boolean success = false;
219         try {
220             // 更改服务器目录
221             if (null != remotePath && remotePath.trim() != "") {
222                 sftp.cd(remotePath);
223             }
224 
225             // 发送文件
226             sftp.put(input, remoteFilename);
227             success = true;
228         } catch (SftpException e) {
229             System.err.println("发送文件时有SftpException异常!");
230             e.printStackTrace();
231             System.err.println(e.getMessage());
232             throw e;
233         } catch (Exception e) {
234             System.err.println("发送文件时有异常!");
235             System.err.println(e.getMessage());
236             throw e;
237         } finally {
238             try {
239                 if (null != input) {
240                     input.close();
241                 }
242                 // 关闭连接
243                 disconnect();
244             } catch (IOException e) {
245                 System.err.println("关闭文件时出错!");
246                 System.err.println(e.getMessage());
247             }
248 
249         }
250         return success;
251     }
252 
253     /**
254      * 删除远程文件
255      * 
256      * @param remotePath
257      * @param remoteFilename
258      * @return
259      * @throws Exception
260      */
261     public boolean deleteFile(String remotePath, String remoteFilename) throws Exception {
262         boolean success = false;
263         try {
264             // 更改服务器目录
265             if (null != remotePath && remotePath.trim() != "") {
266                 sftp.cd(remotePath);
267             }
268 
269             // 删除文件
270             sftp.rm(remoteFilename);
271             System.err.println("删除远程文件" + remoteFilename + "成功!");
272             success = true;
273         } catch (SftpException e) {
274             System.err.println("删除文件时有SftpException异常!");
275             e.printStackTrace();
276             System.err.println(e.getMessage());
277             return success;
278         } catch (Exception e) {
279             System.err.println("删除文件时有异常!");
280             System.err.println(e.getMessage());
281             return success;
282         } finally {
283             // 关闭连接
284             disconnect();
285         }
286         return success;
287     }
288 
289     /**
290      * 遍历远程文件
291      * 
292      * @param remotePath
293      * @return
294      * @throws Exception
295      */
296     public List<String> listFiles(String remotePath) throws SftpException {
297         List<String> ftpFileNameList = new ArrayList<String>();
298         Vector<LsEntry> sftpFile = sftp.ls(remotePath);
299         LsEntry isEntity = null;
300         String fileName = null;
301         Iterator<LsEntry> sftpFileNames = sftpFile.iterator();
302         while (sftpFileNames.hasNext()) {
303             isEntity = (LsEntry) sftpFileNames.next();
304             fileName = isEntity.getFilename();
305             System.out.println(fileName);
306             ftpFileNameList.add(fileName);
307         }
308         return ftpFileNameList;
309     }
310 
311     /**
312      * 判断路径是否存在
313      * 
314      * @param remotePath
315      * @return
316      * @throws SftpException
317      */
318     public boolean isExist(String remotePath) throws SftpException {
319         boolean flag = false;
320         try {
321             sftp.cd(remotePath);
322             System.out.println("存在路径：" + remotePath);
323             flag = true;
324         } catch (SftpException sException) {
325             
326         } catch (Exception Exception) {
327         }
328         return flag;
329     }
330 
331     public String getHostName() {
332         return hostName;
333     }
334 
335     public void setHostName(String hostName) {
336         this.hostName = hostName;
337     }
338 
339     public int getPort() {
340         return port;
341     }
342 
343     public void setPort(int port) {
344         this.port = port;
345     }
346 
347     public String getUserName() {
348         return userName;
349     }
350 
351     public void setUserName(String userName) {
352         this.userName = userName;
353     }
354 
355     public String getPassword() {
356         return password;
357     }
358 
359     public void setPassword(String password) {
360         this.password = password;
361     }
362 
363     /**
364      * 测试方法
365      * 
366      */
367     public static void main(String[] args) {
368         try {
369             SFTPUtil sftp = new SFTPUtil("192.168.0.177", 22, "weblogic", "weblogic");
370             System.out.println(new StringBuffer().append(" 服务器地址: ")
371                     .append(sftp.getHostName()).append(" 端口：").append(sftp.getPort())
372                     .append("用户名：").append(sftp.getUserName()).append("密码:")
373                     .append(sftp.getPassword().toString()));
374             sftp.connect();
375             if (sftp.isExist("/home/weblogic/project")) {
376                 sftp.listFiles("/home/weblogic/project");
377                 sftp.downloadFile("/home/weblogic/project", "S123456_20150126.csv",
378                         "D:\\S123456_20150126.csv");
379                 // sftp.uploadFile("\\", "test.txt", "D:\\work\\readMe.txt");
380                 // sftp.deleteFile("\\", "test.txt");
381             }
382         } catch (Exception e) {
383             System.out.println("异常信息：" + e.getMessage());
384         }
385     }
386 }