Java Http Client для загрузки файла через POST - PullRequest
Новая
       24

Java Http Client для загрузки файла через POST

14 голосов
/ 02 августа 2011

Я разрабатываю клиент J2ME, который должен загрузить файл в сервлет с использованием HTTP.

Часть сервлета покрыта с помощью Apache Commons FileUpload 

protected void doPost(HttpServletRequest request, HttpServletResponse response) 
{       

    ServletFileUpload upload = new ServletFileUpload();
    upload.setSizeMax(1000000);

    File fileItems = upload.parseRequest(request);

    // Process the uploaded items
    Iterator iter = fileItems.iterator();
    while (iter.hasNext()) {
        FileItem item = (FileItem) iter.next();
        File file = new File("\files\\"+item.getName());
        item.write(file);
    }
}

Похоже, что Commons Upload может загружать только многокомпонентный файл, но без приложения / octect-stream.

Но для клиентской стороны нет классов Multipart, и в этом случае невозможно использовать любую библиотеку HttpClient.

Другой вариант может заключаться в использовании HTTP Chunk upload, но я не нашел четкого примера того, как это можно реализовать, особенно на стороне сервлета.

Мой выбор: - Реализация сервлета для загрузки чанка http - Реализовать необработанный клиент для создания http multipart

Я не знаю, как реализовать ни один из вышеперечисленных вариантов. Любое предложение?

Ответы [ 5 ]

28 голосов
/ 02 августа 2011

Отправка файлов по HTTP предполагается в кодировке multipart/form-data.С вашей частью сервлета все в порядке, так как она уже использует Apache Commons FileUpload для анализа multipart/form-data запроса.

Однако ваша клиентская часть явно не в порядке, так как вы, похоже, пишете файлсырье в теле запроса.Вы должны убедиться, что ваш клиент отправляет правильный multipart/form-data запрос.Как именно это сделать, зависит от API, который вы используете для отправки HTTP-запроса.Если это простая ваниль java.net.URLConnection, то вы можете найти конкретный пример где-то в нижней части этого ответа .Если для этого вы используете Apache HttpComponents Client , то вот конкретный пример: 

HttpClient client = new DefaultHttpClient();
HttpPost post = new HttpPost(url);

MultipartEntity entity = new MultipartEntity();
entity.addPart("file", new FileBody(file));
post.setEntity(entity);

HttpResponse response = client.execute(post);
// ...

Несвязанный с конкретной проблемой, есть ошибкав коде на стороне сервера: 

File file = new File("\files\\"+item.getName());
item.write(file);

Это может перезаписать любой ранее загруженный файл с тем же именем.Я бы предложил вместо этого использовать File#createTempFile(). 

String name = FilenameUtils.getBaseName(item.getName());
String ext = FilenameUtils.getExtension(item.getName());
File file = File.createTempFile(name + "_", "." + ext, new File("/files"));
item.write(file);
10 голосов
/ 30 января 2018

Следующий код может быть использован для загрузки файла с HTTP Client 4.x (над ответом используется MultipartEntity, который больше не поддерживается), httpmime.

getClient() можно заменить на HttpClients.createDefault().

0 голосов
/ 26 июня 2019

Пожалуйста, найдите пример рабочего примера для функции выгрузки файлов с использованием HttpClient в Java. 

package test;

import java.io.File;
import java.io.IOException;
import java.io.UnsupportedEncodingException;

import org.apache.http.HttpResponse;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.FileEntity;
import org.apache.http.impl.client.DefaultHttpClient;

public class fileUpload {
private static void executeRequest(HttpPost httpPost) {
    try {
        HttpClient client = new DefaultHttpClient();
        HttpResponse response = client.execute(httpPost);
        System.out.println("Response Code:  " + response.getStatusLine().getStatusCode());
    } catch (UnsupportedEncodingException e) {
        e.printStackTrace();
    } catch (ClientProtocolException e) {
        e.printStackTrace();
    } catch (IllegalStateException e) {
        e.printStackTrace();
    } catch (IOException e) {
        e.printStackTrace();
    }
}

public void executeMultiPartRequest(String urlString, File file) throws IOException {
    HttpPost postRequest = new HttpPost(urlString);
    postRequest = addHeader(postRequest, "Access Token");
    try {
        postRequest.setEntity(new FileEntity(file));
    } catch (Exception ex) {
        ex.printStackTrace();
    }
    executeRequest(postRequest);
}

private static HttpPost addHeader(HttpPost httpPost, String accessToken) {
    httpPost.addHeader("Accept", "application/json;odata=verbose");
    httpPost.setHeader("Authorization", "Bearer " + accessToken);
    return httpPost;
}

public static void main(String args[]) throws IOException {
    fileUpload fileUpload = new fileUpload();
    File file = new File("C:\\users\\bgulati\\Desktop\\test.docx");
    fileUpload.executeMultiPartRequest(
            "Here Goes the URL", file);

}
}
0 голосов
/ 06 марта 2015

Спасибо за весь код, который я отрубил ... Вот немного назад. 

Gradle

compile "org.apache.httpcomponents:httpclient:4.4"  
compile "org.apache.httpcomponents:httpmime:4.4"



import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.StringWriter;
import java.util.Map;

import org.apache.commons.io.IOUtils;
import org.apache.http.HttpEntity;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.entity.mime.content.FileBody;
import org.apache.http.entity.mime.content.StringBody;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;


public class HttpClientUtils {

    public static String post(String postUrl, Map<String, String> params,
            Map<String, String> files) throws ClientProtocolException,
            IOException {
        CloseableHttpResponse response = null;
        InputStream is = null;
        String results = null;
        CloseableHttpClient httpclient = HttpClients.createDefault();

        try {

            HttpPost httppost = new HttpPost(postUrl);

            MultipartEntityBuilder builder = MultipartEntityBuilder.create();

            if (params != null) {
                for (String key : params.keySet()) {
                    StringBody value = new StringBody(params.get(key),
                            ContentType.TEXT_PLAIN);
                    builder.addPart(key, value);
                }
            }

            if (files != null && files.size() > 0) {
                for (String key : files.keySet()) {
                    String value = files.get(key);
                    FileBody body = new FileBody(new File(value));
                    builder.addPart(key, body);
                }
            }

            HttpEntity reqEntity = builder.build();
            httppost.setEntity(reqEntity);

            response = httpclient.execute(httppost);
            // assertEquals(200, response.getStatusLine().getStatusCode());

            HttpEntity entity = response.getEntity();
            if (entity != null) {
                is = entity.getContent();
                StringWriter writer = new StringWriter();
                IOUtils.copy(is, writer, "UTF-8");
                results = writer.toString();
            }

        } finally {
            try {
                if (is != null) {
                    is.close();
                }
            } catch (Throwable t) {
                // No-op
            }

            try {
                if (response != null) {
                    response.close();
                }
            } catch (Throwable t) {
                // No-op
            }

            httpclient.close();
        }

        return results;
    }

    public static String get(String getStr) throws IOException,
            ClientProtocolException {
        CloseableHttpResponse response = null;
        InputStream is = null;
        String results = null;
        CloseableHttpClient httpclient = HttpClients.createDefault();

        try {
            HttpGet httpGet = new HttpGet(getStr);
            response = httpclient.execute(httpGet);

            assertEquals(200, response.getStatusLine().getStatusCode());

            HttpEntity entity = response.getEntity();
            if (entity != null) {
                is = entity.getContent();
                StringWriter writer = new StringWriter();
                IOUtils.copy(is, writer, "UTF-8");
                results = writer.toString();
            }

        } finally {

            try {
                if (is != null) {
                    is.close();
                }
            } catch (Throwable t) {
                // No-op
            }

            try {
                if (response != null) {
                    response.close();
                }
            } catch (Throwable t) {
                // No-op
            }

            httpclient.close();
        }

        return results;
    }

}
0 голосов
/ 02 августа 2011

Без подробных сведений ваш код выглядит нормально.

Теперь вам нужна сторона сервера.Я бы порекомендовал вам использовать Jakarta FileUpload , поэтому вам не нужно ничего реализовывать.Просто разверните и настройте.

...