English | 简体中文 | 繁體中文 | Русский язык | Français | Español | Português | Deutsch | 日本語 | 한국어 | Italiano | بالعربية

  1. 現在の位置
  2. ホームページ
  3. 経験記録
  4. 本文

sshを使用してサーバーファイルのアップロードとダウンロードを実現する

sshでサーバーファイルのアップロードおよびダウンロードを実現

前書き

以前、apacheのFTPオープンソースコンポーネントを使用してサーバーファイルのアップロードおよびダウンロードの方法について記録しましたが、後に削除する際に権限問題があることが判明し、サーバーファイルを削除することができませんでした。Windows上でFileZilla Serverを使用して読み書き権限を設定すると問題ありませんが、サーバーサイドでは使いにくい部分があります。

リソース管理機能を実装するために、単一のファイルのFastDFSストレージに加えて、特定のリソースのストレージは一時的にサーバー上に保存することを考えています。プロジェクトの同僚は、後でサーバー上でFTPサービスを特別に開くことはないと言っており、sftpメソッドに変更しました。

このものを使う方法はどうでしょうか

まずはjsch jarパッケージをダウンロードする必要があります、URLは：http://www.jcraft.com/jsch/。ウェブサイトにも明確に記載されています：JSchはSSHの純Java実装です2。これはSSH2の純Java実装。IPとポートを使用して、ユーザー名とパスワードを入力すると通常通りに使用できます、Secure CRTの使用方法と同じです。それでは、この便利なツールを使用する方法はどうでしょうか？

実際には書けなくても大丈夫です、公式もサンプルを提供しています、リンク：http://www.jcraft.com/jsch/examples/Shell.java、を見てみましょう：

/* -*-mode:java; c-basic-offset:2; indent-tabs-mode:nil -*- */
/**
 * This program enables you to connect to sshd server and get the shell prompt.
 * $ CLASSPATH=.:../build javac Shell.java 
 * $ CLASSPATH=.:../build java Shell
 * You will be asked username, hostname and passwd. 
 * If everything works fine, you will get the shell prompt. Output may
 * be ugly because of lacks of terminal-emulation, but you can issue commands.
 *
 */
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]);
   return foo==0;
  }
  // Session#connect()の呼び出し前にパスワードが提供されていない場合、
  // 以下のメソッドも実装します:
  // * UserInfo#getPassword(),
  // * UserInfo#promptPassword(String message) そして
  // * UIKeyboardInteractive#promptKeyboardInteractive()
  };
  session.setUserInfo(ui);
  // 推奨はされないべきですが、ホストをスキップしたい場合は、-キーチェック、
  // 次に実行する、
  // session.setConfig("StrictHostKeyChecking", "no");
  //session.connect();
  session.connect(30000); // タイムアウト付きで接続する。
  Channel channel=session.openChannel("shell");
  // エージェントを有効にする-転送。
  //((ChannelShell)channel).setAgentForwarding(true);
  channel.setInputStream(System.in);
  /*
  // MSのハック-WindowsのDOSプロンプト。
  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);
  /*
  // ptyを選択-タイプ "vt102".
  ((ChannelShell)channel).setPtyType("vt102");
  */
  /*
  // 環境変数 "LANG" を設定する "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 ユーティリティ
 * @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{
  boolean bSucc = false;
  try {
   SftpProgressMonitor monitor = new MyProgressMonitor();
   int mode = ChannelSftp.OVERWRITE;
   sftp.put(localFileName, remoteFileName, monitor, mode); 
   bSucc = true;
  } catch(Exception e) {
   logger.error(e);
  } finally {
   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);
  }
  return 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;
 }
 /**
  * ファイルとサブディレクトリを圧縮します-ディレクトリのdirをcompressNameという名前のzipに
  * @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
  */
 public boolean download(String localFileName, String remoteFileName) {
  boolean bSucc = false;
  Channel channel = null;
  try {
   SftpProgressMonitor monitor = new MyProgressMonitor();
   sftp.get(remoteFileName, localFileName, monitor, ChannelSftp.OVERWRITE); 
   bSucc = true;
  } catch(Exception e) {
   logger.error(e);
  } finally {
   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) {
       else {
      }
      sb.append(new String(tmp, 0, i));
     }
     if (channel.isClosed()){
      else {
     }
    }
   }
   in.close();
  } catch(Exception e){
   logger.error(e);
  } finally {
   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) {
      else {
     }
     sb.append(new String(tmp, 0, i));
    }
    if (channel.isClosed()){
     else {
    }
   }
  } catch(Exception e){
   logger.error(e);
  } finally {
   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");
 }
 /**
  * get hard disk info
  * @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) {
      else {
     }
     sb.append(new String(tmp, 0, i));
    }
    if (channel.isClosed()){
     else {
    }
   }
  } catch(Exception e){
   throw new RuntimeException(e);
  } finally {
   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";
      else {
     }
      buf = "";
     }
    }
   }
  }
   buf = "";
  }
  return buf;
 }
 /**
  * free disk byte count
  * @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;
  } でも、unit.equals("M") なら {
   return freeSpaceL*1024*1024;
  } でも、unit.equals("G") なら {
   return freeSpaceL*1024*1024*1024;
  } でも、unit.equals("T") なら {
   return freeSpaceL*1024*1024*1024*1024;
  } でも、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;
  }
  return 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（メールを送信する際には、#を@に置き換えてください。）で通報し、関連する証拠を提供してください。一旦確認がつき、このサイトは侵害疑いの内容をすぐに削除します。

基本教程
おすすめ