sftp上传 - 待完

1、搭建本地sftp

　　1.1、下载msftpsrvr.exe软件

　　　　　　下载地址：http://www.download3k.com/Install-Core-FTP-Mini-SFTP-Server.html

　　　　　　

　　1.2、双击msftpsrvr.exe，录入sftp信息

　　　　

2、工具类

SftpUploadUtil

package com.hundsun.channel.util;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.util.Properties;
import java.util.Vector;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import com.jcraft.jsch.Channel;
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;

public class SftpUploadUtil {

    public static final Log logger = LogFactory.getLog(SftpUploadUtil.class);

    /**
     * 连接sftp服务器
     * @param host 主机
     * @param port 端口
     * @param username 用户名
     * @param password 密码
     * @param privateKey 密钥文件路径
     * @param passphrase 密钥口令
     * @return
     */
    public ChannelSftp connect(String host, int port, String username,String password,String privateKey,String passphrase) {
     ChannelSftp sftp = null;
     try {
      JSch jsch = new JSch();
      jsch.getSession(username, host, port);
      if (privateKey != null && !"".equals(privateKey)) {
          //使用密钥验证方式，密钥可以使有口令的密钥，也可以是没有口令的密钥
          if (passphrase != null && !"".equals(passphrase)) {
              jsch.addIdentity(privateKey, passphrase);
          } else {
              jsch.addIdentity(privateKey);
          }
      }      

      Session sshSession = jsch.getSession(username, host, port);
      System.out.println("Session created.");
      if (password != null && !"".equals(password)) {
          sshSession.setPassword(password);
      }
      Properties sshConfig = new Properties();
      sshConfig.put("StrictHostKeyChecking", "no");
      sshSession.setConfig(sshConfig);
      sshSession.connect();
      System.out.println("Session connected.");
      System.out.println("Opening Channel.");
      Channel channel = sshSession.openChannel("sftp");
      channel.connect();
      sftp = (ChannelSftp) channel;
      System.out.println("Connected to " + host + ".");
      //System.out.println("登录成功");
     } catch (Exception e) {
         System.out.println("------");
         e.printStackTrace();
     }
     return sftp;
    }

    /**
     * 关闭
     * @param sftp
     * @param sshSession
     * @throws JSchException
     */
    public void close(ChannelSftp sftp) throws JSchException {
        if (null!=sftp) {
            if (null!=sftp.getSession()) {
                sftp.getSession().disconnect();
            }
            sftp.disconnect();
        }

    }

    /**
     * 上传文件
     * @param directory 上传的目录
     * @param uploadFile 要上传的文件
     * @param sftp
     */
    public void upload(String directory, String uploadFile, ChannelSftp sftp) {
     try {
      sftp.cd(directory);
      File file=new File(uploadFile);
      sftp.put(new FileInputStream(file), file.getName());
      System.out.println("上传成功！");
     } catch (Exception e) {
      e.printStackTrace();
     }
    }

    /**
     * 下载文件
     * @param directory 下载目录
     * @param downloadFile 下载的文件
     * @param saveFile 存在本地的路径
     * @param sftp
     */
    public void download(String directory, String downloadFile, String saveFile, ChannelSftp sftp) {
        try {
            logger.info("下载目录：" + directory + "，下载文件：" + downloadFile + "，存本地路径：" + saveFile);
            sftp.cd(directory);
            File file = new File(saveFile);
            sftp.get(downloadFile, new FileOutputStream(file));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 删除文件
     * @param directory 要删除文件所在目录
     * @param deleteFile 要删除的文件
     * @param sftp
     */
    public void delete(String directory, String deleteFile, ChannelSftp sftp) {
     try {
      sftp.cd(directory);
      sftp.rm(deleteFile);
     } catch (Exception e) {
      e.printStackTrace();
     }
    }

    /**
     * 列出目录下的文件
     * @param directory 要列出的目录
     * @param sftp
     * @return
     * @throws SftpException
     */
    public Vector listFiles(String directory, ChannelSftp sftp) throws SftpException{
     return sftp.ls(directory);
    }

    /**
     * 创建文件夹
     * @param sftp
     * @param directory
     * @throws SftpException
     */
    public void createFolder(ChannelSftp  sftp,String directory) throws SftpException {

        sftp.mkdir(directory);
    }   

    public static void main(String[] args) {

        /*
        Vector<LsEntry> vector = new Vector<LsEntry>();
        String host="192.168.54.112";
        int port=22;
        String username="wjs";
        String password="[email protected]";
        //上传的目录
        String directory="/home/wjs/upload/1001/"+DateUtil.getDateTime("yyyyMMdd", new Date());
        System.out.println("directory:--------------"+directory);

        //要上传的文件
        String uploadFile="F:\\upload\\1001\\20151102\\info_1001_9000_20151102.txt";

        SftpUploadUtil sf = new SftpUploadUtil(); 

        //获取连接
        ChannelSftp  sftp = sf.connect(host, port, username, password); 

        //创建文件夹
        try {
            //home/wjs/upload/1001
            vector = sftp.ls(directory);
        } catch (SftpException e) {
            // TODO Auto-generated catch block
            if (e.id == 2 || "No such file".equals(e.getMessage())) {
                Iterator<LsEntry> it = vector.iterator();
                while (it.hasNext()) {
                    LsEntry lsEntry = it.next();
                    System.out.println(lsEntry.getLongname());
                    System.out.println(lsEntry.getLongname().startsWith("d"));
                }
                try {
                    sftp.mkdir(directory);
                    //上传文件
                    sf.upload(directory, uploadFile, sftp);
                    File file = new File(uploadFile);
                    long fileSize = file.length();

                    sftp.put(directory + "/info_1001_9000_20151026.txt", new FileProgressMonitor(
                        fileSize), ChannelSftp.OVERWRITE);
                    sftp.quit();
                    sf.close(sftp);
                } catch (SftpException e1) {
                    // TODO Auto-generated catch block
                    e1.printStackTrace();
                } catch (JSchException e2) {
                    // TODO Auto-generated catch block
                    e2.printStackTrace();
                }
            }
        }
    */}
}

3、测试连接

    public static void main(String[] args) throws Exception {
        SftpUploadUtil sfUtil = new SftpUploadUtil();
        String sftpHost = "10.23.10.39";
        int sftpPort = 22; // 端口表字段暂时未定义
        String sftpUserName = "quanbs";
        String password = "123456";
        String privateKey = ""; // 秘钥文件路径
        String passphrase = ""; // 秘钥口令
        ChannelSftp sftp = sfUtil.connect(sftpHost, sftpPort, sftpUserName, password, privateKey, passphrase);
    }

运行结果(连接成功)：

4、测试sftp上传

    public static void main(String[] args) throws Exception {
        SftpUploadUtil sfUtil = new SftpUploadUtil();
        String sftpHost = "10.23.10.39";
        int sftpPort = 22; // 端口表字段暂时未定义
        String sftpUserName = "quanbs";
        String password = "123456";
        String privateKey = ""; // 秘钥文件路径
        String passphrase = ""; // 秘钥口令
        ChannelSftp sftp = sfUtil.connect(sftpHost, sftpPort, sftpUserName, password, privateKey, passphrase);

        // 测试sftp上传
        testUploadFile(sfUtil, sftp);
    }
    /**
     * 测试上传文件
     * @param sfUtil
     * @param sftp
     * @throws SftpException
     */
    public static void testUploadFile(SftpUploadUtil sfUtil, ChannelSftp sftp) throws SftpException{
        String sftpDirectory = "E:"+File.separator+"sftp";
        sftpDirectory = "\\";
        String uploadFile = "D:\\log.zip";
        List lsList = getLsListName(File.separator, sftp); // 获取目录下的文件名List
        String date = DateUtils.convertDateToLong(new Date(), "yyyyMMdd").toString(); // 当天文件夹 20161026
        if (!lsList.contains(date)) // 当天日期文件夹不存在则创建
            sftp.mkdir(date);

        sftpDirectory += date;

        sfUtil.upload(sftpDirectory, uploadFile, sftp);

    }
    /**
     * 获取目录下的文件名List
     * @param path 目录
     * @param sftp
     * @throws SftpException
     */
    private static List<String> getLsListName(String path, ChannelSftp sftp) throws SftpException{
        List<String> list = new ArrayList<String>();
        Vector vector = sftp.ls(File.separator);
        Iterator<LsEntry> it = vector.iterator();
        while (it.hasNext()) {
            LsEntry lsEntry = it.next();
            list.add(lsEntry.getFilename());
        }
        return list;
    }

运行结果：

附：

DateUtils

package com.hundsun.channel.util;

import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;

public class DateUtils {

    public static SimpleDateFormat FORMAT_DATE = new SimpleDateFormat("yyyy-MM-dd");

    public static SimpleDateFormat FORMAT_DATETIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    public static SimpleDateFormat FORMAT_DATE_SIMPLE = new SimpleDateFormat("yyyyMMdd");

    public static SimpleDateFormat FORMAT_DATETIME_SIMPLE = new SimpleDateFormat("yyyyMMddHHmmss");

    public static SimpleDateFormat FORMAT_DATE_CN = new SimpleDateFormat("yyyy??MM??dd??");

    public static SimpleDateFormat FORMAT_DATETIME_CN = new SimpleDateFormat("yyyy??MM??dd??HH?mm??ss??");

    public static SimpleDateFormat FORMAT_DATETIME_HOUR = new SimpleDateFormat("yyyy-MM-dd HH:mm");

    public static Date getDateTime(String dateStr, SimpleDateFormat format) {
        Date date = null;
        try {
            date = format.parse(dateStr);
        } catch (ParseException e) {
            return null;
        }
        return date;
    }

    public static String getDateTimeStr(Date date, SimpleDateFormat format) {
        if (date == null || format == null) {
            return null;
        }
        return format.format(date);
    }

    public static Date getDate(String dateStr) {
        if (dateStr == null || "".equals(dateStr)) {
            return null;
        }
        return getDateTime(dateStr, FORMAT_DATE);
    }

    public static Date getDateTime(String dateStr) {
        return getDateTime(dateStr, FORMAT_DATETIME);
    }

    public static String getDateStr(Date date) {
        return getDateTimeStr(date, FORMAT_DATE);
    }

    public static String getDateTimeStr(Date date) {
        return getDateTimeStr(date, FORMAT_DATETIME);
    }

    public static long getDiffDays(Date startTime, Date endTime) {
        long quot = 0;
        if (startTime == null || endTime == null) {
            return quot;
        }
        SimpleDateFormat ft = new SimpleDateFormat("yyyy/MM/dd");
        try {
            Date endDate = ft.parse(ft.format(endTime));
            Date startDate = ft.parse(ft.format(startTime));
            quot = endDate.getTime() - startDate.getTime();
            quot = quot / 1000 / 60 / 60 / 24;
        } catch (ParseException e) {
            e.printStackTrace();
        }
        return quot;
    }

    public static Long convertDateToLong(Date date, String format) {
        SimpleDateFormat ft = new SimpleDateFormat(format);
        String formatStr = ft.format(date);
        long parseLong = Long.parseLong(formatStr);
        return parseLong;
    }

    public static Long convertDateToLong(Date date) {
        String formatStr = FORMAT_DATETIME_SIMPLE.format(date);
        long parseLong = Long.parseLong(formatStr);
        return parseLong;
    }
}

待完，很粗糙的东西 ，花了10分钟整理了下，要赶最后一班地铁回家了。 又是漫长的1个半小时。。。。

时间： 2024-10-13 07:03:09

sftp上传 - 待完的相关文章

SFTP上传下载文件

secureCRT SFTP上传/下载文件 远程登陆IP secureCRT会话中点击SFTP 3.cd  /home/dowload       linux平台切换到/home/dowload目录 4.cd d:\   windows平台切换到d盘 5.put 文件名           上传 /home/dowload目录下 6.get 文件名   下载文件到windows平台 d盘

C#远程执行Linux系统中Shell命令和SFTP上传文件

一.工具:SSH.Net 网址:https://github.com/sshnet/SSH.NET 二.调用命令代码: Renci.SshNet.SshClient ssh = new Renci.SshNet.SshClient("192.168.1.104", "sindrol", "123456"); ssh.Connect(); while (true) { Console.WriteLine("please input com

Java Sftp上传下载文件

需要使用jar包  jsch-0.1.50.jar sftp上传下载实现类 package com.bstek.transit.sftp; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import co

利用nodejs监控文件变化并使用sftp上传到服务器

很久没写博客了,因为最近在用react+express做一个自己的工具型网站(其实就是夺宝岛抢拍器) 然后因为经常要改动,而且又要放到服务器上进行测试.总是要webpack,然后手动把文件上传上去,不胜其烦,索性搜索了下,直接写个能检测文件变化并自动进行上传的脚本好了. 首先,我们使用npm 安装两个别人封装好的模块. npm install ssh2-sftp-client npm install gaze 第一个模块的作用是sftp上传文件, 第二个模块的作用就是监听文件变化了.当然,你也可

java通过sftp上传文件

转载:http://blog.csdn.net/yhl_jxy/article/details/72633034 Linux操作系统我们经常使用ssh中的ftp,sftp连接服务器,做相应操作. 如何通过java代码的形式采用sftp连接到服务器,进行文件上传下载等操作呢? 第一步,引入依赖包 [html] view plain copy <!-- sftp上传依赖包 --> <dependency> <groupId>com.jcraft</groupId>

SFTP上传下载文件、文件夹常用操作

SFTP上传下载文件.文件夹常用操作 1.查看上传下载目录lpwd 2.改变上传和下载的目录(例如D盘):lcd  d:/ 3.查看当前路径pwd 4.下载文件(例如我要将服务器上tomcat的日志文件取出来)进入你要下的文件所在的文件夹:cd /usr/apache-tomcat-6.0.39/logs/下载:get catalina.out 5.上传文件(例如我要上传一个文件到usr目录下)进入你想要上传文件的目录cd /usr上传文件put do.sh 6.上传下载文件夹格式:下载文件夹g

sftp上传到远程服务器

开发遇到一个需求,需要将图片通过sftp上传到远程服务器上,之前没用过这个功能,折腾了我好几天才搞定,下面记录下我的处理方法: $sftp = 'ssh2.sftp://';//连接sftp $conn = ssh2_connect('IP','端口');//登录 ssh2_auth_password($conn,"user","password"); $result = ssh2_sftp($conn);//判断是否存在目录HM if (!file_exists(

如何在Linux中使用sFTP上传或下载文件与文件夹

如何在Linux中使用sFTP上传或下载文件与文件夹 sFTP(安全文件传输程序)是一种安全的交互式文件传输程序,其工作方式与 FTP(文件传输协议)类似. 然而,sFTP 比 FTP 更安全;它通过加密 SSH 传输处理所有操作.在本文中,我们将向你展示如何使用 sFTP 上传/下载整个目录(包括其子目录和子文件). 作者:Aaron Kili来源:Linux中国|2017-03-09 14:42 移动端 收藏 分享 51CTO诚邀您9月23号和秒拍/国美/美团元专家一起聊智能CDN的优化之路

SecureCRT使用sftp上传较大文件意外暂停

今天在一台跳转机使用SecureCRT的sftp上传较大文件时,发现中途会时常停止传输,给出提示如下: 如果此时选择Accept Once,会继续传输,但是过一段时间后,还是会停止并给出相同提示,如果选择Accept & Save,就会给出如下提示: 可以看到是写入内容到这个HostKeyDB.txt文件没有权限,实际操作证明需要修改对应文件和文件所在文件夹的权限,因为正常需要添加如下两处内容: 之后,就没再遇到中途停止传输的事情了. 原文地址:https://www.cnblogs.com/j