java - HTTP 响应 411 : Length Required when communicating with

Question

我正在尝试发送一个 SOAP 请求并不断收到 HTTP 响应 411 错误，因为 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();
    }
}

我尝试通过启用分 block 并将分 block 阈值设置为 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);
}

任何线索如何解决这个问题？

Answer 1

我怀疑您可能会尝试在标题中设置内容长度。 IE，使用超文本传输​​协议(protocol) (HTTP/1.1) 的请求大小:消息语法和路由。
我猜如果您正确识别请求的大小，服务器可能不会阻塞它。值得一试。
内容长度:所需数据的大小(以字节为单位)\n\n
它可能需要访问请求框架的一些较低级别的部分。
引用:
https://www.rfc-editor.org/rfc/rfc7230#section-3.3.2
https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Content-Length