English | 简体中文 | 繁體中文 | Русский язык | Français | Español | Português | Deutsch | 日本語 | 한국어 | Italiano | بالعربية
Загрузка и скачивание файлов с сервера через ssh
Предварительные remarks
Ранее я записывал метод использования открытого компонента FTP apache для загрузки и скачивания файлов с сервера, но后来 обнаружил, что при удалении файлов могут возникнуть проблемы с правами доступа, что делает невозможным удаление файлов с сервера.虽然说在Windows с использованием FileZilla Server и настройки прав доступа не возникает проблем, но все же это неудобно на сервере.
Поскольку мне нужно реализовать функцию управления ресурсами, кроме хранения данных в FastDFS, некоторые специфические ресурсы я намерен временно хранить на сервере. Коллеги из проектной группы сказали, что они не будут专门在服务器上开设FTP-сервис, поэтому я решил использовать метод работы через sftp.
Как использовать эту вещь?
Сначала нужно загрузить jar-архив jsch, адрес: http://www.jcraft.com/jsch/. На сайте также указано: JSch — это чистая Java-реализация SSH2. Это реализация SSH2 на чистом Java. Используя IP и порт, вводя имя пользователя и пароль, можно использовать его как Secure CRT. Так как использовать этот полезный инструмент?
Если вы не умеете программировать, это не проблема, официальные примеры также предоставлены, ссылка:http://www.jcraft.com/jsch/examples/Shell.javaПожалуйста, посмотрите:
/* -*-mode:java; c-basic-offset:2; indent-tabs-mode:nil -*- */
/**
* Эта программа позволяет вам подключиться к серверу sshd и получить приглашение терминала.
* $ CLASSPATH=.:../build javac Shell.java
* $ CLASSPATH=.:../build java Shell
* Вас спросят о имени пользователя, имени хоста и пароле.
* Если все работает хорошо, вы получите приглашение терминала. Вывод может
* Это может быть некрасиво из-за отсутствия эмуляции терминала, но вы можете вводить команды.
*
*/
import com.jcraft.jsch.*;
import java.awt.*;
import javax.swing.*;
public class Shell{
public static void main(String[] arg){
try{
JSch jsch=new JSch();
//jsch.setKnownHosts("/home/foo/.ssh/known_hosts");
String host=null;
if(arg.length>0){
host=arg[0];
}
else{
host=JOptionPane.showInputDialog("Ввведите имя пользователя@имя хоста",
System.getProperty("user.name")+
"@localhost");
}
String user=host.substring(0, host.indexOf('@'));
host=host.substring(host.indexOf('@')+1);
Session session=jsch.getSession(user, host, 22);
String passwd = JOptionPane.showInputDialog("Ввведите пароль");
session.setPassword(passwd);
UserInfo ui = new MyUserInfo(){
public void showMessage(String message){
JOptionPane.showMessageDialog(null, message);
}
public boolean promptYesNo(String message){
Object[] options={ "да", "нет" };
int foo=JOptionPane.showOptionDialog(null,
message,
"Предупреждение",
JOptionPane.DEFAULT_OPTION,
JOptionPane.WARNING_MESSAGE,
null, options, options[0]);
возврат foo==0;
}
// Если пароль не предоставлен до вызова Session#connect(),
// реализовать также следующие методы:
// * UserInfo#getPassword(),
// * UserInfo#promptPassword(String message) и
// * UIKeyboardInteractive#promptKeyboardInteractive()
};
session.setUserInfo(ui);
// Не рекомендуется рекомендовать, но если вы хотите пропустить проверку ключа хоста,
// invoke following,
// session.setConfig("StrictHostKeyChecking", "no");
//session.connect();
session.connect(30000); // making a connection with timeout.
Channel channel=session.openChannel("shell");
// Enable agent-forwarding.
//((ChannelShell)channel).setAgentForwarding(true);
channel.setInputStream(System.in);
/*
// a hack for MS-DOS prompt on Windows.
channel.setInputStream(new FilterInputStream(System.in){
public int read(byte[] b, int off, int len)throws IOException{
return in.read(b, off, (len>1024?1024:len));
}
});
*/
channel.setOutputStream(System.out);
/*
// Choose the pty-type "vt102".
((ChannelShell)channel).setPtyType("vt102");
*/
/*
// Set environment variable "LANG" as "ja_JP.eucJP".
((ChannelShell)channel).setEnv("LANG", "ja_JP.eucJP");
*/
//channel.connect();
channel.connect(3*1000);
}
catch(Exception e){
System.out.println(e);
}
}
public static abstract class MyUserInfo
implements UserInfo, UIKeyboardInteractive{
public String getPassword(){ return null; }
public boolean promptYesNo(String str){ return false; }
public String getPassphrase(){ return null; }
public boolean promptPassphrase(String message){ return false; }
public boolean promptPassword(String message){ return false; }
String[] prompt,
boolean[] echo){
return null;
}
}
}
В этом коде мы видим все необходимое. Сначала мы создаем информацию о пользователе, которая主要用于 аутентификации. Достаточно реализовать интерфейсы UserInfo и UIKeyboardInteractive, затем создать сеанс и добавить userInfo в него, после чего можно установиться.
Оболочка для загрузки и скачивания файлов
Ниже приведены базовые методы использования Jsch, это просто базовые шаблоны. Теперь давайте создадим свою функциональность, которая включает в себя операции по загрузке и скачиванию файлов.
Сначала, также создадим UserInfo:
public class MyUserInfo implements UserInfo, UIKeyboardInteractive{
public String getPassword(){ return null; }
public boolean promptYesNo(String str){
return true;
}
public String getPassphrase(){ return null; }
public boolean promptPassphrase(String message){ return true; }
public boolean promptPassword(String message){
return true;
}
public void showMessage(String message){
}
@Override
public String[] promptKeyboardInteractive(String arg0, String arg1,
String arg2, String[] arg3, boolean[] arg4) {
return null;
}
}
ниже приведен класс реализации:
package com.tfxiaozi.common.utils;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Vector;
import org.apache.log4j.Logger;
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelExec;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.SftpException;
import com.jcraft.jsch.SftpProgressMonitor;
/**
* SSH Utils
* @author tfxiaozi
*
*/
public class Ssh {
Logger logger = Logger.getLogger(this.getClass());
private String host = "";
private String user = "";
private int port = 22;
private String password = "";
private static final String PROTOCOL = "sftp";
JSch jsch = new JSch();
private Session session;
private Channel channel;
private ChannelSftp sftp;
public String getHost() {
return host;
}
public void setHost(String host) {
this.host = host;
}
public String getUser() {
return user;
}
public void setUser(String user) {
this.user = user;
}
public Ssh() {
}
public Ssh(String host, int port, String user, String password) {
this.host = host;
this.user = user;
this.password = password;
this.port = port;
}
/**
* connect ssh
* @throws JSchException
*/
public void connect() throws JSchException {
if (session == null) {
session = jsch.getSession(user, host, port);
MyUserInfo ui = new MyUserInfo();
session.setUserInfo(ui);
session.setPassword(password);
session.connect();
channel = session.openChannel(PROTOCOL);
channel.connect();
sftp = (ChannelSftp)channel;
}
}
/**
* disconnect ssh
*/
public void disconnect() {
if (session != null) {
session.disconnect();
session = null;
}
}
/**
* upload
* @param localFileName
* @param remoteFileName
* @return
*/
public boolean upload(String localFileName, String remoteFileName) throws Exception{
SftpProgressMonitor monitor = new MyProgressMonitor();
try {
SftpProgressMonitor monitor = new MyProgressMonitor();
int mode = ChannelSftp.OVERWRITE;
sftp.put(localFileName, remoteFileName, monitor, mode);
catch(Exception e) {
}
logger.error(e);
}
if (null != channel) {
channel.disconnect();
}
}
return bSucc;
}
/**
* удалить файл
* @param directory
* @param fileName
* @return
*/
public boolean deteleFile(String directory, String fileName) {
boolean flag = false;
try {
sftp.cd(directory);
sftp.rm(fileName);
flag = true;
catch (SftpException e) {
flag = false;
logger.error(e);
}
возврат flag;
}
/**
* удалить каталог
* @param directory каталог для удаления
* @param sure быть уверенным в удалении
* @return
*/
public String deleteDir(String directory, boolean sure) {
String command = "rm -rf " + directory;
String result = execCommand(command, true);
return result;
}
/**
* сжать файлы и подкаталоги каталога в архив с именем compressName
* @param directory каталог содержимого, который нужно сжать
* @param compressName имя в каталоге после сжатия
* @throws SftpException
* @usage ssh.compressDir("/home/tfxiaozi/webapp", "test.zip");
*/
public void compressDir(String directory, String compressName) throws SftpException {
String command = "cd "+ directory +"\nzip -r " + compressName + " ./" + compressName.substring(0, compressName.lastIndexOf("."));
execCommand(command, true);
}
/**
* download
* @param localFileName
* @param remoteFileName
* @return
*/
boolean bSucc = false;
SftpProgressMonitor monitor = new MyProgressMonitor();
Channel channel = null;
try {
sftp.get(remoteFileName, localFileName, monitor, ChannelSftp.OVERWRITE);
bSucc = true;
catch(Exception e) {
}
logger.error(e);
}
if (null != channel) {
channel.disconnect();
}
}
return bSucc;
}
/**
* execute command
* @param command
* @param flag
* @return
*/
public String execCommand(String command, boolean flag) {
Channel channel = null;
InputStream in = null;
StringBuffer sb = new StringBuffer("");
try {
channel = session.openChannel("exec");
System.out.println("command:" + command);
((ChannelExec)channel).setCommand("export TERM=ansi && " + command);
((ChannelExec)channel).setErrStream(System.err);
in = channel.getInputStream();
channel.connect();
if (flag) {
byte[] tmp = new byte[10240];
while (true) {
while (in.available()>0) {
int i = in.read(tmp, 0, 10240);
if(i < 0) {
break;
}
sb.append(new String(tmp, 0, i));
}
if (channel.isClosed()){
break;
}
}
}
in.close();
}
logger.error(e);
}
if (channel != null) {
channel.disconnect();
}
}
return sb.toString();
}
/**
* get cpu info
* @return
*/
public String[] getCpuInfo() {
Channel channel = null;
InputStream in = null;
StringBuffer sb = new StringBuffer("");
try {
channel = session.openChannel("exec");
((ChannelExec)channel).setCommand("export TERM=ansi && top -bn 1");//ansi一定要加
in = channel.getInputStream();
((ChannelExec)channel).setErrStream(System.err);
channel.connect();
byte[] tmp = new byte[10240];
while (true) {
while (in.available()>0) {
int i = in.read(tmp, 0, 10240);
if(i < 0) {
break;
}
sb.append(new String(tmp, 0, i));
}
if (channel.isClosed()){
break;
}
}
}
logger.error(e);
}
if (channel != null) {
channel.disconnect();
}
}
String buf = sb.toString();
if (buf.indexOf("Swap") != -1) {
buf = buf.substring(0, buf.indexOf("Swap"));
}
if (buf.indexOf("Cpu") != -1) {
buf = buf.substring(buf.indexOf("Cpu"), buf.length());
}
buf.replaceAll(" ", " ");
return buf.split("\\n");
}
/**
* Получить информацию о жестком диске
* @return
*/
public String getHardDiskInfo() throws Exception{
Channel channel = null;
InputStream in = null;
StringBuffer sb = new StringBuffer("");
try {
channel = session.openChannel("exec");
((ChannelExec)channel).setCommand("df -lh");
in = channel.getInputStream();
((ChannelExec)channel).setErrStream(System.err);
channel.connect();
byte[] tmp = new byte[10240];
while (true) {
while (in.available()>0) {
int i = in.read(tmp, 0, 10240);
if(i < 0) {
break;
}
sb.append(new String(tmp, 0, i));
}
if (channel.isClosed()){
break;
}
}
}
throw new RuntimeException(e);
}
if (channel != null) {
channel.disconnect();
}
}
String buf = sb.toString();
String[] info = buf.split("\n");
if(info.length > 2) { //first line: Filesystem Size Used Avail Use% Mounted on
String tmp = "";
for(int i=1; i< info.length; i++) {
tmp = info[i];
String[] tmpArr = tmp.split("%");
if(tmpArr[1].trim().equals("/")){
boolean flag = true;
while(flag) {
tmp = tmp.replaceAll(" ", " ");
if (tmp.indexOf(" ") == -1){
flag = false;
}
}
String[] result = tmp.split(" ");
if(result != null && result.length == 6) {
buf = result[1] + " total, " + result[2] + " used, " + result[3] + " free";
break;
}
buf = "";
}
}
}
}
buf = "";
}
return buf;
}
/**
* Возвращает количество свободных байт
* @return
* @throws Exception
*/
public double getFreeDisk() throws Exception {
String hardDiskInfo = getHardDiskInfo();
if(hardDiskInfo == null || hardDiskInfo.equals("")) {
logger.error("get free harddisk space failed.....");
return -1;
}
String[] diskInfo = hardDiskInfo.replace(" ", "").split(",");
if(diskInfo == null || diskInfo.length == 0) {
logger.error("get free disk info failed.........");
return -1;
}
String free = diskInfo[2];
free = free.substring(0, free.indexOf("free"));
//System.out.println("free space:" + free);
String unit = free.substring(free.length()-1);
//System.out.println("unit:" + unit);
String freeSpace = free.substring(0, free.length()-1);
double freeSpaceL = Double.parseDouble(freeSpace);
//System.out.println("free spaceL:" + freeSpaceL);
if(unit.equals("K")) {
return freeSpaceL*1024;
} else if(unit.equals("M")) {
return freeSpaceL*1024*1024;
} else if(unit.equals("G")) {
return freeSpaceL*1024*1024*1024;
} else if(unit.equals("T")) {
return freeSpaceL*1024*1024*1024*1024;
} else if(unit.equals("P")) {
return freeSpaceL*1024*1024*1024*1024*1024;
}
return 0;
}
/**
* Получить все подкаталоги и файлы в указанном каталоге
* @param directory
* @return
* @throws Exception
*/
@SuppressWarnings("rawtypes")
public List<String> listFiles(String directory) throws Exception {
Vector fileList = null;
List<String> fileNameList = new ArrayList<String>();
fileList = sftp.ls(directory);
Iterator it = fileList.iterator();
while (it.hasNext()) {
String fileName = ((ChannelSftp.LsEntry) it.next()).getFilename();
if (fileName.startsWith(".") || fileName.startsWith("..")) {
continue;
}
fileNameList.add(fileName);
}
return fileNameList;
}
public boolean mkdir(String path) {
boolean flag = false;
try {
sftp.mkdir(path);
flag = true;
catch (SftpException e) {
flag = false;
}
возврат flag;
}
}
Тестирование
public static void main(String[] arg) throws Exception{
Ssh ssh = new Ssh("10.10.10.83", 22, "test", "test");
try {
ssh.connect();
} catch (JSchException e) {
e.printStackTrace();
}
/*String remotePath = "/home/tfxiaozi/" + "webapp/";
try {
ssh.listFiles(remotePath);
} catch (Exception e) {
ssh.mkdir(remotePath);
}*/
/*boolean b = ssh.upload("d:/test.zip", "webapp/");
System.out.println(b);*/
//String []buf = ssh.getCpuInfo();
//System.out.println("cpu:" + buf[0]);
//System.out.println("memo:" + buf[1]);
//System.out.println(ssh.getHardDiskInfo().replace(" ", ""));
//System.out.println(ssh.getFreeDisk());
/*List<String> list = ssh.listFiles("webapp/test");
for(String s : list) {
System.out.println(s);
}*/
/*boolean b = ssh.deteleFile("webapp", "test.zip");
System.out.println(b);*/
/*try {
String s = ssh.execCommand("ls -l /home/tfxiaozi/webapp1/test", true);
System.out.println(s);
} catch (Exception e) {
System.out.println(e.getMessage());
}*/
//ssh.sftp.setFilenameEncoding("UTF-8");
/*try {
String ss = ssh.execCommand("unzip /home/tfxiaozi/webapp1/test.zip -d /home/tfxiaozi/webapp1/", true);
System.out.println(ss);
} catch (Exception e) {
System.out.println( e.getMessage());
}*/
/*String path = "/home/tfxiaozi/webapp1/test.zip";
try {
List<String> list = ssh.listFiles(path);
for(String s:list) {
System.out.println(s);
}
System.out.println("ok");
} catch (Exception e) {
System.out.println("extract failed....");
}*/
/*String command = "rm -rf /home/tfxiaozi/webapp1/" + "水墨国学";
String sss = ssh.execCommand(command, true);
System.out.println(sss);*/
/*String findCommand = "find /home/tfxiaozi/webapp1/水墨国学 -name 'index.html'";
String result = ssh.execCommand(findCommand, true);
System.out.println(result);*/
/*String path = "";
ssh.listFiles(remotePath);*/
/*
ssh.deleteDir("/home/tfxiaozi/webapp1", true);
*/
//Этот файл будет разархивирован в директорию webapp1, также в webapp1/test/xxx
//ssh.execCommand("unzip /home/tfxiaozi/webapp1/test.zip -d /home/tfxiaozi/webapp1", true);
//Этот файл будет разархивирован в директорию /webapp1/test, также в webapp1/test/test/xxx
//ssh.execCommand("unzip /home/tfxiaozi/webapp1/test.zip -d /home/tfxiaozi/webapp1", true);
//ssh.compressDir("/home/tfxiaozi/webapp1", "test.zip");
//ssh.sftp.cd("/home/tfxiaozi/webapp1");
//ssh.compressDir("/home/tfxiaozi/webapp1", "test.zip");
/*boolean b = ssh.download("d:/temp/test.zip", "webapp/test.zip");
System.out.println(b);*/
//ssh.getHardDiskInfo();
System.out.println(ssh.getFreeDisk());
ssh.disconnect();
}
Вот как это можно сделать напрямую через linux, но нужно учитывать, что для китайских файлов, при разархивации, при передаче может возникнуть кодировка, необходимо добавить параметры, например, unzip -O cp936 test.zip -d /home/tfxiaozi/test.
Вот и все, что есть в этой статье, мы надеемся, что это поможет вам в изучении, и также надеемся, что вы будете активно поддерживать учебные руководства.
Декларация: содержимое этой статьи взято из интернета, авторские права принадлежат их законным владельцам, контент предоставлен пользователями интернета, сайт не обладает правами собственности, не был подвергнут редактированию, и не несет ответственности за связанные с этим юридические последствия. Если вы обнаружите содержимое,涉嫌侵犯版权， пожалуйста, отправьте письмо по адресу: notice#oldtoolbag.com (при отправке письма, пожалуйста, замените # на @) для сообщения о нарушении и предоставьте соответствующие доказательства. При подтверждении правонарушения сайт немедленно удалят涉嫌侵权的内容。