远程 SOAP Web 服务不断断开连接

简短描述

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

问题

我需要一个想法或解决方案,这里可能有问题。

错误

由以下原因引起:java.net.SocketException:SocketException 调用 https://**********.asmx:来自服务器的文件意外结束

说明和注释

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

工具

  • JBoss EAP 6.4
  • JBoss SwitchYard 2.0.1.redhat-621159

答案 1

例外

java.net.SocketException:来自服务器的文件意外结束

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

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

  • 持久连接(保持活动状态连接)与配置超过
  • 服务器重新启动丢失了连接

通常,持久连接有两个配置:

Keep-Alive: timeout=15, max=100

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

连接与代理连接

让我们比较您描述的三种不同情况:

  • SoapUI: success; ?
  • 直接连接:失败;连接 = 保持活动状态
  • 小提琴手:成功;代理连接 = 保持活动状态

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

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

建议

  • 尝试从响应中获取服务器的持久连接配置(如此所示),以查看直接连接是否超过时间或限制数
  • 尽量不要使用持久连接:java -Dhttp.keepalive=false

裁判


答案 2

问题可能是由于无效的标头或无效格式的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文件最新和服务器位置网址生成的代码也正确无误。

希望它能解决您的问题


推荐