我有一个简单的解决方案,但不是100%准确的,你可以通过增加更多的采样率来改善它。现在我只用一个样品,(TotalFileSize - CurrentByteTransferred /(CURRENTTIME - 开始时间))。您可以添加更多采样来改善结果。下面是代码示例:
更新上传统计这里
private final UploadStats uploadStats = new UploadStats();
private void updateUploadStats(long totalBytesTransferred, int bytesTransferred, long streamSize) {
long current = System.currentTimeMillis();
synchronized (this.uploadStats) {
long timeTaken = (current - uploadStats.getStartTime());
if (timeTaken > 1000L) {
uploadStats.setLastUpdated(current);
uploadStats.setEstimatedSpeed(totalBytesTransferred/(timeTaken/1000L));
}
uploadStats.setTotalBytesTransferred(totalBytesTransferred);
uploadStats.setBytesTransferred(bytesTransferred);
uploadStats.setStreamSize(streamSize);
}
}
创建CopyStreamListener并追加到FTPClient
CopyStreamAdapter copyStreamAdapter = new CopyStreamAdapter() {
@Override
public void bytesTransferred(long totalBytesTransferred, int bytesTransferred, long streamSize) {
updateUploadStats(totalBytesTransferred, bytesTransferred, streamSize);
}
};
FTPClient ftpClient = new FTPClient();
ftpClient.connect(url);
if (!FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {
ftpClient.disconnect();
throw new Exception("Unable to connect.");
}
if (!ftpClient.login(username, password)) {
ftpClient.disconnect();
throw new Exception("Failed to login.");
}
ftpClient.setCopyStreamListener(copyStreamListener);
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
ftpClient.enterLocalPassiveMode();
ftpClient.storeFile(targetPath, inputFile);
ftpClient.logout();
ftpClient.disconnect();
上传统计豆没有的getter/setter。有些是不相关的,可以跳过
这只是一个伪代码。如果您打算阅读并显示进度,则可以使用线程提高,因此同步关键字。