axis2 传递对象

java交流群:38615496

首先在MyEclipse中创建一个web project;

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;
	}
	
}

 

PersonService.java

package sample.ws.service;

import sample.ws.pojo.Person;

public class PersonService {
/**
 * 很简单我们只是将发过来的person返回去
 * @param person
 * @return
 */
	public Person getPerson(Person person){
		
		return person;
	}
	    
	   
}

 

  services.xml 文件内容

<?xml version="1.0" encoding="UTF-8"?>


<service name="PersonService" scope="application">
		<description>PersonService</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.PersonService
    </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/axis2/services/PersonService");
	
	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
           张三