The following code uses the getObject interface as an example to demonstrate how to use the progress bar feature. Other download interfaces are used in a similar manner.

import com.volcengine.tos.TOSV2;​
import com.volcengine.tos.TOSV2ClientBuilder;​
import com.volcengine.tos.TosClientException;​
import com.volcengine.tos.TosServerException;​
import com.volcengine.tos.comm.event.DataTransferListener;​
import com.volcengine.tos.comm.event.DataTransferStatus;​
import com.volcengine.tos.comm.event.DataTransferType;​
import com.volcengine.tos.model.object.GetObjectV2Input;​
import com.volcengine.tos.model.object.GetObjectV2Output;​
​
import java.io.File;​
import java.io.FileOutputStream;​
import java.io.IOException;​
import java.util.Map;​
​
public class GetObjectWithProgressExample {​
    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 objectKey = "example_dir/example_object.txt";​
        String filePath = "example_dir/example_file.txt";​
​
        TOSV2 tos = new TOSV2ClientBuilder().build(region, endpoint, accessKey, secretKey);​
​
        DataTransferListener listener = new DataTransferListener() {​
            @Override​
            public void dataTransferStatusChange(DataTransferStatus dataTransferStatus) {​
                if (dataTransferStatus.getType() == DataTransferType.DATA_TRANSFER_STARTED) {​
                    System.out.println("get object started.");​
                } else if (dataTransferStatus.getType() == DataTransferType.DATA_TRANSFER_RW) {​
                    System.out.printf("get object, read %d bytes once, has read %d bytes, total %d bytes.\n",​
                            dataTransferStatus.getRwOnceBytes(), dataTransferStatus.getConsumedBytes(),​
                            dataTransferStatus.getTotalBytes());​
                } else if (dataTransferStatus.getType() == DataTransferType.DATA_TRANSFER_FAILED) {​
                    System.out.printf("get object failed, has read %d bytes, total %d bytes.\n",​
                            dataTransferStatus.getConsumedBytes(), dataTransferStatus.getTotalBytes());​
                } else if (dataTransferStatus.getType() == DataTransferType.DATA_TRANSFER_SUCCEED) {​
                    System.out.printf("get object succeed, has read %d bytes, total %d bytes.\n",​
                            dataTransferStatus.getConsumedBytes(), dataTransferStatus.getTotalBytes());​
                }​
            }​
        };​
        GetObjectV2Input input = new GetObjectV2Input().setBucket(bucketName).setKey(objectKey).setDataTransferListener(listener);​
        File file = new File(filePath);​
        if (file.getParentFile() != null && !file.getParentFile().exists()) {​
            file.getParentFile().mkdirs();​
        }​
        try(FileOutputStream fos = new FileOutputStream(file);​
            GetObjectV2Output output = tos.getObject(input)) {​
            if (output.getContent() != null) {​
                byte[] buffer = new byte[4096];​
                int length;​
                while ((length = output.getContent().read(buffer)) != -1) {​
                    fos.write(buffer, 0, length);​
                }​
            }​
            fos.flush();​
            System.out.println("getObject succeed.");​
            System.out.println("object's etag is " + output.getEtag());​
            System.out.println("object's lastModified is " + output.getLastModified());​
            System.out.println("object's crc64 value is " + output.getHashCrc64ecma());​
            System.out.println("object's storageClass is " + output.getStorageClass());​
            System.out.println("object's cacheControl is " + output.getCacheControl());​
            System.out.println("object's contentDisposition is " + output.getContentDisposition());​
            System.out.println("object's contentEncoding is " + output.getContentEncoding());​
            System.out.println("object's contentLanguage is " + output.getContentLanguage());​
            System.out.println("object's contentType is " + output.getContentType());​
            if (output.getCustomMetadata() != null) {​
                System.out.println("object has custom meta data.");​
                for (Map.Entry<String, String> entry : output.getCustomMetadata().entrySet()) {​
                    System.out.println("custom meta key: " + entry.getKey() + ", value: " + entry.getValue());​
                }​
            }​
        } catch (IOException e) {​
            System.out.println("write data to file failed");​
            e.printStackTrace();​
        } catch (TosClientException e) {​
            System.out.println("getObject failed");​
            System.out.println("Message: " + e.getMessage());​
            if (e.getCause() != null) {​
                e.getCause().printStackTrace();​
            }​
        } catch (TosServerException e) {​
            System.out.println("getObject 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());​
        } catch (Throwable t) {​
            System.out.println("getObject failed");​
            System.out.println("unexpected exception, message: " + t.getMessage());​
        }​
    }​
}​

Last updated: 2025.09.22 11:34:16

Public security network record in Beijing: No. 11010802032137