axis web service

duantonghai

浏览: 20605 次
性别:
来自: 上海

最近访客更多访客>>

1163735915

hdhhp

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

webservice

以前对axis 生成web service一直比较糊涂，发现个人说个人的，好像有很多方法一样，最近特意查了查资料总结一下。

axis 生成webservice有3 种方式，

1, Dynamic invocation interface

2, Dynamic proxy

3, sub

下面分别做简单介绍

   在开始之前先环境配置：
    下载axis 包解压，把webapps/axis 下的所有文件都拷贝到你的web 工程下，
     这样你就可以在你工程里生成web service和利用一些axis提供的工具.

     打开： http://localhost:9081/TestWebService/index.jsp

      这里去验证你的环境是否建立成功。

     在电脑环境变量里增加

     AXIS_HOME: C:\MyThings\book\program\axis-1_4
     AXIS_LIB : C:\MyThings\book\program\axis-1_4\lib
     AXISCLASSPATH : 
C:\MyThings\book\program\axis-1_4\lib\axis.jar;C:\MyThings\book\program\axis-1_4\lib\axis-ant.jar;C:\MyThings\book\program\axis-1_4\lib\commons-discovery-0.2.jar;C:\MyThings\book\program\axis-1_4\lib\commons-logging-1.0.4.jar;C:\MyThings\book\program\axis-1_4\lib\jaxrpc.jar;C:\MyThings\book\program\axis-1_4\lib\log4j-1.2.8.jar;C:\MyThings\book\program\axis-1_4\lib\saaj.jar;C:\MyThings\book\program\axis-1_4\lib\wsdl4j-1.5.1.jar;C:\MyThings\book\program\axis-1_4\lib\activation.jar;C:\MyThings\book\program\axis-1_4\lib\mail-1.4.jar

这里注意我把mail-1.4.jar 和 activation.jar也加进来了，这两个本来不在lib目录下，但是axis需要依赖我就加进来了

   http://localhost:9081/TestWebService/servlet/AxisServlet
   可以查看现在服务器上都部署了那些服务

   第1种

　　　　动态接口调用，使用及时发布，用户只需提供java类源代码，axis会自动处理的

　　　　heloWorld.java

 public class HelloWorld{
        public String sayHello(){
               return "Hello World";
        }
       }

将hellWorld.java 拷贝到　%TOMCAT_HOME%\webpps\axis下，改名为HelloWorld.jws，　这样就发布成功了。

　测试代码：

　

import java.net.URL;
import org.apache.axis.client.Call;
import org.apache.axis.client.Service;

public class CitiCardSericeTest {

	/**
	 * @param args
	 * @throws Exception 
	 */
	public static void main(String[] args) throws Exception {

		String endpoint = "http://localhost:8080/axis/HelloWorld.jws";
		Service service = new Service();
		Call call = (Call) service.createCall();
		call.setTargetEndpointAddress(new URL(endpoint));
		call.setOperationName("sayHello");
		String res = (String) call.invoke(new Object[] {});
		System.out.println(res);

	}

}

如果复杂对象：
QName qn=new QName("urn:beanservice","User");
		call.registerTypeMapping(User.class, qn, new BeanSerializerFactory(User.class,qn), new BeanDeserializerFactory(User.class,qn));
        User user=new User();
        user.setAge("10");
        user.setName("duant");
        String res = (String) call.invoke(new Object[] {user});
        System.out.println(res);

或者
  call.addParameter( "arg1", qn, ParameterMode.IN );

第2种　Dynamic proxy
将HelloWorld.java编译成HelloWorld.class 放到　%TOMCAT_HOME%\webapps\axis\WEB-INF\classe下

　在 %TOMCAT_HOME%\webapps\axis\WEB-INF下建立deploy.wsdd文件，soap服务发布描述文件

<deployment xmlns="http://xml.apache.org/axis/wsdd/"
	xmlns:java="http://xml.apache.org/axis/wsdd/providers/java">
	
	
	<service name="HelloWorld" provider="java:RPC">
		<parameter name="className"  value="HelloWorld" />
		<parameter name="allowedMethods" value="*" />

	</service>
	
</deployment>

在doc目录下到 %TOMCAT_HOME%\webapps\axis\WEB-INF,命令
　java -cp %AXISCLASSPATH% org.apache.axis.client.AdminClient deploy.wssd

就会发现多了一个servver-config.wsdd文件，这个就是配置文件，
访问　http://localhost:8080/axis/servlet/AxisServlet

测试代码：

import java.net.URL;
import org.apache.axis.client.Call;
import org.apache.axis.client.Service;

public class CitiCardSericeTest {

	/**
	 * @param args
	 * @throws Exception 
	 */
	public static void main(String[] args) throws Exception {

		String endpoint="http://localhost:8080/axis/services/HelloWorld"; //和１不同
		Service service = new Service();
		Call call = (Call) service.createCall();
		call.setTargetEndpointAddress(new URL(endpoint));
		call.setOperationName("sayHello");
		String res = (String) call.invoke(new Object[] {});
		System.out.println(res);

	}

}

第3种 stub 方式

package com.webService;

public class OrderService {
	public String orderProduce(String name, String address, String item, int quantity, Card card){
		String orderInfo=name+" "+address+" "+item+" "+card.getName();
		return orderInfo;
	}
}

package com.webService;

public class Card {
	private String name;
	private String age;
	
	public String getAge() {
		return age;
	}
	public void setAge(String age) {
		this.age = age;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
}

编写完代码后，在WEB-INF 下新建立一个文件 deploy.wsdd

这里需要注意beanMapping,因为card是一个java bean.

<deployment xmlns="http://xml.apache.org/axis/wsdd/"
	xmlns:java="http://xml.apache.org/axis/wsdd/providers/java">
	
	
	<service name="OrderService" provider="java:RPC">
		<parameter name="className"  value="com.webService.OrderService" />
		<parameter name="allowedMethods" value="*" />

               <beanMapping languageSpecificType="java:com.webService.Card"
		qname="myNsn:Card" xmlns:myNsn="urn:BeanService" />
	</service>
	
</deployment>

这个时候已经完成了代码编写，如果你的环境是好的，就可以进入发布环节，如果环境没好，请参考环境建立部分。

在WEB-INF下面执行命令

java -cp %AXISCLASSPATH% org.apache.axis.client.AdminClient -lhttp://localhost:9081/TestWebServices/services/orderService  deploy.wsdd

系统提示 <Admin>Done processing </Admin>

就说明发布成功，可以去 http://localhost:9081/TestWebService/servlet/AxisServlet 查看已经部署结果，

可以用 http://localhost:9081/TestWebServices/services/orderService?wsdl

获得这个service 的wsdl 文件

测试这个webservice时可以用 WSDL2Java 生成测试的类，

执行命令：

java -cp %AXISCLASSPATH% org.apache.axis.wsdl.WSDL2Java -o c:\\temp -p com.webService orderService.wsdl

就可以根据wsdl文成生成客户端调用代码类，

card.java, OrderService_PortType.java, OrderServiceService.java, OrderServiceServiceLocator.java, OrderServiceSoapBindingStub.java

调用类

package com.webService;

import java.rmi.RemoteException;

import javax.xml.rpc.ServiceException;

public class Client {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		OrderServiceServiceLocator locator=new OrderServiceServiceLocator();
		try {
			OrderService_PortType service=locator.getOrderService();
Card card=new Card():
card.setName("laoslais");
			String res=service.orderProduce("one", "two", "three", 2, card);
			System.out.println(res);
		} catch (ServiceException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (RemoteException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

}

执行就的到结果： one two three

handler:

package com.webService.haddler;

import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Date;

import javax.xml.soap.SOAPException;

import org.apache.axis.AxisFault;
import org.apache.axis.Handler;
import org.apache.axis.MessageContext;
import org.apache.axis.handlers.BasicHandler;

public class LogHandler extends BasicHandler {


	private static final long serialVersionUID = 1L;

	public void invoke(MessageContext context) throws AxisFault {
		Handler handler=context.getService();
		String filename=(String) this.getOption("filename");
		

		try {
			FileOutputStream fos=new FileOutputStream(filename,true);
			PrintWriter write=new PrintWriter(fos);
			Integer counter=(Integer)handler.getOption("accesses");
			if(counter==null){
				counter=new Integer(1);
			}
			
			counter=new Integer(counter.intValue()+1);
			Date date=new Date();
			context.getMessage().writeTo(System.out);
			String result="date web service:"+context.getTargetService()+" call "+counter;
			
			handler.setOption("accesses", counter);
			write.println(result);
			write.close();
		} catch (FileNotFoundException e) {
			e.printStackTrace();
		} catch (SOAPException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

}

deploy.wsdd:

<service name="OrderService" provider="java:RPC">
		<parameter name="className"  value="com.webService.OrderService" />
		<parameter name="allowedMethods" value="*" />
		<requestFlow>
		<handler name="logging" type="java:com.webService.haddler.LogHandler">
		 <parameter name="filename" value="c:\\temp\\myservice.log" />
		</handler>
		</requestFlow>
	</service>

客户端代码：

private static Logger logger=Logger.getLogger(AbstractServiceInvoke.class);
	private GbLogger m_gblog;
	private URL endPoint;
	protected Call call;
	
	public AbstractServiceInvoke(URL endPoint) throws ServiceException{
		this.endPoint = endPoint;
		Service service = new Service();

		this.call = (Call) service.createCall();
		this.call.setTargetEndpointAddress(this.endPoint);
		this.setCommonlPropety();
	}
	
	public URL getEndPoint() {
		return endPoint;
	}
	
	protected void setCommonlPropety(){
		call.setEncodingStyle("http://schemas.xmlsoap.org/soap/encoding/");
		call.setProperty(org.apache.axis.client.Call.SEND_TYPE_ATTR, Boolean.FALSE);
	    call.setProperty(org.apache.axis.AxisEngine.PROP_DOMULTIREFS, Boolean.FALSE);
	    call.setSOAPVersion(org.apache.axis.soap.SOAPConstants.SOAP11_CONSTANTS);
	}
	
	protected void registerTypeMapping(Class cls,QName qn){
		call.registerTypeMapping(cls, qn, new BeanSerializerFactory(cls,qn), new BeanDeserializerFactory(cls,qn)); 
	}
	
	protected void registerTypeMapping(String name,Class cls){
		QName qn=new QName("urn:beanservice",name);
		call.registerTypeMapping(cls, new QName("urn:beanservice",name), new BeanSerializerFactory(cls,qn), new BeanDeserializerFactory(cls,qn)); 
	}
	
	protected void registerTypeMapping(Class cls){
		String name=cls.getSimpleName();
		this.registerTypeMapping(name, cls);
	}
	
	
	protected void setInputType(QName qn,Class cls){
		call.addParameter(qn.getLocalPart(), qn,cls, ParameterMode.IN );
	}
	
	protected void setInputType(String name,Class cls){
		QName qn=new QName("urn:beanservice",name);
		call.addParameter(name, qn,cls, ParameterMode.IN );
	}
	
	protected void setInputType(Class cls){
		String name=cls.getSimpleName();
		this.setInputType(name, cls);
	}
	
	protected void setReturnType(Class cls){
		this.call.setReturnClass(cls);
	}
	
	protected Object invokeMethod(Object input,Class output,String operationName) throws RemoteException{
		String DEBUG_HDR = Utilities.getMethodInfo();
		
		try{

			Class inputCls=input.getClass();
			
			if(m_gblog != null){
				m_gblog.info(DEBUG_HDR + " input class:"+inputCls.getSimpleName());
			}else{
				logger.debug(DEBUG_HDR + " input class:"+inputCls.getSimpleName());
			}
			this.registerTypeMapping(inputCls);
			this.setInputType(inputCls);
			
			this.registerTypeMapping(output);
			this.setReturnType(output);
			if(m_gblog != null){
				m_gblog.info(DEBUG_HDR + " return class:"+output.getSimpleName());
			}else{
				logger.debug(DEBUG_HDR + " return class:"+output.getSimpleName());
			}
			
			this.call.setOperationName(operationName);
			if(m_gblog != null){
				m_gblog.info(DEBUG_HDR + " operationName:"+operationName);
			}else{
				logger.debug(DEBUG_HDR + " operationName:"+operationName);
			}
			
			Object res=this.call.invoke(new Object[] {input});
			return res;
		}finally{
			this.printDebugInfo();
		}
	}

分享到：