From 80b6cbfc9c861469146318d0b3dd5f8b8b525b8a Mon Sep 17 00:00:00 2001 From: xiejun <xiejun@vci-tech.com> Date: 星期五, 01 十一月 2024 15:11:19 +0800 Subject: [PATCH] Revert "集成获取mdm分发通用数据格式接口集成" --- Source/BladeX-Tool/blade-starter-oss/src/main/java/org/springblade/core/oss/config/HuaweiObsConfiguration.java | 65 ++++++++++++++++++++++++++++++++ 1 files changed, 65 insertions(+), 0 deletions(-) diff --git a/Source/BladeX-Tool/blade-starter-oss/src/main/java/org/springblade/core/oss/config/HuaweiObsConfiguration.java b/Source/BladeX-Tool/blade-starter-oss/src/main/java/org/springblade/core/oss/config/HuaweiObsConfiguration.java new file mode 100644 index 0000000..6cd5ca4 --- /dev/null +++ b/Source/BladeX-Tool/blade-starter-oss/src/main/java/org/springblade/core/oss/config/HuaweiObsConfiguration.java @@ -0,0 +1,65 @@ +package org.springblade.core.oss.config; + +import com.aliyun.oss.OSSClient; +import com.obs.services.ObsClient; +import com.obs.services.ObsConfiguration; +import lombok.AllArgsConstructor; +import org.springblade.core.oss.HuaweiObsTemplate; +import org.springblade.core.oss.props.OssProperties; +import org.springblade.core.oss.rule.BladeOssRule; +import org.springblade.core.oss.rule.OssRule; +import org.springframework.boot.autoconfigure.AutoConfiguration; +import org.springframework.boot.autoconfigure.condition.ConditionalOnBean; +import org.springframework.boot.autoconfigure.condition.ConditionalOnClass; +import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; +import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; +import org.springframework.boot.context.properties.EnableConfigurationProperties; +import org.springframework.context.annotation.Bean; + +/** + * @author Tonny + */ +@AllArgsConstructor +@AutoConfiguration(after = OssConfiguration.class) +@EnableConfigurationProperties(OssProperties.class) +@ConditionalOnClass({OSSClient.class}) +@ConditionalOnProperty(value = "oss.name", havingValue = "huaweiobs") +public class HuaweiObsConfiguration { + private final OssProperties ossProperties; + + @Bean + @ConditionalOnMissingBean(OssRule.class) + public OssRule ossRule() { + return new BladeOssRule(ossProperties.getTenantMode()); + } + + @Bean + @ConditionalOnMissingBean(ObsClient.class) + public ObsClient ossClient() { + // 浣跨敤鍙畾鍒跺悇鍙傛暟鐨勯厤缃被锛圤bsConfiguration锛夊垱寤篛BS瀹㈡埛绔紙ObsClient锛夛紝鍒涘缓瀹屾垚鍚庝笉鏀寔鍐嶆淇敼鍙傛暟 + ObsConfiguration conf = new ObsConfiguration (); + + conf.setEndPoint(ossProperties.getEndpoint()); + // 璁剧疆OSSClient鍏佽鎵撳紑鐨勬渶澶TTP杩炴帴鏁帮紝榛樿涓�1024涓�� + conf.setMaxConnections(1024); + // 璁剧疆Socket灞備紶杈撴暟鎹殑瓒呮椂鏃堕棿锛岄粯璁や负50000姣銆� + conf.setSocketTimeout(50000); + // 璁剧疆寤虹珛杩炴帴鐨勮秴鏃舵椂闂达紝榛樿涓�50000姣銆� + conf.setConnectionTimeout(50000); + // 璁剧疆浠庤繛鎺ユ睜涓幏鍙栬繛鎺ョ殑瓒呮椂鏃堕棿锛堝崟浣嶏細姣锛夛紝榛樿涓嶈秴鏃躲�� + conf.setConnectionRequestTimeout(1000); + // 璁剧疆杩炴帴绌洪棽瓒呮椂鏃堕棿銆傝秴鏃跺垯鍏抽棴杩炴帴锛岄粯璁や负60000姣銆� + conf.setIdleConnectionTime(60000); + // 璁剧疆澶辫触璇锋眰閲嶈瘯娆℃暟锛岄粯璁や负3娆°�� + conf.setMaxErrorRetry(5); + + return new ObsClient(ossProperties.getAccessKey(), ossProperties.getSecretKey(), conf); + } + + @Bean + @ConditionalOnMissingBean(HuaweiObsTemplate.class) + @ConditionalOnBean({ObsClient.class, OssRule.class}) + public HuaweiObsTemplate huaweiobsTemplate(ObsClient ossClient, OssRule ossRule) { + return new HuaweiObsTemplate(ossClient, ossProperties, ossRule); + } +} -- Gitblit v1.9.3