/* * Copyright (c) 2018-2028, Chill Zhuang All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are met: * * Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * Neither the name of the dreamlu.net developer nor the names of its * contributors may be used to endorse or promote products derived from * this software without specific prior written permission. * Author: Chill 庄骞 (smallchill@163.com) */ package org.springblade.Autowired.builder.oss; import com.aliyun.oss.ClientConfiguration; import com.aliyun.oss.OSSClient; import com.aliyun.oss.common.auth.CredentialsProvider; import com.aliyun.oss.common.auth.DefaultCredentialProvider; import lombok.SneakyThrows; import org.springblade.core.oss.OssTemplate; import org.springblade.core.oss.AliossTemplate; import org.springblade.core.oss.props.OssProperties; import org.springblade.core.oss.rule.OssRule; import org.springblade.Autowired.entity.Oss; /** * 阿里云存储构建类 * * @author Chill */ public class AliOssBuilder { @SneakyThrows public static OssTemplate template(Oss oss, OssRule ossRule) { // 创建ClientConfiguration。ClientConfiguration是OSSClient的配置类,可配置代理、连接超时、最大连接数等参数。 ClientConfiguration conf = new ClientConfiguration(); // 设置OSSClient允许打开的最大HTTP连接数,默认为1024个。 conf.setMaxConnections(1024); // 设置Socket层传输数据的超时时间,默认为50000毫秒。 conf.setSocketTimeout(50000); // 设置建立连接的超时时间,默认为50000毫秒。 conf.setConnectionTimeout(50000); // 设置从连接池中获取连接的超时时间(单位:毫秒),默认不超时。 conf.setConnectionRequestTimeout(1000); // 设置连接空闲超时时间。超时则关闭连接,默认为60000毫秒。 conf.setIdleConnectionTime(60000); // 设置失败请求重试次数,默认为3次。 conf.setMaxErrorRetry(5); OssProperties ossProperties = new OssProperties(); ossProperties.setEndpoint(oss.getEndpoint()); ossProperties.setAccessKey(oss.getAccessKey()); ossProperties.setSecretKey(oss.getSecretKey()); ossProperties.setBucketName(oss.getBucketName()); CredentialsProvider credentialsProvider = new DefaultCredentialProvider(ossProperties.getAccessKey(), ossProperties.getSecretKey()); OSSClient ossClient = new OSSClient(ossProperties.getEndpoint(), credentialsProvider, conf); return new AliossTemplate(ossClient, ossProperties, ossRule); } }