首先在MyEclipse中创建一个web project,创建方式可以参见我博客中的《webservice 笔记(小结) axis2 集成spring <一>发布服务》一文,
project取名 Ws2Pojo
?
服务器端
? 1、创建pojo类:
?
package sample.ws.pojo;
public class Person {
?private String name;
?
?private String age;
?public String getName() {
??return name;
?}
?public void setName(String name) {
??this.name = name;
?}
?public String getAge() {
??return age;
?}
?public void setAge(String age) {
??this.age = age;
?}
?
}
?
-------------------------------------------------------------------------
? TsetService.jave:
package sample.ws.service;
import sample.ws.pojo.Person;
public class ServiceTest {
/**
?* 很简单我们只是将发过来的person返回去
?* @param person
?* @return
?*/
?public Person getPerson(Person person){
??
??return person;
?}
????
???
}
?
--------------------------------------------------
services.xml 文件内容
?
<?xml version="1.0" encoding="UTF-8"?>
<service name="TestService" scope="application">
??<description>TestService</description>
??<messageReceivers>??
???? <messageReceiver???
??????????? mep="http://www.w3.org/2004/08/wsdl/in-only"?
??? class="org.apache.axis2.rpc.receivers.RPCInOnlyMessageReceiver"/>??
??????? <messageReceiver??
??????????? mep="http://www.w3.org/2004/08/wsdl/in-out"?
??? class="org.apache.axis2.rpc.receivers.RPCMessageReceiver"/>??
??? </messageReceivers>?
??? <parameter name="ServiceClass">
??? sample.ws.service.ServiceTest
??? </parameter>
?
</service>
?
?
将项目部署到tomcat上,这样服务器端就发布成功了。
现在是客户端,我们采用rpc的方式调用
1、首先建立pojo类Person(注意包名要和服务器端的person的包名相同)
?? Person.java
package sample.ws.pojo;
public class Person {
private String name;
?
?private String age;
?public String getName() {
??return name;
?}
?public void setName(String name) {
??this.name = name;
?}
?public String getAge() {
??return age;
?}
?public void setAge(String age) {
??this.age = age;
?}
?
}
?
2、创建客户调用类:
?
?? package sample.ws.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;
import sample.ws.pojo.Person;
public class Ws2pojoClient {
?public static void main(String args[]) throws java.lang.Exception{
?
?RPCServiceClient client = new RPCServiceClient();
?
?Options option = client.getOptions();
//?指定客户端访问的webservice服务器端地址
?EndpointReference erf = new EndpointReference("http://localhost:8080/Ws2Pojo/services/TestService");
?
?option.setTo(erf);
//?指定命名空间,指定要调用的方法
?QName name = new QName("http://service.ws.sample","getPerson");
//?创建Person对象
?Person person = new Person();
?person.setAge("20");
?person.setName("张三");
?
//?创建要传送的object数组
?Object[] object = new Object[]{person};
//?创建返回的参数类型
?Class[] returnTypes = new Class[]{Person.class};
//?调用远程服务,得到返回的object数组
?Object[] response = client.invokeBlocking(name,object,returnTypes);
//?强制转换成Person对象
?Person p = (Person)response[0];
?
?System.out.println(p.getAge());
?System.out.println(p.getName());
?
?}
}
?
?
得到输出: 20 ?????????? 张三 ??? 说明调用成功,一开始的时候总是出错,原因是客户端的Person的命名空间,和服务器端的不同,总是说Person找不到。要特别注意命名空间(TCPMonitor是个不错的工具) 下一篇:axis2 传递对象数组