package data;
import java.io.Serializable;
/**
* function:User Entity
* @author hoojo
* @createDate Dec 16,2010 10:20:02 PM
* @file User.java
* @package com.hoo.entity
* @project AxisWebService
* @blog http://blog.csdn.net/IBM_hoojo
* @email hoojo_@126.com
* @version 1.0
*/
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;
}
}
值得注意的是这个User对象的package是data,如果是其它的package,你就需要在tomcat目录下的webapps中的axis2的WEB-INF目录下
创建一个data目录,和你的User对象的目录保持一致。否则你的WebService将会出现ClassNotFontException异常。然后重启你的tomcat,
虽然axis2支持热部署。
2、编写调用上面WebService的客户端代码,代码如下:
package com.hoo.service;
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 com.hoo.entity.User;
/**
* function:复杂类型数据WebService客户端调用代码
* @author hoojo
* @createDate 2011-1-13 下午03:36:38
* @file ComplexTypeServiceClient.java
* @package com.hoo.service
* @project Axis2WebService
* @blog http://blog.csdn.net/IBM_hoojo
* @email hoojo_@126.com
* @version 1.0
*/
public class ComplexTypeServiceClient {
public static void main(String[] args) throws IOException {
RPCServiceClient client = new RPCServiceClient();
Options options = client.getOptions();
String address = "http://localhost:8080/axis2/services/ComplexTypeService";
EndpointReference epr = new EndpointReference(address);
options.setTo(epr);
QName qname = new QName("http://ws.apache.org/axis2","upload4Byte");
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];
int read = fis.read(b);
//System.out.println(read + "#" + len + "#" + new String(b));
fis.close();
Object[] result = client.invokeBlocking(qname,new Object[] { b,len },new Class[] { String.class });
System.out.println("upload:" + result[0]);
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);
}
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);
}
}
qname = new QName("http://ws.apache.org/axis2","getUser");
result = client.invokeBlocking(qname,new Class[] { User.class });
User user = (User) result[0];
System.out.println("User: " + user);
}
}
上面的代码运行后的结果是:
upload:D:/tomcat-6.0.28/bin/28.jsp
int[] :548
int[] :201
int[] :759
String[][]: 中国
String[][]: 北京
String[][]: 日本
String[][]: 东京
String[][]: 中国
String[][]: 上海
String[][]: 南京
User: 22#jack#jack@223.com#china
|