From eb8ae29fed5b5182ac955275de5a512fc0c1ff33 Mon Sep 17 00:00:00 2001 From: xiaohanzi Date: Wed, 26 May 2021 12:51:08 +0800 Subject: [PATCH] fix video --- .../video/aliyun/sdk/server/AliyunVedioServer.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/mallinkVideo/src/main/java/com/iformall/video/aliyun/sdk/server/AliyunVedioServer.java b/mallinkVideo/src/main/java/com/iformall/video/aliyun/sdk/server/AliyunVedioServer.java index 337dd54ca..55a7bacab 100644 --- a/mallinkVideo/src/main/java/com/iformall/video/aliyun/sdk/server/AliyunVedioServer.java +++ b/mallinkVideo/src/main/java/com/iformall/video/aliyun/sdk/server/AliyunVedioServer.java @@ -73,6 +73,9 @@ public class AliyunVedioServer { return client.getAcsResponse(request); } + private static String toLanEndpoint(String bucket) { + return bucket.replace(".aliyuncs.com", "-internal.aliyuncs.com"); + } private static OssUploadClient initOssClient(CreateUploadVideoResponse response) throws UnsupportedEncodingException { final Base64.Decoder decoder = Base64.getDecoder(); String uploadAddressStr = new String(decoder.decode(response.getUploadAddress().getBytes("UTF-8"))); @@ -85,8 +88,8 @@ public class AliyunVedioServer { String accessKeyId = uploadAuth.getString("AccessKeyId"); String accessKeySecret = uploadAuth.getString("AccessKeySecret"); String securityToken = uploadAuth.getString("SecurityToken"); - OSS client = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret,securityToken); - return new OssUploadClient(bucket, endpoint, fileName, client); + OSS client = new OSSClientBuilder().build(toLanEndpoint(endpoint), accessKeyId, accessKeySecret,securityToken); + return new OssUploadClient(bucket, toLanEndpoint(endpoint), fileName, client); } private static OssUploadClient initOssClient(RefreshUploadVideoResponse response) throws UnsupportedEncodingException { @@ -101,8 +104,8 @@ public class AliyunVedioServer { String accessKeyId = uploadAuth.getString("AccessKeyId"); String accessKeySecret = uploadAuth.getString("AccessKeySecret"); String securityToken = uploadAuth.getString("SecurityToken"); - OSS client = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret,securityToken); - return new OssUploadClient(bucket, endpoint, fileName, client); + OSS client = new OSSClientBuilder().build(toLanEndpoint(endpoint), accessKeyId, accessKeySecret,securityToken); + return new OssUploadClient(bucket, toLanEndpoint(endpoint), fileName, client); } public static void uploadVideo(AliyunVideoConfig config,CreateUploadVideoResponse response,String localFile,RedisTemplate redisTemplate) throws UnsupportedEncodingException {