有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java Getting Transferncode=在soap ws调用中分块而不是内容长度

我试图从java调用两个soap ws。当我从两个不同的java线程调用这些ws时,它被成功调用,但当尝试调用同一个线程时,第一个调用成功,第二个调用卡住。我可以在日志中看到这两个请求

我在服务器上检查了tcp转储,可以看到对于第一个请求,所有的头参数都设置正确,但在第二次调用中,而不是在内容长度获取传输编码=分块

first ws call header - 2/15/2018 9:59:40 AM [8]
Content-Length=639 Content-Type=text/xml; charset=UTF-8 Accept=/ Host=test102.com User-Agent=Apache CXF 2.7.11 SOAPAction="Trackem.Web.Services/ReserveServiceTime" Proxy-Connection=Keep-Alive

Second ws call header - 2/15/2018 10:01:11 AM [9]
Transfer-Encoding=chunked Content-Type=text/xml; charset​​=UTF-8 Accept=/ Host=test102.com
User-Agent=Apache CXF 2.7.11 SOAPAction="Trackem.Web.Services/CreateOrUpdateTask" Proxy-Connection=Keep-Alive5:05 PM

请帮助我理解为什么第二次通话不能正常工作

下面是我的java ws方法-

public P getPort(final Class<P> serviceEndpointInterface, final String ascNode) throws MalformedURLException{

final Bus currThreadBus = BusFactory.getThreadDefaultBus();
ClassLoader originalThreadClassLoader = Thread.currentThread().getContextClassLoader();
ClassLoader busFactoryClassLoader = BusFactory.class.getClassLoader();

try {
    Thread.currentThread().setContextClassLoader(busFactoryClassLoader);
    BusFactory.setThreadDefaultBus(BusFactory.newInstance().createBus());

    QName qname = new QName(nameSpace, strQName);

    Service service = Service.create(qname);

    P port = null;

    if (CommonUtil.isEmpty(portName)) {
        port = service.getPort(serviceEndpointInterface);
    } else {
        QName portQname = new QName(nameSpace, portName);
        port = service.getPort(portQname, serviceEndpointInterface);
    }

    BindingProvider bp = (BindingProvider) port;
    // Timeout in millis
    bp.getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, serviceURL);
    bp.getRequestContext().put(Message.CONNECTION_TIMEOUT, Integer.parseInt(connectTimeout));
    bp.getRequestContext().put(Message.RECEIVE_TIMEOUT, Integer.parseInt(requestTimeout));

    final Client client = ClientProxy.getClient(port);
    client.getOutInterceptors().add(new LoggingOutInterceptor());
    client.getInInterceptors().add(new LoggingInInterceptor());

    //Add proxy server details if configured in ASC
    if(!CommonMethods.isEmpty(proxyHost) && !CommonMethods.isEmpty(proxyPort))
    {
        HTTPConduit http = (HTTPConduit) ClientProxy.getClient(port).getConduit();

        http.getClient().setProxyServer(proxyHost);
        http.getClient().setProxyServerPort(Integer.parseInt(proxyPort));

        if(!CommonMethods.isEmpty(proxyUsername) && !CommonMethods.isEmpty(proxyPassword))
        {
            http.getProxyAuthorization().setUserName(proxyUsername);
            http.getProxyAuthorization().setPassword(proxyPassword);
        }
    }
    return port;
}finally {
    BusFactory.setThreadDefaultBus(currThreadBus);
    Thread.currentThread().setContextClassLoader(originalThreadClassLoader);
}}

共 (1) 个答案

  1. # 1 楼答案

    I solved this issue by disabling chunk transfer in HTTP client. http.getClient().setAllowChunking(false);

    我想,问题出在我的代理服务器上,看看这个link