采用RPC方式和document方式 开发Axis2的WebService客户端

import javax.xml.namespace.QName;

import org.apache.axiom.om.OMAbstractFactory;
import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMFactory;
import org.apache.axiom.om.OMNamespace;
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.client.ServiceClient;
import org.apache.axis2.rpc.client.RPCServiceClient;

public class StockQuoteClient {
    /**
     * 方法一： 应用rpc的方式调用 这种方式就等于远程调用， 即通过url定位告诉远程服务器，告知方法名称，参数等， 调用远程服务，得到结果。
     *  使用 org.apache.axis2.rpc.client.RPCServiceClient类调用WebService
     * 
     * 【注】：
     * 
     * 如果被调用的WebService方法有返回值 应使用 invokeBlocking 方法 该方法有三个参数 
     * 第一个参数的类型是QName对象，表示要调用的方法名； 
     * 第二个参数表示要调用的WebService方法的参数值，参数类型为Object[]； 当方法没有参数时，invokeBlocking方法的第二个参数值不能是null，而要使用new Object[]{}。
     * 不过要是服务端发布的方法有多个参数值，RPCServiceClient好像是搞不定，这边参数只提供了一个参数数组，也没有参数对应的描述， 
        如：// 定义参数 
        Object[] params = new Object[] { 1432,"","",0,"" }; 
        会生成以下类型的报文。 
        <arg0 xmlns="">1432</arg0> 
        <arg1 xmlns=""></arg1> 
        <arg2 xmlns=""></arg2> 
        <arg3 xmlns="">0</arg3> 
        <arg4 xmlns=""></arg4> 
        服务端碰到这类型的报文，参数匹配不上
        所以在遇到这种情况是可以采用方法二： testDocument() 
     * 第三个参数表示WebService方法的 返回值类型的Class对象，参数类型为Class[]。
     * 
     * 如果被调用的WebService方法没有返回值 应使用 invokeRobust 方法 该方法只有两个参数，它们的含义与invokeBlocking方法的前两个参数的含义相同。
     * 
     * 在创建QName对象时，QName类的构造方法的第一个参数表示WSDL文件的命名空间名， 也就是 <wsdl:definitions>元素的targetNamespace属性值。
     * 
     */
    public static void testRPCClient() {
        try {
            // axis2 服务端
            String url = "http://192.168.119.22/tds/VRVAuditPlusAlarm.asmx?wsdl";

            // 使用RPC方式调用WebService
            RPCServiceClient serviceClient = new RPCServiceClient();
            // 指定调用WebService的URL
            EndpointReference targetEPR = new EndpointReference(url);
            Options options = serviceClient.getOptions();
            // 确定目标服务地址
            options.setTo(targetEPR);
            // 确定调用方法
            options.setAction("http://tempuri.org/Login");

            /**
             * 指定要调用的getPrice方法及WSDL文件的命名空间 如果 WebService 服务端由axis2编写 命名空间 不一致导致的问题 org.apache.axis2.AxisFault: java.lang.RuntimeException: Unexpected subelement arg0
             */
            QName qname = new QName("http://tempuri.org/", "Login");
            // 指定getPrice方法的参数值
            Object[] parameters = new Object[] { "admin", "123456" };

            // 指定getPrice方法返回值的数据类型的Class对象
            Class[] returnTypes = new Class[] { String.class };

            // 调用方法一 传递参数，调用服务，获取服务返回结果集
            OMElement element = serviceClient.invokeBlocking(qname, parameters);
            // 值得注意的是，返回结果就是一段由OMElement对象封装的XML字符串。
            // 我们可以对之灵活应用,下面我取第一个元素值，并打印之。因为调用的方法返回一个结果
            String result = element.getFirstElement().getText();
            System.out.println(result);

            // 调用方法二 getPrice方法并输出该方法的返回值
            Object[] response = serviceClient.invokeBlocking(qname, parameters, returnTypes);
            String r = (String) response[0];
            System.out.println(r);

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

    /**
     * 方法二： 应用document方式调用 用ducument方式应用现对繁琐而灵活。现在用的比较多。因为真正摆脱了我们不想要的耦合
     */
    public static void testDocument() {
        try {
            String url = "http://192.168.119.22/tds/VRVAuditPlusAlarm.asmx?wsdl";

            Options options = new Options();
            // 指定调用WebService的URL
            EndpointReference targetEPR = new EndpointReference(url);
            options.setTo(targetEPR);
            options.setAction("http://tempuri.org/Login");

            ServiceClient sender = new ServiceClient();
            sender.setOptions(options);

            OMFactory fac = OMAbstractFactory.getOMFactory();
            String tns = "http://tempuri.org/";
            // 命名空间，有时命名空间不增加没事，不过最好加上，因为有时有事，你懂的
            OMNamespace omNs = fac.createOMNamespace(tns, "Login");
            OMElement method = fac.createOMElement("Login", omNs);
            // 对应WebService的方法参数的节点  
            String[] strs = new String[] { "userName","password" };  
            // 参数值  
            String[] val = new String[] { "admin","123456" };  
            for (int i = 0; i < strs.length; i++) {  
                OMElement inner = fac.createOMElement(strs[i], omNs);  
                inner.setText(val[i]);  
                method.addChild(inner);  
            } 
            method.build();

            OMElement result = sender.sendReceive(method);
            System.out.println(result.getFirstElement().getText());

        } catch (AxisFault axisFault) {
            axisFault.printStackTrace();
        }
    }

    /**
     * 为SOAP Header构造验证信息， 如果你的服务端是没有验证的，那么你不用在Header中增加验证信息
     * 
     * @param serviceClient
     * @param tns
     *            命名空间
     * @param user
     * @param passwrod
     */
    public void addValidation(ServiceClient serviceClient, String tns, String user, String passwrod) {
        OMFactory fac = OMAbstractFactory.getOMFactory();
        OMNamespace omNs = fac.createOMNamespace(tns, "nsl");
        OMElement header = fac.createOMElement("AuthenticationToken", omNs);
        OMElement ome_user = fac.createOMElement("Username", omNs);
        OMElement ome_pass = fac.createOMElement("Password", omNs);

        ome_user.setText(user);
        ome_pass.setText(passwrod);

        header.addChild(ome_user);
        header.addChild(ome_pass);

        serviceClient.addHeader(header);
    }

    public static void main(String[] args) {
        // testRPCClient();
        testDocument();
    }
}

注意需要引入：axis2-1.6.3.zip包中lib文件夹下的jar包,还有其他几种生成客户端的方法可以查看这里