【转】axis2实现WebService之复合类型数据的传递

接着昨天的程序，今天又进了一步，学习了webservice的复合类型数据的传递，尤其是教程上没有的部分，我自己尝试着写，虽说耗费了一个下午的时间，但是还是非常值的，废话少说，看招！

      在实际的应用中，不仅需要使用WebService来传递简单类型的数据，有时也需要传递更复杂的数据，这些数据可以被称为复合类型的数据。数组与类（接口）是比较常用的复合类型。在Axis2中可以直接使用将WebService方法的参数或返回值类型声明成数组或类（接口）。但要注意，在定义数组类型时只能使用一维数组，如果想传递多维数组，可以使用分隔符进行分隔，如下面的代码所示：

String[] strArray = new String[]{ "自行车,飞机,火箭","中国,美国,德国", "超人,蜘蛛侠,钢铁侠" } ;

    上面的代码可以看作是一个3*3的二维数组。

    在传递类的对象实例时，除了直接将数组类型声明成相应的类或接口，也可以将对象实例进行序列化，也就是说，将一个对象实例转换成字节数组进行传递，然后接收方再进行反序列化，还原这个对象实例。

    下面的示例代码演示了如何传递数组与类（接口）类型的数据，并演示如何使用字节数组上传图像。本示例的客户端代码使用Java编写。要完成这个例子需要如下几步：

  

一、实现服务端代码

<span style="font-size:14px;">import java.io.FileOutputStream;
import data.DataForm;

public class ComplexTypeService
{
    //  上传图像，imageByte参数表示上传图像文件的字节，
    //  length参数表示图像文件的字节长度（该参数值可能小于imageByte的数组长度）
    public boolean uploadImageWithByte(byte[] imageByte, int length)
    {
        FileOutputStream fos = null;
        try
        {
            //  将上传的图像保存在D盘的test1.jpg文件中
            fos = new FileOutputStream("d:\\test1.jpg");
            //  开始写入图像文件的字节
            fos.write(imageByte, 0, length);
            fos.close();
        }
        catch (Exception e)
        {
            return false;
        }
        finally
        {
            if (fos != null)
            {
                try
                {
                    fos.close();
                }
                catch (Exception e)
                {

                }
            }
        }
        return true;
    }
    //  返回一维字符串数组
    public String[] getArray()
    {
        String[] strArray = new String[]{ "自行车", "飞机", "火箭" };
        return strArray;
    }
    //  返回二维字符串数组
    public String[] getMDArray()
    {
        String[] strArray = new String[]{ "自行车,飞机,火箭","中国,美国,德国", "超人,蜘蛛侠,钢铁侠" } ;
        return strArray;
    }
    //  返回DataForm类的对象实例
    public DataForm getDataForm()
    {
        return new DataForm();
    }
    //  将DataForm类的对象实例序列化，并返回序列化后的字节数组
    public byte[] getDataFormBytes() throws Exception
    {
        java.io.ByteArrayOutputStream baos = new java.io.ByteArrayOutputStream();
        java.io.ObjectOutputStream oos = new java.io.ObjectOutputStream(baos);
        oos.writeObject(new DataForm());
        return baos.toByteArray();
    }
}
</span>

二、实现DataForm类

<span style="font-size:14px;">package data;

public class DataForm implements java.io.Serializable
{
    private String name = "bill";
    private int age = 20;
    setter…………getter方法
}

</span>

三、发布WebService

    由于本示例的WebService类使用了一个Java类（DataForm类），因此，在发布WebService之前，需要先将DataForm.class文件复制到<Tomcat安装目录>\webapps\axis2\WEB-INF\classes\data目录中，然后将ComplexTypeService.class文件复制到<Tomcat安装目录>\webapps\axis2\WEB-INF\pojo目录中，最后启动Tomcat（如果Tomcat已经启动，由于增加了一个DataForm类，因此，需要重新启动Tomcat）。发布之后的结果如下图所示

<span style="font-size:14px;"></span>

<p align="left"><span style="color:black;"></span><span style="font-size:14px;"> </span></p><p align="left"><span style="font-size:14px;"> </span></p><p align="left"><span style="font-size:14px;"><img alt="" src="http://img.my.csdn.net/uploads/201211/06/1352191996_1125.PNG"></span></p>

 四、使用Java编写调用WebService的客户端代码    在客户端仍然使用了RPC的调用方式，代码如下：

<span style="font-size:14px;">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 ComplexTypeRPCClient {

    public static void main(String[] args) throws Exception {
        RPCServiceClient serviceClient = new RPCServiceClient();
        Options options = serviceClient.getOptions();
        EndpointReference targetEPR = new EndpointReference(
                "http://localhost:8080/axis2/services/ComplexTypeService");
        options.setTo(targetEPR);
        // 下面的代码调用uploadImageWithByte方法上传图像文件
        // 打开图像文件，确定图像文件的大小
        java.io.File file = new java.io.File("f:\\images.jpg");
        java.io.FileInputStream fis = new java.io.FileInputStream(
                "f:\\images.jpg");
        // 创建保存要上传的图像文件内容的字节数组
        byte[] buffer = new byte[(int) file.length()];
        // 将图像文件的内容读取buffer数组中
        int n = fis.read(buffer);
        System.out.println("文件长度：" + file.length());
        Object[] opAddEntryArgs = new Object[] { buffer, n };
        Class[] classes = new Class[] { Boolean.class };
        QName opAddEntry = new QName("http://ws.apache.org/axis2",
                "uploadImageWithByte");
        fis.close();
        // 开始上传图像文件，并输出uploadImageWithByte方法的返回传
        System.out.println(serviceClient.invokeBlocking(opAddEntry,
                opAddEntryArgs, classes)[0]);

        // 下面的代码调用了getArray方法，并返回一维String数组
        opAddEntry = new QName("http://ws.apache.org/axis2", "getArray");
        String[] strArray = (String[]) serviceClient.invokeBlocking(opAddEntry,
                new Object[] {}, new Class[] { String[].class })[0];
        for (String s : strArray)
            System.out.print(s + "  ");
        System.out.println();

        // 下面的代码调用了getMDArray方法，并返回一维String数组
        opAddEntry = new QName("http://ws.apache.org/axis2", "getMDArray");
        strArray = (String[]) serviceClient.invokeBlocking(opAddEntry,
                new Object[] {}, new Class[] { String[].class })[0];
        for (String s : strArray) {
            String[] array = s.split(",");
            for (String ss : array)
                System.out.print("<" + ss + "> ");
            System.out.println();
        }
        System.out.println();


        // 下面的代码调用了getDataForm方法，并返回DataForm对象实例
        opAddEntry = new QName("http://ws.apache.org/axis2", "getDataForm");
        data.DataForm df = (data.DataForm) serviceClient.invokeBlocking(
                opAddEntry, new Object[] {},
                new Class[] { data.DataForm.class })[0];
        System.out.println(df.getAge());


        // 下面的代码调用了getDataFormBytes方法，并返回字节数组，最后将返回的字节数组反序列化后，转换成DataForm对象实例
        opAddEntry = new QName("http://ws.apache.org/axis2", "getDataFormBytes");
        buffer = (byte[]) serviceClient.invokeBlocking(opAddEntry,
                new Object[] {}, new Class[] { byte[].class })[0];
        java.io.ObjectInputStream ois = new java.io.ObjectInputStream(
                new java.io.ByteArrayInputStream(buffer));
        df = (data.DataForm) ois.readObject();
        System.out.println(df.getName());
    }
}
</span>

 

运行上面的程序，将输出如下的内容：

文件长度：3617

true

自行车 飞机 火箭 

<自行车> <飞机> <火箭>

<中国> <美国> <德国>

<超人> <蜘蛛侠> <钢铁侠>

20

 

 

如果读者要上传大文件，应尽量使用FTP的方式来传递，而只通过WebService方法来传递文件名等信息。这样有助于提高传输效率。