Object Storage Service:再開可能ダウンロード

次の図は、再開可能なダウンロードの鮮明な説明です。

次のサンプルコードは、OSS SDK for iOSで再開可能ダウンロードを使用する方法の例を示しています。

#import "DownloadService.h"
# import "OSSTestMacros.h"

@ implementation DownloadRequest

@ end

@ implementationチェックポイント

- (instancetype)copyWithZone :( NSZone *)zone {
    Checkpoint * other = [[[self class] allocWithZone:zone] init];

    other.etag = self.etag;
    other.totalExpectedLength = self.totalExpectedLength;

    その他を返します。}

@ end


@ interface DownloadService()<NSURLSessionTaskDelegate, NSURLSessionDataDelegate>

@ property (nonatomic, strong) NSURLSession * session; // ネットワークセッション。 
@ property (non atomic, strong) NSURLSessionDataTask * dataTask; // データ要求タスク。 
@ property (nonatomic, copy) DownloadFailureBlock failure; // リクエストの失敗。 
@ property (nonatomic, copy) DownloadSuccessBlock success; // リクエストの成功。 
@ property (non atomic, copy) DownloadProgressBlock progress; // ダウンロードの進行状況。 
@ property (nonatomic, copy) Checkpoint * checkpoint; // チェックポイントファイル。 
@ property (非アトミック、コピー) NSString * requestURLString; // ダウンロード要求で使用されるオブジェクトリソースURL。 
@ property (非アトミック、コピー) NSString * headURLString; // HEAD要求で使用されるオブジェクトリソースURL。 
@ property (nonatomic, copy) NSString * targetPath; // オブジェクトが格納されるパス。 
@ property (nonatomic, assign) unsigned long totalReceivedContentLength; // ダウンロードしたコンテンツのサイズ。 
@ property (nonatomic, strong) dispatch_semaphore_t semaphore;

@ end

@ implementation DownloadService

- (instancetype)init
{
    self = [super init];
    if (self) {
        NSURLSessionConfiguration * conf = [NSURLSessionConfiguration defaultSessionConfiguration];
        conf.timeoutIntervalForRequest = 15;

        NSOperationQueue * processQueue = [NSOperationQueue new];
        _session = [NSURLSession sessionWithConfiguration:conf delegate:self delegateQueue:processQueue];
        _semaphore = dispatch_semaphore_create(0);
        _checkpoint = [[Checkpoint alloc] init];
    }
    自己を返す。}
// DownloadRequestはダウンロードロジックの中核です。 
+ (instancetype)downloadServiceWithRequest :( DownloadRequest *)request {
    DownloadService * service = [[DownloadService alloc] init];
    if (サービス) {
        service.failure = request.failure;
        service.success = request.success;
        service.requestURLString = request.sourceURLString;
        service.headURLString = request.headURLString;
        service.tar getPath = request.downloadFilePath;
        service.progress = request.downloadProgress;
        if (request.checkpoint) {
            service.checkpoint = request.checkpoint;
        }
    }
    帰りサービス;
}

/**
 * Headメソッドを呼び出してオブジェクト情報を取得します。 OSSは、オブジェクトのETagをローカルチェックポイントファイルに格納されているETagと比較し、比較結果を返します。 
 * /
- (BOOL)getFileInfo {
    __ブロックBOOL再開可能=NO;
    NSURL * url = [NSURL URLWithString:self.headURLString];
    NSMutableURLRequest * request = [[NSMutableURLRequest alloc]initWithURL:url];
    [リクエストsetHTTPMethod:@ "HEAD"];
    // オブジェクトに関する情報を処理します。 たとえば、ETagは再開可能なアップロード中の事前チェックに使用され、Content-Lengthヘッダーはダウンロードの進行状況を計算するために使用されます。 
    NSURLSessionDataTask * task = [[NSURLSession sharedSession] dataTaskWithRequest:request completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
        if (error) {
            NSLog(@ "オブジェクトメタデータの取得に失敗しました。 エラー: % @ ", エラー);
        } else {
            NSHTTPURLResponse * httpResponse = (NSHTTPURLResponse *)response;
            NSString * etag = [httpResponse.allHeaderFields objectForKey:@ "Etag"];
            if ([self.checkpoint.etag isEqualToString:etag]) {
                resumable = YES;
            } else {
                resumable = NO;
            }
        }
        dispatch_semaphore_signal(self.semaphore);
    }];
    [タスク再開];

    dispatch_semaphore_wait(self.semaphore, DISPATCH_TIME_FOREVER);
    resumableを返します;
}

/**
 * ローカルファイルのサイズを照会します。 
 * /
- (unsigned long long)fileSizeAtPath :( NSString *)filePath {
    unsigned long long fileSize = 0;
    NSFileManager * dfm = [NSFileManager defaultManager];
    if ([dfm fileExistsAtPath:filePath]) {
        NSError * error = nil;
        NSDictionary * attributes = [dfm attributesOfItemAtPath:filePathエラー:&エラー];
        if (!error && attributes) {
            fileSize = attributes.fileSize;
        } else if (エラー) {
            NSLog(@ "error: % @" 、エラー);
        }
    }

    fileSizeを返します。}

- (void)resume {
    NSURL * url = [NSURL URLWithString:self.requestURLString];
    NSMutableURLRequest * request = [[NSMutableURLRequest alloc]initWithURL:url];
    [リクエストsetHTTPMethod:@ "GET"];

    BOOL Resumable= [self getFileInfo]; // 再開可能フィールドの値がNOの場合、再開可能ダウンロード条件は満たされません。 
    if (再開可能) {
        self.totalReceivedContentLength = [self fileSizeAtPath:self.tar getPath];
        NSString * requestRange = [NSString stringWithFormat:@ "bytes=% llu-", self.totalReceivedContentLength];
        [リクエストsetValue:requestRange forHTTPHeaderField:@ "Range"];
    } else {
        self.totalReceivedContentLength = 0;
    }

    if (self.totalReceivedContentLength == 0) {
        [[NSFileManager defaultManager] createFileAtPath:self.tar getPathの内容: nil attributes:nil];
    }

    self.dataTask = [self.session dataTaskWithRequest: リクエスト];
    [self.dataTaskの履歴書];
}

- (void)pause {
    [self.dataTaskキャンセル];
    self.dataTask = nil;
}

- (void)cancel {
    [self.dataTaskキャンセル];
    self.dataTask = nil;
    [self removeFileAtPath: self.tar getPath];
}

- (void)removeFileAtPath :( NSString *)filePath {
    NSError * error = nil;
    [[NSFileManager defaultManager] removeItemAtPath:self.tar getPathエラー:&エラー];
    if (error) {
        NSLog(@ "エラーのあるファイルを削除: % @" 、エラー);
    }
}

# pragmaマーク-NSURLSessionDataDelegate

- (void)URLSession :( NSURLSession *) セッションタスク :( NSURLSessionTask *) タスク
// ダウンロードタスクが完了したかどうかを確認し、結果を上位レイヤーに返します。 
didCompleteWithError :( nullable NSError *)error {
    NSHTTPURLResponse * httpResponse = (NSHTTPURLResponse *)task.response;
    if ([httpResponse isKindOfClass:[NSHTTPURLResponseクラス]]) {
        if (httpResponse.statusCode == 200) {
            self.checkpoint.etag = [[httpResponse allHeaderFields] objectForKey:@ "Etag"];
            self.checkpoint.totalExpectedLength = httpResponse.expectedContentLength;
        } else if (httpResponse.statusCode == 206) {
            self.checkpoint.etag = [[httpResponse allHeaderFields] objectForKey:@ "Etag"];
            self.checkpoint.totalExpectedLength = self.totalReceivedContentLength + httpResponse.expectedContentLength;
        }
    }

    if (error) {
        if (self.failure) {
            NSMutableDictionary * userInfo = [NSMutableDictionary dictionaryWithDictionar y:error.us erInfo];
            [userInfo oss_setObject:self.checkpoint forKey:@ "checkpoint"];

            NSError * tError = [NSError errorWithDomain:error.domainコード: error.code userInfo:userInfo];
            self.failure(tError);
        }
    } else if (self.success) {
        self.success(@{@ "status": @ "success"});
    }
}

- (void)URLSession :( NSURLSession *)session dataTask :( NSURLSessionDataTask *)dataTask didReceiveResponse :( NSURLResponse *)response completionHandler :( void (^)(NSURLSessionResponseDisposition))completionHandler
{
    NSHTTPURLResponse * httpResponse = (NSHTTPURLResponse *)dataTask.response;
    if ([httpResponse isKindOfClass:[NSHTTPURLResponseクラス]]) {
        if (httpResponse.statusCode == 200) {
            self.checkpoint.totalExpectedLength = httpResponse.expectedContentLength;
        } else if (httpResponse.statusCode == 206) {
            self.checkpoint.totalExpectedLength = self.totalReceivedContentLength + httpResponse.expectedContentLength;
        }
    }

    completionHandler(NSURLSessionResponseAllow);
}
// 受信したネットワークデータを追加アップロードを使用してオブジェクトに書き込み、ダウンロードの進行状況を更新します。 
- (void)URLSession :( NSURLSession *)session dataTask :( NSURLSessionDataTask *)dataTask didReceiveData :( NSData *)data {

    NSFileHandle * fileHandle = [NSFileHandleForWritingAtPath: self.tar getPath];
    [fileHandle seekToEndOfFile];
    [fileHandle writeData: データ];
    [fileHandle closeFile];

    self.totalReceivedContentLength += data.length;
    if (self.progress) {
        self.progress(data.length、self.totalReceivedContentLength、self.checkpoint.totalExpectedLength);
    }
}

@ end