Загрузить видео файл по чанкам
Yes, it's a long question with a lot of detail... Итак, мой вопрос: как я могу передать поток загрузки в Vimeo в сегментах?
For anyone wanting to copy and debug on their own machine: Вот что вам нужно:
My code here. Include the Scribe library found here Have a valid video file (mp4) which is at least greater than 10 MB and put it in the directoryC:\test.mp4
or change that code to point wherever yours is.
That's it! Thanks for helping me out!
Big update: Я оставил рабочий код API Key and Secret для Vimeo в коде.Вот, Таким образом, если у вас есть учетная запись Vimeo, весь код должен работать нормально, как только вы разрешите приложение и введете свой токен. Просто скопируйте код из этой ссылки в проект в вашей любимой IDE и посмотрите, сможете ли вы это исправить со мной. Я дам вознаграждение тому, кто даст мне рабочий код. Спасибо! О, и не надейтесь использовать этот Ключ и Секрет надолго. Как только эта проблема будет решена, я удалю ее. :)
Overview of the problem: Проблема заключается в том, что когда я отправляю последний кусок байтов в Vimeo и затем проверяю загрузку, в ответ возвращается, что длина всего содержимого равна длине только последнего фрагмента, а не всех фрагментов, вместе взятых, как должно быть.
SSCCE Note: У меня есть весь мой SSCCEВот, Я положил это куда-то еще, чтобы это могло бытьC ompilable. Это не оченьS Hort (около 300 строк), но, надеюсь, вы найдете егоS эльфийские, и это, безусловно,E Xample!). Однако я публикую соответствующие части своего кода в этом сообщении.
This is how it works: При загрузке видео в Vimeo с помощью метода потоковой передачи (см. Документацию «Загрузка API»).Вот для настройки, чтобы добраться до этой точки), вы должны указать несколько заголовков: конечная точка, длина содержимого и тип содержимого. Документация говорит, что игнорирует любые другие заголовки. Вы также даете ему полезную информацию о байтах для файла, который вы загружаете. А затем подписать и отправить его (у меня есть метод, который будет делать это с помощьюписец).
My problem: Все отлично работает, когда я просто отправляю видео в одном запросе. Моя проблема в тех случаях, когда я загружаю несколько больших файлов, на компьютере, на котором я использую, недостаточно памяти, чтобы загрузить всю эту байтовую информацию и поместить ее в запрос HTTP PUT, поэтому мне нужно разделить ее на: 1 МБ сегментов. Здесь все становится сложнее. В документации упоминается, что можно «возобновить» загрузок, поэтому я пытаюсь сделать это с помощью своего кода, но он работает не совсем правильно. Ниже вы увидите код для отправки видео.Remember мой SSCCEВот.
Things I've tried: Я думаю, что это как-то связано с заголовком Content-Range ... Итак, вот что я пытался изменить, что говорит заголовок Content-Range ...
Not adding content range header to the first chunkAdding a prefix to the content range header (each with a combination of the previous header):
"bytes" "bytes " (throws connection error, see the very bottom for the error) --> It appears in the documentation that this is what they're looking for, but I'm pretty sure there are typos in the documentation because they have the content-range header on their "resume" example as:1001-339108/339108
when it should be 1001-339107/339108
. So... Yeah...
"bytes%20"
"bytes:"
"bytes: "
"bytes="
"bytes= "
Not adding anything as a prefix to the content range header
Вот код:
<code>/** * Send the video data * * @return whether the video successfully sent */ private static boolean sendVideo(String endpoint, File file) throws FileNotFoundException, IOException { // Setup File long contentLength = file.length(); String contentLengthString = Long.toString(contentLength); FileInputStream is = new FileInputStream(file); int bufferSize = 10485760; // 10 MB = 10485760 bytes byte[] bytesPortion = new byte[bufferSize]; int byteNumber = 0; int maxAttempts = 1; while (is.read(bytesPortion, 0, bufferSize) != -1) { String contentRange = Integer.toString(byteNumber); long bytesLeft = contentLength - byteNumber; System.out.println(newline + newline + "Bytes Left: " + bytesLeft); if (bytesLeft < bufferSize) { //copy the bytesPortion array into a smaller array containing only the remaining bytes bytesPortion = Arrays.copyOf(bytesPortion, (int) bytesLeft); //This just makes it so it doesn't throw an IndexOutOfBounds exception on the next while iteration. It shouldn't get past another iteration bufferSize = (int) bytesLeft; } byteNumber += bytesPortion.length; contentRange += "-" + (byteNumber - 1) + "/" + contentLengthString; int attempts = 0; boolean success = false; while (attempts < maxAttempts && !success) { int bytesOnServer = sendVideoBytes("Test video", endpoint, contentLengthString, "video/mp4", contentRange, bytesPortion, first); if (bytesOnServer == byteNumber) { success = true; } else { System.out.println(bytesOnServer + " != " + byteNumber); System.out.println("Success is not true!"); } attempts++; } first = true; if (!success) { return false; } } return true; } /** * Sends the given bytes to the given endpoint * * @return the last byte on the server (from verifyUpload(endpoint)) */ private static int sendVideoBytes(String videoTitle, String endpoint, String contentLength, String fileType, String contentRange, byte[] fileBytes, boolean addContentRange) throws FileNotFoundException, IOException { OAuthRequest request = new OAuthRequest(Verb.PUT, endpoint); request.addHeader("Content-Length", contentLength); request.addHeader("Content-Type", fileType); if (addContentRange) { request.addHeader("Content-Range", contentRangeHeaderPrefix + contentRange); } request.addPayload(fileBytes); Response response = signAndSendToVimeo(request, "sendVideo on " + videoTitle, false); if (response.getCode() != 200 && !response.isSuccessful()) { return -1; } return verifyUpload(endpoint); } /** * Verifies the upload and returns whether it's successful * * @param endpoint to verify upload to * @return the last byte on the server */ public static int verifyUpload(String endpoint) { // Verify the upload OAuthRequest request = new OAuthRequest(Verb.PUT, endpoint); request.addHeader("Content-Length", "0"); request.addHeader("Content-Range", "bytes */*"); Response response = signAndSendToVimeo(request, "verifyUpload to " + endpoint, true); if (response.getCode() != 308 || !response.isSuccessful()) { return -1; } String range = response.getHeader("Range"); //range = "bytes=0-10485759" return Integer.parseInt(range.substring(range.lastIndexOf("-") + 1)) + 1; //The + 1 at the end is because Vimeo gives you 0-whatever byte where 0 = the first byte } </code>
Вот метод signAndSendToVimeo:
<code>/** * Signs the request and sends it. Returns the response. * * @param service * @param accessToken * @param request * @return response */ public static Response signAndSendToVimeo(OAuthRequest request, String description, boolean printBody) throws org.scribe.exceptions.OAuthException { System.out.println(newline + newline + "Signing " + description + " request:" + ((printBody && !request.getBodyContents().isEmpty()) ? newline + "\tBody Contents:" + request.getBodyContents() : "") + ((!request.getHeaders().isEmpty()) ? newline + "\tHeaders: " + request.getHeaders() : "")); service.signRequest(accessToken, request); printRequest(request, description); Response response = request.send(); printResponse(response, description, printBody); return response; } </code>
И здесьsome (пример ... Все выходные можно найтиВот) вывода из методов printRequest и printResponse:NOTE Этот выход изменяется в зависимости от того, чтоcontentRangeHeaderPrefix
установлен иfirst
boolean установлен в (который указывает, включать ли заголовок Content-Range в первый блок).
<code>We're sending the video for upload! Bytes Left: 15125120 Signing sendVideo on Test video request: Headers: {Content-Length=15125120, Content-Type=video/mp4, Content-Range=bytes%200-10485759/15125120} sendVideo on Test video >>> Request Headers: {Authorization=OAuth oauth_signature="zUdkaaoJyvz%2Bt6zoMvAFvX0DRkc%3D", oauth_version="1.0", oauth_nonce="340477132", oauth_signature_method="HMAC-SHA1", oauth_consumer_key="5cb447d1fc4c3308e2c6531e45bcadf1", oauth_token="460633205c55d3f1806bcab04174ae09", oauth_timestamp="1334336004", Content-Length=15125120, Content-Type=video/mp4, Content-Range=bytes: 0-10485759/15125120} Verb: PUT Complete URL: http://174.129.125.96:8080/upload?ticket_id=5ea64d64547e38e5e3c121852b2d306d sendVideo on Test video >>> Response Code: 200 Headers: {null=HTTP/1.1 200 OK, Content-Length=0, Connection=close, Content-Type=text/plain, Server=Vimeo/1.0} Signing verifyUpload to http://174.129.125.96:8080/upload?ticket_id=5ea64d64547e38e5e3c121852b2d306d request: Headers: {Content-Length=0, Content-Range=bytes */*} verifyUpload to http://174.129.125.96:8080/upload?ticket_id=5ea64d64547e38e5e3c121852b2d306d >>> Request Headers: {Authorization=OAuth oauth_signature="FQg8HJe84nrUTdyvMJGM37dpNpI%3D", oauth_version="1.0", oauth_nonce="298157825", oauth_signature_method="HMAC-SHA1", oauth_consumer_key="5cb447d1fc4c3308e2c6531e45bcadf1", oauth_token="460633205c55d3f1806bcab04174ae09", oauth_timestamp="1334336015", Content-Length=0, Content-Range=bytes */*} Verb: PUT Complete URL: http://174.129.125.96:8080/upload?ticket_id=5ea64d64547e38e5e3c121852b2d306d verifyUpload to http://174.129.125.96:8080/upload?ticket_id=5ea64d64547e38e5e3c121852b2d306d >>> Response Code: 308 Headers: {null=HTTP/1.1 308 Resume Incomplete, Range=bytes=0-10485759, Content-Length=0, Connection=close, Content-Type=text/plain, Server=Vimeo/1.0} Body: Bytes Left: 4639360 Signing sendVideo on Test video request: Headers: {Content-Length=15125120, Content-Type=video/mp4, Content-Range=bytes: 10485760-15125119/15125120} sendVideo on Test video >>> Request Headers: {Authorization=OAuth oauth_signature="qspQBu42HVhQ7sDpzKGeu3%2Bn8tM%3D", oauth_version="1.0", oauth_nonce="183131870", oauth_signature_method="HMAC-SHA1", oauth_consumer_key="5cb447d1fc4c3308e2c6531e45bcadf1", oauth_token="460633205c55d3f1806bcab04174ae09", oauth_timestamp="1334336015", Content-Length=15125120, Content-Type=video/mp4, Content-Range=bytes%2010485760-15125119/15125120} Verb: PUT Complete URL: http://174.129.125.96:8080/upload?ticket_id=5ea64d64547e38e5e3c121852b2d306d sendVideo on Test video >>> Response Code: 200 Headers: {null=HTTP/1.1 200 OK, Content-Length=0, Connection=close, Content-Type=text/plain, Server=Vimeo/1.0} Signing verifyUpload to http://174.129.125.96:8080/upload?ticket_id=5ea64d64547e38e5e3c121852b2d306d request: Headers: {Content-Length=0, Content-Range=bytes */*} verifyUpload to http://174.129.125.96:8080/upload?ticket_id=5ea64d64547e38e5e3c121852b2d306d >>> Request Headers: {Authorization=OAuth oauth_signature="IdhhhBryzCa5eYqSPKAQfnVFpIg%3D", oauth_version="1.0", oauth_nonce="442087608", oauth_signature_method="HMAC-SHA1", oauth_consumer_key="5cb447d1fc4c3308e2c6531e45bcadf1", oauth_token="460633205c55d3f1806bcab04174ae09", oauth_timestamp="1334336020", Content-Length=0, Content-Range=bytes */*} Verb: PUT Complete URL: http://174.129.125.96:8080/upload?ticket_id=5ea64d64547e38e5e3c121852b2d306d 4639359 != 15125120 verifyUpload to http://174.129.125.96:8080/upload?ticket_id=5ea64d64547e38e5e3c121852b2d306d >>> Response Success is not true! Code: 308 Headers: {null=HTTP/1.1 308 Resume Incomplete, Range=bytes=0-4639359, Content-Length=0, Connection=close, Content-Type=text/plain, Server=Vimeo/1.0} Body: </code>
Затем код продолжается для завершения загрузки и установки видеоинформации (вы можете увидеть это вмой полный код).
Edit 2: Попытка удаления "% 20" из диапазона содержимого и получил это соединение с ошибкой. Я должен использовать любой из "байтов% 20" или не добавлять & quot; байты & quot; совсем...
<code>Exception in thread "main" org.scribe.exceptions.OAuthException: Problems while creating connection. at org.scribe.model.Request.send(Request.java:70) at org.scribe.model.OAuthRequest.send(OAuthRequest.java:12) at autouploadermodel.VimeoTest.signAndSendToVimeo(VimeoTest.java:282) at autouploadermodel.VimeoTest.sendVideoBytes(VimeoTest.java:130) at autouploadermodel.VimeoTest.sendVideo(VimeoTest.java:105) at autouploadermodel.VimeoTest.main(VimeoTest.java:62) Caused by: java.io.IOException: Error writing to server at sun.net.www.protocol.http.HttpURLConnection.writeRequests(HttpURLConnection.java:622) at sun.net.www.protocol.http.HttpURLConnection.writeRequests(HttpURLConnection.java:634) at sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1317) at java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:468) at org.scribe.model.Response.<init>(Response.java:28) at org.scribe.model.Request.doSend(Request.java:110) at org.scribe.model.Request.send(Request.java:62) ... 5 more Java Result: 1 </code>
Edit 1: Обновлен код и вывод. Все еще нужна помощь!