java - 在休息服务中收到多部分请求时会出现问题

Question

我正在尝试通过 angularjs 使用多部分请求上传文件，并在我的 Rest 服务上接收内容。在过去 4 天尝试了几种帮助并且让自己疲惫不堪之后，我在这里提出这个问题。如果您可以微调我的方法或建议其他方法，我将不胜感激(我愿意接受任何可能有效的建议，因为我现在没有想法)。

只是一个指针，我尝试编写一个servlet来读取通过angularjs发送的多部分请求，并且我正确地得到了这些部分。但我仍然将 Angular 代码放在这里供您引用，因为我在 Angular 和休息方面都不是更好。

以下是文件上传的 html 摘录:

<div>
    <input type="file" data-file-upload multiple/>
    <ul>
        <li data-ng-repeat="file in files">{{file.name}}</li>
    </ul>
</div>

以下是 angularjs 指令代码摘录:

.directive('fileUpload', function () {
    return {
        scope: true,        //create a new scope
        link: function (scope, el, attrs) {
            el.bind('change', function (event) {
                var files = event.target.files;
                //iterate files since 'multiple' may be specified on the element
                for (var i = 0;i<files.length;i++) {
                    //emit event upward
                    scope.$emit("fileSelected", { file: files[i] });
                }                                       
            });
        }
    };
})

以下是 angularjs Controller 代码摘录

    //a simple model to bind to and send to the server
    $scope.model = {
        name: "test",
        comments: "TC"
    };

    //an array of files selected
    $scope.files = [];

    //listen for the file selected event
    $scope.$on("fileSelected", function (event, args) {
        $scope.$apply(function () {            
            //add the file object to the scope's files collection
            $scope.files.push(args.file);
        });
    });

    //the save method
    $scope.save = function() {
        $http({
            method: 'POST',
            url: "/services/testApp/settings/api/vsp/save",
            headers: { 'Content-Type': undefined },
            transformRequest: function (data) {
                var formData = new FormData();
                formData.append("model", angular.toJson(data.model));
                for (var i = 0; i < data.files.length; i++) {
                    formData.append("file" , data.files[i]);
                }
                return formData;
            },
            data: { model: $scope.model, files: $scope.files }
        }).
        success(function (data, status, headers, config) {
            alert("success!");
        }).
        error(function (data, status, headers, config) {
            alert("failed!");
        });
    };

这是我的休息服务代码:

@Path("/vsp")
public class SampleService{

    @Path("/save")
    @POST
    @Consumes(MediaType.MULTIPART_FORM_DATA)
    public void saveProfile(@FormParam("model") String theXml,
            @FormParam("file") List<File> files) throws ServletException, IOException {
        final String response = "theXML: " + theXml + " and " + files.size() + " file(s) received";
        System.out.println(response);
    }

}

这是回应: theXML: {"name":"test","comments":"TC"} 和 1 个文件已收到

问题是文件的内容来自路径，我无法获取输入流来读取文件。我什至尝试使用

  new ByteArrayInputStream(files.get(0).getPath().getBytes())

如果内容是文本(如 txt 或 csv)，则它可以工作，但如果内容是任何其他文件(如 xls 等)，则检索到的内容将损坏且无法使用。还尝试使用 Jeresy api，但结果相同。我错过了什么明显的事情吗？如有任何帮助，我们将不胜感激。

Answer 1

我发现了一些链接，但没有一个对我有用。所以最后，我必须编写一个 servlet 来读取多部分请求，并将文件和请求参数添加为请求属性。设置请求属性后，我将请求转发到我的 Rest 服务。

仅供记录，如果一次读取多部分请求以提取部分，则该请求将不会在转发的 servlet 中包含这些部分。所以我必须在转发之前将它们设置为请求属性。

这是 servlet 代码:

public class UploadServlet extends HttpServlet {

    @Override
    protected void doPost(HttpServletRequest request,
            HttpServletResponse response) throws ServletException, IOException {

        // process only if its multipart content
        RequestContext reqContext = new ServletRequestContext(request);
        if (ServletFileUpload.isMultipartContent(reqContext)) {
            try {
                List<FileItem> multiparts = new ServletFileUpload(
                        new DiskFileItemFactory()).parseRequest(request);
                ArrayList<FileItem> fileList = new ArrayList<FileItem>();
                request.setAttribute("files", fileList);
                for (FileItem item : multiparts) {
                    if (!item.isFormField()) {
                        fileList.add(item);
                    } else {
                        request.setAttribute(item.getFieldName(),
                                item.getString());
                    }
                }

                request.setAttribute("message", "success");
            } catch (Exception ex) {
                request.setAttribute("message", "fail"
                        + ex);
            }

        } else {
            request.setAttribute("message",
                    "notMultipart");
        }

        System.out.println(request.getRequestURI().substring(request.getRequestURI().indexOf("upload")+6));

        String forwardUri = "/api" + request.getRequestURI().substring(request.getRequestURI().indexOf("upload")+6);

        request.getRequestDispatcher(forwardUri)
                .forward(request, response);

    }

}

任何以/upload/ 开头的请求都将被 servlet 接收，一旦设置了属性，它们将被转发到/ api/<其余 API 路径>.

在其余 api 中，我使用以下代码来检索参数。

@Path("/vsp")
public class SampleService{

    @Path("/save")
    @POST
    @Consumes(MediaType.MULTIPART_FORM_DATA)
    public void saveProfile(@Context HttpServletRequest request, 
            @Context HttpServletResponse response) throws Exception {

        // getting the uploaded files
        ArrayList<FileItem> items = (ArrayList<FileItem>)request.getAttribute("files");
        FileItem item = items.get(0);
        String name = new File(item.getName()).getName();
        item.write( new File("C:" + File.separator + name));

        // getting the data
        String modelString = (String)request.getAttribute("model");

        // Getting JSON from model string
        JSONObject obj = JSONObject.parse(modelString);

        String responseString = "model.name: " + obj.get("name") + " and " + items.size() + " file(s) received";
        System.out.println(responseString);
    }

}