import com.volcengine.tos.TOSV2;
import com.volcengine.tos.TOSV2ClientBuilder;
import com.volcengine.tos.TosClientException;
import com.volcengine.tos.TosServerException;
import com.volcengine.tos.model.object.*;
import java.util.ArrayList;
public class UploadFileWithDirectoryExample {
public static void main(String[] args) {
String endpoint = "your endpoint";
String region = "your region";
String accessKey = System.getenv("TOS_ACCESS_KEY");
String secretKey = System.getenv("TOS_SECRET_KEY");
String bucketName = "bucket-example";
String uploadFileDirectory = "example_dir";
long threshold = 100 * 1024 * 1024;
TOSV2 tos = new TOSV2ClientBuilder().build(region, endpoint, accessKey, secretKey);
List<String> fileList = getFileListFromPath(uploadFileDirectory);
if (fileList == null || fileList.size() == 0) {
System.out.println("uploadFile done, there are no files under " + uploadFileDirectory);
for (String file : fileList) {
if (new File(file).length() >= threshold) {
uploadLargeFile(tos, bucketName, file);
uploadSmallFile(tos, bucketName, file);
private static void uploadSmallFile(TOSV2 tos, String bucketName, String file) {
PutObjectFromFileInput putObjectInput = new PutObjectFromFileInput().setBucket(bucketName).setKey(file).setFilePath(file);
PutObjectFromFileOutput output = tos.putObjectFromFile(putObjectInput);
System.out.println("putObject succeed, object's etag is " + output.getEtag());
System.out.println("putObject succeed, object's crc64 is " + output.getHashCrc64ecma());
} catch (TosClientException e) {
System.out.println("putObject failed");
System.out.println("Message: " + e.getMessage());
if (e.getCause() != null) {
e.getCause().printStackTrace();
} catch (TosServerException e) {
System.out.println("putObject failed");
System.out.println("StatusCode: " + e.getStatusCode());
System.out.println("Code: " + e.getCode());
System.out.println("Message: " + e.getMessage());
System.out.println("RequestID: " + e.getRequestID());
System.out.println("putObject failed");
System.out.println("unexpected exception, message: " + t.getMessage());
private static void uploadLargeFile(TOSV2 tos, String bucketName, String file) {
long partSize = 20 * 1024 * 1024;
boolean enableCheckpoint = true;
String checkpointFilePath = "the checkpoint file path";
UploadFileV2Input input = new UploadFileV2Input().setBucket(bucketName).setKey(file)
.setFilePath(file).setEnableCheckpoint(enableCheckpoint)
.setCheckpointFile(checkpointFilePath).setPartSize(partSize).setTaskNum(taskNum);
UploadFileV2Output output = tos.uploadFile(input);
System.out.println("uploadFile succeed, object's etag is " + output.getEtag());
System.out.println("uploadFile succeed, object's crc64 is " + output.getHashCrc64ecma());
} catch (TosClientException e) {
System.out.println("uploadFile failed");
System.out.println("Message: " + e.getMessage());
if (e.getCause() != null) {
e.getCause().printStackTrace();
} catch (TosServerException e) {
System.out.println("uploadFile failed");
System.out.println("StatusCode: " + e.getStatusCode());
System.out.println("Code: " + e.getCode());
System.out.println("Message: " + e.getMessage());
System.out.println("RequestID: " + e.getRequestID());
System.out.println("uploadFile failed");
System.out.println("unexpected exception, message: " + t.getMessage());
private static List<String> getFileListFromPath(String filePath) {
List<String> fileList = new ArrayList<>();
File file = new File(filePath);
File[] files = file.listFiles();
if (files == null || files.length == 0) {
fileList.addAll(getFileListFromPath(f.getPath()));
fileList.add(f.getPath());