阿里云oss授权访问文档示例地址
阿里云没有提供直接的获取是视频时长的API接口，需要曲线处理
1、引入阿里云oss pom
<dependency>
<groupId>com.aliyun.oss</groupId>
<artifactId>aliyun-sdk-oss</artifactId>
<version>3.10.2</version>
</dependency>
阿里云工具类
/**
* @author ful
*/
@Component
@Slf4j
public class AliOSSUtil {
// endpoint 访问OSS的域名
@Value("${oss.agora.endpoint}")
public String endpoint;
// accessKeyId和accessKeySecret OSS的访问密钥
@Value("${oss.agora.id}")
public String accessKeyId;
@Value("${oss.agora.secret}")
public String accessKeySecret;
// Bucket 用来管理所存储Object的存储空间
@Value("${oss.agora.bucket}")
public String bucketName;
@Value("${oss.agora.region}")
public String region;
@Value("${oss.agora.vendor}")
public String vendor;
@Value("${oss.agora.cdn}")
public String cdn;
/**
* 文件直传
*
* @param objectKey 上传路径
* @param inputStream 上传流
* @throws RuntimeException
*/
public void fileUpload(String objectKey, InputStream inputStream) throws RuntimeException {
Map map = getCommon(objectKey);
OSS ossClient = null;
try {
ossClient = (OSS) map.get(0);
AliOssPublicEntity model = (AliOssPublicEntity) map.get(1);
if (ossClient.doesObjectExist(model.getBucketName(), model.getObjectKey())) {
log.error("此文件重名,请更改文件名重试!");
throw new RuntimeException("此文件重名,请更改文件名重试!");
}
PutObjectRequest putObjectRequest = new PutObjectRequest(model.getBucketName(), model.getObjectKey(), inputStream);
PutObjectResult putObjectResult = ossClient.putObject(putObjectRequest);
String eTag = putObjectResult.getETag();
if (StringUtils.isBlank(eTag)) {
log.error("文件直传失败!");
throw new RuntimeException("文件直传失败");
}
} catch (Exception e) {
log.error("文件直传失败,exp={}", e);
throw new RuntimeException("文件直传失败:" + e.getMessage());
} finally {
ossClient.shutdown();
try {
inputStream.close();
} catch (IOException e) {
log.error("关闭文件流异常={}", e);
}
}
}
/**
* OSS获取下载签名URL
*
* @param objectKey 文件对象key
* @return 签名URL
*/
public String getOssObjectDownAuthUrl(String objectKey) throws RuntimeException {
Map map = getCommon(objectKey);
OSS ossClient = null;
try {
ossClient = (OSS) map.get(0);
AliOssPublicEntity model = (AliOssPublicEntity) map.get(1);
GeneratePresignedUrlRequest req =
new GeneratePresignedUrlRequest(model.getBucketName(), model.getObjectKey(), HttpMethod.GET);
//这里设置签名在30小时后过期
Date expiration = new Date(new Date().getTime() + 30L * 60L * 60L * 1000);// 生成URL
// Date expireDate = new Date(System.currentTimeMillis() + 30L * 60L * 60L * 1000L);
req.setExpiration(expiration);
URL url = ossClient.generatePresignedUrl(req);
String urlStr = url.toString();
return urlStr;
} catch (Exception e) {
log.error("getOssObjectDownAuthUrl 获取下载签名URL失败,exp={}", e);
throw new RuntimeException("获取下载签名URL失败");
} finally {
ossClient.shutdown();
}
}
/**
* OSS获取下载签名URL
*
* @param objectKey 文件对象key
* @param expireTime 当前时间加多少毫秒后过期，过期时间（毫秒）
* @return 签名URL
*/
public String getOssObjectDownAuthUrl(String objectKey, long expireTime) throws RuntimeException {
Map map = getCommon(objectKey);
OSS ossClient = null;
try {
ossClient = (OSS) map.get(0);
AliOssPublicEntity model = (AliOssPublicEntity) map.get(1);
GeneratePresignedUrlRequest req =
new GeneratePresignedUrlRequest(model.getBucketName(), model.getObjectKey(), HttpMethod.GET);
//这里设置签名在半个小时后过期
Date expireDate = new Date(System.currentTimeMillis() + expireTime);
req.setExpiration(expireDate);
URL url = ossClient.generatePresignedUrl(req);
String urlStr = url.toString();
return urlStr;
} catch (Exception e) {
log.error("getOssObjectDownAuthUrl long获取下载签名URL失败,exp={}", e);
throw new RuntimeException("获取下载签名URL失败");
} finally {
ossClient.shutdown();
}
}
/**
* OSS获取上传签名URL
*
* @param objectKey 文件对象key
* @return 签名URL
*/
public String getOssObjectUploadAuthUrl(String objectKey) throws RuntimeException {
Map map = getCommon(objectKey);
OSS ossClient = null;
try {
ossClient = (OSS) map.get(0);
AliOssPublicEntity model = (AliOssPublicEntity) map.get(1);
if (ossClient.doesObjectExist(model.getBucketName(), model.getObjectKey())) {
throw new RuntimeException("此文件重名,请更改文件名重试!");
}
Date expirationTime = new Date(System.currentTimeMillis() + 30L * 60L * 1000L);
GeneratePresignedUrlRequest request = new GeneratePresignedUrlRequest(model.getBucketName(), model.getObjectKey(), HttpMethod.PUT);
request.setExpiration(expirationTime);
//必须要!!!!!!，而且前端上传时，也需要在header里面设置，content-type为"application/octet-stream"
request.setContentType("application/octet-stream");
URL url = ossClient.generatePresignedUrl(request);
String urlstr = url.toString();
return urlstr;
} catch (Exception e) {
log.error("getOssObjectDownAuthUrl long获取上传签名URL失败,exp={}", e);
throw new RuntimeException("获取上传签名URL失败" + e.getMessage());
} finally {
ossClient.shutdown();
}
}
/**
* 删除存储对象
*
* @param objectKey 文件对象key
* @return 签名URL
*/
public void deleteObject(String objectKey) throws RuntimeException {
Map map = getCommon(objectKey);
OSS ossClient = null;
try {
ossClient = (OSS) map.get(0);
AliOssPublicEntity model = (AliOssPublicEntity) map.get(1);
// 指定对象所在的存储桶
ossClient.deleteObject(model.getBucketName(), model.getObjectKey());
} catch (RuntimeException clientException) {
log.error("deleteObject 删除存储对象失败,exp={}", clientException);
throw new RuntimeException("删除存储对象失败");
} finally {
ossClient.shutdown();
}
}
/**
* 绝对路径更换为相对路径
*
* @param url 绝对路径
* @return 相对路径
*/
public String getRelativePath(String url) {
url = url.substring(url.indexOf(".com") + 5, url.indexOf("?"));
return url;
}
/**
* client公共参数
*
* @param objectKey
* @return
*/
private Map getCommon(String objectKey) {
AliOssPublicEntity entity = AliOssPublicEntity.build(objectKey, endpoint, accessKeyId, accessKeySecret, bucketName);
OSS ossClient = new OSSClientBuilder().build(entity.getEndpoint(), entity.getAccessKeyId(), entity.getAccessKeySecret());
Map map = new HashMap();
map.put(0, ossClient);
map.put(1, entity);
return map;
}
}
阿里云配置类
@Data
public class AliOssPublicEntity {
private String endpoint;
private String accessKeyId;
private String accessKeySecret;
private String bucketName;
private String objectKey;
public static AliOssPublicEntity build(String objectKey,String endpoint,String accessKeyId,
String accessKeySecret,String bucketName) {
AliOssPublicEntity entity = new AliOssPublicEntity();
entity.setEndpoint(endpoint);
entity.setAccessKeyId(accessKeyId);
entity.setAccessKeySecret(accessKeySecret);
entity.setBucketName(bucketName);
entity.setObjectKey(objectKey);
return entity;
}
}
阿里云根据资源路径获取资源时长代码
public int getVideoDuration(String videoUrl) {
if (StringUtils.isNotEmpty(videoUrl) && "m3u8".equals(videoUrl.substring(videoUrl.length() - 4))) {
try {
videoUrl = aliOSSUtil.getOssObjectDownAuthUrl(videoUrl);
log.info("getVideoDuration:aliOSSUtil.videoUrl ={}", videoUrl);
HttpRequest httpRequest = HttpRequest.get(videoUrl)
.timeout(30000);
log.info("getRequest httpRequest:{}", httpRequest);
HttpResponse res = httpRequest.execute();
String result = res.body();
String pattern = "\\d+[.]\\d+";
List<String> matchStrs = new ArrayList<>();
Pattern r = Pattern.compile(pattern);
Matcher m = r.matcher(result);
while (m.find()) { //此处find（）每次被调用后，会偏移到下一个匹配
matchStrs.add(m.group());//获取当前匹配的值
}
Double durationDouble = 0.0;
for (int i = 0; i < matchStrs.size(); i++) {
durationDouble += Double.parseDouble(matchStrs.get(i));
}
log.info("LiveDetailController.getVideoDuration->duration=", durationDouble.intValue());
return durationDouble.intValue();
} catch (Exception e) {
log.error("getVideoDuration 异常={}", e);
}
}
return 0;
}
这里需要注意：
HttpRequest httpRequest = HttpRequest.get(videoUrl) .timeout(30000);请求是一定不要加 .header(“Content-Type”, “application/json”) 头，不然会验证签名失败