first commit

xm

2024-06-14 722af26bc6fec32bb289b1df51a9016a4935610f

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
Êþº¾4
ä
‚è    é    êì
íî
íï
ðñ
íò
íó
ðô
õö
è÷ø
íù
úû    üý
þ    üÿ
 
 
 
 

    



    
 
 


    
 





&è

&

$


&

%

í
!


0



 
0
!



 

!!
"
#
$
:
%

&

'
(
)
>è
>
*

+
,
>
-
.
C
/
C
!
0
1

2
3

4
5

6
7

6
8

6
9
:
ú
;!
<
=
í
>

?

@!
A

B
C

B
D
í
E
F
G


H
I

J
K

L
M
N
_ð    
O
P
_
Q
R

S
Tè

U
V
c
W
_
X!
Y

Z

íû
í
[


\
]    
^
_
`    
^
a
b
c
d
e    
^
f
g
h    ƒ
i

^
j
k
l
m
n
o
p
q
r
InnerClasses
    configKey
Ljava/lang/String;

properties
%Lcom/dl/oss/properties/OssProperties;
client
$Lcom/amazonaws/services/s3/AmazonS3;
<init>
:(Ljava/lang/String;Lcom/dl/oss/properties/OssProperties;)V
Code
LineNumberTable
LocalVariableTable
endpointConfig
EndpointConfiguration
ELcom/amazonaws/client/builder/AwsClientBuilder$EndpointConfiguration;
credentials
#Lcom/amazonaws/auth/AWSCredentials;
credentialsProvider
+Lcom/amazonaws/auth/AWSCredentialsProvider;
clientConfig
#Lcom/amazonaws/ClientConfiguration;
build
1Lcom/amazonaws/services/s3/AmazonS3ClientBuilder;

e
Ljava/lang/Exception;
this
Lcom/dl/oss/core/OssClient;
 ossProperties
 StackMapTable
p
s
tì
u
vö


createBucket
()V

bucketName
createBucketRequest
5Lcom/amazonaws/services/s3/model/CreateBucketRequest;
accessPolicy
#Lcom/dl/oss/enumd/AccessPolicyType;
upload
H([BLjava/lang/String;Ljava/lang/String;)Lcom/dl/oss/entity/UploadResult;
data
[B
path
contentType
[(Ljava/io/InputStream;Ljava/lang/String;Ljava/lang/String;)Lcom/dl/oss/entity/UploadResult;
metadata
0Lcom/amazonaws/services/s3/model/ObjectMetadata;
putObjectRequest
2Lcom/amazonaws/services/s3/model/PutObjectRequest;
inputStream
Ljava/io/InputStream;
delete
(Ljava/lang/String;)V
uploadSuffix
suffix
getObjectMetadata
D(Ljava/lang/String;)Lcom/amazonaws/services/s3/model/ObjectMetadata;
object
*Lcom/amazonaws/services/s3/model/S3Object;
getObjectContent
)(Ljava/lang/String;)Ljava/io/InputStream;
getUrl
()Ljava/lang/String;
domain
endpoint
header
getPath
8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
prefix
uuid
getConfigKey
 getPrivateUrl
9(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/String;
    objectKey
second
Ljava/lang/Integer;
generatePresignedUrlRequest
=Lcom/amazonaws/services/s3/model/GeneratePresignedUrlRequest;
url
Ljava/net/URL;
checkPropertiesSame
((Lcom/dl/oss/properties/OssProperties;)Z
getAccessPolicy
%()Lcom/dl/oss/enumd/AccessPolicyType;
    getPolicy
C(Ljava/lang/String;Lcom/dl/oss/enumd/PolicyType;)Ljava/lang/String;

policyType
Lcom/dl/oss/enumd/PolicyType;
builder
Ljava/lang/StringBuilder;


SourceFile
OssClient.java‹«…†‡ˆ
w
Ccom/amazonaws/client/builder/AwsClientBuilder$EndpointConfiguration
t
xÉ
yÉ‹
z
&com/amazonaws/auth/BasicAWSCredentials
{É
|É
/com/amazonaws/auth/AWSStaticCredentialsProvider‹
}
!com/amazonaws/ClientConfiguration
com/dl/oss/constant/OssConstant

Y
~É
s

€

‚
ƒ
„
…
†
ƒ
‡ã
ˆ
‰
Š
/com/amazonaws/services/s3/AmazonS3ClientBuilder
‹
Œ

Ž


‘
’
“
”
•
–
™
—
"com/amazonaws/services/s3/AmazonS3‰Šª«
java/lang/Exception
!com/dl/oss/exception/OssException
java/lang/StringBuilder
%配置错误! è¯·æ£€æŸ¥ç³»ç»Ÿé…ç½®:[
˜
™
šÉ

]
›É‹¿
σ

ž
3com/amazonaws/services/s3/model/CreateBucketRequestÝÞ
Ÿ
 
¡
¢
£ª
¤
¥
¦ßà
§
z
+创建Bucket失败, è¯·æ ¸å¯¹é…ç½®ä¿¡æ¯:[
java/io/ByteArrayInputStream‹
¨±·
©
ª
«
.com/amazonaws/services/s3/model/ObjectMetadata
¬¿
­
®
¯
°
±
0com/amazonaws/services/s3/model/PutObjectRequest‹
²
³
´
,上传文件失败，请检查配置信息:[
µã
·ÈÉ

/
¸Ù
¹
º
¹™
»

¼
½
¾
z
,删除文件失败，请检查配置信息:[
¿ÉÍÎ±²
À
Á
ÂÂ
ÃÆ
Ä
ÅÉ
https://
http://
Æ
Ç

.
È
ÉÉ
Ê
ËÉ
;com/amazonaws/services/s3/model/GeneratePresignedUrlRequest
Ì
Í
Î
Ï
Ð
java/util/Date
Ñ
Ò
Ó
Ô
Õ
¯‹
±
Ö
×
Ø
Ù
ÚÝÉ
Û
Ü
{
"Statement": [
{
"Action": [

Ý
Þâ
8"s3:GetBucketLocation",
"s3:ListBucketMultipartUploads"

ßâ
I"s3:GetBucketLocation",
"s3:ListBucket",
"s3:ListBucketMultipartUploads"

"s3:GetBucketLocation"

B],
"Effect": "Allow",
"Principal": "*",
"Resource": "arn:aws:s3:::
"
},

àâ
_{
"Action": [
"s3:ListBucket"
],
"Effect": "Deny",
"Principal": "*",
"Resource": "arn:aws:s3:::
{
"Action": 
á
â
ã
¯
a[
"s3:AbortMultipartUpload",
"s3:DeleteObject",
"s3:ListMultipartUploadParts",
"s3:PutObject"
],

q[
"s3:AbortMultipartUpload",
"s3:DeleteObject",
"s3:GetObject",
"s3:ListMultipartUploadParts",
"s3:PutObject"
],

"s3:GetObject",

?"Effect": "Allow",
"Principal": "*",
"Resource": "arn:aws:s3:::
#/*"
}
],
"Version": "2012-10-17"
}

com/dl/oss/core/OssClient
java/lang/Object
com/dl/oss/core/OssClient$1
java/lang/String
#com/dl/oss/properties/OssProperties
!com/amazonaws/auth/AWSCredentials
)com/amazonaws/auth/AWSCredentialsProvider
-com/amazonaws/client/builder/AwsClientBuilder
getEndpoint
    getRegion
'(Ljava/lang/String;Ljava/lang/String;)V
getAccessKey
getSecretKey
&(Lcom/amazonaws/auth/AWSCredentials;)V

getIsHttps
equals
(Ljava/lang/Object;)Z
com/amazonaws/Protocol
HTTPS
Lcom/amazonaws/Protocol;
setProtocol
(Lcom/amazonaws/Protocol;)V
HTTP
(com/amazonaws/services/s3/AmazonS3Client
3()Lcom/amazonaws/services/s3/AmazonS3ClientBuilder;
withEndpointConfiguration
v(Lcom/amazonaws/client/builder/AwsClientBuilder$EndpointConfiguration;)Lcom/amazonaws/client/builder/AwsClientBuilder;
withClientConfiguration
T(Lcom/amazonaws/ClientConfiguration;)Lcom/amazonaws/client/builder/AwsClientBuilder;
withCredentials
\(Lcom/amazonaws/auth/AWSCredentialsProvider;)Lcom/amazonaws/client/builder/AwsClientBuilder;
disableChunkedEncoding
-()Lcom/amazonaws/services/s3/AmazonS3Builder;
 CLOUD_SERVICE
[Ljava/lang/String;
com/dl/common/utils/StringUtils
containsAny
4(Ljava/lang/CharSequence;[Ljava/lang/CharSequence;)Z
enablePathStyleAccess
()Ljava/lang/Object;
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;

getMessage
toString
 getBucketName
doesBucketExistV2
(Ljava/lang/String;)Z
!com/dl/oss/enumd/AccessPolicyType
getAcl
;()Lcom/amazonaws/services/s3/model/CannedAccessControlList;
setCannedAcl
<(Lcom/amazonaws/services/s3/model/CannedAccessControlList;)V
_(Lcom/amazonaws/services/s3/model/CreateBucketRequest;)Lcom/amazonaws/services/s3/model/Bucket;
 getPolicyType
()Lcom/dl/oss/enumd/PolicyType;
setBucketPolicy
([B)V
cn/hutool/core/io/IoUtil
    readBytes
(Ljava/io/InputStream;)[B
setContentType
java/io/InputStream
    available
()I
setContentLength
(J)V
l(Ljava/lang/String;Ljava/lang/String;Ljava/io/InputStream;Lcom/amazonaws/services/s3/model/ObjectMetadata;)V
    putObject
e(Lcom/amazonaws/services/s3/model/PutObjectRequest;)Lcom/amazonaws/services/s3/model/PutObjectResult;
com/dl/oss/entity/UploadResult
UploadResultBuilder
6()Lcom/dl/oss/entity/UploadResult$UploadResultBuilder;
2com/dl/oss/entity/UploadResult$UploadResultBuilder
H(Ljava/lang/String;)Lcom/dl/oss/entity/UploadResult$UploadResultBuilder;
filename
"()Lcom/dl/oss/entity/UploadResult;
replace
D(Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Ljava/lang/String;
deleteObject
    getPrefix
    getObject
P(Ljava/lang/String;Ljava/lang/String;)Lcom/amazonaws/services/s3/model/S3Object;
(com/amazonaws/services/s3/model/S3Object
2()Lcom/amazonaws/services/s3/model/ObjectMetadata;
7()Lcom/amazonaws/services/s3/model/S3ObjectInputStream;
    getDomain

isNotBlank
(Ljava/lang/CharSequence;)Z
cn/hutool/core/util/IdUtil
fastSimpleUUID
com/dl/common/utils/DateUtils
datePath
com/amazonaws/HttpMethod
GET
Lcom/amazonaws/HttpMethod;

withMethod
Y(Lcom/amazonaws/HttpMethod;)Lcom/amazonaws/services/s3/model/GeneratePresignedUrlRequest;
java/lang/System
currentTimeMillis
()J
java/lang/Integer
intValue
withExpiration
O(Ljava/util/Date;)Lcom/amazonaws/services/s3/model/GeneratePresignedUrlRequest;
generatePresignedUrl
M(Lcom/amazonaws/services/s3/model/GeneratePresignedUrlRequest;)Ljava/net/URL;
java/net/URL
    getByType
7(Ljava/lang/String;)Lcom/dl/oss/enumd/AccessPolicyType;
com/dl/oss/enumd/PolicyType
WRITE

READ_WRITE
READ
&$SwitchMap$com$dl$oss$enumd$PolicyType
[I
ordinal!‚…†‡ˆ‰Š
‹Œ
ê*·
*+µ*,µ»Y*´¶*´¶·N»Y*´¶    *´¶
·:»Y· :»Y·:*´¶¶™²¶§²¶¸-¶À¶À¶À¶À:*´¶²¸š    ¶W*¶ À!µ"*¶#§0N-Á%™-¿»%Y»&Y·'(¶)-¶*¶)+¶)¶,·-¿±
¹¼$Žj-.    /12$4;5F6O7^8i:q<u=}>…?‹@“A£C©EµG¹M¼H½IÄJÆLéN\    $•’;~“”Fs•–Oj—˜“&™š½,›œꝞꅆ
ꟈ Aÿi¡¢£¤¥¦§ü7¨ÿ¡¢£
©ü    ©ú"
ª«

q*´¶.L*´"+¹/™±»0Y+·1M*¶2N,-¶3¶4*´",¹5W*´"++-¶6¸7¹8§'L»%Y»&Y·'9¶)+¶*¶)+¶)¶,·-¿±L$IL$Ž2RSTVW$X,Y7ZI]L[M\p^4A¬†
*­®$%¯°M#›œ
qž ü¢ÿ5
¡
©#
±²
W*»:Y+·;,-¶<°Ž
a*ž³´
µ†¶†
±·

S©+Á:š»:Y+¸=·;L»>Y·?:-¶@+¶A…¶B»CY*´¶.,+·D:*¶2¶3¶E*´"¹FW§):»%Y»&Y·'G¶)¶*¶)+¶)¶,·-¿¸H»&Y·'*¶I¶)J¶),¶)¶,¶K,¶L¶M°
X[$Ž2efij"k,l@nLoXr[p]qsH<¸¹@º»]$›œ©ž©¼½
©µ†©¶† 
÷G©%
¾¿
½V+»&Y·'*¶I¶)J¶)¶,N¶OL*´"*´¶.+¹P§'M»%Y»&Y·'Q¶),¶*¶)+¶)¶,·-¿±
.1$Žwy.|1z2{U} 2#›œVžVµ†
 q©#
À²
[*+**´¶R,¶S-¶T°Ž
€*ž³´
Á†¶†
À·
[*+**´¶R,¶S-¶<°Ž
„*ž¼½
Á†¶†
ÂÃ
z4+»&Y·'*¶I¶)J¶)¶,N¶OL*´"*´¶.+¹UM,¶V°ŽŽ/ 4ž4µ†
/ÄÅ
ÆÇ
z4+»&Y·'*¶I¶)J¶)¶,N¶OL*´"*´¶.+¹UM,¶W°Ž“”/• 4ž4µ†
/ÄÅ
ÈÉ

A¸*´¶XL*´¶M*´¶¶™Y§ZN,²¸™?+¸[™»&Y·'-¶)+¶)¶,°»&Y·'-¶)*´¶.¶)\¶),¶)¶,°+¸[™%»&Y·'-¶)+¶)J¶)*´¶.¶)¶,°»&Y·'-¶),¶)J¶)*´¶.¶)¶,°Ž*
™š›'1ž8ŸK¡m¤t¥–§*¸ž°Ê†
¨Ë†'‘̆ ý$¢¢A¢ü$¢!(
ÍÎ
ÇT¸]N»&Y·'¸^¶)J¶)-¶)¶,:+¸[™»&Y·'+¶)J¶)¶)¶,:»&Y·'¶),¶)¶,°Ž¬®¯&°@²4TžTφ
TÁ†PІ5µ† 
ý@¢¢
ÑÉ
/

*´°Ž
·
ž
ÒÓ
¥    ?»_Y*´¶.+·`²a¶b»cY¸de,¶g…ia·h¶iN*´"-¹j:¶k°ŽÁÂÃÄ-Å9Ə4?ž?Ԇ
?ÕÖ-×Ø9ÙÚ
ÛÜ
=    *´+¶l¬Ž
͏    ž    ‡ˆ

ÝÞ
5

*´¶m¸n°Ž
֏
ž
ßà

wÄ»&Y·'M,o¶)W+²p¦ ,q¶)W§+²r¦ ,s¶)W§
,t¶)W,u¶)W,*¶)W,v¶)W+²w¦,x¶)W,*¶)W,v¶)W,y¶)W²z+¶{.«.
$,|¶)W§,}¶)W§
,~¶)W,¶)W,*¶)W,€¶)W,¶,°ŽfÚÛÜÝ Þ'ß1á8ã?äEåLæSçZè`égënìî—ïšñ¡ò¤ô«÷²ø¸ù¿ú Ĭ†Äáâ
¼ãä ü å.(        æ焃ë‘
6
2
¶