Java -在WebRequest调用上重写WebRequest

Question

快速的背景，我们公司连接到一个ERP系统(Sage)通过web服务的一些功能。我们有c# (.net)和java代码来执行对Web (WS)的调用。最近，Sage在WS中引入了Basic身份验证。

请注意:这是一个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")));
}

webservice定位器如下所示：

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();
}

因此，我的问题是，我如何模仿覆盖，这是我在.net程序中看到的？它看起来像是在服务定位器或调用程序中的某个地方，但是程序不使用标准的http类，而是这个附加的东西。我尝试了一个直接的c#到java转换，但这种方式没有帮助。我见过实现basicAuth的例子，但不是针对web服务调用的。

c#非常清晰，因为一旦我使用basicAuth覆盖创建了服务对象，每个web服务调用都会通过命令。这是如何在Java中发生的呢？

如果需要的话，我会很乐意提供更多的信息，我会继续寻找/实验，但是现在我正在踩水。

增加：

在通过java代码进行跟踪时，我发现了创建apache " call“对象的特定web服务调用(run)。这是可以增加基础设施的地方吗？

    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服务WSDL

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

BaiscAuth设置的关键点是在getCAdxWebServiceXmlCC方法中。我将setPassword和setUserName添加到返回的存根中。这样做的目的是，每次我执行webservice方法调用时，该存根现在都是标头的一部分。

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;
}

}