从Android示例上载Azure存储块Blob

Question

我使用android应用程序中的以下代码将blob上传到Azure blob存储。注意：下面的sasUrl参数是从我的web服务获取的签名url：

    // upload file to azure blob storage
    private static Boolean upload(String sasUrl, String filePath, String mimeType) {
        try {
            // Get the file data
            File file = new File(filePath);
            if (!file.exists()) {           
                    return false;
            }

            String absoluteFilePath = file.getAbsolutePath();

            FileInputStream fis = new FileInputStream(absoluteFilePath);
            int bytesRead = 0;
            ByteArrayOutputStream bos = new ByteArrayOutputStream();
            byte[] b = new byte[1024];
            while ((bytesRead = fis.read(b)) != -1) {
                bos.write(b, 0, bytesRead);
            }
            fis.close();
            byte[] bytes = bos.toByteArray();
            // Post our image data (byte array) to the server
            URL url = new URL(sasUrl.replace("\"", ""));
            HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();
            urlConnection.setDoOutput(true);
            urlConnection.setConnectTimeout(15000);
            urlConnection.setReadTimeout(15000);
            urlConnection.setRequestMethod("PUT");
            urlConnection.addRequestProperty("Content-Type", mimeType);
            urlConnection.setRequestProperty("Content-Length", "" + bytes.length);
            urlConnection.setRequestProperty("x-ms-blob-type", "BlockBlob");
            // Write file data to server
            DataOutputStream wr = new DataOutputStream(urlConnection.getOutputStream());
            wr.write(bytes);
            wr.flush();
            wr.close();
            int response = urlConnection.getResponseCode();
            if (response == 201 && urlConnection.getResponseMessage().equals("Created")) {
                return true;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return false;
    }

该代码对于小的blob来说运行良好，但是当blob达到一定的大小（取决于我测试的手机）时，我开始出现内存不足的异常。我想拆分这些blob并将它们分块上传。然而，我在网上找到的所有示例都是基于C#的，并且都在使用存储客户端库。我正在寻找一个Java/Android示例，它使用Azure Storage Rest API分块上传blob。

Answer 1

这里发布了一个Azure存储Android库。示例文件夹中有一个基本blob存储示例。您可能希望使用的方法是blob类中的uploadFromFile。默认情况下，如果blob的大小小于64MB，则会尝试将其放入一个put中，否则将以4MB的块发送blob。如果希望减少64MB的限制，可以在CloudBlobClient（将影响所有请求）的BlobRequestOptions对象上设置singleBlobPutThresholdInBytes属性，或者将其传递给uploadFromFile方法（仅影响该请求）。存储库包括许多方便的功能，如自动重试和块put请求的最大执行超时，这些都是可配置的。

如果您仍然想使用更手动的方法，这里提供了PutBlock和Put Block List API参考，并提供了通用的跨语言文档。这些在Azure存储Android库的CloudBlockBlob类中有很好的包装，称为uploadBlock和commitBlockList，这可能会为手动请求构造节省大量时间，并提供上述一些便利。