那些遇到过的问题

Azure Functions - 如何使用默认的“run()”方法中的“MultipartHttpServletRequest”类？

Dec*_*ard 1 java image-processing httprequest azure 

   public HttpResponseMessage run(
            @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.FUNCTION) HttpRequestMessage<Optional<String>> request,
            final ExecutionContext context) {
Run Code Online (Sandbox Code Playgroud)

Azure Functions(Java)规范中的 run() 方法只有 HttpRequestMessage 参数。我需要声明并使用 MultipartHttpServletRequest 从 multipart/data 请求中获取文件。我正在尝试，但看不到任何可以投射HttpRequestMessag到MultipartHttpServletRequest.

请给我一些建议。

HttpTrigger 规范是：https ://docs.microsoft.com/en-us/java/api/com.microsoft.azure.functions.annotation.httptrigger?view = azure-java-stable

-----------------------更新-------------------------

上传的图片仍然损坏。大小与原始大小相同，但看起来像这样：

在此处输入图片说明

我将粘贴整个代码。请检查一下。

函数类源：

public class HttpTriggerJava {
    private static final String storageConnectionString =
            "DefaultEndpointsProtocol=http;" +
                    "AccountName=00000;" +
                    "AccountKey=00000";

    @FunctionName("HttpTriggerJava")
    public HttpResponseMessage run(
            @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.FUNCTION) HttpRequestMessage<Optional<String>> request,
            final ExecutionContext context) throws Exception{

        context.getLogger().info("Java HTTP trigger processed a request.");

        CloudStorageAccount storageAccount = CloudStorageAccount.parse(storageConnectionString);
        CloudBlobClient blobClient = storageAccount.createCloudBlobClient();
        CloudBlobContainer container = blobClient.getContainerReference("contents");

        // here the "content-type" must be lower-case
        String contentType = request.getHeaders().get("content-type"); // Get content-type header

        String body = request.getBody().get(); // Get request body
        String boundary = contentType.split(";")[1].split("=")[1]; // Get boundary from content-type header
        int bufSize = 1024;
        InputStream in = new ByteArrayInputStream(body.getBytes()); // Convert body to an input stream
        MultipartStream multipartStream  = new MultipartStream(in, boundary.getBytes(), bufSize, null); // Using MultipartStream to parse body input stream
        boolean nextPart = multipartStream.skipPreamble();
        while(nextPart) {
            String header = multipartStream.readHeaders();
            System.out.println("");
            System.out.println("Headers:");
            System.out.println(header);
            System.out.println("Body:");
            if (header.contains("Content-Type: image/")) {
                int start = header.indexOf("filename=")+"filename=".length()+1;
                int end = header.indexOf("\r\n")-1;
                String filename = header.substring(start, end);
                System.out.println(filename);
                FileOutputStream fos = new FileOutputStream(filename);
                multipartStream.readBodyData(fos);

                File sourceFile = new File(filename);
                CloudBlockBlob blob = container.getBlockBlobReference(filename);
                blob.uploadFromFile(sourceFile.getAbsolutePath());

            } else {
                multipartStream.readBodyData(System.out);
            }
            System.out.println("");
            nextPart = multipartStream.readBoundary();
        }

        return request.createResponseBuilder(HttpStatus.OK).body("Success").build();
    }
}
Run Code Online (Sandbox Code Playgroud)

而 HTML 是：

<head>
<script src="https://code.jquery.com/jquery-3.3.1.min.js"></script>
<script>
$(document).ready(function () {
    $("#myFile").change(function() {
      readURL(this);
    });

    $("#submit").click(function (event) {
        event.preventDefault();

        var form = $('#form')[0];
        var data = new FormData(form);

        $("#submit").prop("disabled", true);

        $.ajax({
            type: "POST",
            enctype: 'multipart/form-data',
            url: $(form).attr('action'),
            data: data,
            processData: false,
            contentType: false,
            cache: false,
            timeout: 600000,
            success: function (data) {
                $("#result").text(data);
                console.log("SUCCESS : ", data);
                $("#submit").prop("disabled", false);
            },
            error: function (e) {
                $("#result").text(e.responseText);
                console.log("ERROR : ", e);
                $("#submit").prop("disabled", false);
            }
        });
    });
});
function readURL(input) {
  if (input.files && input.files[0]) {
    var reader = new FileReader();

    reader.onload = function(e) {
      $('#blah').attr('src', e.target.result).show();
    }
    reader.readAsDataURL(input.files[0]);
  }
}
</script>
</head>

<body>
    <form id=form
        action="http://doopediafunctiontest.azurewebsites.net/api/HttpTriggerJava?code=00000"
        method="post" enctype="multipart/form-data">
        <p>
            <br /> <br /> <strong>My file:</strong><br /> <input type="file" id="myFile" name="myFile">
            <br /><img id="blah" src="#" alt="your image" style="display:none" />
        </p>
        <input id=submit type="submit" value="upload to Blob Storage">
    </form>

    <div id=result></div>
</body>
Run Code Online (Sandbox Code Playgroud)

我通过十六进制编辑器比较原始图像和损坏的图像。而且我发现一些随机的十六进制更改为3f，应该是原因。也许有一些编码问题。但是我该如何解决这个问题？

（请点击放大） 在此处输入图片说明

Pet*_*Pan 5

听起来您想通过multipart/form-data如下所示的 HTML 表单使用 Java 中的 Http 触发器将文件上传到 Azure 函数。

<form method="POST" enctype="multipart/form-data" action="https://<your function app>/api/HttpTrigger-Java">
  File to upload: <input type="file" name="upfile"><br/>
  Notes about the file: <input type="text" name="note"><br/>
  <br/>
  <input type="submit" value="Press"> to upload the file!
</form>
Run Code Online (Sandbox Code Playgroud)

然而，没有任何类实现了接口HttpRequestMessage<T>，似乎不投HttpRequestMessage来HttpServletRequest后，我研究了GitHub库的源代码Azure/azure-functions-java-library。

根据我的经验，唯一的方法是解析multipart/form-data请求的标头和正文以获取文件。有一个类似的 SO 线程库的答案以及从问题所有者发布的输入流中解析多部分/表单数据的示例，其中包括使用Apache Commons FileUploadMultipartStream类的代码，该类在我测试后起作用。

这是从 Azure Function for Java 收到Content-Type的multipart/form-data请求的标头和正文。

标题 Content-Type

content-type: multipart/form-data; boundary=----WebKitFormBoundaryT2TWuevX3RIYWRQF
Run Code Online (Sandbox Code Playgroud)

multipart/form-data 请求体

------WebKitFormBoundaryT2TWuevX3RIYWRQF
Content-Disposition: form-data; name="upfile"; filename="z.txt"
Content-Type: text/plain
1234
ABCD
------WebKitFormBoundaryT2TWuevX3RIYWRQF
Content-Disposition: form-data; name="note"
test.txt
------WebKitFormBoundaryT2TWuevX3RIYWRQF--
Run Code Online (Sandbox Code Playgroud)

这是我获取文件的示例代码。

@FunctionName("HttpTrigger-Java")
public HttpResponseMessage run(
        @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS) HttpRequestMessage<Optional<String>> request,
        final ExecutionContext context) {
    String contentType = request.getHeaders().get("content-type"); // Get content-type header
    // here the "content-type" must be lower-case
    String body = request.getBody().get(); // Get request body
    InputStream in = new ByteArrayInputStream(body.getBytes()); // Convert body to an input stream
    String boundary = contentType.split(";")[1].split("=")[1]; // Get boundary from content-type header
    int bufSize = 1024;
    MultipartStream multipartStream  = new MultipartStream(in, boundary.getBytes(), bufSize, null); // Using MultipartStream to parse body input stream
    // the code below comes from the SO thread above
    // you can fetch a file content from readBodyData 
    // after the headers Content-Disposition: form-data; name="upfile"; filename="test.txt" \n Content-Type: text/plain
    boolean nextPart = multipartStream.skipPreamble();
    while (nextPart) {
        String header = multipartStream.readHeaders();
        System.out.println("");
        System.out.println("Headers:");
        System.out.println(header);
        System.out.println("Body:");
        multipartStream.readBodyData(System.out);
        System.out.println("");
        nextPart = multipartStream.readBoundary();
    }
    return request.createResponseBuilder(HttpStatus.OK).body("Success").build();
}
Run Code Online (Sandbox Code Playgroud)

上面代码在终端的输出：

Headers:
Content-Disposition: form-data; name="upfile"; filename="test.txt"
Content-Type: text/plain


Body:
1234
ABCD


Headers:
Content-Disposition: form-data; name="note"


Body:
test.txt
Run Code Online (Sandbox Code Playgroud)

更新：如果上传图片，上面代码的输出如下。

Headers:
Content-Disposition: form-data; name="upfile"; filename="test.jpg"
Content-Type: image/png


Body:
<the binary content of an image>
Run Code Online (Sandbox Code Playgroud)

因此，您可以解析标头以获取用于存储它的filename值FileOutputStream，如下面的代码。

while(nextPart) {
    String header = multipartStream.readHeaders();
    System.out.println("");
    System.out.println("Headers:");
    System.out.println(header);
    System.out.println("Body:");
    if (header.contains("Content-Type: image/")) {
        int start = header.indexOf("filename=")+"filename=".length()+1;
        int end = header.indexOf("\r\n")-1;
        String filename = header.substring(start, end);
        System.out.println(filename);
        FileOutputStream fos = new FileOutputStream(filename);
        multipartStream.readBodyData(fos);
    } else {
        multipartStream.readBodyData(System.out);
    }
    System.out.println("");
    nextPart = multipartStream.readBoundary();
}
Run Code Online (Sandbox Code Playgroud)

更新 2：

我发现 Azure Function for Java 似乎存在一个问题，这可能是一个错误，在上传二进制文件时会丢失一些字节，但上传文本文件时不会发生这种情况。因此，一个变通的解决方案是在浏览器中将上传文件转换为 base64 字符串以发布到 Azure Function，并将上传的 base64 内容转换为 Azure Function 中的原始二进制文件。

这是我的测试 HTML 代码。

File to upload: <input type="file" name="upfile" id="fileup"><br/>
<form method="POST" enctype="multipart/form-data" action="http://localhost:7071/api/HttpTrigger-Java">
  Notes about the file: <input type="text" name="note"><br/>
  <input type="hidden" name="file_base64" id="file_base64"><br/>
  <input type="submit" value="Press"> to upload the file!
</form>
<script src="http://ajax.googleapis.com/ajax/libs/jquery/1.9.1/jquery.min.js">/script>
<script>
$(document).ready(function(){
    $("#fileup").change(function(){
        var v = $(this).val();
        var reader = new FileReader();
        reader.readAsDataURL(this.files[0]);
        reader.onload = function(e){
            console.log(e.target.result);
            $('#file_base64').val(e.target.result);
        };
    });
});
</script>
Run Code Online (Sandbox Code Playgroud)

上面的表单将发布 base64 文件块的标题和正文，如下所示。

Header:
Content-Disposition: form-data; name="file_base64"
Body:
data:image/jpg;base64,iVBORw0KGgoAAAANSUhEUgAAB.............
Run Code Online (Sandbox Code Playgroud)

我在 Azure 函数中的 Java 代码：

import java.io.ByteArrayOutputStream;
import java.util.Base64;

if (header.equals("Content-Disposition: form-data; name=\"file_base64\"")) {
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    multipartStream.readBodyData(baos);
    String content = baos.toString();
    // System.out.println(content);
    int index = content.indexOf(",")+1; // Get the index of base64 string in data-uploaded string
    byte[] imgBytes = Base64.getDecoder().decode(content.substring(index)); // convert image base64 string to image byte arrays
    ....
    // To upload image byte array to Blob Storage
    // You can get the upload image filename from the form input `note`, please notes the order of form input elements.
} else {
    multipartStream.readBodyData(System.out);
}
Run Code Online (Sandbox Code Playgroud)

归档时间：

查看次数：

2299 次

最近记录：

5 年，4 月 前
库和从输入流解析multipart/form-data的示例 7
更多相关链接
相关归档
在Java中将文件转换为byte [] 711
Java中的全局变量 202
是否在Java中定义了Newline常量,如C#中的Environment.Newline？ 187
使用EL和JSTL访问枚举值 103
如何将Java枚举转换为流？ 56
强制应用程序启动Azure Web角色 6
使用经过转换的 web.config 发布后更新 Azure CSPKG 6
Azure网站连接保持活跃 6
使用 OWIN Pipeline 进行多租户身份验证 5
将 webapp 部署到 Azure 时加载 msvcr100.dll 时出错（错误代码：126） 5
难疑归档
如何使用Curl从终端/命令行发布JSON数据到测试Spring REST？ 2606
如何检查字符串是否为数字(浮点数)？ 1519
在YAML中,如何在多行中断字符串？ 1388
如何将字节数组转换为十六进制字符串,反之亦然？ 1313
"无法找到或加载主类"是什么意思？ 1277
在HTML中嵌入PDF的推荐方法？ 1128
如何在div中垂直对齐文本？ 1102
自定义HTTP标头:命名约定 1051
#Hibernate hbm2ddl.auto配置的可能值是什么,它们做了什么 1046
如何将div中的绝对定位元素居中？ 1034