1.依赖的jar文件 jsch-0.1.53.jar
2.登录方式有密码登录,和密匙登录
代码:
主函数:
java" id="highlighter_779889">
|
1
2
3
4
5
6
7
8
9
10
11
|
import java.util.Properties;import com.cloudpower.util.Login;import com.util.LoadProperties;public class Ftp { public static void main(String[] args) { Properties properties = LoadProperties.getProperties(); Login.login(properties); }} |
登陆页面的代码:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
package com.cloudpower.util;import java.io.Console;import java.util.Properties;import com.jcraft.jsch.JSch;import com.jcraft.jsch.Session;public class Login { public static void login(Properties properties) { String ip = properties.getProperty("ip"); String user = properties.getProperty("user"); String pwd = properties.getProperty("pwd"); String port = properties.getProperty("port"); String privateKeyPath = properties.getProperty("privateKeyPath"); String passphrase = properties.getProperty("passphrase"); String sourcePath = properties.getProperty("sourcePath"); String destinationPath = properties.getProperty("destinationPath"); if (ip != null && !ip.equals("") && user != null && !user.equals("") && port != null && !port.equals("") && sourcePath != null && !sourcePath.equals("") && destinationPath != null && !destinationPath.equals("")) { if (privateKeyPath != null && !privateKeyPath.equals("")) { sshSftp2(ip, user, Integer.parseInt(port), privateKeyPath, passphrase, sourcePath, destinationPath); } else if (pwd != null && !pwd.equals("")) { sshSftp(ip, user, pwd, Integer.parseInt(port), sourcePath, destinationPath); } else { Console console = System.console(); System.out.print("Enter password:"); char[] readPassword = console.readPassword(); sshSftp(ip, user, new String(readPassword), Integer.parseInt(port), sourcePath, destinationPath); } } else { System.out.println("请先设置配置文件"); } } /** * 密码方式登录 * * @param ip * @param user * @param psw * @param port * @param sPath * @param dPath */ public static void sshSftp(String ip, String user, String psw, int port, String sPath, String dPath) { System.out.println("password login"); Session session = null; JSch jsch = new JSch(); try { if (port <= 0) { // 连接服务器，采用默认端口 session = jsch.getSession(user, ip); } else { // 采用指定的端口连接服务器 session = jsch.getSession(user, ip, port); } // 如果服务器连接不上，则抛出异常 if (session == null) { throw new Exception("session is null"); } // 设置登陆主机的密码 session.setPassword(psw);// 设置密码 // 设置第一次登陆的时候提示，可选值：(ask | yes | no) session.setConfig("StrictHostKeyChecking", "no"); // 设置登陆超时时间 session.connect(300000); UpLoadFile.upLoadFile(session, sPath, dPath); } catch (Exception e) { e.printStackTrace(); } System.out.println("success"); } /** * 密匙方式登录 * * @param ip * @param user * @param port * @param privateKey * @param passphrase * @param sPath * @param dPath */ public static void sshSftp2(String ip, String user, int port, String privateKey, String passphrase, String sPath, String dPath) { System.out.println("privateKey login"); Session session = null; JSch jsch = new JSch(); try { // 设置密钥和密码 // 支持密钥的方式登陆，只需在jsch.getSession之前设置一下密钥的相关信息就可以了 if (privateKey != null && !"".equals(privateKey)) { if (passphrase != null && "".equals(passphrase)) { // 设置带口令的密钥 jsch.addIdentity(privateKey, passphrase); } else { // 设置不带口令的密钥 jsch.addIdentity(privateKey); } } if (port <= 0) { // 连接服务器，采用默认端口 session = jsch.getSession(user, ip); } else { // 采用指定的端口连接服务器 session = jsch.getSession(user, ip, port); } // 如果服务器连接不上，则抛出异常 if (session == null) { throw new Exception("session is null"); } // 设置第一次登陆的时候提示，可选值：(ask | yes | no) session.setConfig("StrictHostKeyChecking", "no"); // 设置登陆超时时间 session.connect(300000); UpLoadFile.upLoadFile(session, sPath, dPath); System.out.println("success"); } catch (Exception e) { e.printStackTrace(); } }} |
文件上传的代码:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
package com.cloudpower.util;import java.io.File;import java.io.FileInputStream;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.util.Scanner;import com.jcraft.jsch.Channel;import com.jcraft.jsch.ChannelSftp;import com.jcraft.jsch.Session;import com.jcraft.jsch.SftpException;public class UpLoadFile { public static void upLoadFile(Session session, String sPath, String dPath) { Channel channel = null; try { channel.connect(10000000); ChannelSftp sftp = (ChannelSftp) channel; try { sftp.cd(dPath); Scanner scanner = new Scanner(System.in); System.out.println(dPath + ":此目录已存在,文件可能会被覆盖!是否继续y/n?"); String next = scanner.next(); if (!next.toLowerCase().equals("y")) { return; } } catch (SftpException e) { sftp.mkdir(dPath); sftp.cd(dPath); } File file = new File(sPath); copyFile(sftp, file, sftp.pwd()); } catch (Exception e) { e.printStackTrace(); } finally { session.disconnect(); channel.disconnect(); } } public static void copyFile(ChannelSftp sftp, File file, String pwd) { if (file.isDirectory()) { File[] list = file.listFiles(); try { try { String fileName = file.getName(); sftp.cd(pwd); System.out.println("正在创建目录:" + sftp.pwd() + "/" + fileName); sftp.mkdir(fileName); System.out.println("目录创建成功:" + sftp.pwd() + "/" + fileName); } catch (Exception e) { // TODO: handle exception } pwd = pwd + "/" + file.getName(); try { sftp.cd(file.getName()); } catch (SftpException e) { // TODO: handle exception e.printStackTrace(); } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } for (int i = 0; i < list.length; i++) { copyFile(sftp, list[i], pwd); } } else { try { sftp.cd(pwd); } catch (SftpException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } System.out.println("正在复制文件:" + file.getAbsolutePath()); InputStream instream = null; OutputStream outstream = null; try { outstream = sftp.put(file.getName()); instream = new FileInputStream(file); byte b[] = new byte[1024]; int n; try { while ((n = instream.read(b)) != -1) { outstream.write(b, 0, n); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } catch (SftpException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { try { outstream.flush(); outstream.close(); instream.close(); } catch (Exception e2) { // TODO: handle exception e2.printStackTrace(); } } } }} |
读取配置文件的代码:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
package com.util;import java.io.File;import java.io.FileInputStream;import java.io.IOException;import java.io.InputStream;import java.util.Properties;public class LoadProperties { public static Properties getProperties() { File file = new File(Class.class.getClass().getResource("/").getPath() + "properties.properties"); InputStream inputStream = null; try { inputStream = new FileInputStream(file); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } Properties properties = new Properties(); try { properties.load(inputStream); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } return properties; }} |
代码目录结构:
测试运行时配置文件放在项目的bin目录下(打包成可运行jar文件的时候要删除,打包完成后将配置文件和jar包放在同级目录下即可):
properties.properties
|
1
2
3
4
5
6
7
8
|
ip=user=pwd=port=22privateKeyPath=passphrase=sourcePath=destinationPath=/home/dbbs/f |
打包可运行jar文件:
Export->java->Runnabe JAR file
完成后
在控制台运行java -jar 导出jar包的名字.jar 即可
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
原文链接：http://www.cnblogs.com/zuo-java/p/5913295.html
