Java - 覆盖 Web 服务调用上的 WebRequest

Question

简单介绍一下，我们公司通过 Web 服务连接到 ERP 系统(Sage)以实现某些功能。我们有 C# (.net) 和 java 代码来执行对 Web 服务 (WS) 的调用。最近，Sage 在他们的 WS 中引入了基本身份验证。

请注意:这是一个JAVA问题，但我将首先展示一个 C# 示例来解释。

在 C# 程序中，我首先创建一个用于访问 WS 的对象:

                var sageService = new CAdxWebServiceXmlCCServiceBasicAuth();

然后我设置凭据信息:

                var sageServiceCallContext = SageFactory.Instance.GetCallContext();

            sageService.Credentials = new NetworkCredential(SageUser, SagePwd);      
            sageService.PreAuthenticate = true;

最后调用具体的Web服务方法:

                    sageCustomerSvcResponse = sageService.run(sageServiceCallContext, "YTDPROF", sageCustomerRequestInXml);

当我设置服务对象时，我使用一个如下所示的自定义类:

    public class CAdxWebServiceXmlCCServiceBasicAuth : CAdxWebServiceXmlCCService
{
    protected override WebRequest GetWebRequest(Uri uri)
    {
        HttpWebRequest webRequest = (HttpWebRequest)base.GetWebRequest(uri);

        NetworkCredential credentials = Credentials as NetworkCredential;
        if (credentials != null)
        {
            string authInfo = "";
            if (credentials.Domain != null && credentials.Domain.Length > 0)
            {
                authInfo = string.Format(@"{0}\{1}:{2}", credentials.Domain, credentials.UserName, credentials.Password);
            }
            else
            {
                authInfo = string.Format(@"{0}:{1}", credentials.UserName, credentials.Password);
            };
            authInfo = Convert.ToBase64String(Encoding.Default.GetBytes(authInfo));
            webRequest.Headers["Authorization"] = "Basic " + authInfo;
        }
        return webRequest;
    }

}

现在发生的情况是，当我对 Web 服务方法执行任何调用时，每次都会调用该类中的 GetWebRequest。这就是我们在 C# 中实现基本身份验证的方式。

如何在 Java 中执行此操作？

在当前的 java 代码中，我通过以下方式创建服务对象(访问 Web 服务的对象):

WebServiceInvoker service = new WebServiceInvoker(SageWSURL,""); 

WebServiceInvoker 看起来像这样(为了简洁而被截断):

    public WebServiceInvoker(String url, String dummy) throws ServiceException, IOException {
    serviceLocator = new CAdxWebServiceXmlCCServiceLocator();
    service = serviceLocator.getCAdxWebServiceXmlCC(url);  
    cc = new CAdxCallContext();
    cc.setCodeLang("ENG");
    cc.setCodeUser("USER");
    cc.setPassword("PAWWORD"); 
    cc.setPoolAlias("POOL"); 
    cc.setRequestConfig("adxwss.trace.on=on&adxwss.trace.size=16384&adonix.trace.on=on&adonix.trace.level=3&adonix.trace.size=8");
    log = new PrintWriter(new BufferedWriter(new FileWriter("C:/Kalio/service/orders/log.txt")));
}

网络服务定位器如下所示:

public class CAdxWebServiceXmlCCServiceLocator extends org.apache.axis.client.Service implements com.adonix.www.WSS.CAdxWebServiceXmlCCService {

public CAdxWebServiceXmlCCServiceLocator() {
}

    public com.adonix.www.WSS.CAdxWebServiceXmlCC getCAdxWebServiceXmlCC() throws javax.xml.rpc.ServiceException {
   java.net.URL endpoint;
   System.out.println("using local Sage Web Servivce URL:" + CAdxWebServiceXmlCC_address);

    try {
        endpoint = new java.net.URL(CAdxWebServiceXmlCC_address);
    }
    catch (java.net.MalformedURLException e) {
        throw new javax.xml.rpc.ServiceException(e);
    }
    return getCAdxWebServiceXmlCC(endpoint);
}

public com.adonix.www.WSS.CAdxWebServiceXmlCC getCAdxWebServiceXmlCC(java.net.URL portAddress) throws javax.xml.rpc.ServiceException {
    try {
        com.adonix.www.WSS.CAdxWebServiceXmlCCSoapBindingStub _stub = new com.adonix.www.WSS.CAdxWebServiceXmlCCSoapBindingStub(portAddress, this);
        _stub.setPortName(getCAdxWebServiceXmlCCWSDDServiceName());
        return _stub;
    }
    catch (org.apache.axis.AxisFault e) {
        return null;
    }
}

该类中的具体方法是这样的:

    public String getCustomer(String constructedXML) throws RemoteException {
    **CAdxResultXml result = service.run(cc, "XTDPROF", constructedXML);**
    CAdxMessage[] messages = result.getMessages();
    for (int i = 0; i<messages.length; i++) {
        CAdxMessage message = messages[i];
        log.println("X3 get customer message: " + message.getMessage());
        log.println("X3 get customer message type: " + message.getType());
    }
    return result.getResultXml();
}

所以我的问题是，如何在 Java 中模拟我在 .net 程序中看到的覆盖？看起来它可能位于服务定位器或调用器中的某个位置，但该程序不使用标准 http 类，而是使用这种 adxwss 东西。我尝试了直接将 C# 转换为 Java，但这种方式没有帮助。我见过实现 basicAuth 的示例，但不是针对 Web 服务调用。

C# 非常清晰，因为一旦我使用 basicAuth 覆盖创建服务对象，每个 Web 服务调用都会经过 orderride。在 Java 中这是如何发生的？

如果需要，我很乐意提供更多信息，并且我会继续寻找/实验，但目前我正停滞不前。

添加:

在跟踪 java 代码时，我发现了创建 apache“调用”对象的特定 Web 服务调用(运行)。这是可以添加 basicauth 的地方吗？

    public com.adonix.www.WSS.CAdxResultXml run(com.adonix.www.WSS.CAdxCallContext callContext, java.lang.String publicName, java.lang.String inputXml) throws java.rmi.RemoteException {
    if (super.cachedEndpoint == null) {
        throw new org.apache.axis.NoEndPointException();
    }
    org.apache.axis.client.Call _call = createCall();
    _call.setOperation(_operations[0]);
    _call.setUseSOAPAction(true);
    _call.setSOAPActionURI("");
    _call.setSOAPVersion(org.apache.axis.soap.SOAPConstants.SOAP11_CONSTANTS);
    _call.setOperationName(new javax.xml.namespace.QName("http://www.adonix.com/WSS", "run"));

    setRequestHeaders(_call);
    setAttachments(_call);
 try {        java.lang.Object _resp = _call.invoke(new java.lang.Object[] {callContext, publicName, inputXml});

    if (_resp instanceof java.rmi.RemoteException) {
        throw (java.rmi.RemoteException)_resp;
    }
    else {
        extractAttachments(_call);
        try {
            return (com.adonix.www.WSS.CAdxResultXml) _resp;
        } catch (java.lang.Exception _exception) {
            return (com.adonix.www.WSS.CAdxResultXml) org.apache.axis.utils.JavaUtils.convert(_resp, com.adonix.www.WSS.CAdxResultXml.class);
        }
    }
  } catch (org.apache.axis.AxisFault axisFaultException) {
  throw axisFaultException;
}
}

Answer 1

我想出的解决方案并不优雅，但我不是 Java 专家，只是知道足够的知识来完成这些任务。

我们公司使用 Sage 作为我们的 ERP 系统，Sage 有一个 WSDL 来定义它提供的基本 Web 服务。

Sage Web Servicew WSDL

在最新版本的 Sage 中，他们采用了基本身份验证，但没有将其构建到新的 WSDL 中。由于我似乎无法扩展该类(CAdxWebServiceXmlCCService)，因此我只是复制/粘贴了一个名为 CAdxWebServiceXmlCCServiceBasicAuth 的新类。如果有人需要在网络服务中处理类似的事情，完整的代码如下所示。

BaiscAuth 设置的关键点是在 getCAdxWebServiceXmlCC 方法中。我将 setPassword 和 setUserName 添加到返回的 stub 中。这样做的结果是，每次我执行 Web 服务方法调用时，该 stub 现在都是 header 的一部分。

package com.adonix.www.WSS;

import java.net.URL;
import java.util.Base64;
import java.io.IOException;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;

import javax.xml.rpc.ServiceException;

public class CAdxWebServiceXmlCCServiceBasicAuth extends org.apache.axis.client.Service implements com.adonix.www.WSS.CAdxWebServiceXmlCCService {

public CAdxWebServiceXmlCCServiceBasicAuth() {
}


public CAdxWebServiceXmlCCServiceBasicAuth(org.apache.axis.EngineConfiguration config) {
    super(config);
}

public CAdxWebServiceXmlCCServiceBasicAuth(java.lang.String wsdlLoc, javax.xml.namespace.QName sName) throws javax.xml.rpc.ServiceException {
    super(wsdlLoc, sName);
}

// Use to get a proxy class for CAdxWebServiceXmlCC
private java.lang.String CAdxWebServiceXmlCC_address = "http://10.28.0.7:8124/soap-generic/syracuse/collaboration/syracuse/CAdxWebServiceXmlCC";

public java.lang.String getCAdxWebServiceXmlCCAddress() {
    return CAdxWebServiceXmlCC_address;
}

// The WSDD service name defaults to the port name.
private java.lang.String CAdxWebServiceXmlCCWSDDServiceName = "CAdxWebServiceXmlCC";

public java.lang.String getCAdxWebServiceXmlCCWSDDServiceName() {
    return CAdxWebServiceXmlCCWSDDServiceName;
}

public void setCAdxWebServiceXmlCCWSDDServiceName(java.lang.String name) {
    CAdxWebServiceXmlCCWSDDServiceName = name;
}

public com.adonix.www.WSS.CAdxWebServiceXmlCC getCAdxWebServiceXmlCC(String userName,String password) throws javax.xml.rpc.ServiceException {
   java.net.URL endpoint;
    try {
        endpoint = new java.net.URL(CAdxWebServiceXmlCC_address);
    }
    catch (java.net.MalformedURLException e) {
        throw new javax.xml.rpc.ServiceException(e);
    }
    return getCAdxWebServiceXmlCC(endpoint,userName,password);
}

public com.adonix.www.WSS.CAdxWebServiceXmlCC getCAdxWebServiceXmlCC(java.net.URL portAddress,String userName,String password) throws javax.xml.rpc.ServiceException {
    try {
        com.adonix.www.WSS.CAdxWebServiceXmlCCSoapBindingStub _stub = new com.adonix.www.WSS.CAdxWebServiceXmlCCSoapBindingStub(portAddress, this);
        _stub.setPortName(getCAdxWebServiceXmlCCWSDDServiceName());
        _stub.setPassword(password);
        _stub.setUsername(userName);
        return _stub;
    }
    catch (org.apache.axis.AxisFault e) {
        return null;
    }
}

public void setCAdxWebServiceXmlCCEndpointAddress(java.lang.String address) {
    CAdxWebServiceXmlCC_address = address;
}

/**
 * For the given interface, get the stub implementation.
 * If this service has no port for the given interface,
 * then ServiceException is thrown.
 */
public java.rmi.Remote getPort(Class serviceEndpointInterface) throws javax.xml.rpc.ServiceException {
    try {
        if (com.adonix.www.WSS.CAdxWebServiceXmlCC.class.isAssignableFrom(serviceEndpointInterface)) {
            com.adonix.www.WSS.CAdxWebServiceXmlCCSoapBindingStub _stub = new com.adonix.www.WSS.CAdxWebServiceXmlCCSoapBindingStub(new java.net.URL(CAdxWebServiceXmlCC_address), this);
            _stub.setPortName(getCAdxWebServiceXmlCCWSDDServiceName());
            return _stub;
        }
    }
    catch (java.lang.Throwable t) {
        throw new javax.xml.rpc.ServiceException(t);
    }
    throw new javax.xml.rpc.ServiceException("There is no stub implementation for the interface:  " + (serviceEndpointInterface == null ? "null" : serviceEndpointInterface.getName()));
}

/**
 * For the given interface, get the stub implementation.
 * If this service has no port for the given interface,
 * then ServiceException is thrown.
 */
public java.rmi.Remote getPort(javax.xml.namespace.QName portName, Class serviceEndpointInterface) throws javax.xml.rpc.ServiceException {
    if (portName == null) {
        return getPort(serviceEndpointInterface);
    }
    java.lang.String inputPortName = portName.getLocalPart();
    if ("CAdxWebServiceXmlCC".equals(inputPortName)) {
        return getCAdxWebServiceXmlCC();
    }
    else  {
        java.rmi.Remote _stub = getPort(serviceEndpointInterface);
        ((org.apache.axis.client.Stub) _stub).setPortName(portName);
        return _stub;
    }
}

public javax.xml.namespace.QName getServiceName() {
    return new javax.xml.namespace.QName("http://www.adonix.com/WSS", "CAdxWebServiceXmlCCService");
}

private java.util.HashSet ports = null;

public java.util.Iterator getPorts() {
    if (ports == null) {
        ports = new java.util.HashSet();
        ports.add(new javax.xml.namespace.QName("http://www.adonix.com/WSS", "CAdxWebServiceXmlCC"));
    }
    return ports.iterator();
}

/**
* Set the endpoint address for the specified port name.
*/
public void setEndpointAddress(java.lang.String portName, java.lang.String address) throws javax.xml.rpc.ServiceException {

if ("CAdxWebServiceXmlCC".equals(portName)) {
            setCAdxWebServiceXmlCCEndpointAddress(address);
        }
        else 
{ // Unknown Port Name
            throw new javax.xml.rpc.ServiceException(" Cannot set Endpoint Address for Unknown Port" + portName);
        }
    }

/**
* Set the endpoint address for the specified port name.
*/
public void setEndpointAddress(javax.xml.namespace.QName portName, java.lang.String address) throws javax.xml.rpc.ServiceException {
    setEndpointAddress(portName.getLocalPart(), address);
}


@Override
public CAdxWebServiceXmlCC getCAdxWebServiceXmlCC() throws ServiceException {
    // TODO Auto-generated method stub
    return null;
}


@Override
public CAdxWebServiceXmlCC getCAdxWebServiceXmlCC(URL portAddress) throws ServiceException {
    // TODO Auto-generated method stub
    return null;
}

}