1、在%TOMCAT_HOME%\webapps中放入axis2.war，這個(gè)可以在www.apache.org下載
2、啟動(dòng)Tomcat，將該war包解開
3、服務(wù)端代碼
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
/**
* @company
*
* @description
*
* @author Terry.B.Li
*
* @date 2009.1.7
*/
public class WSServer {
public byte[] invoke(String id, byte[] bytes) {
byte[] result = null;
System.out.println("id:" + id);
Object[] params = byteConvertObj(bytes);
System.out.print("參數(shù)：");
for (Object param : params) {
System.out.println(param.getClass());
}
// 通過 Axis2 反射調(diào)用返回的對(duì)象
Object resultObj = "返回值";
//根據(jù)功能號(hào) ID 解析調(diào)用方法
ByteArrayOutputStream arrayOutputStream = new ByteArrayOutputStream();
ObjectOutputStream objectOutputStream = null;
try {
objectOutputStream = new ObjectOutputStream(arrayOutputStream);
objectOutputStream.writeObject(resultObj);
result = arrayOutputStream.toByteArray();
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
objectOutputStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return result;
}
private Object[] byteConvertObj(byte[] bytes) {
Object[] result = null;
ByteArrayInputStream byteArrayInputStream = null;
ObjectInputStream objectInputStream = null;
try {
byteArrayInputStream = new ByteArrayInputStream(bytes);
objectInputStream = new ObjectInputStream(byteArrayInputStream);
result = (Object[]) objectInputStream.readObject();
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
return result;
}
}
4、將該代碼編譯后放入%TOMCAT_HOME%\webapps\axis2\WEB-INF\pojo下
5、客戶端代碼如下
package com.newegg.lab.ws.client;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.Serializable;
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 org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
public class WSClient implements Serializable{
private static final long serialVersionUID = -8513162370253557533L;
private static final Log log = LogFactory.getLog(WSClient.class);
private static EndpointReference endpointReference = new EndpointReference("http://localhost:8080/axis2/services/WSServer");
private static String namespace = "http://ws.apache.org/axis2";
/**
* @param args
*/
public static void main(String[] args) {
try {
log.info(invoke("123456", "aaa", "得到的的", "埃擔(dān)罰埃擔(dān)罰",34,new WSClient()));
} catch (Exception e) {
e.printStackTrace();
}
log.info("OK");
}
private static Object invoke(String id,Object
params){
Object result = null;
try {
RPCServiceClient serviceClient = new RPCServiceClient();
Options options = serviceClient.getOptions();
options.setTo(endpointReference);
QName qname = new QName(namespace,"invoke");
Class[] clz = new Class[]{byte[].class};
Object[] _params = new Object[]{id,objConvertByte((Object[])params)};
Object[] results = serviceClient.invokeBlocking(qname, _params, clz);
byte[] bytes = (byte[]) results[0];
result = byteConvertObj(bytes);
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
private static byte[] objConvertByte(Object obj){
byte[] result = null;
ByteArrayOutputStream byteArrayOutputStream = null;
ObjectOutputStream objectOutputStream = null;
try {
byteArrayOutputStream = new ByteArrayOutputStream();
objectOutputStream = new ObjectOutputStream(byteArrayOutputStream);
objectOutputStream.writeObject(obj);
result = byteArrayOutputStream.toByteArray();
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
objectOutputStream.close();
byteArrayOutputStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return result;
}
private static Object byteConvertObj(byte[] bytes){
Object result = null;
ByteArrayInputStream byteArrayInputStream = null;
ObjectInputStream objectInputStream = null;
try {
byteArrayInputStream = new ByteArrayInputStream(bytes);
objectInputStream = new ObjectInputStream(byteArrayInputStream);
result = objectInputStream.readObject();
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return result;
}
}
6、將客戶端代碼打包放入%TOMCAT_HOME%\webapps\axis2\WEB-INF\lib下
7、啟動(dòng)Tomcat
8、測(cè)試訪問：
http://localhost:8080/axis2/services/WSServer?wsdl
9、執(zhí)行客戶端代碼