spark java: comment gérer l'entrée de données multipart/form?

j'utilise spark pour développer une application web; le problème survient lorsque je veux télécharger un fichier:

public final class SparkTesting
{
    public static void main(final String... args)
    {
        Spark.staticFileLocation("/site");

        Spark.port(8080);

        Spark.post("/upload", (request, response) -> {
            final Part uploadedFile = request.raw().getPart("uploadedFile");
            final Path path = Paths.get("/tmp/meh");
            try (final InputStream in = uploadedFile.getInputStream()) {
                Files.copy(in, path);
            }

            response.redirect("/");
            return "OK";
        });
    }
}

Mais j'obtiens cette erreur:

[qtp509057984-36] ERROR spark.webserver.MatcherFilter - 
java.lang.IllegalStateException: No multipart config for servlet
    at org.eclipse.jetty.server.Request.getPart(Request.java:2039)
    at javax.servlet.http.HttpServletRequestWrapper.getPart(HttpServletRequestWrapper.java:361)
    at com.github.fge.grappa.debugger.web.SparkTesting.lambda$main(SparkTesting.java:20)
    at com.github.fge.grappa.debugger.web.SparkTesting$$Lambda/920011586.handle(Unknown Source)
    at spark.SparkBase.handle(SparkBase.java:264)
    at spark.webserver.MatcherFilter.doFilter(MatcherFilter.java:154)
    at spark.webserver.JettyHandler.doHandle(JettyHandler.java:60)
    at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:179)
    at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:136)
    at org.eclipse.jetty.server.handler.HandlerList.handle(HandlerList.java:52)
    at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:97)
    at org.eclipse.jetty.server.Server.handle(Server.java:451)
    at org.eclipse.jetty.server.HttpChannel.run(HttpChannel.java:252)
    at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:266)
    at org.eclipse.jetty.io.AbstractConnection$ReadCallback.run(AbstractConnection.java:240)
    at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:596)
    at org.eclipse.jetty.util.thread.QueuedThreadPool.run(QueuedThreadPool.java:527)
    at java.lang.Thread.run(Thread.java:745)

Et même si j'essaie de le spécifier le type de manière explicite, comme dans:

Spark.post("/upload", "multipart/form-data", etc etc)

il échouera toujours.

je pourrais probablement trouver une bibliothèque pour analyser multipart/form-data, saisir tout le contenu et juste analyser moi-même, mais ce serait du gâchis.

puis-je configurer étincelle gérer ce cas?

10
demandé sur fge 2015-03-31 19:18:45

4 réponses

La réponse fournie par Yao Kai est correct sauf que lors de l'utilisation:

request.raw().setAttribute("org.eclipse.multipartConfig", multipartConfigElement);

utiliser ceci à la place:

request.raw().setAttribute("org.eclipse.jetty.multipartConfig", multipartConfigElement);
5
répondu HaiderAgha 2015-09-28 08:19:08

en ajoutant quelques lignes de code pour ajouter la configuration multipart, vous pouvez gérer les données multipart / form sans bibliothèque externe:

public Object handle(Request request, Response response) {
    MultipartConfigElement multipartConfigElement = new MultipartConfigElement("/tmp");
    request.raw().setAttribute("org.eclipse.multipartConfig", multipartConfigElement);
    ....
    Part file = request.raw().getPart("file"); //file is name of the upload form
}

Source:http://deniz.dizman.org/file-uploads-using-spark-java-micro-framework/

4
répondu Kai Yao 2015-05-17 18:34:08

j'ai utilisé apache commons fileupload pour gérer cela.

post("/upload", (req, res) -> {
final File upload = new File("upload");
if (!upload.exists() && !upload.mkdirs()) {
    throw new RuntimeException("Failed to create directory " + upload.getAbsolutePath());
}

// apache commons-fileupload to handle file upload
DiskFileItemFactory factory = new DiskFileItemFactory();
factory.setRepository(upload);
ServletFileUpload fileUpload = new ServletFileUpload(factory);
List<FileItem> items = fileUpload.parseRequest(req.raw());

// image is the field name that we want to save
FileItem item = items.stream()
                .filter(e -> "image".equals(e.getFieldName()))
                .findFirst().get();
String fileName = item.getName();
item.write(new File(dir, fileName));
halt(200);
return null;
});

voir https://github.com/perwendel/spark/issues/26#issuecomment-95077039

4
répondu shauvik 2015-09-02 20:39:42

j'ai trouvé l'exemple complet ici: https://github.com/tipsy/spark-file-upload/blob/master/src/main/java/UploadExample.java

import spark.*;
import javax.servlet.*;
import javax.servlet.http.*;
import java.io.*;
import java.nio.file.*;
import static spark.Spark.*;
import static spark.debug.DebugScreen.*;

public class UploadExample {

    public static void main(String[] args) {
        enableDebugScreen();

        File uploadDir = new File("upload");
        uploadDir.mkdir(); // create the upload directory if it doesn't exist

        staticFiles.externalLocation("upload");

        get("/", (req, res) ->
                  "<form method='post' enctype='multipart/form-data'>" // note the enctype
                + "    <input type='file' name='uploaded_file' accept='.png'>" // make sure to call getPart using the same "name" in the post
                + "    <button>Upload picture</button>"
                + "</form>"
        );

        post("/", (req, res) -> {

            Path tempFile = Files.createTempFile(uploadDir.toPath(), "", "");

            req.attribute("org.eclipse.jetty.multipartConfig", new MultipartConfigElement("/temp"));

            try (InputStream input = req.raw().getPart("uploaded_file").getInputStream()) { // getPart needs to use same "name" as input field in form
                Files.copy(input, tempFile, StandardCopyOption.REPLACE_EXISTING);
            }

            logInfo(req, tempFile);
            return "<h1>You uploaded this image:<h1><img src='" + tempFile.getFileName() + "'>";

        });

    }

    // methods used for logging
    private static void logInfo(Request req, Path tempFile) throws IOException, ServletException {
        System.out.println("Uploaded file '" + getFileName(req.raw().getPart("uploaded_file")) + "' saved as '" + tempFile.toAbsolutePath() + "'");
    }

    private static String getFileName(Part part) {
        for (String cd : part.getHeader("content-disposition").split(";")) {
            if (cd.trim().startsWith("filename")) {
                return cd.substring(cd.indexOf('=') + 1).trim().replace("\"", "");
            }
        }
        return null;
    }

}

Veuillez noter que dans cet exemple, pour itérer sur tous les fichiers, utilisez javax.servlet.http.HttpServletRequest#getParts. Aussi dans cet exemple, au lieu d'analyser le nom du fichier, vous pouvez simplement l'obtenir en utilisant javax.servlet.http.Part#getSubmittedFileName. Et aussi n'oubliez pas de fermer le ruisseau que vous obtenez. Et aussi supprimer le fichier en utilisant javax.servlet.http.Part#delete si nécessaire

1
répondu alex.b 2017-08-30 13:39:47