Сброс соединения по пиру: ошибка записи сокета httpclient и геосервер - PullRequest
Новая
       14

Сброс соединения по пиру: ошибка записи сокета httpclient и геосервер

2 голосов
/ 22 марта 2019

Мне нужно загрузить сжатые шейп-файлы на GeoServer через REST.GeoServer предоставляет пример команды CURL для загрузки zip-файла шейп-файла следующим образом: 

curl -v -u admin:geoserver -XPUT -H "Content-type: application/zip" --data-binary @data.zip http://172.16.17.86:9090/geoserver/rest/workspaces/IDIRA6/datastores/Murrindindi/file.shp

Приведенная выше команда CURL работает нормально.Тем не менее, я хочу сделать эту загрузку в Java httpclient.Я новичок в Java, но для этого написал следующий код: 

import java.io.FileInputStream;
import java.io.InputStream;

import org.apache.http.HttpEntity;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.client.CredentialsProvider;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPut;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;

public class QuickStart {

    public static void main(String[] args) throws Exception {
    	String file="data.zip";       
        
        CredentialsProvider credsProvider = new BasicCredentialsProvider();
        credsProvider.setCredentials(
                AuthScope.ANY,
                new UsernamePasswordCredentials("admin", "geoserver"));
        
        CloseableHttpClient httpclient = HttpClients.custom()
                .setDefaultCredentialsProvider(credsProvider)
                .build();
        
        try {
            HttpPut httpPut = new HttpPut("http://172.16.17.86:9090/geoserver/rest/workspaces/IDIRA6/datastores/Murrindindi/file.shp");
            File file2 = new File("data.zip");                
            InputStream inputStream = new FileInputStream(file);          
            

            HttpEntity reqEntity = MultipartEntityBuilder.create()    
                    .addPart("file", new FileBody(file2, ContentType.DEFAULT_BINARY))                  
                    .addBinaryBody("upstream", inputStream, ContentType.create("application/zip"), "data.zip")
                    .build();

            httpPut.setEntity(reqEntity);

            System.out.println("executing request " + httpPost.getRequestLine());
            CloseableHttpResponse response = httpclient.execute(httpPut );
            try {
                System.out.println("----------------------------------------");
                System.out.println(response.getStatusLine());
                HttpEntity resEntity = response.getEntity();
                if (resEntity != null) {
                    System.out.println("Response content length: " + resEntity.getContentLength());
                }
                EntityUtils.consume(resEntity);
            } finally {
                response.close();
            }
        } finally {
            httpclient.close();
        }
    }

}

Когда я запускаю этот код, я получаю следующую ошибку: 

INFO: I/O exception (java.net.SocketException) caught when processing request to {}->http://172.16.17.86:9090: 
Connection reset by peer: socket write error
Exception in thread "main" org.apache.http.client.ClientProtocolException

Есть идеи, как это можно решить?Я проверил POST с простой аутентификацией, и это работает.Однако при попытке загрузить файл zip возникает проблема.

Вывод curl выглядит следующим образом: 

curl -v -u admin:geoserver -XPUT -H "Content-type: application/zip" --data-binary @Murrindindi_OvalCorrected.zip http://172.16.17.86:9090/geoserver/rest/workspaces/IDIRA6/datastores/Murrindindi/file.shp

* Trying 172.16.17.86...
* TCP_NODELAY set
* Connected to 172.16.17.86 (172.16.17.86) port 9090 (#0)
* Server auth using Basic with user 'shapeuploader'
> PUT /geoserver/rest/workspaces/IDIRA6/datastores/Murrindindi/file.shp HTTP/1.1
> Host: 172.16.17.86:9090
> Authorization: Basic c2hhcGV1cGxvYWRlcjo2OHJpOURwazdJR001bEo=
> User-Agent: curl/7.63.0
> Accept: */*
> Content-type: application/zip
> Content-Length: 7022252
> Expect: 100-continue
>
< HTTP/1.1 100
* We are completely uploaded and fine
< HTTP/1.1 201
< X-Frame-Options: SAMEORIGIN
< Content-Length: 0
< Date: Sat, 23 Mar 2019 23:04:27 GMT
* Connection #0 to host 172.16.17.86 left intact

1 Ответ

0 голосов
/ 25 марта 2019

После сравнения необработанных HTTP-данных, сгенерированных curl, с данными, сгенерированными вашим кодом, я обнаружил следующие различия:

  • curl не генерирует составной запрос
  • curl генерируетзаголовок Expect: 100-continue
  • curl использует приоритетную базовую аутентификацию

Следующий код должен быть эквивалентен этой команде curl, однако я не могу проверить ее с GeoServer.Я использовал свободный API apache-httpclient (то есть fluent-hc-4.5.7.jar).Дайте мне знать, если это работает. 

import java.io.File;
import org.apache.http.client.fluent.*;
import org.apache.http.entity.ContentType;

public class QuickStart {

    public static void main(String[] args) throws Exception {
        File file = new File("data.zip");
        Executor executor = Executor.newInstance()
                .auth("admin", "geoserver")
                .authPreemptive("172.16.17.86:9090");
        String response = executor.execute(Request.Put("http://172.16.17.86:9090/geoserver/rest/workspaces/IDIRA6/datastores/Murrindindi/file.shp")
                .useExpectContinue()
                .bodyFile(file, ContentType.create("application/zip")))
                .returnResponse()
                .toString();
        System.out.println(response);
    }

}
...