通过Axis2搭建一个简单的webservice服务端和客户端

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
package com.xcs.axis2;

public class HelloAxis2 {

   public String getHello(String name,String num,int age) {
   	return "Hello， " + name + "."+num+ ":" +age;
   }
   public String getWorld(String name) {
   	return "World," + name + ".";
   }
   public String getHelloWorld() {
   	return "Hello,Axis";
   }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
   <!-- 加载Axis -->
<servlet>
<servlet-name>AxisServlet</servlet-name>
<servlet-class>org.apache.axis2.transport.http.AxisServlet</servlet-class>
<load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>AxisServlet</servlet-name>
<url-pattern>/services/*</url-pattern>
</servlet-mapping>
</web-app>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
<?xml version="1.0" encoding="UTF-8"?>

<serviceGroup>
   <service name="HelloAxis2">  
       <description>  
           HelloWorld Service Example
       </description>  
       <parameter name="ServiceClass">  
           com.xcs.axis2.HelloAxis2
       </parameter>  
       <operation name="getHello">
           <messageReceiver class="org.apache.axis2.rpc.receivers.RPCMessageReceiver" />  
       </operation>  
       <operation name="getWorld">  
           <messageReceiver class="org.apache.axis2.rpc.receivers.RPCMessageReceiver" />  
       </operation>  
       <operation name="getHelloWorld">  
   <!-- 这里要注意，当没有返回值时才用 org.apache.axis2.rpc.receivers.RPCInOnlyMessageReceiver，没有参数还是用RPCMessageReceiver-->
           <messageReceiver class="org.apache.axis2.rpc.receivers.RPCMessageReceiver" />  
       </operation>  
   </service>
</serviceGroup>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
package com.axis;


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 ClientTest {
   public static void main(String[] args) {
   	String url = "http://127.0.0.1:8080/HelloAxis2/services/HelloAxis2";
   	String result = null;
   	try {
   	// 使用RPC方式调用WebService
   	RPCServiceClient serviceClient = new RPCServiceClient();
   	Options options = serviceClient.getOptions();
   	// 指定调用WebService的URL
   	EndpointReference targetEPR = new EndpointReference(url);
   	options.setTo(targetEPR);
   	// 在创建QName对象时，QName类的构造方法的第一个参数表示WSDL文件的命名空间名，也就是<wsdl:definitions>元素的targetNamespace属性值
   	// // 指定要调用的getWorld方法及WSDL文件的命名空间.....
   	QName opAddEntry = new QName("http://axis2.xcs.com", "getWorld");
   	// 
   	// 指定getGreeting方法的参数值，如果有多个，继续往后面增加即可，不用指定参数的名称
   	Object[] opAddEntryArgs = new Object[] { "java" };
   	// 返回参数类型，这个和axis1有点区别
   	// invokeBlocking方法有三个参数，其中第一个参数的类型是QName对象，表示要调用的方法名；
   	// 第二个参数表示要调用的WebService方法的参数值，参数类型为Object[]；
   	// 第三个参数表示WebService方法的返回值类型的Class对象，参数类型为Class[]。
   	// 当方法没有参数时，invokeBlocking方法的第二个参数值不能是null，而要使用new Object[]{}
   	// 如果被调用的WebService方法没有返回值，应使用RPCServiceClient类的invokeRobust方法，
   	// 该方法只有两个参数，它们的含义与invokeBlocking方法的前两个参数的含义相同
   	// 指定getGreeting方法返回值的数据类型的Class对象.....
   	Class[] classes = new Class[] { String.class };
   	// 调用getGreeting方法并输出该方法的返回值.......
   	result = (String) serviceClient.invokeBlocking(opAddEntry,
   	opAddEntryArgs, classes)[0];
   	System.out.println(result);
   	// 下面是调用getHello方法的代码，这些代码与调用getWorld方法的代码类似
   	// classes = new Class[] {String.class};
   	opAddEntry = new QName("http://axis2.xcs.com", "getHello");
   	opAddEntryArgs = new Object[] { "王亚坤" ,"22","21312"};
//		opAddEntryArgs = new Object[] { "王亚坤" ,"22",21312};
   	System.out.println(serviceClient.invokeBlocking(opAddEntry,
   	opAddEntryArgs, classes)[0]);
   	// 下面是调用getHelloWorld方法的代码
   	opAddEntry = new QName("http://axis2.xcs.com", "getHelloWorld");
   	System.out.println(serviceClient.invokeBlocking(opAddEntry,
   	new Object[]{}, classes)[0]);
   	} catch (Exception e) {
   	e.printStackTrace();
   	}
   	}
}