轉載：http://blog.csdn.net/yhl_jxy/article/details/72633034

Linux操作系統我們經常使用ssh中的ftp,sftp連接服務器，做相應操作。

如何通過java代碼的形式采用sftp連接到服務器，進行文件上傳下載等操作呢？

第一步，引入依賴包

1. <!-- sftp上傳依賴包 -->
2. <dependency>
3. <groupId>com.jcraft</groupId>
4. <artifactId>jsch</artifactId>
5. <version>0.1.53</version>
6. </dependency>

1. package com.guohuai.util;
3. import java.io.ByteArrayInputStream;
4. import java.io.File;
5. import java.io.FileInputStream;
6. import java.io.FileNotFoundException;
7. import java.io.FileOutputStream;
8. import java.io.IOException;
9. import java.io.InputStream;
10. import java.io.UnsupportedEncodingException;
11. import java.util.Properties;
12. import java.util.Vector;
14. import org.apache.commons.io.IOUtils;
15. import org.slf4j.Logger;
16. import org.slf4j.LoggerFactory;
18. import com.jcraft.jsch.Channel;
19. import com.jcraft.jsch.ChannelSftp;
20. import com.jcraft.jsch.JSch;
21. import com.jcraft.jsch.JSchException;
22. import com.jcraft.jsch.Session;
23. import com.jcraft.jsch.SftpException;
24. /**
25. *
26. * @ClassName: SFTPUtil
27. * @Description: sftp連接工具類
28. * @date 2017年5月22日 下午11:17:21
29. * @version 1.0.0
30. */
31. public class SFTPUtil {
32. private transient Logger log = LoggerFactory.getLogger(this.getClass());
34. private ChannelSftp sftp;
36. private Session session;
37. /** FTP 登錄用戶名*/
38. private String username;
39. /** FTP 登錄密碼*/
40. private String password;
41. /** 私鑰 */
42. private String privateKey;
43. /** FTP 服務器地址IP地址*/
44. private String host;
45. /** FTP 端口*/
46. private int port;
49. /**
50. * 構造基於密碼認證的sftp對象
51. * @param userName
52. * @param password
53. * @param host
54. * @param port
55. */
56. public SFTPUtil(String username, String password, String host, int port) {
57. this.username = username;
58. this.password = password;
59. this.host = host;
60. this.port = port;
61. }
63. /**
64. * 構造基於秘鑰認證的sftp對象
65. * @param userName
66. * @param host
67. * @param port
68. * @param privateKey
69. */
70. public SFTPUtil(String username, String host, int port, String privateKey) {
71. this.username = username;
72. this.host = host;
73. this.port = port;
74. this.privateKey = privateKey;
75. }
77. public SFTPUtil(){}
79. /**
80. * 連接sftp服務器
81. *
82. * @throws Exception
83. */
84. public void login(){
85. try {
86. JSch jsch = new JSch();
87. if (privateKey != null) {
88. jsch.addIdentity(privateKey);// 設置私鑰
89. log.info("sftp connect,path of private key file：{}" , privateKey);
90. }
91. log.info("sftp connect by host:{} username:{}",host,username);
93. session = jsch.getSession(username, host, port);
94. log.info("Session is build");
95. if (password != null) {
96. session.setPassword(password);
97. }
98. Properties config = new Properties();
99. config.put("StrictHostKeyChecking", "no");
101. session.setConfig(config);
102. session.connect();
103. log.info("Session is connected");
105. Channel channel = session.openChannel("sftp");
106. channel.connect();
107. log.info("channel is connected");
109. sftp = (ChannelSftp) channel;
110. log.info(String.format("sftp server host:[%s] port:[%s] is connect successfull", host, port));
111. } catch (JSchException e) {
112. log.error("Cannot connect to specified sftp server : {}:{} \n Exception message is: {}", new Object[]{host, port, e.getMessage()});
113. }
114. }
116. /**
117. * 關閉連接 server
118. */
119. public void logout(){
120. if (sftp != null) {
121. if (sftp.isConnected()) {
122. sftp.disconnect();
123. log.info("sftp is closed already");
124. }
125. }
126. if (session != null) {
127. if (session.isConnected()) {
128. session.disconnect();
129. log.info("sshSession is closed already");
130. }
131. }
132. }
134. /**
135. * 將輸入流的數據上傳到sftp作為文件
136. *
137. * @param directory
138. * 上傳到該目錄
139. * @param sftpFileName
140. * sftp端文件名
141. * @param in
142. * 輸入流
143. * @throws SftpException
144. * @throws Exception
145. */
146. public void upload(String directory, String sftpFileName, InputStream input) throws SftpException{
147. try {
148. sftp.cd(directory);
149. } catch (SftpException e) {
150. log.warn("directory is not exist");
151. sftp.mkdir(directory);
152. sftp.cd(directory);
153. }
154. sftp.put(input, sftpFileName);
155. log.info("file:{} is upload successful" , sftpFileName);
156. }
158. /**
159. * 上傳單個文件
160. *
161. * @param directory
162. * 上傳到sftp目錄
163. * @param uploadFile
164. * 要上傳的文件,包括路徑
165. * @throws FileNotFoundException
166. * @throws SftpException
167. * @throws Exception
168. */
169. public void upload(String directory, String uploadFile) throws FileNotFoundException, SftpException{
170. File file = new File(uploadFile);
171. upload(directory, file.getName(), new FileInputStream(file));
172. }
174. /**
175. * 將byte[]上傳到sftp，作為文件。註意:從String生成byte[]是，要指定字符集。
176. *
177. * @param directory
178. * 上傳到sftp目錄
179. * @param sftpFileName
180. * 文件在sftp端的命名
181. * @param byteArr
182. * 要上傳的字節數組
183. * @throws SftpException
184. * @throws Exception
185. */
186. public void upload(String directory, String sftpFileName, byte[] byteArr) throws SftpException{
187. upload(directory, sftpFileName, new ByteArrayInputStream(byteArr));
188. }
190. /**
191. * 將字符串按照指定的字符編碼上傳到sftp
192. *
193. * @param directory
194. * 上傳到sftp目錄
195. * @param sftpFileName
196. * 文件在sftp端的命名
197. * @param dataStr
198. * 待上傳的數據
199. * @param charsetName
200. * sftp上的文件，按該字符編碼保存
201. * @throws UnsupportedEncodingException
202. * @throws SftpException
203. * @throws Exception
204. */
205. public void upload(String directory, String sftpFileName, String dataStr, String charsetName) throws UnsupportedEncodingException, SftpException{
206. upload(directory, sftpFileName, new ByteArrayInputStream(dataStr.getBytes(charsetName)));
207. }
209. /**
210. * 下載文件
211. *
212. * @param directory
213. * 下載目錄
214. * @param downloadFile
215. * 下載的文件
216. * @param saveFile
217. * 存在本地的路徑
218. * @throws SftpException
219. * @throws FileNotFoundException
220. * @throws Exception
221. */
222. public void download(String directory, String downloadFile, String saveFile) throws SftpException, FileNotFoundException{
223. if (directory != null && !"".equals(directory)) {
224. sftp.cd(directory);
225. }
226. File file = new File(saveFile);
227. sftp.get(downloadFile, new FileOutputStream(file));
228. log.info("file:{} is download successful" , downloadFile);
229. }
230. /**
231. * 下載文件
232. * @param directory 下載目錄
233. * @param downloadFile 下載的文件名
234. * @return 字節數組
235. * @throws SftpException
236. * @throws IOException
237. * @throws Exception
238. */
239. public byte[] download(String directory, String downloadFile) throws SftpException, IOException{
240. if (directory != null && !"".equals(directory)) {
241. sftp.cd(directory);
242. }
243. InputStream is = sftp.get(downloadFile);
245. byte[] fileData = IOUtils.toByteArray(is);
247. log.info("file:{} is download successful" , downloadFile);
248. return fileData;
249. }
251. /**
252. * 刪除文件
253. *
254. * @param directory
255. * 要刪除文件所在目錄
256. * @param deleteFile
257. * 要刪除的文件
258. * @throws SftpException
259. * @throws Exception
260. */
261. public void delete(String directory, String deleteFile) throws SftpException{
262. sftp.cd(directory);
263. sftp.rm(deleteFile);
264. }
266. /**
267. * 列出目錄下的文件
268. *
269. * @param directory
270. * 要列出的目錄
271. * @param sftp
272. * @return
273. * @throws SftpException
274. */
275. public Vector<?> listFiles(String directory) throws SftpException {
276. return sftp.ls(directory);
277. }
279. public static void main(String[] args) throws SftpException, IOException {
280. SFTPUtil sftp = new SFTPUtil("lanhuigu", "123456", "192.168.200.12", 22);
281. sftp.login();
282. //byte[] buff = sftp.download("/opt", "start.sh");
283. //System.out.println(Arrays.toString(buff));
284. File file = new File("D:\\upload\\index.html");
285. InputStream is = new FileInputStream(file);
287. sftp.upload("/data/work", "test_sftp_upload.csv", is);
288. sftp.logout();
289. }
290. }

java通過sftp上傳文件