我正在尝试在 Android 中使用 Drive Rest API 创建一个可恢复的上传 session 。
根据文档,需要遵循的 3 个步骤是
- 开始可续会
- 保存可恢复 session URI
- 上传文件
第 1 步:我使用以下代码启动可恢复 session 。
File body = new File();
body.setName(fileName);
body.setMimeType(mimeType);
body.setCreatedTime(modifiedDate);
body.setModifiedTime(modifiedDate);
body.setParents(Collections.singletonList(parentId));
HttpHeaders header = new HttpHeaders();
header.setContentLength(0L);
header.setContentType("application/json; charset=UTF-8");
header.set("X-Upload-Content-Type","image/jpeg");
HttpResponse response= driveObject
.files()
.create(body)
.setRequestHeaders(header)
.set("uploadType","resumable")
.buildHttpRequest()
.execute();
第 2 步:执行完成后,我将打印请求的响应 header 以查看 Location URI
System.out.println(response.getHeader().toString());
输出如下
{
cache-control=[no-cache, no-store, max-age=0, must-revalidate],
content-encoding=[gzip],
content-type=[application/json; charset=UTF-8],
date=[Thu, 06 Oct 2016 02:20:18 GMT],
expires=[Mon, 01 Jan 1990 00:00:00 GMT],
alt-svc=[quic=":443"; ma=2592000; v="36,35,34,33,32"],
pragma=[no-cache],
server=[GSE],
transfer-encoding=[chunked],
vary=[Origin, X-Origin],
x-android-received-millis=[1475720421761],
x-android-response-source=[NETWORK 200],
x-android-sent-millis=[1475720420804],
x-content-type-options=[nosniff],
x-frame-options=[SAMEORIGIN],
x-xss-protection=[1; mode=block]
}
我没有在响应 header 中找到 Location URI 来开始上传文档中指定的文件数据,也没有找到任何 Java 示例来执行可恢复上传。
如何检索文档中指定的位置 URI?
最佳答案
我已经尝试了一周的大部分时间,终于可以运行可续传上传。它没有像我预期的那样工作,但它确实有效。
不要对一切都使用 Drive REST API
据我所知,据我所知,Google Drive REST API 并不能真正进行分块上传。这可能是一个错误,也可能是设计使然。也可能是我太笨了。
但让我想到的是,我在任何地方都看不到代码示例。每个人一直都在谈论 Http
header 。这就是我们下面要做的。我们将仅使用 header 。
下面是如何使用 Google Drive REST API 和 Android 进行可恢复的分块上传:
0) 初始化
String accountName = "account_name";
GoogleAccountCredential credential = GoogleAccountCredential.usingOAuth2(context, Arrays.asList(SCOPES)).setBackOff(new ExponentialBackOff()).setSelectedAccountName(accountName);
1) 启动可恢复 session
遵循 Google 在 this document 中概述的规则:
POST /upload/drive/v3/files?uploadType=resumable HTTP/1.1
Host: www.googleapis.com
Authorization: Bearer your_auth_token
Content-Length: 38
Content-Type: application/json; charset=UTF-8
X-Upload-Content-Type: image/jpeg
X-Upload-Content-Length: 2000000
{
"name": "My File"
}
像 Google 的示例一样设置所有标题字段。将其作为 POST
请求发送。使用您的 credential
变量获取授权 token 。 X-Upload-Content-Type
的 mime 类型并不是那么重要,没有它它也能工作(this SO answer 提供了一个很好的函数来从路径中检索它)。将 X-Upload-Content-Length
设置为文件的总长度。将 Content-Type
设置为 JSON 格式,因为我们的正文将以 JSON 格式为 Google 提供元数据。
现在创建您的元数据主体。我输入了文件名和父级。将 Content-Length
设置为 body
的字节长度。然后将您的主体写入 request.getOutputStream()
输出流。
URL url = new URL("https://www.googleapis.com/upload/drive/v3/files?uploadType=resumable");
HttpURLConnection request = (HttpURLConnection) url.openConnection();
request.setRequestMethod("POST");
request.setDoInput(true);
request.setDoOutput(true);
request.setRequestProperty("Authorization", "Bearer " + credential.getToken());
request.setRequestProperty("X-Upload-Content-Type", getMimeType(file.getPath()));
request.setRequestProperty("X-Upload-Content-Length", String.format(Locale.ENGLISH, "%d", file.length()));
request.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
String body = "{\"name\": \"" + file.getName() + "\", \"parents\": [\"" + parentId + "\"]}";
request.setRequestProperty("Content-Length", String.format(Locale.ENGLISH, "%d", body.getBytes().length));
OutputStream outputStream = request.getOutputStream();
outputStream.write(body.getBytes());
outputStream.close();
request.connect();
2) 保存可恢复 session URI
最后,connect()
并等待响应。如果响应代码为 200
,则您已成功启动分块可续传上传。现在将 location
header URI 保存在某处(数据库、文本文件等)。您稍后会需要它。
if (request.getResponseCode() == HttpURLConnection.HTTP_OK) {
String sessionUri = request.getHeaderField("location");
}
3) 上传文件
PUT {session_uri} HTTP/1.1
Host: www.googleapis.com
Content-Length: 524288
Content-Type: image/jpeg
Content-Range: bytes 0-524287/2000000
bytes 0-524288
将以下代码循环,直到上传整个文件。在每个 block 之后,您将收到代码为 308
和 range
header 的响应。从这个 range
header ,您可以读取下一个 block 开始(请参阅 (4))。
Content-Type
将再次成为 mime 类型。 Content-Length
是您在此 block 中上传的字节数。 Content-Range
需要采用 bytes startByte-EndByte/BytesTotal
形式。您将其放入 PUT
请求中。
然后您创建一个 FileInputStream
并将位置设置为您的起始字节(您从上次响应 range
header 中获得)并将另一个 block 读入您的缓冲区。然后将该缓冲区写入连接输出流。最后,connect()
。
URL url = new URL(sessionUri);
HttpURLConnection request = (HttpURLConnection) url.openConnection();
request.setRequestMethod("PUT");
request.setDoOutput(true);
request.setConnectTimeout(10000);
request.setRequestProperty("Content-Type", getMimeType(file.getPath()));
long uploadedBytes = chunkSizeInMb * 1024 * 1024;
if (chunkStart + uploadedBytes > file.length()) {
uploadedBytes = (int) file.length() - chunkStart;
}
request.setRequestProperty("Content-Length", String.format(Locale.ENGLISH, "%d", uploadedBytes));
request.setRequestProperty("Content-Range", "bytes " + chunkStart + "-" + (chunkStart + uploadedBytes - 1) + "/" + file.length());
byte[] buffer = new byte[(int) uploadedBytes];
FileInputStream fileInputStream = new FileInputStream(file);
fileInputStream.getChannel().position(chunkStart);
if (fileInputStream.read(buffer, 0, (int) uploadedBytes) == -1) { /* break, return, exit*/ }
fileInputStream.close();
OutputStream outputStream = request.getOutputStream();
outputStream.write(buffer);
outputStream.close();
request.connect();
4) 处理响应
在此之后,您将收到代码为 308
的响应(如果成功)。此响应包含一个 range
header (已提及)。
HTTP/1.1 308 Resume Incomplete
Content-Length: 0
Range: bytes=0-524287
您将其拆分并获得新的 block 起始字节。
String range = chunkUploadConnection.getHeaderField("range");
int chunkPosition = Long.parseLong(range.substring(range.lastIndexOf("-") + 1, range.length())) + 1;
5)响应码不是308?!
您可能会收到 5xx
响应。您的互联网连接可能会失败,文件可能会在上传过程中被删除/重命名等。
不用担心。只要保存 session URI 和 block 起始字节,就可以随时恢复上传。
为此,请发送以下形式的 header :
PUT {session_uri} HTTP/1.1
Content-Length: 0
Content-Range: bytes */TotalFileLength
URL url = new URL(sessionUri);
HttpURLConnection request = (HttpURLConnection) url.openConnection();
request.setRequestMethod("PUT");
request.setDoOutput(true);
request.setConnectTimeout(10000);
request.setRequestProperty("Content-Length", "0");
request.setRequestProperty("Content-Range", "bytes */" + file.length());
request.connect();
然后您将收到带有 range
header 的 308
,您可以从中读取最后上传的字节(就像我们在上面所做的那样)。取这个数字,重新开始循环。
我希望我能帮助到你们中的一些人。如果您还有其他问题,请在评论中提问,我会编辑答案。
关于java - Drive Rest API V3 中的可恢复上传,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39887303/