Axis2发布webservice（1）--0配置发布

import java.util.Random;

public class HelloWorldService {

    public String sayHello(String name) {

        return name + " say: hello [axis2]";

}

public int getAge(int i) {

        return i + new Random().nextInt(100);

}}

package client;

import javax.xml.namespace.QName;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.rpc.client.RPCServiceClient;

public class RPCClient{
    public static void main(String[] args) throws Exception{
      
        //  使用RPC方式调用WebService        
        RPCServiceClient serviceClient = new RPCServiceClient();
        Options options = serviceClient.getOptions();

        //  指定调用WebService的URL
        EndpointReference targetEPR = new EndpointReference(
                "http://localhost:8080/axis2/services/HelloWorldService");
        options.setTo(targetEPR);
       
        //  指定getGreeting方法的参数值
        Object[] opAddEntryArgs = new Object[] {"超人"};
        //  指定getGreeting方法返回值的数据类型的Class对象
        Class[] classes = new Class[] {String.class};
      
         //  指定要调用的SayHello方法及WSDL文件的命名空间
        QName opAddEntry = new QName("http://ws.apache.org/axis2", "SayHello");
       
        //  调用SayHello方法并输出该方法的返回值
        System.out.println(serviceClient.invokeBlocking(opAddEntry, opAddEntryArgs, classes)[0]);
      
       //  下面是调用getAge方法的代码，这些代码与调用getAge方法的代码类似
        classes = new Class[] {int.class};
        opAddEntry = new QName("http://ws.apache.org/axis2", "getAge");
        System.out.println(serviceClient.invokeBlocking(opAddEntry, new Object[]{new Integer(22)}, classes)[0]);
    } 
}

package data;

import java.io.Serializable;

public class User implements Serializable {

    private static final long serialVersionUID = 677484458789332877L;

    private int id;

    private String name;

    private String email;

    private String address;

getter和setter方法省略...................

    @Override

    public String toString() {

    return this.id + "#" + this.name + "#" + this.email + "#" + this.address;

}

}

import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.Random;

import data.User;

/**
 * 复杂数据类型的WebService，返回数组和JavaBean
 * */
public class ComplexTypeService {

    /*将字节保存到本地jsp文件中*/
    public String upload4Byte(byte[] b,int len){
        
        //输出文件路径
        String path = "";
        
        //文件输出流
        FileOutputStream fos = null;
                
        //此处用户工作目录为服务器的bin目录，比如我的是F:\install\tomcat8.0\apache-tomcat-8.0.9\bin\
        String dir = System.getProperty("user.dir"); 
        
        //新建file对象
        File file = new File(dir + "/" +(new Random().nextInt(100))+".jsp");
        
        try {
            fos = new FileOutputStream(file);
            
            //输出字节到文件
            fos.write(b,0,len);
            
            //获取文件的绝对路径
            path = file.getAbsolutePath();
            
            System.out.println("File path:"+path);
            
        } catch (FileNotFoundException e) {
            
            e.printStackTrace();
        
        } catch (IOException e) {
            
            e.printStackTrace();
        
        }finally{//finally可以保证文件输出流正常关闭
            
            try{
                //关闭文件输出流
                fos.close();
            
            }catch(IOException e){
            
                e.printStackTrace();
            }
        }
        return path;        
    }
    
    /*根据参数新建数组并返回*/
    public int[] getArray(int i){
        
        int[] arr = new int[i];
        
        //遍历数组给其元素赋予随机整数值
        for(int j=0;j<i;j++){
        
            arr[j] = new Random().nextInt(1000);    
        }
        
        return arr;
    }
    
    /*返回多维字符串数组*/
    public String[][] getTwoArray(){
        
        return new String[][]{
                {"中国","北京"},
                {"日本","东京"},
                {"中国","上海","南京"}
        };
    }
    
    /*返回自定义对象*/
    public User getUser(){
        
        //自定义User对象
        User user = new User();
        
        //设置属性值
        user.setAddress("China");
        user.setName("jack");
        user.setEmail("123@123.com");
        user.setId(22);
        
        return user;
    }
}

package service.client;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;

import javax.xml.namespace.QName;

import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.rpc.client.RPCServiceClient;

import data.User;

public class ComplexTypeServiceClient {

    public static void main(String[] args) throws IOException {
    
        //实例化RPC访问对象，并获取Options对象
        RPCServiceClient client = new RPCServiceClient();
        Options options = client.getOptions();
        
        //webservice的网络地址
        String address = "http://localhost:8080/axis2/services/ComplexTypeService";
        
        //实例化EPR对象，将客户端指向该webservice
        EndpointReference epr = new EndpointReference(address);
        options.setTo(epr);
        
        //方法upload4Byte在服务器上相应命名空间中的位置
        QName qname = new QName("http://ws.apache.org/axis2", "upload4Byte");
        
        //从本地读取文件，将byte数据存入数组
        String path = System.getProperty("user.dir");
        File file = new File(path + "/WebRoot/index.jsp");
        FileInputStream fis = new FileInputStream(file);
        int len = (int) file.length();
        byte[] b = new byte[len];
        fis.read(b);
        fis.close();
        
        //访问webservice，调用upload4Byte方法
        Object[] result = client.invokeBlocking(qname, new Object[] { b, len }, new Class[] { String.class });
        System.out.println("upload:" + result[0]);
        
        //方法getArray在服务器上相应命名空间中的位置
        qname = new QName("http://ws.apache.org/axis2", "getArray");
        result = client.invokeBlocking(qname, new Object[] { 3 },new Class[] { int[].class });
        int[] arr = (int[]) result[0];
        for (Integer i : arr) {
            System.out.println("int[] :" + i);
        }
        
        //方法getTwoArray在服务器上相应命名空间中的位置
        qname = new QName("http://ws.apache.org/axis2", "getTwoArray");
        result = client.invokeBlocking(qname, new Object[] {}, new Class[] { String[][].class });
        String[][] arrStr = (String[][]) result[0];
        for (String[] s : arrStr) {
            for (String str : s) {
                System.out.println("String[][]: " + str);
            }
        }
        
        //方法getUser在服务器上相应命名空间中的位置
        qname = new QName("http://ws.apache.org/axis2", "getUser");
        result = client.invokeBlocking(qname, new Object[] {}, new Class[] { User.class });
        User user = (User) result[0];
        System.out.println("User: " + user);
    }    }