cn.orionsec.kit.net.host.sftp.transfer

Class SftpUploader

java.lang.Object

cn.orionsec.kit.net.specification.transfer.BaseFileUploader

cn.orionsec.kit.net.host.sftp.transfer.SftpUploader

All Implemented Interfaces:

SafeCloseable, IFileTransfer, IFileUploader, Closeable, AutoCloseable, Runnable

public class SftpUploader
extends BaseFileUploader

SFTP 大文件上传 支持断点续传, 实时速率

Since:

2020/10/13 18:43

Version:

1.0.0

Author:

Jiahang Li

Field Summary

Fields inherited from class cn.orionsec.kit.net.specification.transfer.BaseFileUploader

bufferSize, fileSizeEqualOverride, forceOverride, local, lock, progress, remote, remoteFileLength

Constructor Summary

Constructors

Constructor and Description
SftpUploader(SftpExecutor executor, String remote, File local)
SftpUploader(SftpExecutor executor, String remote, String local)

Method Summary

Modifier and Type	Method and Description
void	abort() 终止传输
void	close() 安全关闭
SftpExecutor	getExecutor()
protected long	getRemoteFileSize() 获取远程文件大小
protected void	initUpload(boolean breakPoint, long skip) 准开始上传
void	run()
protected void	transferFinish() 传输完成回调
protected void	write(byte[] bs, int len) 写入

Methods inherited from class cn.orionsec.kit.net.specification.transfer.BaseFileUploader

breakPointResume, checkRemoteFilePresentSizeEqual, fileSizeEqualOverride, forceOverride, getProgress, getRemoteFileLength, startUpload, upload

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SftpUploader

public SftpUploader(SftpExecutor executor,
                    String remote,
                    String local)

SftpUploader

public SftpUploader(SftpExecutor executor,
                    String remote,
                    File local)

Method Detail

run

public void run()

getRemoteFileSize

protected long getRemoteFileSize()

Description copied from class: BaseFileUploader

获取远程文件大小

Specified by:

getRemoteFileSize in class BaseFileUploader

Returns:

fileSize 文件不存在则返回 -1

initUpload

protected void initUpload(boolean breakPoint,
                          long skip)
                   throws IOException

Description copied from class: BaseFileUploader

准开始上传

Specified by:

initUpload in class BaseFileUploader

Parameters:

breakPoint - 是否为断点续传

skip - skip

Throws:

IOException - IOException

write

protected void write(byte[] bs,
                     int len)
              throws IOException

Description copied from class: BaseFileUploader

写入

Specified by:

write in class BaseFileUploader

Parameters:

bs - bs

len - 长度

Throws:

IOException - IOException

transferFinish

protected void transferFinish()

Description copied from class: BaseFileUploader

传输完成回调

Specified by:

transferFinish in class BaseFileUploader

close

public void close()

Description copied from interface: SafeCloseable

安全关闭

abort

public void abort()

Description copied from interface: IFileTransfer

终止传输

getExecutor

public SftpExecutor getExecutor()