九、 编写Module模块

  
  

   
   
编写实现Handler接口的实现类，代码如下： 
?
    
    

     
     
package com.hoo.module;

import org.apache.axis2.AxisFault;
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.description.HandlerDescription;
import org.apache.axis2.description.Parameter;
import org.apache.axis2.engine.Handler;

/**
 * <b>function:</b>axis2模块Handler接口实现
 * @author hoojo
 * @createDate 2011-3-15 上午03:37:43
 * @file CustomHandler.java
 * @package com.hoo.module
 * @project Axis2WebService
 * @blog http://blog.csdn.net/IBM_hoojo
 * @email hoojo_@126.com
 * @version 1.0
 */
public class CustomHandler implements Handler {
	
	private String name;
	
	public void setName(String name) {
		this.name = name;
	}

	public String getName() {
		return this.name;
	}
	
	public void cleanup() {
		System.out.println("###########cleanup###########");
	}

	public void flowComplete(MessageContext ctx) {
		System.out.println("###########flowComplete###########");
		System.out.println(ctx.getEnvelope().toString());
	}

	public HandlerDescription getHandlerDesc() {
		System.out.println("###########getHandlerDesc###########");
		return null;
	}

	public Parameter getParameter(String name) {
		System.out.println("###########getParameter###########");
		return null;
	}

	public void init(HandlerDescription handlerDescription) {
		System.out.println("###########init###########");
	}

	public InvocationResponse invoke(MessageContext ctx) throws AxisFault {
		System.out.println(ctx.getEnvelope().toString());
		return InvocationResponse.CONTINUE;
	}
}
    
    


     
     
编写module.xml文件 
?
      
      

       
       
<module name="customModule" class="com.hoo.module.CustomModule">
    <InFlow>
        <handler name="InFlowLogHandler" class="com.hoo.module.CustomHandler">
            <order phase="customPhase"/>
        </handler>
    </InFlow>
    <OutFlow>
        <handler name="OutFlowLogHandler" class="com.hoo.module.CustomHandler">
            <order phase="customPhase"/> 
        </handler>
    </OutFlow>
	
	<InFaultFlow>
        <handler name="FaultInFlowLogHandler" class="com.hoo.module.CustomHandler">
            <order phase="customPhase"/>
        </handler>
    </InFaultFlow>
	
    <OutFaultFlow>
        <handler name="FaultOutFlowLogHandler" class="com.hoo.module.CustomHandler">
            <order phase="customPhase"/>
        </handler>
    </OutFaultFlow>
</module>
      
      


       
       
编写services.xml文件 
        
        

         
         
<service name="CustomModuleService">
    <description>使用CustomModule SimpleWebService模块</description>
    <!--  引用customModule模块  -->
    <module ref="customModule"/>
    <parameter name="ServiceClass">
        com.hoo.module.SimpleWebService   
    </parameter>
    <messageReceivers>
        <messageReceiver mep="http://www.w3.org/2004/08/wsdl/in-out"
				class="org.apache.axis2.rpc.receivers.RPCMessageReceiver" />
		<messageReceiver mep="http://www.w3.org/2004/08/wsdl/in-only"
				class="org.apache.axis2.rpc.receivers.RPCInOnlyMessageReceiver" />
    </messageReceivers>
</service>
        
        
?
在[tomcat_home]/webapps/axis2/WEB-INF/conf中axis2.xml文件中加入内容，在所有的<phaSEOrder>标签中加入 <phase name="customPhase"/> 
        
        

         
         
打包发布module，在c盘建立CustomModuleService，然后将CustomModule.class和CustomHandler.class以及类路径目录复制到该目录。
然后将module.xml文件放到META-INF（没有新建）目录。 
运行jar命令：jar cvf custom-module.mar . 
将生成的custom-module.mar文件粘贴到[tomcat_home] /webapps/axis2/WEB-INF/modules目录中 
发布WebService，建立目录simpleWebService，将SimpleWebService.xml和类路径复制到该目录下，将services.xml复制到META-INF目录。 
运行jar命令：jar cvf simple-service.aar . 
将生成的simple-service.aar文件复制到[tomcat_home] /webapps/axis2/WEB-INF/services目录下 
然后重启tomcat服务。 
客户端访问WebService代码
?
          
          

           
           
package com.hoo.service;

import javax.xml.namespace.QName;
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.rpc.client.RPCServiceClient;

/**
 * <b>function:</b>访问SimpleWebService
 * @author hoojo
 * @createDate 2011-3-15 上午07:26:08
 * @file SimpleWebServiceClient.java
 * @package com.hoo.service
 * @project Axis2WebService
 * @blog http://blog.csdn.net/IBM_hoojo
 * @email hoojo_@126.com
 * @version 1.0
 */
public class SimpleWebServiceClient {

	public static void main(String[] args) throws AxisFault {
		String target = "http://localhost:8080/axis2/services/CustomModuleService";
		RPCServiceClient client = new RPCServiceClient();
		Options options = client.getOptions();
		options.setManageSession(true);
		
		EndpointReference epr = new EndpointReference(target);
		options.setTo(epr);
		
		QName qname = new QName("http://module.hoo.com","randInt");
		Object[] result = client.invokeBlocking(qname,new Object[] { null },new Class[] { int.class });
		System.out.println(result[0]);
	}
}