【工具类】JAVA开发从SFTP服务器下载文件

SFTPConstants SFTP设置文件

1. package main;
2. public class SFTPConstants {
3.     public static final String SFTP_REQ_HOST = "192.168.1.11";
4.     public static final String SFTP_REQ_PORT = "22";
5.     public static final String SFTP_REQ_USERNAME = "svc_sftp_service";
6.     public static final String SFTP_REQ_PASSWORD = "ZZZZ4VeIm5Ids3HgxxfZZZ";
7.     public static final int SFTP_DEFAULT_PORT = 22;
8.     public static final String SFTP_REQ_LOC = "location";
9. }

复制代码

SftpClientUtil SFTP工具类

1. package main;
2. import com.jcraft.jsch.*;
3. import org.jboss.logging.Logger;
4. import java.io.*;
5. import java.util.*;
7. public class SftpClientUtil {
8.     private static Logger logger = Logger.getLogger(SftpClientUtil.class);
9.     private Session session;
10.     private Channel channel;
11.     private ChannelSftp sftp;
12.     private InputStream in;
13.     private OutputStream out;
15.     /**
16.      * 构造函数1
17.      *
18.      * @param host       主机
19.      * @param username   用户名
20.      * @param password   密码
21.      * @param port       端口
22.      * @param isHightSSH :jsch 与 ssh 版本适配，ssh>7.6 为true,反之为false
23.      * @throws Exception
24.      */
25.     public SftpClientUtil(String host, String username, String password, int port, boolean isHightSSH) throws Exception {
26.         JSch jsch = new JSch();
27.         this.session = jsch.getSession(username, host, port);
28.         session.setPassword(password);
29.         Properties config = new Properties();
30.         config.put("StrictHostKeyChecking", "no"); // 不验证 HostKey
31.         if (isHightSSH) {
32.             config.put("kex", "diffie-hellman-group1-sha1,"
33.                     + "diffie-hellman-group-exchange-sha1,"
34.                     + "diffie-hellman-group-exchange-sha256"); //适配新版本ssh需添加对应的加密算法
35.         }
36.         session.setConfig(config);
37.         try {
38.             session.connect();
39.         } catch (Exception e) {
40.             if (session.isConnected())
41.                 session.disconnect();
42.             logger.error("链接报错!!!", e);
43.             throw new Exception("连接服务器失败,请检查主机[" + host + "],端口[" + port + "],用户名[" + username + "],端口[" + port + "]是否正确,以上信息正确的情况下请检查网络连接是否正常或者请求被防火墙拒绝.");
44.         }
45.         channel = session.openChannel("sftp");
46.         try {
47.             if (channel.isConnected())
48.                 channel.disconnect();
49.             channel.connect();
50.         } catch (Exception e) {
51.             throw new Exception("连接服务器失败,请检查主机[" + host + "],端口[" + port + "],用户名[" + username + "],端口[" + port + "]是否正确,以上信息正确的情况下请检查网络连接是否正常或者请求被防火墙拒绝.");
52.         }
53.         sftp = (ChannelSftp) channel;
54.     }
56.     /**
57.      * 构造函数2
58.      *
59.      * @param host     主机
60.      * @param username 用户名
61.      * @param password 密码
62.      * @param port     端口
63.      * @param encoding 字符集编码
64.      * @throws Exception
65.      */
66.     public SftpClientUtil(String host, String username, String password, int port, String encoding) throws Exception {
67.         JSch jsch = new JSch();
68.         this.session = jsch.getSession(username, host, port);
69.         session.setPassword(password);
70.         Properties config = new Properties();
71.         config.put("StrictHostKeyChecking", "no"); // 不验证 HostKey
72.         session.setConfig(config);
73.         try {
74.             session.connect();
75.         } catch (Exception e) {
76.             if (session.isConnected())
77.                 session.disconnect();
78.             throw new Exception("连接服务器失败,请检查主机[" + host + "],端口1[" + port + "],用户名[" + username + "],端口[" + port + "]是否正确,以上信息正确的情况下请检查网络连接是否正常或者请求被防火墙拒绝.");
79.         }
80.         channel = session.openChannel("sftp");
81.         try {
82.             channel.connect();
83.         } catch (Exception e) {
84.             if (channel.isConnected())
85.                 channel.disconnect();
86.             throw new Exception("连接服务器失败,请检查主机[" + host + "],端口[" + port + "],用户名[" + username + "],密码[" + password + "]是否正确,以上信息正确的情况下请检查网络连接是否正常或者请求被防火墙拒绝.");
87.         }
88.         sftp = (ChannelSftp) channel;
89.         sftp.setFilenameEncoding(encoding);
90.     }
92.     /**
93.      * 构造函数3
94.      *
95.      * @param host     主机
96.      * @param username 用户名
97.      * @param password 密码
98.      * @param port     端口
99.      * @param encoding 字符集
100.      * @param timeout  超时时间
101.      * @throws Exception
102.      */
103.     private SftpClientUtil(String host, String username, String password, int port, String encoding, int timeout)
104.             throws Exception {
105.         JSch jsch = new JSch();
106.         this.session = jsch.getSession(username, host, port);
107.         session.setPassword(password);
108.         Properties config = new Properties();
109.         config.put("StrictHostKeyChecking", "no"); // 不验证 HostKey
110.         session.setConfig(config);
111.         try {
112.             session.connect();
113.         } catch (Exception e) {
114.             if (session.isConnected())
115.                 session.disconnect();
116.             throw new Exception("连接服务器失败,请检查主机[" + host + "],端口[" + port + "],用户名[" + username + "],密码[" + password + "]是否正确,以上信息正确的情况下请检查网络连接是否正常或者请求被防火墙拒绝.");
117.         }
118.         session.setTimeout(timeout);
119.         channel = session.openChannel("sftp");
120.         try {
121.             channel.connect();
122.         } catch (Exception e) {
123.             if (channel.isConnected())
124.                 channel.disconnect();
125.             throw new Exception("连接服务器失败,请检查主机[" + host + "],端口[" + port + "],用户名[" + username + "],密码[" + password + "]是否正确,以上信息正确的情况下请检查网络连接是否正常或者请求被防火墙拒绝.");
126.         }
127.         sftp = (ChannelSftp) channel;
128.         sftp.setFilenameEncoding(encoding);
129.     }
131.     /**
132.      * 文件上传
133.      *
134.      * @param remotePath     远端路径
135.      * @param remoteFileName 上传到远端后的文件名
136.      * @param localPath      本地路径
137.      * @param localFileName  本地文件名
138.      * @return
139.      */
140.     public boolean uploadFile(String remotePath, String remoteFileName, String localPath, String localFileName) {
141.         FileInputStream in = null;
142.         try {
143.             createDir(remotePath);
144.             File file = new File(localPath + localFileName);
145.             in = new FileInputStream(file);
146.             sftp.put(in, remoteFileName);
147.             return true;
148.         } catch (FileNotFoundException e) {
149.             e.printStackTrace();
150.         } catch (SftpException e) {
151.             e.printStackTrace();
152.         } finally {
153.             if (in != null) {
154.                 try {
155.                     in.close();
156.                 } catch (IOException e) {
157.                     e.printStackTrace();
158.                 }
159.             }
160.         }
161.         return false;
162.     }
164.     //创建目录
165.     public boolean createDir(String createpath) {
166.         try {
167.             createpath = createpath.trim();
168.             if (isDirExist(createpath)) {
169.                 this.sftp.cd(createpath);
170.                 logger.info("cd " + createpath);
171.                 return true;
172.             }
173.             String[] pathArray = createpath.split("/");
174.             for (String path : pathArray) {
175.                 path = path.trim();
176.                 if ("".equals(path)) {
177.                     continue;
178.                 }
179.                 if (!isDirExist(path)) {
180.                     sftp.mkdir(path);
181.                 }
182.                 logger.info("cd " + path);
183.                 sftp.cd(path);
184.             }
185.             return true;
186.         } catch (SftpException e) {
187.             e.printStackTrace();
188.         }
189.         return false;
190.     }
192.     //判断目录是否存在
193.     public boolean isDirExist(String directory) {
194.         boolean isDirExistFlag = false;
195.         try {
196.             SftpATTRS sftpATTRS = sftp.lstat(directory);
197.             return sftpATTRS.isDir();
198.         } catch (Exception e) {
199.             if (e.getMessage().toLowerCase().equals("no such file")) {
200.                 logger.error("directory：" + directory + ",no such file ERROR!!！");
201.             }
202.         }
203.         return isDirExistFlag;
204.     }
206.     /**
207.      * 文件下载
208.      *
209.      * @param remotePath    远程文件存放路径
210.      * @param localPath     下载到本地的路径
211.      * @return 下载后的文件名集合
212.      * @throws Exception
213.      */
214.     public List<String> downloadFiles(String remotePath, String localPath){
215.         List<String> downloadFiles = new ArrayList<String>();
217.         try {
218.             logger.info("切换到指定目录：" + remotePath);
219.             boolean flag = openDir(remotePath, sftp);
220.             if (flag) {
221.                 //1.获取远端路径下所有文件
222.                 Vector<?> vv = listFiles("*");
223.                 if (vv == null) {
224.                     return null;
225.                 } else {
226.                     for (Object object : vv) {
227.                         ChannelSftp.LsEntry entry = (ChannelSftp.LsEntry) object;
228.                         String remoteFileName = entry.getFilename();
230.                         logger.info("校验文件名：" + remoteFileName);
231.                         String path = localPath.substring(localPath.length() - 1).equals("/") ? localPath : localPath + "/";
232.                         File file = new File(path + remoteFileName);
233.                         logger.info("保存校对文件的本地路径为:" + file.getAbsolutePath());
235.                         logger.info("start downLoad " + remoteFileName + " ~~");
236.                         sftp.get(remoteFileName, new FileOutputStream(file));
237.                         logger.info("downLoad ok ~~");
239.                         downloadFiles.add(remoteFileName);
240.                     }
242.                     if (downloadFiles.size() < 1) {
243.                         logger.error("remotePath：" + remotePath + "路径下，未匹配到校对文件！");
244.                     }
245.                 }
246.             } else {
247.                 logger.info("对应的目录" + remotePath + "不存在！");
248.             }
250.         } catch (Exception e) {
251.             e.printStackTrace();
252.         } finally {
253.             if (sftp != null) {
254.                 if (sftp.isConnected()) {
255.                     sftp.disconnect();
256.                 }
257.             }
258.             if (session != null) {
259.                 if (session.isConnected()) {
260.                     session.disconnect();
261.                 }
262.             }
263.         }
264.         return downloadFiles;
265.     }
267.     //打开或者进入指定目录
268.     public boolean openDir(String directory, ChannelSftp sftp) {
269.         try {
270.             sftp.cd(directory);
271.             logger.info("cd " + directory + " ok");
272.             return true;
273.         } catch (SftpException e) {
274.             logger.error(e + "");
275.             return false;
276.         }
277.     }
279.     //返回目录下所有文件信息
280.     public Vector listFiles(String directory) throws SftpException {
281.         return sftp.ls(directory);
282.     }
284.     /**
285.      * 断开与主机的连接
286.      */
287.     public void disconnect() {
288.         try {
289.             sftp.disconnect();
290.         } catch (Exception ignored) {
291.         }
292.         try {
293.             channel.disconnect();
294.         } catch (Exception ignored) {
295.         }
296.         try {
297.             session.disconnect();
298.         } catch (Exception ignored) {
299.         }
300.     }
302.     /**
303.      * 得到SFTP实例
304.      *
305.      * @param host     主机
306.      * @param username 用户名
307.      * @param password 密码
308.      * @param port     端口
309.      * @return
310.      * @throws Exception
311.      */
312.     public static SftpClientUtil getInstans(String host, String username, String password, int port) throws Exception {
313.         return new SftpClientUtil(host, username, password, port, false);
314.     }
316.     /**
317.      * 得到SFTP实例
318.      *
319.      * @param host     主机
320.      * @param username 用户名
321.      * @param password 密码
322.      * @param port     端口
323.      * @param encoding 字符集编码
324.      * @return
325.      * @throws Exception
326.      */
327.     public static SftpClientUtil getInstans(String host, String username, String password, int port, String encoding)
328.             throws Exception {
329.         return new SftpClientUtil(host, username, password, port, encoding);
330.     }
332.     /**
333.      * 得到SFTP实例
334.      *
335.      * @param host     主机
336.      * @param username 用户名
337.      * @param password 密码
338.      * @param port     端口
339.      * @param encoding 字符集编码
340.      * @param timeout  超时时间
341.      * @return
342.      * @throws Exception
343.      */
344.     public static SftpClientUtil getInstans(String host, String username, String password, int port, String encoding,
345.                                             int timeout) throws Exception {
346.         return new SftpClientUtil(host, username, password, port, encoding, timeout);
347.     }
348. }

复制代码

SftpSEGMain main方法

打成JAR文件后 直接放到服务器上执行

1. package main;
4. public class SftpSEGMain {
5.     public static void main(String[] args) {
6.         try {
7.             SftpClientUtil sftp =new SftpClientUtil(SFTPConstants.SFTP_REQ_HOST,SFTPConstants.SFTP_REQ_USERNAME,SFTPConstants.SFTP_REQ_PASSWORD, SFTPConstants.SFTP_DEFAULT_PORT,"UTF-8");
8.             sftp.downloadFiles("/svc_sftp_zmj","D:\\\\DevSoft\\\");
9.         } catch (Exception e) {
10.             e.printStackTrace();
11.         }
12.     }
13. }

复制代码

所需JAR文件下载地址：
JAR包

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。