Browse Source

add ssh

pull/3/head
liuhuan 9 years ago
parent
commit
273ca39b5f
  1. 16
      pom.xml
  2. 2
      src/main/java/com/rekoe/module/admin/AdminProjectGroupUsrAct.java
  3. 51
      src/main/java/com/rekoe/ssh/PublicKeyAuthentication.java
  4. 29
      src/main/java/com/rekoe/ssh/Scp.java

16
pom.xml

@ -82,19 +82,9 @@
<version>2.9.1</version>
</dependency>
<dependency>
<groupId>org.apache.shiro</groupId>
<artifactId>shiro-ehcache</artifactId>
<version>1.2.4</version>
<exclusions>
<exclusion>
<artifactId>ehcache-core</artifactId>
<groupId>net.sf.ehcache</groupId>
</exclusion>
<exclusion>
<artifactId>shiro-core</artifactId>
<groupId>org.apache.shiro</groupId>
</exclusion>
</exclusions>
<groupId>ch.ethz.ganymed</groupId>
<artifactId>ganymed-ssh2</artifactId>
<version>build210</version>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>

2
src/main/java/com/rekoe/module/admin/AdminProjectGroupUsrAct.java

@ -162,7 +162,7 @@ public class AdminProjectGroupUsrAct extends BaseAction {
root.put("url", url);
List<String> urlList = new ArrayList<String>();
Cnd cnd = Cnd.where("pj", "=", project.getPj()).and("usr", "=", usr.getUsr());
List<PjGrUsr> list = projectGroupUsrService.query(cnd);
List<PjGrUsr> list = projectGroupUsrService.query(cnd,null);
if (Lang.isEmpty(list)) {
log.errorf("Cant Not Set User %s Project %s Gruop", usr.getUsr(), project.getPj());
return;

51
src/main/java/com/rekoe/ssh/PublicKeyAuthentication.java

@ -0,0 +1,51 @@
package com.rekoe.ssh;
import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import ch.ethz.ssh2.Connection;
import ch.ethz.ssh2.ConnectionInfo;
import ch.ethz.ssh2.Session;
import ch.ethz.ssh2.StreamGobbler;
public class PublicKeyAuthentication {
public static void main(String[] args) {
String hostname = "xxx.xxx.xxx.xxx";
String username = "root";
File keyfile = new File("~/.ssh/id_dsa"); // or "~/.ssh/id_dsa"
try {
/* Create a connection instance */
Connection conn = new Connection(hostname, 59231);
/* Now connect */
ConnectionInfo info = conn.connect();
System.out.println(info.keyExchangeAlgorithm);
/* Authenticate */
boolean isAuthenticated = conn.authenticateWithPublicKey(username, keyfile, "");
if (isAuthenticated == false)
throw new IOException("Authentication failed.");
/* Create a session */
Session sess = conn.openSession();
sess.execCommand("ls");
InputStream stdout = new StreamGobbler(sess.getStdout());
BufferedReader br = new BufferedReader(new InputStreamReader(stdout));
System.out.println("Here is some information about the remote host:");
while (true) {
String line = br.readLine();
if (line == null)
break;
System.out.println(line);
}
/* Close this session */
sess.close();
/* Close the connection */
conn.close();
} catch (IOException e) {
e.printStackTrace(System.err);
System.exit(2);
}
}
}

29
src/main/java/com/rekoe/ssh/Scp.java

@ -0,0 +1,29 @@
package com.rekoe.ssh;
import java.io.File;
import java.io.IOException;
import ch.ethz.ssh2.Connection;
import ch.ethz.ssh2.SCPClient;
public class Scp {
public static void main(String[] args) {
String hostname = "xxx.xxxx.xxxx.xxxx";
String username = "root";
File keyfile = new File("~/.ssh/id_dsa"); // or ""
try {
/* Create a connection instance */
Connection conn = new Connection(hostname, 59231);
/* Now connect */
conn.connect();
boolean isAuthenticated = conn.authenticateWithPublicKey(username, keyfile, "");
if (isAuthenticated == false)
throw new IOException("Authentication failed.");
/* Create a session */
SCPClient scpClient = conn.createSCPClient();
scpClient.put("d:/xxx.json", "/root/");
} catch (Exception e) {
e.printStackTrace();
}
}
}
Loading…
Cancel
Save