HTTP-ответ 411: длина, необходимая для связи с - PullRequest
Новая
       33

HTTP-ответ 411: длина, необходимая для связи с

4 голосов
/ 27 февраля 2020

Я пытаюсь отправить запрос soap и получаю сообщение об ошибке HTTP 411 error из-за большего размера запроса soap. В большинстве случаев soap длина запроса превышает 8k.

СООБЩЕНИЕ ОБ ОШИБКЕ 

2020-02-27 08:26:09,618 WARNING [100] [org.apache.cxf.phase.PhaseInterceptorChain] (my-thread-1) Interceptor for {http://example.com}CreationService#{http://cxf.apache.org/jaxws/dispatch}Invoke has thrown exception, unwinding now: org.apache.cxf.interceptor.Fault: Could not send Message.
    at org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndingInterceptor.handleMessage(MessageSenderInterceptor.java:64) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:308) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.endpoint.ClientImpl.doInvoke(ClientImpl.java:514) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:423) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:324) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:277) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.endpoint.ClientImpl.invokeWrapped(ClientImpl.java:312) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.jaxws.DispatchImpl.invoke(DispatchImpl.java:327) [cxf-rt-frontend-jaxws-3.1.6.jar:3.1.6]
    at org.apache.cxf.jaxws.DispatchImpl.invoke(DispatchImpl.java:246) [cxf-rt-frontend-jaxws-3.1.6.jar:3.1.6]
    ...
Caused by: org.apache.cxf.transport.http.HTTPException: HTTP response '411: Length Required' when communicating with http://192.100.110.17:8504/example/services/CreationREQ
    at org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.doProcessResponseCode(HTTPConduit.java:1600) [cxf-rt-transports-http-3.1.6.jar:3.1.6]
    at org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.handleResponseInternal(HTTPConduit.java:1607) [cxf-rt-transports-http-3.1.6.jar:3.1.6]
    at org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.handleResponse(HTTPConduit.java:1551) [cxf-rt-transports-http-3.1.6.jar:3.1.6]
    at org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.close(HTTPConduit.java:1348) [cxf-rt-transports-http-3.1.6.jar:3.1.6]
    at org.apache.cxf.io.CacheAndWriteOutputStream.postClose(CacheAndWriteOutputStream.java:56) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.io.CachedOutputStream.close(CachedOutputStream.java:216) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.transport.AbstractConduit.close(AbstractConduit.java:56) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.transport.http.HTTPConduit.close(HTTPConduit.java:651) [cxf-rt-transports-http-3.1.6.jar:3.1.6]
    at org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndingInterceptor.handleMessage(MessageSenderInterceptor.java:62) [cxf-core-3.1.6.jar:3.1.6]
    ... 84 more

2020-02-27 08:26:09,621 ERROR [100] [org.jboss.as.ejb3.invocation] (my-thread-1) JBAS014134: EJB invocation failed on DaoFacade component for method public abstract void com.example.addon.core.dao.facade.DaoFacadeInterface.invokeExternalService(com.example.db.models.Synchronizable) throws com.example.addon.addon.SOAPException: javax.ejb.EJBException: javax.xml.ws.WebServiceException: Could not send Message.
    ...
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [rt.jar:1.7.0_79]
    at java.lang.Thread.run(Thread.java:745) [rt.jar:1.7.0_79]
Caused by: javax.xml.ws.WebServiceException: Could not send Message.
    at org.apache.cxf.jaxws.DispatchImpl.mapException(DispatchImpl.java:272) [cxf-rt-frontend-jaxws-3.1.6.jar:3.1.6]
    at org.apache.cxf.jaxws.DispatchImpl.invoke(DispatchImpl.java:334) [cxf-rt-frontend-jaxws-3.1.6.jar:3.1.6]
    at org.apache.cxf.jaxws.DispatchImpl.invoke(DispatchImpl.java:246) [cxf-rt-frontend-jaxws-3.1.6.jar:3.1.6]
    ...
    at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:288) [jboss-invocation-1.1.2.Final-redhat-1.jar:1.1.2.Final-redhat-1]
    at org.jboss.as.ejb3.tx.CMTTxInterceptor.invokeInOurTx(CMTTxInterceptor.java:280) [jboss-as-ejb3-7.5.0.Final-redhat-21.jar:7.5.0.Final-redhat-21]
    ... 40 more
Caused by: org.apache.cxf.transport.http.HTTPException: HTTP response '411: Length Required' when communicating with http://192.100.110.17:8504/example/services/CreationREQ
    at org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.doProcessResponseCode(HTTPConduit.java:1600) [cxf-rt-transports-http-3.1.6.jar:3.1.6]
    at org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.handleResponseInternal(HTTPConduit.java:1607) [cxf-rt-transports-http-3.1.6.jar:3.1.6]
    at org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.handleResponse(HTTPConduit.java:1551) [cxf-rt-transports-http-3.1.6.jar:3.1.6]
    at org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.close(HTTPConduit.java:1348) [cxf-rt-transports-http-3.1.6.jar:3.1.6]
    at org.apache.cxf.io.CacheAndWriteOutputStream.postClose(CacheAndWriteOutputStream.java:56) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.io.CachedOutputStream.close(CachedOutputStream.java:216) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.transport.AbstractConduit.close(AbstractConduit.java:56) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.transport.http.HTTPConduit.close(HTTPConduit.java:651) [cxf-rt-transports-http-3.1.6.jar:3.1.6]
    at org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndingInterceptor.handleMessage(MessageSenderInterceptor.java:62) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:308) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.endpoint.ClientImpl.doInvoke(ClientImpl.java:514) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:423) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:324) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:277) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.endpoint.ClientImpl.invokeWrapped(ClientImpl.java:312) [cxf-core-3.1.6.jar:3.1.6]
    at org.apache.cxf.jaxws.DispatchImpl.invoke(DispatchImpl.java:327) [cxf-rt-frontend-jaxws-3.1.6.jar:3.1.6]
    ... 77 more

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

import static java.lang.Boolean.FALSE;
import static java.lang.Boolean.TRUE;

import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.Reader;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.security.GeneralSecurityException;

import javax.xml.namespace.QName;
import javax.xml.soap.MessageFactory;
import javax.xml.soap.SOAPException;
import javax.xml.soap.SOAPMessage;
import javax.xml.soap.SOAPPart;
import javax.xml.transform.stream.StreamSource;
import javax.xml.ws.BindingProvider;
import javax.xml.ws.Dispatch;
import javax.xml.ws.Service;
import javax.xml.ws.soap.SOAPBinding;

import org.apache.cxf.endpoint.Client;
import org.apache.cxf.jaxws.DispatchImpl;
import org.apache.cxf.transport.http.HTTPConduit;
import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
import org.apache.log4j.Logger;

public class SOAPClient {

    private static final String CXF_RESPONSE_CODE = "org.apache.cxf.message.Message.RESPONSE_CODE";
    private static final String JAXRS_RESPONSE_CODE = "javax.xml.ws.http.response.code";
    private static Logger logger = Logger.getLogger(SOAPClient.class);

    /**
     * Nested class only accessible after {@link SOAPClient#builder()} method call
     * <p>
     * It provides a Fluent Interface to make the client code more readable.
     */
    public static class Builder {
        private String endpoint;
        private String namespace;
        private String serviceName;
        private Boolean basicAuthentication = FALSE;
        private String username;
        private String password;
        private Long connectionTimeout;
        private Long receiveTimeout;
        private String portName;
        private String soapAction;
        private StreamSource soapRequest;
        private OutputStream soapResponse;
        private Dispatch<SOAPMessage> dispatch;
        private SOAPMessage requestSOAPMessage;
        private SOAPMessage returnedSOAPMessage;

        public Builder endpoint(String endpoint) {
            this.endpoint = endpoint;
            return this;
        }

        public Builder namespace(String namespace) {
            this.namespace = namespace;
            return this;
        }

        public Builder serviceName(String serviceName) {
            this.serviceName = serviceName;
            return this;
        }

        public Builder portName(String portName) {
            this.portName = portName;
            return this;
        }

        public Builder soapAction(String soapAction) {
            this.soapAction = soapAction;
            return this;
        }

        public Builder basicAuthentication(Boolean basicAuthentication) {
            this.basicAuthentication = basicAuthentication;
            return this;
        }

        public Builder username(String username) {
            this.username = username;
            return this;
        }

        public Builder password(String password) {
            this.password = password;
            return this;
        }

        public Builder connectionTimeout(Long connectionTimeout) {
            this.connectionTimeout = connectionTimeout;
            return this;
        }

        public Builder receiveTimeout(Long receiveTimeout) {
            this.receiveTimeout = receiveTimeout;
            return this;
        }       

        public Builder soapRequest(File soapRequest) throws IOException {
            if (soapRequest == null)
                throw new IllegalStateException("soapRequest not set");
            InputStream is = Files.newInputStream(soapRequest.toPath());
            this.soapRequest = new StreamSource(is, StandardCharsets.UTF_8.name());
            return this;
        }

        public Builder soapRequest(InputStream soapRequest) {
            this.soapRequest = new StreamSource(soapRequest);
            return this;
        }

        public Builder soapRequest(Reader soapRequest) {
            this.soapRequest = new StreamSource(soapRequest);
            return this;
        }

        public int execute(File soapResponse) throws IOException, SOAPException, GeneralSecurityException {
            if (soapResponse == null)
                throw new IllegalStateException("soapResponse not set");
            this.soapResponse = Files.newOutputStream(soapResponse.toPath());
            return execute();
        }

        public int execute(OutputStream soapResponse) throws IOException, SOAPException, GeneralSecurityException {
            if (soapResponse == null)
                throw new IllegalStateException("soapResponse not set");
            this.soapResponse = soapResponse;
            return execute();
        }

        private int execute() throws SOAPException, IOException, GeneralSecurityException {
            createDispatch();
            addBasicAuthentication();
            addSoapAction();
            addTimeouts();
            setSOAPMessage();
            returnedSOAPMessage = dispatch.invoke(requestSOAPMessage);
            returnedSOAPMessage.writeTo(soapResponse);
            return Integer.parseInt(getResponseCode());
        }

        private String getResponseCode() {
            Object responseCode = dispatch.getResponseContext().get(CXF_RESPONSE_CODE);
            if (responseCode != null)
                return responseCode.toString();
            else {
                responseCode = dispatch.getResponseContext().get(JAXRS_RESPONSE_CODE);
                if (responseCode != null)
                    return responseCode.toString();
                else
                    return "-1";
            }
        }

        private void createDispatch() {
            if (endpoint == null || endpoint.isEmpty())
                throw new IllegalStateException("endpoint not set");

            QName serviceQName = new QName(namespace, serviceName);
            logger.debug("Creating the Service QName, " + serviceQName);

            // Add a separate name space for method if required
            QName portQName = new QName(namespace, portName);

            logger.debug("Creating port QName, " + portQName);

            Service serviceRef = Service.create(serviceQName);
            serviceRef.addPort(portQName, SOAPBinding.SOAP11HTTP_BINDING, endpoint);

            dispatch = serviceRef.createDispatch(portQName, SOAPMessage.class, Service.Mode.MESSAGE);
        }

        private void addBasicAuthentication() throws GeneralSecurityException {
            if (basicAuthentication)
                setBasicAuthentication();
        }

        private void setBasicAuthentication() throws GeneralSecurityException {
            if (username == null || username.isEmpty())
                throw new IllegalStateException("username not set with BasicAuthentication");

            if (password == null || password.isEmpty())
                throw new IllegalStateException("password not set with BasicAuthentication");

            dispatch.getRequestContext().put(BindingProvider.USERNAME_PROPERTY, username);
            dispatch.getRequestContext().put(BindingProvider.PASSWORD_PROPERTY, JcodificaLib.decrypt(password));
        }

        private void addSoapAction() {
            if (soapAction != null)
                setSoapAction();
        }

        private void setSoapAction() {
            logger.debug("SoapAction:" + soapAction);
            dispatch.getRequestContext().put(BindingProvider.SOAPACTION_USE_PROPERTY, TRUE);
            dispatch.getRequestContext().put(BindingProvider.SOAPACTION_URI_PROPERTY, soapAction);
        }

        private void addTimeouts() {
            if (receiveTimeout != null) {
                setReceiveTimeout();
            }

            if (connectionTimeout != null) {
                setConnectionTimeout();
            }
        }

        private void setConnectionTimeout() {
            logger.debug("connectionTimeout:" + connectionTimeout);
            dispatch.getRequestContext().put("javax.xml.ws.client.connectionTimeout", connectionTimeout);
        }

        private void setReceiveTimeout() {
            logger.debug("receiveTimeout:" + receiveTimeout);
            dispatch.getRequestContext().put("javax.xml.ws.client.receiveTimeout", receiveTimeout);
        }

        private void setSOAPMessage() throws SOAPException {
            MessageFactory messageFactory = MessageFactory.newInstance();
            requestSOAPMessage = messageFactory.createMessage();
            SOAPPart soapPart = requestSOAPMessage.getSOAPPart();
            soapPart.setContent(soapRequest);
        }   

    }

    public static SOAPClient.Builder builder() {
        return new SOAPClient.Builder();
    }
}

Я попытался исправить проблему, включив чанкирование и установив порог чанкинга на 8192, как показано ниже, но я получаю то же сообщение об ошибке: 

private void setHttpClientPolicies() {
        final Client client = ((DispatchImpl<SOAPMessage>) dispatch).getClient();
        final HTTPConduit httpConduit = (HTTPConduit) client.getConduit();
        final HTTPClientPolicy httpClientPolicy = httpConduit.getClient();
        httpConduit.setClient(httpClientPolicy);

        httpClientPolicy.setAllowChunking(TRUE);
        httpClientPolicy.setChunkingThreshold(8192);
}

Любая подсказка, как решить проблему

Ответы [ 4 ]

2 голосов
/ 07 марта 2020

Я бы попробовал вопреки тому, что ты сделал. Я подозреваю, что сервер не поддерживает чанкинг. Поэтому вы должны настроить CXF на отключить (и не включать!) Разбиение на блоки, как это делает do c:

Если вы получаете странные ошибки (обычно нет *) 1009 * сбои, но другие ошибки типа HTTP) при попытке взаимодействия со службой попробуйте отключить chunking, чтобы посмотреть, поможет ли это.

2 голосов
/ 07 марта 2020

Я подозреваю, что вы можете попытаться установить длину содержимого в заголовке. IE, размер вашего запроса с использованием протокола передачи гипертекста (HTTP / 1.1): синтаксис сообщения и маршрутизация. Я полагаю, что если вы правильно определили размер запроса, сервер может не подавиться им. Стоит попробовать.

Content-Length: РАЗМЕР ТРЕБУЕМЫХ ДАННЫХ В БАЙТАХ \ n \ n

Может потребоваться доступ к некоторым частям нижнего уровня вашей структуры запросов. Рекомендации: https://tools.ietf.org/html/rfc7230#section -3.3.2 https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Content-Length

1 голос
/ 09 марта 2020

SOAP запрос от организации. apache .http.client.HttpClient (4.1) Необходимо указать длину данных. req_ xml .length () // SOAP файл чтения (xml) запроса req_ xml = новый файл ("test / xml / request. xml"); 

 // SOAP request send
 HttpPost post = new HttpPost("http://localhost:8080/test/api/");
 post.setEntity(new InputStreamEntity(new FileInputStream(req_xml), **req_xml.length()**));
 post.setHeader("Content-type", "text/xml; charset=UTF-8");
 post.setHeader("SOAPAction", "");
 HttpClient client = new DefaultHttpClient();
 HttpResponse response = client.execute(post);

 // SOAP response(xml) get
 String res_xml = EntityUtils.toString(response.getEntity());

Проверьте, что рабочий код просто указывает xml и измените веб-путь. У вас есть весь код разработчика, и я не понимаю, делаете ли вы post / get. По умолчанию все http get. 

createDispatch();
            addBasicAuthentication();
            addSoapAction();
            addTimeouts();
            setSOAPMessage();
            returnedSOAPMessage = dispatch.invoke(requestSOAPMessage);
            returnedSOAPMessage.writeTo(soapResponse);
            return Integer.parseInt(getResponseCode());
0 голосов
/ 10 марта 2020

Отвечая на мой собственный вопрос.

Ответы, опубликованные здесь, правильно указывают на то, что путем отключения чанкинга или добавления Content-Length проблема может быть решена. Но моя проблема заключалась в том, что я не смог отключить блок, как это видно из описания моего вопроса.

Итак, я пытался добавить Content-Length в заголовок http, и, как вы можете видеть, я не использую какую-либо библиотеку Apache для написания моего soap клиентского кода, поэтому было трудно понять, как добавьте Content-Length к заголовку HTTP. Наконец я нашел способ сделать это. Фрагмент кода можно найти ниже: 

private void setSOAPMessage() throws SOAPException {
        MessageFactory messageFactory = MessageFactory.newInstance();
        requestSOAPMessage = messageFactory.createMessage();
        SOAPPart soapPart = requestSOAPMessage.getSOAPPart();
        soapPart.setContent(soapRequest);

        // Added Content-Length to HTTP Header
        Map<String, List<String>> requestHeaderMap = new HashMap<String, List<String>>();
        requestHeaderMap.put("Content-Length", Collections.singletonList(String.valueOf(soapRequestXMLSize)));
        dispatch.getRequestContext().put(MessageContext.HTTP_REQUEST_HEADERS, requestHeaderMap);
}

Здесь soapRequestXMLSize был вычислен из фактического soap запроса xml, который хранится как String в моем случае. 

Integer soapRequestSize = soapRequestXML.length();
...