public void put(String src, String dst)

将本地文件名为src的文件上传到目标服务器，目标文件名为dst，若dst为目录，则目标文件名将与src文件名相同。

采用默认的传输模式：OVERWRITE

public void put(String src, String dst, int mode)

将本地文件名为src的文件上传到目标服务器，目标文件名为dst，若dst为目录，则目标文件名将与src文件名相同。

指定文件传输模式为mode(mode可选值为：ChannelSftp.OVERWRITE，ChannelSftp.RESUME，

ChannelSftp.APPEND)

public void put(String src, String dst, SftpProgressMonitor monitor)

将本地文件名为src的文件上传到目标服务器，目标文件名为dst，若dst为目录，则目标文件名将与src文件名相同。

采用默认的传输模式：OVERWRITE

并使用实现了SftpProgressMonitor接口的monitor对象来监控文件传输的进度。

public void put(String src, String dst,

SftpProgressMonitor monitor, int mode)

将本地文件名为src的文件上传到目标服务器，目标文件名为dst，若dst为目录，则目标文件名将与src文件名相同。

指定传输模式为mode

并使用实现了SftpProgressMonitor接口的monitor对象来监控文件传输的进度。

public void put(InputStream src, String dst)

将本地的input stream对象src上传到目标服务器，目标文件名为dst，dst不能为目录。

采用默认的传输模式：OVERWRITE

public void put(InputStream src, String dst, int mode)

将本地的input stream对象src上传到目标服务器，目标文件名为dst，dst不能为目录。

指定文件传输模式为mode

public void put(InputStream src, String dst, SftpProgressMonitor monitor)

将本地的input stream对象src上传到目标服务器，目标文件名为dst，dst不能为目录。

采用默认的传输模式：OVERWRITE

并使用实现了SftpProgressMonitor接口的monitor对象来监控传输的进度。

public void put(InputStream src, String dst,

SftpProgressMonitor monitor, int mode)

将本地的input stream对象src上传到目标服务器，目标文件名为dst，dst不能为目录。

指定文件传输模式为mode

并使用实现了SftpProgressMonitor接口的monitor对象来监控传输的进度。

public OutputStream put(String dst)

该方法返回一个输出流，可以向该输出流中写入数据，最终将数据传输到目标服务器，目标文件名为dst，dst不能为目录。

采用默认的传输模式：OVERWRITE

public OutputStream put(String dst, final int mode)

该方法返回一个输出流，可以向该输出流中写入数据，最终将数据传输到目标服务器，目标文件名为dst，dst不能为目录。

指定文件传输模式为mode

public OutputStream put(String dst, final SftpProgressMonitor monitor, final int mode)

该方法返回一个输出流，可以向该输出流中写入数据，最终将数据传输到目标服务器，目标文件名为dst，dst不能为目录。

指定文件传输模式为mode

并使用实现了SftpProgressMonitor接口的monitor对象来监控传输的进度。

public OutputStream put(String dst, final SftpProgressMonitor monitor, final int mode, long offset)

该方法返回一个输出流，可以向该输出流中写入数据，最终将数据传输到目标服务器，目标文件名为dst，dst不能为目录。

指定文件传输模式为mode

并使用实现了SftpProgressMonitor接口的monitor对象来监控传输的进度。

offset指定了一个偏移量，从输出流偏移offset开始写入数据。

应用实例：

SFTPTest.java

SFTPTest.java

packagecom.longyg.sftp;importjava.util.HashMap;importjava.util.Map;importcom.jcraft.jsch.ChannelSftp;public classSFTPTest {publicSFTPChannel getSFTPChannel() {return newSFTPChannel();

}/***@paramargs

*@throwsException*/

public static void main(String[] args) throwsException {

SFTPTest test= newSFTPTest();

Map sftpDetails = new HashMap();//设置主机ip，端口，用户名，密码

sftpDetails.put(SFTPConstants.SFTP_REQ_HOST, "10.9.167.55");

sftpDetails.put(SFTPConstants.SFTP_REQ_USERNAME,"root");

sftpDetails.put(SFTPConstants.SFTP_REQ_PASSWORD,"arthur");

sftpDetails.put(SFTPConstants.SFTP_REQ_PORT,"22");

String src= "D:\\DevSoft\\HB-SnagIt1001.rar"; //本地文件名

String dst = "/home/omc/ylong/sftp/HB-SnagIt1001.rar"; //目标文件名

SFTPChannel channel=test.getSFTPChannel();

ChannelSftp chSftp= channel.getChannel(sftpDetails, 60000);/*** 代码段1

OutputStream out = chSftp.put(dst, ChannelSftp.OVERWRITE); // 使用OVERWRITE模式

byte[] buff = new byte[1024 * 256]; // 设定每次传输的数据块大小为256KB

int read;

if (out != null) {

System.out.println("Start to read input stream");

InputStream is = new FileInputStream(src);

do {

read = is.read(buff, 0, buff.length);

if (read > 0) {

out.write(buff, 0, read);

}

out.flush();

} while (read >= 0);

System.out.println("input stream read done.");

}

**/chSftp.put(src, dst, ChannelSftp.OVERWRITE);//代码段2//chSftp.put(new FileInputStream(src), dst, ChannelSftp.OVERWRITE);//代码段3

chSftp.quit();

channel.closeChannel();

}

}

注：请分别将代码段1，代码段2，代码段3取消注释，运行程序来进行测试。这三段代码分别演示了如何使用JSch的不同的put方法来进行文件上传。

代码段1：采用向put方法返回的输出流中写入数据的方式来传输文件。 需要由程序来决定写入什么样的数据，这里是将本地文件的输入流写入输出流。采用这种方式的好处是，可以自行设定每次写入输出流的数据块大小，如本示例中的语句：

byte[] buff = new byte[1024 * 256]; //设定每次传输的数据块大小为256KB

代码段2：直接将本地文件名为src的文件上传到目标服务器，目标文件名为dst。(注：使用这个方法时，dst可以是目录，当dst是目录时，上传后的目标文件名将与src文件名相同)

代码段3：将本地文件名为src的文件输入流上传到目标服务器，目标文件名为dst。

这三段代码实现的功能是一样的，都是将本地的文件src上传到了服务器的dst文件。使用时可根据具体情况选择使用哪种实现方式。

监控传输进度

从前面的介绍中知道，JSch支持在文件传输时对传输进度的监控。可以实现JSch提供的SftpProgressMonitor接口来完成这个功能。

SftpProgressMonitor接口类的定义为：

SftpProgressMonitor.java

packagecom.jcraft.jsch;public interfaceSftpProgressMonitor{public static final int PUT=0;public static final int GET=1;void init(int op, String src, String dest, longmax);boolean count(longcount);voidend();

}

init():当文件开始传输时，调用init方法。

count(): 当每次传输了一个数据块后，调用count方法，count方法的参数为这一次传输的数据块大小。

end():当传输结束时，调用end方法。

下面是一个简单的实现：

MyProgressMonitor.java

MyProgressMonitor.java

packagecom.longyg.sftp;importcom.jcraft.jsch.SftpProgressMonitor;public class MyProgressMonitor implementsSftpProgressMonitor {private longtransfered;

@Overridepublic boolean count(longcount) {

transfered= transfered +count;

System.out.println("Currently transferred total size: " + transfered + " bytes");return true;

}

@Overridepublic voidend() {

System.out.println("Transferring done.");

}

@Overridepublic void init(int op, String src, String dest, longmax) {

System.out.println("Transferring begin.");

}

}

此时如果改变SFTPTest main方法里调用的put方法，即可实现监控传输进度：

SFTPTest.java

SFTPTest.java

packagecom.longyg.sftp;importjava.util.HashMap;importjava.util.Map;importcom.jcraft.jsch.ChannelSftp;public classSFTPTest {publicSFTPChannel getSFTPChannel() {return newSFTPChannel();

}/***@paramargs

*@throwsException*/

public static void main(String[] args) throwsException {

SFTPTest test= newSFTPTest();

Map sftpDetails = new HashMap();//设置主机ip，端口，用户名，密码

sftpDetails.put(SFTPConstants.SFTP_REQ_HOST, "10.9.167.55");

sftpDetails.put(SFTPConstants.SFTP_REQ_USERNAME,"root");

sftpDetails.put(SFTPConstants.SFTP_REQ_PASSWORD,"arthur");

sftpDetails.put(SFTPConstants.SFTP_REQ_PORT,"22");

String src= "D:\\DevSoft\\HB-SnagIt1001.rar"; //本地文件名

String dst = "/home/omc/ylong/sftp/HB-SnagIt1001.rar"; //目标文件名

SFTPChannel channel=test.getSFTPChannel();

ChannelSftp chSftp= channel.getChannel(sftpDetails, 60000);/*** 代码段1

OutputStream out = chSftp.put(dst, new MyProgressMonitor(), ChannelSftp.OVERWRITE); // 使用OVERWRITE模式

byte[] buff = new byte[1024 * 256]; // 设定每次传输的数据块大小为256KB

int read;

if (out != null) {

System.out.println("Start to read input stream");

InputStream is = new FileInputStream(src);

do {

read = is.read(buff, 0, buff.length);

if (read > 0) {

out.write(buff, 0, read);

}

out.flush();

} while (read >= 0);

System.out.println("input stream read done.");

}

**/chSftp.put(src, dst,new MyProgressMonitor(), ChannelSftp.OVERWRITE); //代码段2//chSftp.put(new FileInputStream(src), dst, new MyProgressMonitor(), ChannelSftp.OVERWRITE);//代码段3

chSftp.quit();

channel.closeChannel();

}

}

注意修改的内容仅仅是put方法，在put方法中增加了SftpProgressMonitor的实现类对象monitor作为参数，即添加了对进度监控的支持。

运行，输出结果如下：

logs

Start to read input stream

Currently transferred total size:262144bytes

Currently transferred total size:524288bytes

Currently transferred total size:786432bytes

Currently transferred total size:1048576bytes

Currently transferred total size:1310720bytes

Currently transferred total size:1572864bytes

Currently transferred total size:1835008bytes

Currently transferred total size:2097152bytes

Currently transferred total size:2359296bytes

Currently transferred total size:2621440bytes

Currently transferred total size:2883584bytes

Currently transferred total size:3145728bytes

Currently transferred total size:3407872bytes

Currently transferred total size:3670016bytes

Currently transferred total size:3848374bytes

input stream read done.

当然这个SftpProgressMonitor的实现实在太简单。JSch每次传输一个数据块，就会调用count方法来实现主动进度通知。

现在我们希望每间隔一定的时间才获取一下文件传输的进度。。。看看下面的SftpProgressMonitor实现：

FileProgressMonitor.java

packagecom.longyg.sftp;importjava.text.DecimalFormat;importjava.util.Timer;importjava.util.TimerTask;importcom.jcraft.jsch.SftpProgressMonitor;public class FileProgressMonitor extends TimerTask implementsSftpProgressMonitor {private long progressInterval = 5 * 1000; //默认间隔时间为5秒

private boolean isEnd = false; //记录传输是否结束

private long transfered; //记录已传输的数据总大小

private long fileSize; //记录文件总大小

private Timer timer; //定时器对象

private boolean isScheduled = false; //记录是否已启动timer记时器

public FileProgressMonitor(longfileSize) {this.fileSize =fileSize;

}

@Overridepublic voidrun() {if (!isEnd()) { //判断传输是否已结束

System.out.println("Transfering is in progress.");long transfered =getTransfered();if (transfered != fileSize) { //判断当前已传输数据大小是否等于文件总大小

System.out.println("Current transfered: " + transfered + " bytes");

sendProgressMessage(transfered);

}else{

System.out.println("File transfering is done.");

setEnd(true); //如果当前已传输数据大小等于文件总大小，说明已完成，设置end

}

}else{

System.out.println("Transfering done. Cancel timer.");

stop();//如果传输结束，停止timer记时器

return;

}

}public voidstop() {

System.out.println("Try to stop progress monitor.");if (timer != null) {

timer.cancel();

timer.purge();

timer= null;

isScheduled= false;

}

System.out.println("Progress monitor stoped.");

}public voidstart() {

System.out.println("Try to start progress monitor.");if (timer == null) {

timer= newTimer();

}

timer.schedule(this, 1000, progressInterval);

isScheduled= true;

System.out.println("Progress monitor started.");

}/*** 打印progress信息

*@paramtransfered*/

private void sendProgressMessage(longtransfered) {if (fileSize != 0) {double d = ((double)transfered * 100)/(double)fileSize;

DecimalFormat df= new DecimalFormat( "#.##");

System.out.println("Sending progress message: " + df.format(d) + "%");

}else{

System.out.println("Sending progress message: " +transfered);

}

}/*** 实现了SftpProgressMonitor接口的count方法*/

public boolean count(longcount) {if (isEnd()) return false;if (!isScheduled) {

start();

}

add(count);return true;

}/*** 实现了SftpProgressMonitor接口的end方法*/

public voidend() {

setEnd(true);

System.out.println("transfering end.");

}private synchronized void add(longcount) {

transfered= transfered +count;

}private synchronized longgetTransfered() {returntransfered;

}public synchronized void setTransfered(longtransfered) {this.transfered =transfered;

}private synchronized void setEnd(booleanisEnd) {this.isEnd =isEnd;

}private synchronized booleanisEnd() {returnisEnd;

}public void init(int op, String src, String dest, longmax) {//Not used for putting InputStream

}

}

再次修改SFTPTest main方法里的put方法，改为使用新的SftpProgressMonitor的实现类对象monitor作为参数，注意新的monitor对象的构造函数需要传入文件大小作为参数：

SFTPTest.java

packagecom.longyg.sftp;importjava.io.File;importjava.util.HashMap;importjava.util.Map;importcom.jcraft.jsch.ChannelSftp;public classSFTPTest {publicSFTPChannel getSFTPChannel() {return newSFTPChannel();

}/***@paramargs

*@throwsException*/

public static void main(String[] args) throwsException {

SFTPTest test= newSFTPTest();

Map sftpDetails = new HashMap();//设置主机ip，端口，用户名，密码

sftpDetails.put(SFTPConstants.SFTP_REQ_HOST, "10.9.167.55");

sftpDetails.put(SFTPConstants.SFTP_REQ_USERNAME,"root");

sftpDetails.put(SFTPConstants.SFTP_REQ_PASSWORD,"arthur");

sftpDetails.put(SFTPConstants.SFTP_REQ_PORT,"22");

String src= "D:\\DevSoft\\HB-SnagIt1001.rar"; //本地文件名

String dst = "/home/omc/ylong/sftp/HB-SnagIt1001.rar"; //目标文件名

SFTPChannel channel=test.getSFTPChannel();

ChannelSftp chSftp= channel.getChannel(sftpDetails, 60000);

File file= newFile(src);long fileSize =file.length();/*** 代码段1

OutputStream out = chSftp.put(dst, new FileProgressMonitor(fileSize), ChannelSftp.OVERWRITE); // 使用OVERWRITE模式

byte[] buff = new byte[1024 * 256]; // 设定每次传输的数据块大小为256KB

int read;

if (out != null) {

System.out.println("Start to read input stream");

InputStream is = new FileInputStream(src);

do {

read = is.read(buff, 0, buff.length);

if (read > 0) {

out.write(buff, 0, read);

}

out.flush();

} while (read >= 0);

System.out.println("input stream read done.");

}

**/chSftp.put(src, dst,new FileProgressMonitor(fileSize), ChannelSftp.OVERWRITE); //代码段2//chSftp.put(new FileInputStream(src), dst, new FileProgressMonitor(fileSize), ChannelSftp.OVERWRITE);//代码段3

chSftp.quit();

channel.closeChannel();

}

}

再次运行，结果输出为：

logs

Try to start progress monitor.

Progress monitor started.

Transfering is in progress.

Current transfered: 98019 bytes

Sending progress message: 2.55%

Transfering is in progress.

Current transfered: 751479 bytes

Sending progress message: 19.53%

Transfering is in progress.

Current transfered: 1078209 bytes

Sending progress message: 28.02%

......

Transfering is in progress.

Current transfered: 3430665 bytes

Sending progress message: 89.15%

transfering end.

Transfering done. Cancel timer.

Try to stop progress monitor.

Progress monitor stoped.

现在，程序每隔5秒钟才会打印一下进度信息。可以修改FileProgressMonitor类里的progressInterval变量的值，来修改默认的间隔时间。

channelsftp的put_JSch - Java实现的SFTP（文件上传详解篇）相关推荐

  1. JAVA文件上传详解（附源码）

    文章目录 JAVA文件上传详解(附源码) 1.准备工作 2.使用类介绍 FileItem类 ServletFileUpload类 3.代码编写 JAVA文件上传详解(附源码) 在web应用中,文件上传 ...

  2. Struts2之struts2文件上传详解

    一.学习案例:通过在uploadfile.jsp页面填写完表单,提交后跳转到success.jsp页面,然后验证upload包下上传文件是否成功. 二.案例分析:struts2文件上传并不是表面上看的 ...

  3. Multipart/form-data POST文件上传详解

    Multipart/form-data POST文件上传详解 理论 简单的HTTP POST 大家通过HTTP向服务器发送POST请求提交数据,都是通过form表单提交的,代码如下: <form ...

  4. php文件上传详解,PHP文件上传实例详解！！！

    这篇文章主要介绍了PHP文件上传实例代码,需要的朋友可以参考下 首先来看下上传部分的表单代码: 文件:  这里有几个要注意的地方,首先看这句 ,这里我们采用POST方法,个别浏览器还支持PUT方法,当 ...

  5. java jsch实现sftp文件上传,并且控制上传的速度，同时监控上传进度

    工作中,有些环境带宽有限,比如说专线,通常带宽比较小,又不便宜,当业务量大的时间,如果在专线上还要传输文件的话,往往在文件传输的时间会导致带宽占慢,就有可能导致时实交易进不来,有可能影响交易,今天贴一 ...

  6. java web文件上传详解_java web图片上传和文件上传实例详解

    java web图片上传和文件上传 图片上传和文件上传本质上是一样的,图片本身也是文件.文件上传就是将图片上传到服务器,方式虽然有很多,但底层的实现都是文件的读写操作. 注意事项 1.form表单一定 ...

  7. python爬虫：Multipart/form-data POST文件上传详解

    简单的HTTP POST 大家通过HTTP向服务器发送POST请求提交数据,都是通过form表单提交的,代码如下: <form method="post"action=&qu ...

  8. elment-ui文件上传详解

    文件上传总有各种问题,算是给自己一个总结吧 HTML <el-form-item prop="" class="form-item"><tem ...

  9. Retrofit2 multpart多文件上传详解

    原文出处:http://www.chenkaihua.com/2016/04/02/retrofit2-upload-multipart-files.html Retrofit2是目前很流行的andr ...

最新文章

  1. 深度学习调参tricks总结！
  2. Finding iPhone Memory Leaks: A “Leaks” Tool Tutorial[转]
  3. 传统路由器被抛弃的理由—Vecloud
  4. 2019 年 React 学习路线图
  5. c# 访问hbase_C#教程之通过Thrift实现C#与Hbase交流
  6. Spring-05 -AOP [面向切面编程] -Schema-based 实现aop的步骤
  7. [Python人工智能] 二.TensorFlow基础及一元直线预测案例
  8. 【MYSQL命令】查看一个表的建表语句
  9. C++中各种智能指针的实现及弊端（二）
  10. 常用20个正则表达式
  11. 轻松搞懂【TF-IDF、word2vec、svm、cnn、textcnn、bilstm、cnn+bilstm、bilstm+attention实现】英文长文本分类
  12. leetcode-412 -Fizz Buzz-(fizz bzz)-java
  13. 工欲擅其事必先利器，磨刀不误砍柴工
  14. openvswitch console输出
  15. 金彩教育：店铺中的人才布局
  16. 科学计算机可以用多久,科学家公布“寿命计算器” 算一下你能活多久？
  17. 获取微信昵称乱码php,Android 微信登录昵称乱码问题，及获取微信用户信息
  18. vCode组件的使用
  19. EditText的hint居中，设置EditText的hint位置
  20. While 循环语句 和do while循环语句

热门文章

  1. java 获得响应内容_Java 纯HTTP Get请求获取响应内容，如果302，继而获取重定向后的响应内容。...
  2. Idea的debug断点调试
  3. JAVA中基本类型Boolean占几个字节
  4. typeof 数据类型转换
  5. 随机抽样java_实现随机抽样【随机数生成问题】
  6. Iterator 和 ListIterator 的区别
  7. Java网络编程————UDP实现ThinkPad S5网络唤醒
  8. Spring jndi连接数据库
  9. python火爆的原因_为什么Python这么火爆？原因是什么？
  10. 8a 中断 传感器采集_加速度传感器的安装，你get了吗