当前位置: 代码迷 >> Web前端 >> WebService大讲堂之Axis2系列课程之二:复合类型数据的传递
  详细解决方案

WebService大讲堂之Axis2系列课程之二:复合类型数据的传递

热度:331   发布时间:2012-10-13 11:38:17.0
WebService大讲堂之Axis2系列教程之二:复合类型数据的传递

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

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

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

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

??? 下面的示例代码演示了如何传递数组与类(接口)类型的数据,并演示如何使用字节数组上传图像。本示例的客户端代码使用JavaC#编写。要完成这个例子需要如下几步:

一、实现服务端代码

??? ComplexTypeService是一个WebService类,该类的代码如下:

<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> -->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();
????}????
}

?

二、实现DataForm

??? DataForm是要返回的对象实例所对应的类,该类的实现代码如下:

<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> -->package?data;

public?class?DataForm?implements?java.io.Serializable
{
????
private?String?name?=?"bill";
????
private?int?age?=?20;

????
public?String?getName()
????{
????????
return?name;
????}
????
public?void?setName(String?name)
????{
????????
this.name?=?name;
????}
????
public?int?getAge()
????{
????????
return?age;
????}
????
public?void?setAge(int?age)
????{
????????
this.age?=?age;
????}
}

?

?

三、发布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)。

四、使用Java编写调用WebService的客户端代码

??? 在客户端仍然使用了RPC的调用方式,代码如下:

<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> -->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());
????????
//////////////////////////////////////////
????}
}

?

??? 运行上面的程序,将输出如下的内容:

<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> -->文件长度:3617

true

自行车?飞机?火箭?

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

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

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

20

bill

本文来自CSDN博客:http://blog.csdn.net/ycyangcai/archive/2009/10/15/4675239.aspx

  相关解决方案