<dependency>
    <groupId>com.amazonaws</groupId>  
    <artifactId>aws-java-sdk-s3</artifactId>  
    <version>1.11.136</version>  
</dependency>

/**
 * Created on 一月 06, 2020.
 *
 * @author Zhangxi19
 */
public class Upload {
    private static final Logger logger = LoggerFactory.getLogger(Upload .class);

    public static void main(String[ ] args) {
        //通过点播sdk vodClient.createVideoUploadTask或vodClient.refreshVideoUploadTask ,从结果中可获取上传凭证authToken,
        //用base64解析后可得到具体的上传凭证，该凭证可用于创建aws的客户端，完成分片上传
        String region = "region";
        String endpoint = "endpoint";
        String bucket = "bucket";
        String accessKey = "accessKey";
        String secretKey = "secretKey";
        String token = "token";
        String objectKey = "objectKey";
        String localFile = "localFile";
        multipartUpload(region, endpoint, accessKey, secretKey, token, bucket, objectKey, localFile);
    }

    public static void multipartUpload(String region, String endpoint, String accessKey, String secretKey, String token, String bucket, String objectKey, String localFile) {

        AmazonS3 ossClient = initAwsClient(region, endpoint, accessKey, secretKey, token, Protocol.HTTP);
        try {
            File partFile = new File(localFile);
            String md5 = Md5Utils.md5AsBase64(partFile);
            logger.info("md5={}", md5);
            // 初始化分片上传
            InitiateMultipartUploadRequest partRequest = new InitiateMultipartUploadRequest(bucket, objectKey);
            ObjectMetadata objectMetadata = new ObjectMetadata();
            // 以具体视频源为准
            objectMetadata.setContentType("video/mp4");
            objectMetadata.setContentMD5(md5);
            partRequest.setObjectMetadata(objectMetadata);
            InitiateMultipartUploadResult initiateMultipartUpload = ossClient.initiateMultipartUpload(partRequest);
            String key = initiateMultipartUpload.getKey();
            String uploadId = initiateMultipartUpload.getUploadId();
            String bucketName = initiateMultipartUpload.getBucketName();

            logger.info("InitiateMultipartUploadResult,bucket={},key={},uploadId={}", bucket, key, uploadId);
            //根据实际需求确定分片大小
            final int partSize = 1024 * 1024 * 5;
            int partCount = (int) (partFile.length() / partSize);
            if (partFile.length() % partSize != 0) {
                partCount++;
            }
            // 创建对象的Etag列表，并取回每个分片的Etag。
            List<PartETag> partETagList = new ArrayList<>();
            for (int i = 0; i < partCount; i++) {
                FileInputStream fis = new FileInputStream(partFile);
                long skipBytes = partSize * i;
                fis.skip(skipBytes);

                long size = Math.min(partSize, partFile.length() - skipBytes);
                logger.info("partSize={}", size);
                UploadPartRequest uploadPartRequest = new UploadPartRequest();
                uploadPartRequest.setBucketName(bucketName);
                uploadPartRequest.setKey(key);
                uploadPartRequest.setUploadId(uploadId);
                uploadPartRequest.setInputStream(fis);
                uploadPartRequest.setPartSize(size);
                uploadPartRequest.setPartNumber(i + 1);
                // 上传分片并将返回的Etag加入列表中
                UploadPartResult uploadPartResult = ossClient.uploadPart(uploadPartRequest);
                PartETag partETag = uploadPartResult.getPartETag();
                partETagList.add(partETag);
                logger.info("uploadPartResult={}", JSON.toJSON(uploadPartResult));
                fis.close();
            }
            Collections.sort(partETagList, new Comparator<PartETag>() {
                public int compare(PartETag p1, PartETag p2) {
                    return p1.getPartNumber() - p2.getPartNumber();
                }
            });
            //完成上传
            CompleteMultipartUploadRequest completeMultipartUploadRequest = new CompleteMultipartUploadRequest(bucket, objectKey, uploadId, partETagList);
            Map<String, String> customRequestHeaders = completeMultipartUploadRequest.getCustomRequestHeaders();
            CompleteMultipartUploadResult uploadResult = ossClient.completeMultipartUpload(completeMultipartUploadRequest);
            ossClient.shutdown();

            logger.info("CompleteMultipartUploadResult={},customRequestHeaders={}", JSON.toJSON(uploadResult), customRequestHeaders);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static AmazonS3 initAwsClient(String region, String endpoint, String accessKey, String secretKey, String token, com.amazonaws.Protocol protocol) {
        BasicSessionCredentials basicSessionCredentials = new BasicSessionCredentials(accessKey, secretKey, token);
        ClientConfiguration config = new ClientConfiguration();
        config.setProtocol(protocol);
        AwsClientBuilder.EndpointConfiguration endpointConfig = new AwsClientBuilder.EndpointConfiguration(endpoint, region);

        AWSCredentialsProvider awsCredentialsProvider = new AWSStaticCredentialsProvider(basicSessionCredentials);
        return AmazonS3Client.builder()
                .withEndpointConfiguration(endpointConfig)
                .withClientConfiguration(config)
                .withCredentials(awsCredentialsProvider)
                .disableChunkedEncoding()
                .withPathStyleAccessEnabled(true)
                .build();
    }
}