前言:
項(xiàng)目要把圖床從七牛遷到阿里云。因此,就要使用阿里云的圖床上傳。我去看了阿里云開(kāi)發(fā)文檔給出的示例代碼和git。然而,我覺(jué)得他們給出的代碼不好用,demo寫得也不那么弱智易懂,shit!
上傳圖片有兩種方式,一種是使用三個(gè)key,可以參考這位iOS玩家的文章:
iOS 阿里云圖片上傳
還有一個(gè)是使用 “initWithAuthServerUrl” 這種方式。我這里用的就是這個(gè)方式。
我不想再看見(jiàn)阿里云了。
自己新建一個(gè)類: AliyunOSSUpload,繼承自 NSObject,
然后在 AliyunOSSUpload.m 里面,寫一個(gè)內(nèi)部類:ISAuthCredentialProvider ,繼承自阿里云的 OSSFederationCredentialProvider。
上代碼
.h
#import <Foundation/Foundation.h>
#import <AliyunOSSiOS/AliyunOSSiOS.h>
NS_ASSUME_NONNULL_BEGIN
/// 上傳到阿里云的 EndPoint
static NSString * _Nonnull const OSS_ENDPOINT = @"這個(gè)地址,找自己后臺(tái)要";
/// 上傳到阿里云的 BucketName
static NSString * _Nonnull const BucketName = @"這個(gè),找自己后臺(tái)要";
@interface AliyunOSSUpload : NSObject
+(AliyunOSSUpload *)aliyunInit;
/// 上傳圖片
/// @param imgArray 放入需要上傳的圖片
/// @param success 上傳成功,返回自己拼接的圖片名字
- (void)uploadImage:(NSArray <UIImage *>*)imgArray success:(void (^)(NSArray <NSString *> * nameArray))success;
@end
NS_ASSUME_NONNULL_END
.m
#import "AliyunOSSUpload.h"
/// 在使用 initWithAuthServerUrl 這種方式初始化阿里云的時(shí)候, 傳入的 url 是自己家的url.
/// 但是! 一般自己家的url在做請(qǐng)求的時(shí)候, 往往在請(qǐng)求頭(HTTPHeaderField)里面需要加入?yún)?shù), 比如自己家用戶登錄的時(shí)候拿到的 token, 需要在后續(xù)所有請(qǐng)求頭里加上這個(gè)token,
/// 再就是加入一些其他請(qǐng)求頭參數(shù), 比如, 哪個(gè)端,iOS,Android, 版本號(hào)之類.
/// 所以,我們 新建一個(gè)類, 繼承自 OSSFederationCredentialProvider, 然后把 阿 里 云 代 碼 直 接 拷 貝 過(guò) 來(lái) 改寫.
@interface ISAuthCredentialProvider : OSSFederationCredentialProvider
@property (nonatomic, copy) NSString * authServerUrl;
@property (nonatomic, copy) NSData * (^responseDecoder)(NSData *);
- (instancetype)initWithAuthServerUrl:(NSString *)authServerUrl;
- (instancetype)initWithAuthServerUrl:(NSString *)authServerUrl responseDecoder:(nullable OSSResponseDecoderBlock)decoder;
@end
@implementation ISAuthCredentialProvider
- (instancetype)initWithAuthServerUrl:(NSString *)authServerUrl {
return [self initWithAuthServerUrl:authServerUrl responseDecoder:nil];
}
- (instancetype)initWithAuthServerUrl:(NSString *)authServerUrl responseDecoder:(nullable OSSResponseDecoderBlock)decoder {
self = [super initWithFederationTokenGetter:^OSSFederationToken * {
NSURL * url = [NSURL URLWithString:authServerUrl];
//把原來(lái)的 NSURLRequest 改成 NSMutableURLRequest, 這樣可以加入新的請(qǐng)求頭參數(shù), 就加入這么點(diǎn)東西,其余的代碼不改.
NSMutableURLRequest * request = [NSMutableURLRequest requestWithURL:url];
[request setValue:@"用戶登錄時(shí)候拿到的 token" forHTTPHeaderField:@"你們定義好的 token key"];
[request setValue:@"其他需要放進(jìn)來(lái)的參數(shù)" forHTTPHeaderField:@"其他的參數(shù) key"];
OSSTaskCompletionSource * tcs = [OSSTaskCompletionSource taskCompletionSource];
NSURLSession * session = [NSURLSession sharedSession];
NSURLSessionTask * sessionTask = [session dataTaskWithRequest:request completionHandler:^(NSData *data, NSURLResponse *response, NSError *error) {
if (error) {
[tcs setError:error];
return;
}
[tcs setResult:data];
}];
[sessionTask resume];
[tcs.task waitUntilFinished];
if (tcs.task.error) {
return nil;
} else {
NSData* data = tcs.task.result;
if(decoder){
data = decoder(data);
}
NSDictionary * object = [NSJSONSerialization JSONObjectWithData:data
options:kNilOptions
error:nil];
int statusCode = [[object objectForKey:@"StatusCode"] intValue];
if (statusCode == 200) {
OSSFederationToken * token = [OSSFederationToken new];
// All the entries below are mandatory.
token.tAccessKey = [object objectForKey:@"AccessKeyId"];
token.tSecretKey = [object objectForKey:@"AccessKeySecret"];
token.tToken = [object objectForKey:@"SecurityToken"];
token.expirationTimeInGMTFormat = [object objectForKey:@"Expiration"];
OSSLogDebug(@"token: %@ %@ %@ %@", token.tAccessKey, token.tSecretKey, token.tToken, [object objectForKey:@"Expiration"]);
return token;
}else{
return nil;
}
}
}];
if(self){
self.authServerUrl = authServerUrl;
}
return self;
}
@end
OSSClient * client;
@implementation AliyunOSSUpload
static AliyunOSSUpload *_uploader;
+ (AliyunOSSUpload *)aliyunInit {
@synchronized(self) {
if (_uploader == nil) {
[OSSLog enableLog];
_uploader = [[AliyunOSSUpload alloc] init];
NSString *OSS_STSTOKEN_URL = @"這個(gè) AuthServerUrl 找后臺(tái)要";
id<OSSCredentialProvider> credentialProvider = [[ISAuthCredentialProvider alloc] initWithAuthServerUrl:OSS_STSTOKEN_URL];
OSSClientConfiguration *cfg = [[OSSClientConfiguration alloc] init];
client = [[OSSClient alloc] initWithEndpoint:OSS_ENDPOINT credentialProvider:credentialProvider clientConfiguration:cfg];
}
}
return _uploader;
}
- (void)uploadImage:(NSArray <UIImage *>*)imgArray success:(void (^)(NSArray <NSString *> * nameArray))success {
dispatch_group_t group = dispatch_group_create();
//名字?jǐn)?shù)組
NSMutableArray *nameArray = [NSMutableArray array];
for (int i = 0; i < imgArray.count; i ++) {
dispatch_group_enter(group); //進(jìn)入組
NSString *s = [NSString stringWithFormat:@"photot_name_%d_%@.jpg",i,[NSUUID UUID].UUIDString];
OSSPutObjectRequest * put = [OSSPutObjectRequest new];
put.contentType = @"image/jpeg";
put.bucketName = BucketName;
put.objectKey = s;
put.uploadingData = UIImageJPEGRepresentation(imgArray[i], 1);
put.uploadProgress = ^(int64_t bytesSent, int64_t totalByteSent, int64_t totalBytesExpectedToSend) {
NSLog(@"%lld, %lld, %lld", bytesSent, totalByteSent, totalBytesExpectedToSend);
};
OSSTask * putTask = [client putObject:put];
[putTask continueWithBlock:^id(OSSTask *task) {
if (!task.error) {
NSLog(@"圖片上傳成功!");
[nameArray addObject:s];
} else{
NSLog(@"圖片上傳失敗: %@" , task.error);
}
dispatch_group_leave(group); //不論是成功或者失敗,都離開(kāi)組
return nil;
}];
}
dispatch_group_notify(group, dispatch_get_main_queue(), ^{
success(nameArray);
NSLog(@"任務(wù)全部完成,當(dāng)前線程 %@",[NSThread currentThread]); //收到任務(wù)全部完成的通知
});
}
@end
調(diào)用
[[AliyunOSSUpload aliyunInit] uploadImage:arrayNewPhoto success:^(NSArray<NSString *> * _Nonnull nameArray) {'
NSLog(@"%@", nameArray);
}];