1 <web-app>
 2     <display-name>Apache-Axis</display-name>
 3     <listener>
 4       <listener-class>org.apache.axis.transport.http.AxisHTTPSessionListener</listener-class>
 5     </listener>
 6     <servlet>
 7       <display-name>Apache-Axis Servlet</display-name>
 8       <servlet-name>AxisServlet</servlet-name>
 9       <servlet-class>
10           org.apache.axis.transport.http.AxisServlet
11       </servlet-class>
12     </servlet>
13     <!-- 服務(wù)管理 -->
14     <servlet>
15       <display-name>Axis Admin Servlet</display-name>
16       <servlet-name>AdminServlet</servlet-name>
17       <servlet-class>
18           org.apache.axis.transport.http.AdminServlet
19       </servlet-class>
20       <load-on-startup>100</load-on-startup>
21     </servlet>
22     <!-- 對輸入輸出的SOAP信息進行檢測 -->
23     <servlet>
24       <display-name>SOAPMonitorService</display-name>
25       <servlet-name>SOAPMonitorService</servlet-name>
26       <servlet-class>
27           org.apache.axis.monitor.SOAPMonitorService
28       </servlet-class>
29       <init-param>
30         <param-name>SOAPMonitorPort</param-name>
31         <param-value>5001</param-value>
32       </init-param>
33       <load-on-startup>100</load-on-startup>
34     </servlet>
35     <servlet-mapping>
36       <servlet-name>AxisServlet</servlet-name>
37       <url-pattern>/servlet/AxisServlet</url-pattern>
38     </servlet-mapping>
39     <servlet-mapping>
40       <servlet-name>AxisServlet</servlet-name>
41       <url-pattern>*.jws</url-pattern>
42     </servlet-mapping>
43     <servlet-mapping>
44       <servlet-name>AxisServlet</servlet-name>
45       <url-pattern>/services/*</url-pattern>
46     </servlet-mapping>
47     <servlet-mapping>
48       <servlet-name>SOAPMonitorService</servlet-name>
49       <url-pattern>/SOAPMonitor</url-pattern>
50     </servlet-mapping>
51   </web-app>

 1  <deployment xmlns="http://xml.apache.org/axis/wsdd/" 
 2              xmlns:java="http://xml.apache.org/axis/wsdd/providers/java">  
 3         <handler name="soapmonitor" type="java:org.apache.axis.handlers.SOAPMonitorHandler">  
 4             <parameter name="wsdlURL" value="/axis/SOAPMonitorService-impl.wsdl"/>  
 5             <parameter name="namespace" 
 6              value="http://tempuri.org/wsdl/2001/12/SOAPMonitorService-impl.wsdl"/>  
 7             <parameter name="serviceName" value="SOAPMonitorService"/>  
 8             <parameter name="portName" value="Demo"/>  
 9         </handler>  
10         <service name="SOAPMonitorService" provider="java:RPC">  
11             <parameter name="allowedMethods" value="publishMessage"/>  
12             <parameter name="className" value="org.apache.axis.monitor.SOAPMonitorService"/>  
13             <parameter name="scope" value="Application"/>  
14         </service>  
15 
16      <service name="myService" provider="java:RPC">  
17         <requestFlow>  
18             <handler type="soapmonitor"/>  
19         </requestFlow>  
20         <responseFlow>  
21             <handler type="soapmonitor"/>  
22         </responseFlow>  
23         <parameter name="allowedMethods" value="*"/>  
24         <parameter name="className" value="axis.server.myService"/>  
25     </service>  
26 </deployment>  

 1 <deployment xmlns="http://xml.apache.org/axis/wsdd/"
 2              xmlns:java="http://xml.apache.org/axis/wsdd/providers/java">
 3     <!--在瀏覽器暴露服務(wù) PersonService-->
 4     <service name="PersonService" provider="java:RPC">
 5          <!--綁定服務(wù)實現(xiàn)類型 PersonServiceImpl-->
 6         <parameter name="className"  value="axis.serviceImpls.PersonServiceImpl" />
 7         <parameter name="allowedMethods" value="*" />
 8         <parameter name="scope"  value="application" />
 9     </service>
10     <!--當(dāng)接收到 http 請求時交由 URLMapper 進行處理-->
11     <transport name="http">
12         <requestFlow>
13             <handler type="java:org.apache.axis.handlers.http.URLMapper"/>
14         </requestFlow>
15     </transport>
16  </deployment>

 1  public interface IPersonService {
 2      String HelloWorld(String name);
 3  }
 4  
 5  public class PersonServiceImpl  implements IPersonService { 
 6      @Override  
 7      public String HelloWorld(string name){
 8          return "Hello "+name;
 9      }
10  }

 1     public static void main(String[] args) throws 
 2         RemoteException, MalformedURLException, ServiceException {
 3         // TODO Auto-generated method stub
 4          HelloWorld();
 5     }
 6     
 7     private static void HelloWorld() throws 
 8         RemoteException, MalformedURLException{
 9         PersonServiceImpl personService=new PersonServiceSoapBindingStub(
10             new URL("http://localhost:8080/axis.server/services/PersonService"),
11             new PersonServiceImplServiceLocator());
12         System.out.println(personService.helloWorld("Leslie"));
13     }

 1     public static void main(String[] args) throws 
 2         RemoteException, MalformedURLException, ServiceException {
 3         HelloWorld();
 4     }
 5 
 6     private static void HelloWorld() throws
 7         ServiceException,RemoteException{
 8         //生成服務(wù)對象Service
 9         Service service=new Service();
10         Call call=(Call) service.createCall();
11         //設(shè)置Endpoint地址
12         call.setTargetEndpointAddress(
13             "http://localhost:8080/axis.server/services/PersonService");
14         //綁定請求方法名稱
15         call.setOperationName("HelloWorld");
16         //通過call.invoke調(diào)用服務(wù)，獲取返回值
17         String data=(String)call.invoke(new Object[]{"Leslie"});
18         System.out.println(data);
19     }

 1     public static void main(String[] args) throws 
 2         RemoteException, MalformedURLException, ServiceException {
 3         // TODO Auto-generated method stub
 4          HelloWorld();
 5     }
 6 
 7     private static void HelloWorld() throws 
 8         ServiceException, RemoteException, MalformedURLException {
 9         String wsdl="http://localhost:8080/axis.server/services/PersonService?wsdl";
10         String uri="http://localhost:8080/axis.server/services/PersonService";
11         String serviceName="PersonServiceImplService";
12         
13         //使用serviceFacotry直接生成服務(wù)
14         ServiceFactory factory=ServiceFactory.newInstance();
15         Service service=(Service) factory.createService(
16                 new URL(wsdl),new QName(uri,serviceName));
17         
18         //使用service.getPort方法實現(xiàn)服務(wù)接口
19         PersonServiceImpl personService=(PersonServiceImpl)service
20                 .getPort(PersonServiceImpl.class);
21         String data=personService.helloWorld("Leslie");
22         System.out.println(data);
23     }

 1 public class PersonEntity implements Serializable {
 2      private Integer id;
 3      private String name;
 4      private Integer age;
 5      private String address;
 6      
 7      public PersonEntity(Integer id,String name,Integer age,String address){
 8          this.id=id;
 9          this.name=name;
10          this.age=age;
11          this.address=address;
12      }
13      
14      public Integer getId(){
15          return id;
16      }
17      
18      public void setId(Integer id){
19          this.id=id;
20      }
21      ..........
22  }
23  
24  public interface IPersonService {
25      PersonEntity GetPerson(int id);
26      PersonEntity[] GetList();
27      List GetList(String name);
28  }
29  
30  public class PersonServiceImpl implements IPersonService {
31      @Override
32      public PersonEntity[] GetList(){
33          PersonEntity[] list=new PersonEntity[2];
34          PersonEntity person1=new PersonEntity(1,"Leslie",32,"tianhe");
35          PersonEntity person2=new PersonEntity(2,"Elva",31,"henan");
36          list[0]=person1;
37          list[1]=person2;
38          return list;
39      }
40      
41      @Override
42      public List GetList(String name){
43          List list=new ArrayList();
44          PersonEntity person1=new PersonEntity(1,name+" Lee",32,"tianhe");
45          PersonEntity person2=new PersonEntity(2,name+" Chen",31,"henan");
46          list.add(person1);
47          list.add(person2);
48          return list;
49      }
50      
51      @Override
52      public PersonEntity GetPerson(int id){
53          return new PersonEntity(id,"Leslie",32,"tianhe");
54      }
55  }

1   .........
2    <service name="PersonService" provider="java:RPC">
3        <parameter name="className"  value="axis.serviceImpls.PersonServiceImpl" />
4        <parameter name="allowedMethods" value="*" />
5        <parameter name="scope"  value="application" />
6        <beanMapping qname="myNS:PersonEntity" xmlns:myNS="urn:PersonEntity" 
7            languageSpecificType="java:axis.entity.PersonEntity" />
8    </service>
9    .........

 1      public static void main(String[] args) throws 
 2          RemoteException, MalformedURLException, ServiceException {
 3          GetList();
 4          GetPerson();
 5      }     
 6      
 7      private static void GetPerson() throws 
 8          RemoteException, MalformedURLException{
 9          PersonServiceImpl personService=new PersonServiceSoapBindingStub(
10                  new URL("http://localhost:8080/axis.server/services/PersonService"),
11                  new PersonServiceImplServiceLocator());
12          PersonEntity person=personService.getPerson(1);
13          DisplayPersonProperty(person);
14      }
15 
16      private static void GetList() throws 
17         ServiceException, RemoteException, MalformedURLException{
18         PersonServiceImpl personService=new PersonServiceSoapBindingStub(
19                 new URL("http://localhost:8080/axis.server/services/PersonService"),
20                 new PersonServiceImplServiceLocator());
21         Object[] objs=personService.getList("Leslie");
22         for(Object person:objs)
23            DisplayPersonProperty((PersonEntity)person);
24      }
25 
26      //顯示對象屬性
27      private static void DisplayPersonProperty(PersonEntity person){
28          System.out.println("Id:"+person.getId()+"  Name:"+person.getName()+"  Age:"+
29              person.getAge()+"  Address:"+person.getAddress());
30      }

 1      public static void main(String[] args) throws 
 2          RemoteException, MalformedURLException, ServiceException {
 3          // TODO Auto-generated method stub
 4          GetArray();
 5          GetList();
 6      }    
 7 
 8      private static void GetArray() throws 
 9          ServiceException, RemoteException{
10          Service service=new Service();
11          Call call=(Call)service.createCall();
12          call.setTargetEndpointAddress(
13               "http://localhost:8080/axis.server/services/PersonService");
14          
15          //注冊返回類型，namespaceURI 必須與服務(wù)端注冊值一致
16          QName qName2=new QName("urn:PersonEntity","PersonEntity");     
17          call.registerTypeMapping(PersonEntity.class, qName2,
18                 new BeanSerializerFactory(PersonEntity.class,qName2), 
19                 new BeanDeserializerFactory(PersonEntity.class,qName2));
20          
21          //綁定請求方法
22          call.setOperation("GetList");
23          
24          //設(shè)置返回類型
25          call.setReturnClass(PersonEntity[].class);
26          PersonEntity[] list=(PersonEntity[]) call.invoke(new Object[]{});
27          for(PersonEntity person:list)
28              DisplayPersonProperty(person);
29      }
30     
31      private static void GetList() throws 
32         ServiceException, RemoteException{
33         Service service=new Service();
34         Call call=(Call)service.createCall();
35         call.setTargetEndpointAddress(
36                 "http://localhost:8080/axis.server/services/PersonService");
37         
38         //注冊返回類型，namespaceURI 必須與服務(wù)端注冊值一致
39         QName qName2=new QName("urn:PersonEntity","PersonEntity");     
40         call.registerTypeMapping(PersonEntity.class, qName2,
41                new BeanSerializerFactory(PersonEntity.class,qName2), 
42                new BeanDeserializerFactory(PersonEntity.class,qName2));
43         
44         //綁定請求方法
45         call.setOperationName(new javax.xml.namespace.QName(
46                 "http://serviceImpls.axis", "GetList"));
47         //輸入?yún)?shù)
48         Object[] list=(Object[]) call.invoke(new Object[]{"Leslie"});
49         for(Object person:list)
50             DisplayPersonProperty((PersonEntity)person);
51      }
52      
53      private static void DisplayPersonProperty(PersonEntity person){
54          System.out.println("Id:"+person.getId()+"  Name:"+person.getName()+"  Age:"+
55              person.getAge()+"  Address:"+person.getAddress());
56      }

 1 public interface ILoginService {
 2     public Boolean Login(String name,String password);
 3     public String GetUserName();
 4 }
 5 
 6 public class LoginServiceImpl implements ILoginService {
 7 
 8     @Override
 9     public Boolean Login(String name, String password) {
10         // TODO Auto-generated method stub
11         MessageContext context=MessageContext.getCurrentContext();
12         Session session=context.getSession();
13         if(session!=null)
14             context.getSession().set("User",name);
15          return true;
16     }
17     
18     @Override
19     public String GetUserName(){
20         MessageContext context=MessageContext.getCurrentContext();
21         Session session=context.getSession();
22         return session.get("User").toString();
23     }
24 }

1    .......
2    <service name="LoginService" provider="java:RPC" style="wrapped">
3        <parameter name="className"  value="axis.serviceImpls.LoginServiceImpl" />
4        <parameter name="allowedMethods" value="*" />
5        <parameter name="scope"  value="session" />
6    </service>
7    .......

 1     public static void main(String[] args) throws 
 2         RemoteException, MalformedURLException, ServiceException {
 3         // TODO Auto-generated method stub
 4         Login();
 5     }
 6     
 7     private static void Login() throws 
 8         MalformedURLException, RemoteException{
 9         LoginServiceImpl service1=getService();
10         LoginServiceImpl service2=getService();
11         
12         service1.login("Leslie", "12345678");
13         service2.login("Jack", "12345678");
14         
15         System.out.println("UserName: "+service1.getUserName());
16         System.out.println("UserName: "+service2.getUserName());
17     }
18     
19     private static LoginServiceImpl getService() throws
20         AxisFault, MalformedURLException{
21         LoginServiceImplServiceLocator locator=new LoginServiceImplServiceLocator();
22         locator.setMaintainSession(true);
23         LoginServiceImpl loginService=new LoginServiceSoapBindingStub(
24                 new URL("http://localhost:8080/axis.server/services/LoginService"),
25                 locator);      
26         return loginService;
27     }

 1    .......
 2    <service name="LoginService" provider="java:RPC" style="wrapped">
 3        <parameter name="className"  value="axis.serviceImpls.LoginServiceImpl" />
 4        <parameter name="allowedMethods" value="*" />
 5        <parameter name="scope"  value="session" />
 6        <requestFlow>
 7            <handler type="java:axis.handler.LoginHandler"/>
 8        </requestFlow>
 9    </service>
10    ......

 1 public interface ILoginService {
 2      public Boolean Login(String name,String password);
 3  }
 4  
 5  public class LoginServiceImpl implements ILoginService {
 6  
 7      @Override
 8      public Boolean Login(String name, String password) {
 9          // TODO Auto-generated method stub
10          UserService service=new UserService();
11          User user=service.getUser(name);
12          if(user!=null)
13              return user.password==password;
14          else
15              return false;
16      }
17  }
18  
19  public class LoginHandler extends BasicHandler{
20      private MessageContext context;
21      
22      public void invoke(MessageContext context){
23          this.context=context;
24          GetServletRequest();
25          GetSOAP();
26      }
27      
28      //獲取HtppServletRequest對象
29      private void GetServletRequest(){
30          HttpServletRequest request = (HttpServletRequest)context
31                  .getProperty(HTTPConstants.MC_HTTP_SERVLETREQUEST);
32          String remoteAddress=request.getRemoteAddr();
33          String method=request.getMethod();
34          StringBuffer URL=request.getRequestURL();
35          String message=String.format("Client Address:%s\nMethod:%s\n" +
36                  "RequestURL:%s\n", remoteAddress,method,URL);
37          System.out.println(message);
38      }
39      
40      //獲取SOAPBody信息
41      private void GetSOAP(){
42          String soap=null;
43          try {
44              soap=context.getCurrentMessage().getSOAPBody().toString();
45          } catch (SOAPException e) {
46              // TODO Auto-generated catch block
47              e.printStackTrace();
48          }
49          if(soap!=null){
50              String[] data= soap.split(">");
51              for(String line:data)
52                 System.out.println(line+">");
53          }
54      }
55  }

 1     public static void main(String[] args) throws 
 2          RemoteException, MalformedURLException, ServiceException {
 3          LoginServiceImpl service1=getService();
 4          service1.login("Leslie", "12345678");  
 5      }
 6 
 7      private static LoginServiceImpl getService() throws
 8          AxisFault, MalformedURLException{
 9          LoginServiceImplServiceLocator locator=new LoginServiceImplServiceLocator();
10          locator.setMaintainSession(true);
11          LoginServiceImpl loginService=new LoginServiceSoapBindingStub(
12                  new URL("http://localhost:8080/axis.server/services/LoginService"),
13                  locator);      
14          return loginService;
15      }

1    <service name="LoginService" provider="java:RPC" style="wrapped">
2        <parameter name="className"  value="axis.serviceImpls.LoginServiceImpl" />
3        <parameter name="allowedMethods" value="*" />
4        <parameter name="scope"  value="session" />
5        <responseFlow>
6            <handler type="java:axis.handler.LoginHandler"/>
7        </responseFlow>
8    </service>

 1   public interface ILoginService {
 2          public Boolean login(String name,String password);
 3   }
 4   
 5   public class LoginServiceImpl implements ILoginService {
 6   
 7       @Override
 8       public Boolean login(String name, String password) {
 9           UserService userService=new UserService();
10           User user=userSerivice.getUser(name);
11           if(user!=null)
12             return user.password==password;
13           else
14             return false;
15       }
16   }
17   
18  public class LoginHandler extends BasicHandler{
19      private MessageContext context;
20      
21      public void invoke(MessageContext context){
22          this.context=context;
23          try {
24              if(success())
25                 logged();
26              addElement();
27              getSOAP();
28          } catch (AxisFault e) {
29              e.printStackTrace();
30          } catch (SOAPException e) {
31              e.printStackTrace();
32          }
33      }
34      
35      //記錄登錄人數(shù) 
36      private void logged(){
37          Handler handler=context.getService();
38          //判斷服務(wù)是否為LoginService
39          if(handler.getName().equals("LoginService")){
40              if(this.getOption("loggedCount")==null)
41                  this.setOption("loggedCount", 0);
42  
43              Integer count=Integer.parseInt(
44                      this.getOption("loggedCount").toString());
45              count++;
46              this.setOption("loggedCount", count);
47  
48              System.out.println("logged count: "+count+"   "+
49                 new Date().toString()+"\n");
50          }
51      }
52      
53      //獲取LoginService服務(wù)返回值
54      //若登錄成功則返回true,失敗則返回false
55      private Boolean success() throws SOAPException{
56          SOAPBody soap=context.getCurrentMessage().getSOAPBody();
57          Node node=soap.getElementsByTagName("LoginReturn").item(0);
58          return node.toString().contains("true");
59      }
60      
61      //在回發(fā)的SOAP中加入已登錄人數(shù)的信息
62      private void addElement() throws SOAPException  {
63          SOAPEnvelope soap=context.getCurrentMessage().getSOAPEnvelope();
64          SOAPElement element=soap.getHeader().addChildElement("loggedOnline");
65          element.addTextNode(this.getOption("loggedCount").toString());
66      }
67      
68      //顯示SOAP信息
69      private void getSOAP() throws AxisFault{
70          SOAPEnvelope soap=context.getCurrentMessage().getSOAPEnvelope();
71          if(soap!=null){
72              String[] data= soap.toString().split(">");
73              for(String line:data)
74                 System.out.println(line+">");
75          }
76      }
77  }

 1     public static void main(String[] args) throws 
 2          RemoteException, MalformedURLException, ServiceException {
 3          LoginServiceImpl service1=getService();
 4          service1.login("Leslie", "12345678");  
 5      }
 6 
 7      private static LoginServiceImpl getService() throws
 8          AxisFault, MalformedURLException{
 9          LoginServiceImplServiceLocator locator=new LoginServiceImplServiceLocator();
10          locator.setMaintainSession(true);
11          LoginServiceImpl loginService=new LoginServiceSoapBindingStub(
12                  new URL("http://localhost:8080/axis.server/services/LoginService"),
13                  locator);      
14          return loginService;
15      }

1 public class Example {
2     public String HelloWorld(String name){
3         return "Hello "+name;
4     }
5 }

 1 public class PersonEntity implements Serializable {
 2     private Integer id;
 3     private String name;
 4     private Integer age;
 5     private String address;
 6     
 7     public PersonEntity(Integer id,String name,Integer age,String address){
 8         this.id=id;
 9         this.name=name;
10         this.age=age;
11         this.address=address;
12     }
13     
14     public Integer getId(){
15         return id;
16     }
17     
18     public void setId(Integer id){
19         this.id=id;
20     }
21     ........
22 }
23 
24 public interface PersonService {
25     PersonEntity getPerson(int id);
26     PersonEntity[] getList();
27     List<PersonEntity> getListByName(String name);
28 }
29 
30 public class PersonServiceImpl implements PersonService {
31 
32     @Override
33     public PersonEntity[] getList(){
34         PersonEntity[] list=new PersonEntity[2];
35         PersonEntity person1=new PersonEntity(1,"Leslie",32,"tianhe");
36         PersonEntity person2=new PersonEntity(2,"Elva",31,"henan");
37         list[0]=person1;
38         list[1]=person2;
39         return list;
40     }
41     
42     @Override
43     public List<PersonEntity> getListByName(String name){
44         List<PersonEntity> list=new LinkedList<PersonEntity>();
45         PersonEntity person1=new PersonEntity(1,name+" Lee",32,"tianhe");
46         PersonEntity person2=new PersonEntity(2,name+" Chen",31,"henan");
47         list.add(person1);
48         list.add(person2);
49         return list;
50     }
51     
52     @Override
53     public PersonEntity getPerson(int id){
54         return new PersonEntity(id,"Leslie",32,"tianhe");
55     }
56 }

 1  <service name="PersonService">  
 2    <description>This is a sample Web Service.</description>
 3    <!--ServiceClass指定實現(xiàn)服務(wù)的類。   -->  
 4    <parameter name="ServiceClass" locked="false">
 5        axis2.serviceImpl.PersonServiceImpl
 6    </parameter>  
 7    <!-- operation 與Java Class中方法名對應(yīng)。 -->  
 8    <operation name="getPerson">  
 9       <messageReceiver class="org.apache.axis2.rpc.receivers.RPCMessageReceiver"/>  
10    </operation>
11    <operation name="getList">  
12       <messageReceiver class="org.apache.axis2.rpc.receivers.RPCMessageReceiver"/>  
13    </operation> 
14    <operation name="getListByName">  
15       <messageReceiver class="org.apache.axis2.receivers.RawXMLINOutMessageReceiver"/>  
16    </operation> 
17 </service> 

 1     public static void main(String[] args) throws  MalformedURLException {
 2         // TODO Auto-generated method stub
 3         getList();
 4     }
 5     
 6     private static void getList() throws MalformedURLException{
 7          PersonService personService=new PersonService();
 8          PersonServicePortType personServicePortType=personService
 9                  .getPersonServiceHttpSoap12Endpoint();
10          List<PersonEntity> personList=personServicePortType.getList();
11          for(PersonEntity person:personList)
12              displayPersonProperty(person);
13     }
14 
15     private static void displayPersonProperty(PersonEntity person){
16         System.out.println("Id:"+person.getId().getValue()+"  Name:"
17            +person.getName().getValue()+"  Age:"+ person.getAge().getValue()
18            +"  Address:"+person.getAddress().getValue());
19     }

 1      public static void main(String[] args) throws AxisFault {
 2          excute();
 3      }
 4  
 5      public static void excute() throws AxisFault{
 6          //設(shè)置 endpoint 地址
 7          EndpointReference targetEndpoint=new EndpointReference(
 8          "http://leslie-laptop:8080/axis2-1.6.2/services/PersonService"); 
 9          Options options=new Options();   
10          options.setTo(targetEndpoint); 
11          
12          //設(shè)置傳輸方式
13          //可使用 TRANSPORT_JMS;TRANSPORT_HTTP;TRANSPORT_MAIL;TRANSPORT_TCP;
14          options.setTransportInProtocol(Constants.TRANSPORT_HTTP);   
15          
16          //把設(shè)置的地址、傳輸方式綁定到Service請求當(dāng)中
17          ServiceClient sender=new ServiceClient();   
18          sender.setOptions(options);   
19          
20          //設(shè)置請求的 SOAP 信息
21          OMElement requestOMElement=getPersonRequest(1);   
22          OMElement responseOMElement=sender.sendReceive(requestOMElement);   
23          
24          //對返回的SOAP進行處理，顯示返回值
25          PersonEntity person=convertToPerson(responseOMElement);
26          displayPersonProperty(person);
27      }
28      
29      private static OMElement getPersonRequest(Integer id){
30          //新建OMFactory工廠
31          OMFactory factory=OMAbstractFactory.getOMFactory();   
32          
33          //加入OMNamespace、OMElement、OMText 等數(shù)據(jù)
34          OMNamespace omNs=factory.createOMNamespace(
35                 "http://ws.apache.org/axis2","myNS");     
36          OMElement value=factory.createOMElement("id",omNs);   
37          value.addChild(factory.createOMText(value,id.toString()));  
38          
39          //加入請求方法名
40          OMElement method=factory.createOMElement("getPerson",omNs); 
41          method.addChild(value);  
42          return method;  
43      }
44      
45      //把返回OMElement對象轉(zhuǎn)換成 person對象 
46      private static PersonEntity convertToPerson(OMElement element) 
47              throws AxisFault{
48          PersonEntity person =null;
49          OMElement omElement = element.getFirstElement().getFirstElement();
50          String localName=omElement.getLocalName().toLowerCase();
51          if (localName.equals("personentity")) {
52             person = (PersonEntity) BeanUtil.processObject(omElement,
53             PersonEntity.class, null, true, new DefaultObjectSupplier(), null);      
54          }
55          return person;
56      }
57      
58      private static void displayPersonProperty(PersonEntity person){
59          System.out.println("Id:"+person.getId()+"  Name:"+person.getName()
60             +"  Age:"+ person.getAge() +"  Address:"+person.getAddress());
61      }

 1 public class PersonService {
 2 
 3     public OMElement getPerson(OMElement element){
 4         //獲取請求條件 Id
 5         Integer id=Integer.valueOf(element.getText());
 6         //模擬返回數(shù)據(jù)
 7         PersonEntity person=new PersonEntity(id,"Leslie",32,"tianhe");
 8         //把person對象轉(zhuǎn)換為OMElement
 9         javax.xml.stream.XMLStreamReader reader=BeanUtil.getPullParser(person);
10         StreamWrapper parser=new StreamWrapper(reader);
11         OMXMLParserWrapper stAXOMBuilder=OMXMLBuilderFactory
12                 .createStAXOMBuilder(OMAbstractFactory.getOMFactory(), parser);
13         return stAXOMBuilder.getDocumentElement();
14     }
15 }

  1 public class BookEntity {
  2     private Integer id;
  3     private String title;
  4     private String author;
  5     private String publishing;
  6     private String introduction;
  7     private String type;
  8 
  9     public BookEntity(Integer id,String title,String author
 10           ,String type,String publishing,String introduction){
 11        this.id=id;
 12        this.title=title;
 13        this.author=author;
 14        this.type=type;
 15        this.publishing=publishing;
 16        this.introduction=introduction;
 17     }
 18     
 19     public Integer getId(){
 20         return id;
 21     }
 22     
 23     public void setId(Integer id){
 24         this.id=id;
 25     }
 26     ........
 27 }
 28 
 29 public interface BookService {
 30    OMElement getList(OMElement element);
 31 }
 32 
 33 public class BookServiceImpl implements BookService{
 34 
 35     @Override
 36     public OMElement getList(OMElement element) {
 37         //獲取請求信息 publishing 出版社名稱
 38         OMElement child=(OMElement)element.getChildren().next();
 39         String publishing=child.getText();
 40         
 41         // 構(gòu)建 OMFactory 工廠
 42         OMFactory factory=OMAbstractFactory.getOMFactory(); 
 43         OMNamespace omNamespace=factory.createOMNamespace(
 44                 "http://serviceImpl.axis2","ns");   
 45         
 46         //獲取計算機類書本子節(jié)computerElement
 47         List<BookEntity> computerTypeList=getBooks(
 48                 publishing,"computer");
 49         OMElement computerElement=convertToOMElement(
 50                 computerTypeList,"computer",omNamespace);
 51         
 52         //獲取文學(xué)類書本子節(jié)literatureElement
 53         List<BookEntity> literatureTypeList=getBooks(
 54                 publishing,"literature");
 55         OMElement literatureElement=convertToOMElement(
 56                 literatureTypeList,"literature",omNamespace);
 57         //加入多個類型的書本
 58         ...........
 59         //構(gòu)建XML樹
 60         OMElement response=factory.createOMElement(
 61                 "getListResponse",omNamespace); 
 62         OMElement returnValue=factory.createOMElement
 63                 ("return",omNamespace);
 64         OMElement books=factory.createOMElement(
 65                 "publishing",omNamespace);
 66         
 67         books.addAttribute("name", publishing, omNamespace);
 68         books.addChild(computerElement);
 69         books.addChild(literatureElement);
 70         .........
 71         returnValue.addChild(books);
 72         response.addChild(returnValue);
 73         return response;
 74     }
 75 
 76     //把計算機類書本對象轉(zhuǎn)換為XML信息    
 77     private OMElement convertToOMElement(List<BookEntity> list
 78             ,String typeName,OMNamespace omNamespace){    
 79         OMElement omElement=BeanUtil.getOMElement(new QName("theme")
 80           ,list.toArray(),new QName("book"),false,null);
 81         omElement.addAttribute("name",typeName,omNamespace);
 82         return omElement;
 83     }
 84     
 85     //根據(jù)書本類型查找數(shù)據(jù)
 86     private List<BookEntity> getBooks(String publishing,String type){
 87         List<BookEntity> list=new ArrayList<BookEntity>();
 88         for(BookEntity book:virtualDatabase(publishing))
 89             if(book.getType()=="computer")
 90                 list.add(book);
 91         return list;
 92     }
 93     
 94     //虛擬數(shù)據(jù)
 95     private List<BookEntity> virtualDatabase(String publishing){
 96         List<BookEntity> list=new ArrayList<BookEntity>();
 97         BookEntity book1=new BookEntity(
 98             1,"Core JAVA Advanced Features","Gary Cornell",
 99             "computer",publishing,
100             "Core Java by Cay S. Horstmann and Gary Cornell is a book\n"+
101             "in the Java series of Sun Microsystems Press, published \n"+
102             "by Prentice-Hall. The book is aimed at experienced \n"+
103             "programmers who want to learn how to write useful Java \n" +
104             "applications and applets. No hype, no toy code, no language \n"+
105             "lawyering, just solid facts and in-depth research to help you \n"+
106             "write real programs."
107         );
108         list.add(book1);
109         ........
110         return list;
111     }
112 }

1  <service name="BookService">  
2    <description>This is a sample Web Service.</description>  
3    <!--ServiceClass指定實現(xiàn)服務(wù)的類。   -->
4    <parameter name="ServiceClass" locked="false">axis2.serviceImpl.BookServiceImpl</parameter>  
5    <!-- operation 與Java Class中方法名對應(yīng)。 -->  
6    <operation name="getList">  
7       <messageReceiver class="org.apache.axis2.receivers.RawXMLINOutMessageReceiver"/>  
8    </operation>
9  </service>   

 1     public static void main(String[] args) throws AxisFault {
 2         //設(shè)置請求的endpoint地址
 3         EndpointReference targetEndpoint=new EndpointReference(
 4             "http://leslie-laptop:8080/axis2-1.6.2/services/BookService"); 
 5         Options options=new Options();   
 6         options.setTo(targetEndpoint); 
 7         
 8         //設(shè)置傳輸方式
 9         //可使用 TRANSPORT_JMS;TRANSPORT_HTTP;TRANSPORT_MAIL;TRANSPORT_TCP;
10         options.setTransportInProtocol(Constants.TRANSPORT_HTTP);   
11         
12         //把設(shè)置的地址、傳輸方式綁定到Service請求當(dāng)中
13         ServiceClient sender=new ServiceClient();   
14         sender.setOptions(options);   
15         
16         //設(shè)置請求的 SOAP 信息，輸入出版社名稱
17         OMElement requestOMElement=getBookRequest("China Machine Press");  
18         //發(fā)送請求
19         OMElement responseOMElement=sender.sendReceive(requestOMElement); 
20         //遍歷返回值，在返回信息中獲取computer類的Element
21         OMElement computerBookElement=getComputerElement(responseOMElement);
22         //把XML轉(zhuǎn)換為BookEntity對象集
23         List<BookEntity> list=convertToBooks(computerBookElement);
24         for(BookEntity book:list)
25             DisplayBook(book);
26     }
27 
28     //把XML數(shù)據(jù)轉(zhuǎn)換為BookEntity對象集
29     private static List<BookEntity> convertToBooks(OMElement element)
30             throws AxisFault{
31         List<BookEntity> list=new ArrayList<BookEntity>();
32         Iterator books=element.getChildElements();
33         while(books.hasNext()){
34             OMElement bookElement=(OMElement)books.next();
35             BookEntity book=(BookEntity) BeanUtil.processObject(bookElement,
36                 BookEntity.class, null, true, new DefaultObjectSupplier(), null);
37             list.add(book);
38         }
39         return list;
40     }
41     
42     //對OMElement元素進行遍歷，找到computer類型的節(jié)點
43     private static OMElement getComputerElement(OMElement element){
44         OMElement returnOMElement=(OMElement)element
45             .getChildElements().next();
46         OMElement publishingOMElement=(OMElement)returnOMElement
47             .getChildElements().next();
48         Iterator themes=publishingOMElement.getChildElements();
49         OMElement theme=null;
50         while(themes.hasNext()){
51             theme=(OMElement)themes.next();
52             OMAttribute themeName=(OMAttribute)theme.getAllAttributes().next();
53             if(themeName.getAttributeValue().equals("computer"))
54                break;
55         }
56         return theme;
57     }
58     
59     //構(gòu)建請求文檔
60     private static OMElement getBookRequest(String publishing){
61         //新建OMFactory工廠
62         OMFactory factory=OMAbstractFactory.getOMFactory();   
63         
64         //綁定OMNamespace，請求數(shù)據(jù)
65         OMNamespace omNamespace=factory.createOMNamespace(
66                 "http://serviceImpl.axis2","ns");     
67         OMElement value=factory.createOMElement("publishing",omNamespace);   
68         value.addChild(factory.createOMText(value,publishing.toString()));  
69         
70         //綁定請求方法名
71         OMElement method=factory.createOMElement("getList",omNamespace); 
72         method.addChild(value);  
73         return method;  
74     }
75     
76     private static void DisplayBook(BookEntity book){
77         System.out.println("##Id##:"+book.getId()+"  ##Title##:"+book.getTitle()
78             +"\n##Author##:"+book.getAuthor()+"  ##Type##:"+book.getType()
79             +"  ##Publishing##:"+book.getPublishing()+"\n##Introduction##:\n"
80             +book.getIntroduction()+"\n");
81     }

 1 public class MyModule implements Module{
 2  
 3      @Override
 4      public void applyPolicy(Policy arg0, AxisDescription arg1)
 5          throws AxisFault {
 6          // TODO Auto-generated method stub
 7      }
 8  
 9      @Override
10      public boolean canSupportAssertion(Assertion arg0) {
11          // TODO Auto-generated method stub
12          return false;
13      }
14  
15      @Override
16      public void engageNotify(AxisDescription arg0) throws AxisFault {
17          // TODO Auto-generated method stub
18      }
19  
20      @Override
21      public void init(ConfigurationContext arg0, AxisModule arg1)
22              throws AxisFault {
23          // TODO Auto-generated method stub
24      }
25  
26      @Override
27      public void shutdown(ConfigurationContext arg0) throws AxisFault {
28          // TODO Auto-generated method stub
29      }  
30  }
31  
32  public class InputHandler
33        extends AbstractHandler implements Handler{
34      
35      public InvocationResponse invoke(MessageContext context){
36          //顯示當(dāng)前上下文信息
37          System.out.println("##from:##\n  "+context.getFrom()
38                  +"\n##to:##\n  "+context.getTo());
39          //顯示所執(zhí)行的phase信息
40          phasesMessageDisplay(context.getExecutedPhases());
41          //顯示服務(wù)對象信息
42          AxisService axisService=context.getAxisService();
43          serviceMessageDisplay(axisService);
44          //顯示當(dāng)前operation信息
45          AxisOperation operation=context.getOperationContext().getAxisOperation();
46          currentOperationDisplay(operation);
47          //顯示服務(wù)的所有operation信息
48          operationsMessageDisplay(axisService.getOperations());
49          //顯示服務(wù)參數(shù)parameters信息
50          parametersMessageDisplay(axisService.getParameters());
51          return InvocationResponse.CONTINUE;
52      }
53      
54      //顯示所執(zhí)行的phases
55      private void phasesMessageDisplay(Iterator<Handler> iterator){
56          String data="##phaseList:##\n";
57          while(iterator.hasNext()){
58              Handler handler=(Handler)iterator.next();
59              data+="  "+handler.getName();  
60          }
61          System.out.println(data);
62      }
63      
64      //顯示服務(wù)信息
65      private void serviceMessageDisplay(AxisService axisService){
66          System.out.println("\n##serviceFile:##\n  "+axisService.getFileName()+ 
67              "\n##targetNamespace:##\n  "+axisService.getTargetNamespace()+
68              "\n##endpointName##:\n  "+axisService.getEndpointName()+"\n");
69      }
70      
71      //顯示當(dāng)前Operation信息
72      private void currentOperationDisplay(AxisOperation operation){
73          System.out.println("##currentOperation:##\n  name:"
74                  +operation.getName().getLocalPart()+"\n  messageReceive:"
75                  +operation.getMessageReceiver().toString()+"\n");
76      }
77      
78      //顯示服務(wù)的所有Operation信息
79      private void operationsMessageDisplay(Iterator operations){
80          while(operations.hasNext()){
81              AxisOperation operation=(AxisOperation)operations.next();
82              System.out.println("##operation:##\n  name:"
83                  +operation.getName().getLocalPart()+"\n  messageReceive:"
84                  +operation.getMessageReceiver().toString());
85          }
86          System.out.println();
87      }
88      
89      //顯示parameter信息
90      private void parametersMessageDisplay(List<Parameter> parameters){
91          for(Parameter parameter:parameters){
92              System.out.println("##parameter:##\n  name:"+parameter.getName()
93                      +"\n  value:"+parameter.getValue().toString());
94          }
95      }
96  }

1 <module name="myModule" class="axis2.module.MyModule">
2     <InFlow>
3        <handler name="inputHandler" class="axis2.handler.InputHandler">
4           <order phase="orderInPhase"/>
5        </handler>
6     </InFlow>
7 </module>

注意：自定義 handler 可以在 axis2.xml 或者 module.xml 中進行綁定。

axis2.xml 中所配置的是全局變量，如果直接在 axis2.xml 文件中加入對 handler 進行綁定，那所有的服務(wù)在 InFlow 和 OutFlow 中都執(zhí)行此 handler。
如果只在 axis2.xml 中建立自定義 phase，然后在 module.xml 中綁定 handler，那只有在服務(wù)綁定此 module 時，該 handler 才會被執(zhí)行 。配置應(yīng)該按需要而定，一般只有登錄、日志記錄、系統(tǒng)信息監(jiān)視等 handler 才會在 axis2.xml 中直接綁定。

1     <phaseOrder type="InFlow">
2         <phase name="orderInPhase">
3            <handler name="inputHandler" class="axis2.handler.InputHandler"/>
4         </phase>
5     </phaseOrder>

 1 <service name="PersonService">  
 2    <description>This is a sample Web Service.</description>
 3    <!--使用myModule模塊-->  
 4    <module ref="myModule"/>
 5    <!-- ServiceClass指定實現(xiàn)服務(wù)的類。 -->  
 6    <parameter name="ServiceClass" locked="false">axis2.serviceImpl.PersonServiceImpl</parameter>  
 7    <!-- operation 與Java Class中方法名對應(yīng)。   -->
 8    <operation name="GetPerson">  
 9       <messageReceiver class="org.apache.axis2.rpc.receivers.RPCMessageReceiver"/>  
10    </operation>
11    <operation name="GetList">  
12       <messageReceiver class="org.apache.axis2.receivers.RawXMLINOutMessageReceiver"/>  
13    </operation> 
14    <operation name="GetListByName">  
15       <messageReceiver class="org.apache.axis2.rpc.receivers.RPCMessageReceiver"/>  
16    </operation> 
17 </service>   

  1 public class MyModule implements Module{
  2     
  3         @Override
  4         public void applyPolicy(Policy arg0, AxisDescription arg1)
  5             throws AxisFault {
  6             // TODO Auto-generated method stub
  7         }
  8     
  9         @Override
 10         public boolean canSupportAssertion(Assertion arg0) {
 11             // TODO Auto-generated method stub
 12             return false;
 13         }
 14     
 15         @Override
 16         public void engageNotify(AxisDescription arg0) throws AxisFault {
 17             // TODO Auto-generated method stub    
 18         }
 19     
 20         @Override
 21         public void init(ConfigurationContext arg0, AxisModule arg1)
 22                 throws AxisFault {
 23             // TODO Auto-generated method stub
 24         }
 25     
 26         @Override
 27         public void shutdown(ConfigurationContext arg0) throws AxisFault {
 28             // TODO Auto-generated method stub
 29         }  
 30     }
 31     
 32     public class OrderInputHandler 
 33        extends AbstractHandler implements Handler {
 34     
 35         public InvocationResponse invoke(MessageContext context){
 36             //判斷被調(diào)用的是否OrderSerivce的addOrder方法
 37             if(context.getOperationContext().getAxisOperation()
 38                     .getName().getLocalPart().equals("addOrder")){
 39                 //獲取頭文件信息
 40                 SOAPHeader head=context.getEnvelope().getHeader();
 41                 //把頭文件信息轉(zhuǎn)換成User對象進行登錄
 42                 String[] userMes=head.getFirstElement().getText().split(",");
 43                 //用戶登錄
 44                 UserEntity user=UserManager.Login(userMes[0],userMes[1]);
 45                 .......
 46                 if(user!=null){
 47                    //登錄成功記錄User
 48                    SessionContext session=context.getSessionContext();
 49                    if(session.getProperty("User")==null)
 50                        session.setProperty("User", user);
 51                 } 
 52             }
 53             return InvocationResponse.CONTINUE;
 54         }
 55     }
 56     
 57     public class OrderOutputHandler 
 58         extends AbstractHandler implements Handler{
 59          
 60         public InvocationResponse invoke(MessageContext context){
 61             //判斷被調(diào)用的是否OrderSerivce的addOrder方法
 62             if(context.getOperationContext().getAxisOperation()
 63                     .getName().getLocalPart().equals("addOrder")){
 64               //獲取返回信息的SOAPBody，判斷訂單總體價格是否高于 200 dollar
 65               SOAPBody body=context.getEnvelope().getBody();
 66               OMElement element=body.getFirstElement();
 67               try {
 68                  OrderEntity order = (OrderEntity) BeanUtil.processObject(element,
 69                      OrderEntity.class, null, true, new DefaultObjectSupplier(), null);
 70                 
 71                  //總體價格高于 200 dollar的訂單在頭文件中輸入獲獎信息
 72                  if(order.getTotalPrice()>200){
 73                  //在數(shù)據(jù)庫中記錄獲獎訂單
 74                  Favourable favourable=FavourableManager.addOrder(order); 
 75                  .......
 76                  //修改頭文件，加入獲獎信息 
 77                  setHead(context.getEnvelope().getHeader(),favourable);
 78               } catch (AxisFault e) {
 79                  e.printStackTrace();
 80               }      
 81           }
 82           return InvocationResponse.CONTINUE;
 83         }
 84         
 85         //修改頭文件，加入獲獎信息
 86         private void setHead(SOAPHeader head,favourable){
 87             OMFactory factory=OMAbstractFactory.getOMFactory(); 
 88             OMNamespace omNamespace=factory.createOMNamespace(
 89                     "http://serviceImpl.axis2","ns");    
 90             OMElement element=factory.createOMElement("favourable",omNamespace);
 91             element.setText("Congratulations! Price is higher than 200 dollar ......");
 92             //加入favourable 信息
 93             .........
 94             head.addChild(element);
 95         }
 96     }
 97     
 98     public class OrderEntity implements Serializable {
 99         private Integer id;
100         private String orderCode;
101         private Double totalPrice;
102         .........
103      
104         public OrderEntity(Integer id,String orderCode,Double totalPrice，........){
105             this.id=id;
106             this.orderCode=orderCode;
107             this.totalPrice=totalPrice;
108             ........
109         }
110         ..........
111     }

 1 <module name="myModule" class="axis2.module.MyModule">
 2     <InFlow>
 3        <handler name="orderInputHandler" class="axis2.handler.OrderInputHandler">
 4           <order phase="orderInPhase"/>
 5        </handler>
 6     </InFlow>
 7     <OutFlow>
 8         <handler name="orderOutputHandler" class="axis2.handler.OrderOutputHandler">
 9             <order phase="orderOutPhase"/>
10         </handler>
11     </OutFlow>
12 </module>

1      <phaseOrder type="InFlow">
2         <phase name="orderInPhase"/>
3      </phaseOrder>
4      <phaseOrder type="OutFlow">
5          <!-- 調(diào)用自定義模塊進行處理 -->
6          <phase name="orderOutPhase"/>
7      </phaseOrder>

 1     public interface OrderService {
 2        OMElement addOrder(OMElement element) throws Exception;
 3     } 
 4     
 5     public class OrderServiceImpl implements OrderService{
 6         
 7         @Override
 8         public OMElement addOrder(OMElement element) throws Exception{
 9             //驗證是否登錄成功
10             if(isLogged()){
11                 //把訂單加入數(shù)據(jù)庫，把更新后的訂單返回客戶端
12                 OrderEntity order = (OrderEntity) BeanUtil.processObject(
13                    element.getFirstElement(),OrderEntity.class, 
14                    null, true, new DefaultObjectSupplier(), null);
15                 //加入訂單，計算總體價格，Code號碼等信息
16                 OrderEntity orderRefresh=OrderManager.addOrder(order);
17                 .......
18                 //把修改后order對象轉(zhuǎn)換為OMElement
19                 XMLStreamReader reader=BeanUtil.getPullParser(orderRefresh);
20                 StreamWrapper parser=new StreamWrapper(reader);
21                 OMXMLParserWrapper stAXOMBuilder=OMXMLBuilderFactory
22                   .createStAXOMBuilder(OMAbstractFactory.getOMFactory(), parser);
23                 return  stAXOMBuilder.getDocumentElement();
24             }
25             else
26                 throw new Exception();
27         }
28         
29         //驗證用戶是否已經(jīng)登錄
30         private boolean isLogged(){
31             MessageContext context=MessageContext.getCurrentMessageContext();
32             SessionContext session=context.getSessionContext();
33             return session.getProperty("User")!=null;    
34         }
35     }

 1 <service name="OrderService">  
 2    <description>This is a sample Web Service.</description>  
 3    <module ref="myModule"/>
 4    <!--  ServiceClass指定實現(xiàn)服務(wù)的類。 -->  
 5    <parameter name="ServiceClass" locked="false">axis2.serviceImpl.OrderServiceImpl</parameter>  
 6    <!-- operation 與Java Class中方法名對應(yīng)。   -->
 7    <operation name="addOrder">  
 8       <messageReceiver class="org.apache.axis2.receivers.RawXMLINOutMessageReceiver"/>  
 9    </operation>
10  </service>   

 1      public static void main(String[] args) throws RemoteException, OrderServiceExceptionException {
 2          // TODO Auto-generated method stub
 3          excute();
 4      }
 5      
 6      public static void excute() throws AxisFault{
 7          EndpointReference targetEndpoint=new EndpointReference(
 8                  "http://leslie-laptop:8080/axis2-1.6.2/services/OrderService"); 
 9          Options options=new Options();   
10          options.setManageSession(true);
11          options.setTo(targetEndpoint); 
12         
13          //設(shè)置傳輸方式
14          //可使用 TRANSPORT_JMS;TRANSPORT_HTTP;TRANSPORT_MAIL;TRANSPORT_TCP;
15          options.setTransportInProtocol(Constants.TRANSPORT_HTTP);   
16          
17          //把設(shè)置的地址、傳輸方式綁定到Service請求當(dāng)中
18          ServiceClient sender=new ServiceClient();   
19          sender.setOptions(options);   
20          
21          //設(shè)置請求的 SOAP 信息
22          OMElement requestOMElement=getOrderRequest(new OrderEntity(-1,null,200.5,......));   
23          //在頭文件中加入用戶資料
24          sender.addHeader(setHead());
25          OMElement responseOMElement=sender.sendReceive(requestOMElement);   
26         
27          //對返回的SOAP進行處理，顯示返回值
28          OrderEntity order=convertToOrder(responseOMElement);
29          displayOrderProperty(order);
30      }
31      
32      //在頭文件中加入用戶資料    
33      private static OMElement setHead(){
34          //新建OMFactory工廠
35          OMFactory factory=OMAbstractFactory.getOMFactory();   
36          //綁定OMNamespace，請求數(shù)據(jù)
37          OMNamespace omNamespace=factory.createOMNamespace(
38                  "http://serviceImpl.axis2","ns");     
39          //加入用戶資料
40          OMElement user=factory.createOMElement("User",omNamespace); 
41          user.setText("Leslie,12345678");
42          return user;
43      }
44      
45      private static OMElement getOrderRequest(OrderEntity order){
46          //新建OMFactory工廠
47          OMFactory factory=OMAbstractFactory.getOMFactory();     
48          //綁定OMNamespace
49          OMNamespace omNamespace=factory.createOMNamespace(
50                  "http://serviceImpl.axis2","ns");     
51          //綁定請求方法名
52          OMElement method=factory.createOMElement("addOrder",omNamespace); 
53  
54          //把order對象轉(zhuǎn)換為OMElement
55          javax.xml.stream.XMLStreamReader reader=BeanUtil.getPullParser(order);
56          StreamWrapper parser=new StreamWrapper(reader);
57          OMXMLParserWrapper stAXOMBuilder=OMXMLBuilderFactory
58                  .createStAXOMBuilder(OMAbstractFactory.getOMFactory(), parser);
59          OMElement param=stAXOMBuilder.getDocumentElement();
60          
61          method.addChild(param);
62          return method;
63      }
64      
65      //把返回OMElement對象轉(zhuǎn)換成 person對象 
66      private static OrderEntity convertToOrder(OMElement element) 
67              throws AxisFault{
68          OrderEntity order =null;
69          OMElement omElement = element.getFirstElement().getFirstElement();
70          String localName=element.getLocalName().toLowerCase();
71          if (localName.equals("orderentity")) {
72             order = (OrderEntity) BeanUtil.processObject(element,
73             OrderEntity.class, null, true, new DefaultObjectSupplier(), null);      
74          }
75          return order;
76      }
77      //顯示Order數(shù)據(jù)
78      private static void displayOrderProperty(OrderEntity order){
79          System.out.println("Id:"+order.getId()+"  Code:"+order.getOrderCode()
80             +"  TotalPrice:"+ order.getTotalPrice());
81      }

1 public class PersonService{
2 
3     public List<PersonEntity> getList(){
4         List<PersonEntity> list=new ArrayList<PersonEntity>();
5         list.add(new PersonEntity(1,"Leslie",32,"tianhe"));
6         list.add(new PersonEntity(2,"Elva",28,"henan"));
7         return list;
8     }
9 }

 1     public static void main(String[] args)
 2             throws InterruptedException, RemoteException {
 3         // TODO Auto-generated method stub
 4         threadMessage("start "); 
 5         //建立服務(wù)對象
 6         PersonServiceStub personService=new PersonServiceStub();        
 7         PersonServiceStub.GetList getList=new PersonServiceStub.GetList();
 8         //建立回調(diào)函數(shù)
 9         PersonServiceCallbackHandler callback=new PersonServiceCallbackHandler(){
10             public void receiveResultgetList(GetListResponse response){
11                 threadMessage("callback ");
12                 PersonEntity[] list=response.get_return();
13                 for(Integer n=0;n<list.length;n++)
14                     displayPersonProperty(list[n]);
15             }
16         };
17         //啟動異步服務(wù)
18         personService.startgetList(getList,callback);
19         Thread.sleep(500);
20     }
21 
22     //顯示線程id
23     private static void threadMessage(String data){
24            Thread thread=Thread.currentThread();
25            System.out.println(data +"threadId: "+thread.getId());
26     }
27     
28     //顯示對象信息
29     private static void displayPersonProperty(PersonEntity person){
30         System.out.println("Id:"+person.getId() +"  Name:"
31            +person.getName() +"  Age:"+ person.getAge() 
32            +"  Address:"+person.getAddress() );
33     }

作者：風(fēng)塵浪子

原創(chuàng)作品，轉(zhuǎn)載時請注明作者及出處