远程SOAP web服务不断中断连接

Question

我正在使用JBoss开关站连接到安全的远程SOAP web服务。在发送请求后出于某种原因；远程web服务正在停止任何进一步的通信；所以我没有收到回复。

我需要一个想法或解决方案，这可能是个问题。

原因：java。网SocketException:SocketException调用https://***********。asmx:来自服务器的文件意外结束

• 远程Web服务正在使用自签名证书；我已将服务器证书导入到我的本地信任库中，并且我有其他证书（在我的密钥库中）来向远程服务器识别我自己。
• 感谢-Djavax.net.debug=所有SSL调试日志和Wireshark日志，我知道客户端和服务器都成功进行了SSL握手，并且客户端已成功发送请求。
• 服务器还使用IP过滤来允许直接通信，并且我的IP被列入白名单。
• 如果我尝试通过SoapUI发送相同的XML请求，它会正常工作并收到响应。您应该考虑到SoapUI只使用密钥库；它被设置为始终信任远程服务，因此不需要或使用信任库。
• 现在是有趣的部分。如果我使用Fiddler（免费Web调试代理）作为我的JBoss SwitchYard和远程Web服务之间的“中间人”（看看发生了什么），突然一切都正常了。
• 直接连接和使用Fiddler作为代理之间的唯一区别是在实际连接中使用Connection=Keep-Alive标头参数，在Fiddler的情况下使用Proxy-Connection=Keep-Alive参数。我不知道还有其他显着区别。
• 如果我在SoapUI中手动更改这些标头参数，我仍然会收到成功的响应。只有当我缺少SOAPAction和Content-Type标头参数时，连接才会失败，但它们在每种情况下都存在（并且是相同的）。
• 当我通过Wireshark观察到这种通信时，我唯一能看到的区别是远程服务器正在停止进一步的通信（当JBoss Switchard应用程序直接与远程Web服务通信时）。
• 我无权访问远程日志，也不被允许获取它们。所以我在盲目工作。
• 在每种情况下（有或没有Fiddler）我都在使用公司代理来访问远程Web服务。此代理不是问题，因为其他SwitchYard应用程序运行良好。

• JBoss EAP 6.4

Answer 1

问题可能是由于SOAP请求的头无效或格式无效，您可以尝试下面的代码

1你需要HeaderHandlerResolver

 public class HeaderHandlerResolver implements HandlerResolver {

        public List<Handler> getHandlerChain(PortInfo portInfo) {
            List<Handler> handlerChain = new ArrayList<Handler>();

            HeaderHandler hh = new HeaderHandler();

            handlerChain.add(hh);

            return handlerChain;
        }
    }

然后您需要添加HeaderHandler类

 public class HeaderHandler implements SOAPHandler<SOAPMessageContext> {

        public boolean handleMessage(SOAPMessageContext smc) {

            Boolean outboundProperty = (Boolean) smc.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);

            if (outboundProperty.booleanValue()) {

                SOAPMessage message = smc.getMessage();

                try {

                    SOAPEnvelope envelope = smc.getMessage().getSOAPPart().getEnvelope();

                    SOAPHeader header = envelope.getHeader();
                    header.setPrefix("soapenv");
                    header.setAttribute("xmlns:wsa", "http://www.w3.org/2005/08/addressing");

                    SOAPElement security =
                            header.addChildElement("Security", "wsse", "http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-secext-1.0.xsd");

                    SOAPElement usernameToken =
                            security.addChildElement("UsernameToken", "wsse");
                    usernameToken.addAttribute(new QName("xmlns:wsu"), "http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd");

                    SOAPElement username =
                            usernameToken.addChildElement("Username", "wsse");
                    username.addTextNode("USERNAME");

                    SOAPElement password =
                            usernameToken.addChildElement("Password", "wsse");
                    password.setAttribute("Type", "http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-username-token-profile-1.0#PasswordText");
                    password.addTextNode("PASSWORD");

                    SOAPElement encode =
                            usernameToken.addChildElement("Nonce", "wsse");
                    encode.setAttribute("EncodingType", "http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-soap-message-security-1.0#Base64Binary");
                    encode.addTextNode(generateNonce());

                    Calendar createdTime = new GregorianCalendar(TimeZone.getTimeZone("IST"));
                    Date todayDate = createdTime.getTime();
                    todayDate.setTime(todayDate.getTime()-20000000);

                    SOAPElement created = usernameToken.addChildElement("Created", "wsu");
                    created.addTextNode(new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.sss'Z'").format(todayDate));

                    SOAPElement action = header.addChildElement("Action", "wsa");
                    //YOUR ACTION URL SHOULD BE in BELOW Text Content
                    action.setTextContent("SET HERE YOUR ACTION URL");

                    message.saveChanges();
                    message.writeTo(System.out);
                    System.out.println("");

                } catch (Exception e) {
                    e.printStackTrace();
                }

            } else {
                try {

                    //This handler does nothing with the response from the Web Service so
                    //we just print out the SOAP message.
                    SOAPMessage message = smc.getMessage();
                    message.writeTo(System.out);
                    System.out.println("");
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }


            return outboundProperty;

        }

        public Set getHeaders() {
            return null;
        }

        public boolean handleFault(SOAPMessageContext context) {
            return true;
        }

        public void close(MessageContext context) {
        }

        private static String generateNonce() throws NoSuchAlgorithmException, NoSuchProviderException, UnsupportedEncodingException {
            String dateTimeString = Long.toString(new Date().getTime());
            byte[] nonceByte = dateTimeString.getBytes();
            return Base64.encodeBase64String(nonceByte);
        }
    }

现在，最后是调用SOAP服务的主要类

public class SoapClientClass {

    public static void main(String[] args) {

        ImplService service = new ImplService();
        HeaderHandlerResolver handlerResolver = new HeaderHandlerResolver();
        service.setHandlerResolver(handlerResolver);

        ResponseClass port = service.getPortClass();

        Response response = null;
        try {
            response = port.getServerMehotd("Params");
        } catch (PolicyException_Exception e) {
            e.printStackTrace();
        } catch (ServiceException_Exception e) {
            e.printStackTrace();
        }

        }
    }
}

另外，确保从wsdl文件生成的代码最新，并且服务器位置url也正确。

希望它能解决你的问题

Answer 2

java.net.SocketException：服务器文件意外结束

此异常意味着服务器已接受您的连接，这意味着您的SSL握手确实成功。但是，在您得到响应之前，服务器（通过TCP重置或fin）关闭了连接。

重置通常在两种情况下发送：

• 配置超过的持久连接（保持活动连接）
• 服务器重启丢失连接

通常，持久连接有两种配置：

Keep-Alive: timeout=15, max=100

timeout表示以秒为单位的时间，max表示最大请求。

让我们比较一下您描述的三个不同案例：

• 成功
• 直接连接：失败；连接=保持活动状态
• 小提琴手：成功；代理连接=保持活动状态

在第三种情况下，如果我理解正确的话，您的持久连接是从客户端到代理，而从代理到服务器是不清楚的。

 client----->Proxy----->server

• 尝试从响应中获取服务器的持久连接配置（如这里），查看直接连接是否超过时间或数量限制
• 尝试不使用持久连接：java-Dhttp.keepalive=false

• fin vs rst in tcp
• 保持活头