axis2创建,部署,发布和访问web service

使用axis2创建web service是一种常用的发布web服务的方式，下面从搭建axis2开发环境开始，写一个简单的web服务，然后再写一个客户端程序，访问我们刚才创建的WEB 服务。

一、搭建axis2环境

  1.到apache官网下载：http://axis.apache.org/axis2/java/core/download.cgi

  2.解压下载到的ZIP包

  3.集成到TOMCAT上：

   运行CMD，切换目录到解压包的webapp目录下，该目录下有一个build.xml，运行ant命令，完成之后会在webapp同级目录中生成一个 dist目录，将该目录下的axis2.war拷贝到TOMCAT下的webapp目录下，当启动TOMCAT时，会自动解压axis2.war,生成 axis2文件夹，axis2/WEB-INF/services 目录很重要，以后的web服务都是部署在这个目录下面的。

【如果没有ANT，可以到apache官网下载：http://ant.apache.org/bindownload.cgi ，完成后可将解压后的bin目录添加到系统变量path中，这样方便在任意的地方运行ant命令。】

效果如下：

4.启动TOMCAT服务器，在浏览器中输入http://localhost:8080/axis2/，如果出现下图，则表明环境OK。

二、创建一个简单的web服务

  1.服务代码如下：

package samples.quickstart.service.pojo;
import java.util.HashMap;
public class StockQuoteService {
    private HashMap map = new HashMap();
    public double getPrice(String symbol) {
        Double price = (Double) map.get(symbol);
        if(price != null){
            return price.doubleValue();
        }
        return 42.00;
    }
    public void update(String symbol, double price) {
        map.put(symbol, new Double(price));
    }
}

 2.写完服务代码还需要用XML配置该服务，如下：

<service name="StockQuoteService" scope="application" targetNamespace="http://quickstart.samples/">
    <description>
        Stock Quote Service
    </description>
    <messageReceivers>
        <messageReceiver mep="http://www.w3.org/2004/08/wsdl/in-only"
                         class="org.apache.axis2.rpc.receivers.RPCInOnlyMessageReceiver"/>
        <messageReceiver mep="http://www.w3.org/2004/08/wsdl/in-out"
                         class="org.apache.axis2.rpc.receivers.RPCMessageReceiver"/>
    </messageReceivers>
    <schema schemaNamespace="http://quickstart.samples/xsd"/>
    <parameter name="ServiceClass">samples.quickstart.service.pojo.StockQuoteService</parameter>
</service>

 3.部署服务：

  到部署目录下，新建一个文件夹如myfirstservice(名称没有要求)，然后再其下新建META-INF 目录，把刚才的服务配置services.xml放到该目录下，然后把含包结构的class文件放到部署目录下，即可完成部署。

axis2/WEB-INF/services

                               -myfirstservice

                                      -META-INF

                                                -services.xml

                                      -samples

                                                -quickstart

                                                         -service

                                                                -pojo

                                                                     -StockQuoteService.class

4.重启TOMCAT，输入http://localhost:8080/axis2/，点击Services链接，如果出现下图，表明服务发布成功。

点击StockQuoteService可以看到该服务的WSDL：

<?xml version="1.0" encoding="UTF-8" ?> 
- <wsdl:definitions xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/" xmlns:ns1="http://org.apache.axis2/xsd" xmlns:ns="http://quickstart.samples/xsd" xmlns:wsaw="http://www.w3.org/2006/05/addressing/wsdl" xmlns:http="http://schemas.xmlsoap.org/wsdl/http/" xmlns:tns="http://quickstart.samples/" xmlns:xs="http://www.w3.org/2001/XMLSchema" xmlns:mime="http://schemas.xmlsoap.org/wsdl/mime/" xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/" xmlns:soap12="http://schemas.xmlsoap.org/wsdl/soap12/" targetNamespace="http://quickstart.samples/">
  <wsdl:documentation>StockQuoteService</wsdl:documentation> 
- <wsdl:types>
- <xs:schema attributeFormDefault="qualified" elementFormDefault="qualified" targetNamespace="http://quickstart.samples/xsd">
- <xs:element name="update">
- <xs:complexType>
- <xs:sequence>
  <xs:element minOccurs="0" name="symbol" nillable="true" type="xs:string" /> 
  <xs:element minOccurs="0" name="price" type="xs:double" /> 
  </xs:sequence>
  </xs:complexType>
  </xs:element>
- <xs:element name="getPrice">
- <xs:complexType>
- <xs:sequence>
  <xs:element minOccurs="0" name="symbol" nillable="true" type="xs:string" /> 
  </xs:sequence>
  </xs:complexType>
  </xs:element>
- <xs:element name="getPriceResponse">
- <xs:complexType>
- <xs:sequence>
  <xs:element minOccurs="0" name="return" type="xs:double" /> 
  </xs:sequence>
  </xs:complexType>
  </xs:element>
  </xs:schema>
  </wsdl:types>
- <wsdl:message name="getPriceRequest">
  <wsdl:part name="parameters" element="ns:getPrice" /> 
  </wsdl:message>
- <wsdl:message name="getPriceResponse">
  <wsdl:part name="parameters" element="ns:getPriceResponse" /> 
  </wsdl:message>
- <wsdl:message name="updateRequest">
  <wsdl:part name="parameters" element="ns:update" /> 
  </wsdl:message>
- <wsdl:portType name="StockQuoteServicePortType">
- <wsdl:operation name="getPrice">
  <wsdl:input message="tns:getPriceRequest" wsaw:Action="urn:getPrice" /> 
  <wsdl:output message="tns:getPriceResponse" wsaw:Action="urn:getPriceResponse" /> 
  </wsdl:operation>
- <wsdl:operation name="update">
  <wsdl:input message="tns:updateRequest" wsaw:Action="urn:update" /> 
  </wsdl:operation>
  </wsdl:portType>
- <wsdl:binding name="StockQuoteServiceSoap11Binding" type="tns:StockQuoteServicePortType">
  <soap:binding transport="http://schemas.xmlsoap.org/soap/http" style="document" /> 
- <wsdl:operation name="getPrice">
  <soap:operation soapAction="urn:getPrice" style="document" /> 
- <wsdl:input>
  <soap:body use="literal" /> 
  </wsdl:input>
- <wsdl:output>
  <soap:body use="literal" /> 
  </wsdl:output>
  </wsdl:operation>
- <wsdl:operation name="update">
  <soap:operation soapAction="urn:update" style="document" /> 
- <wsdl:input>
  <soap:body use="literal" /> 
  </wsdl:input>
  </wsdl:operation>
  </wsdl:binding>
- <wsdl:binding name="StockQuoteServiceSoap12Binding" type="tns:StockQuoteServicePortType">
  <soap12:binding transport="http://schemas.xmlsoap.org/soap/http" style="document" /> 
- <wsdl:operation name="getPrice">
  <soap12:operation soapAction="urn:getPrice" style="document" /> 
- <wsdl:input>
  <soap12:body use="literal" /> 
  </wsdl:input>
- <wsdl:output>
  <soap12:body use="literal" /> 
  </wsdl:output>
  </wsdl:operation>
- <wsdl:operation name="update">
  <soap12:operation soapAction="urn:update" style="document" /> 
- <wsdl:input>
  <soap12:body use="literal" /> 
  </wsdl:input>
  </wsdl:operation>
  </wsdl:binding>
- <wsdl:binding name="StockQuoteServiceHttpBinding" type="tns:StockQuoteServicePortType">
  <http:binding verb="POST" /> 
- <wsdl:operation name="getPrice">
  <http:operation location="getPrice" /> 
- <wsdl:input>
  <mime:content type="text/xml" part="parameters" /> 
  </wsdl:input>
- <wsdl:output>
  <mime:content type="text/xml" part="parameters" /> 
  </wsdl:output>
  </wsdl:operation>
- <wsdl:operation name="update">
  <http:operation location="update" /> 
- <wsdl:input>
  <mime:content type="text/xml" part="parameters" /> 
  </wsdl:input>
  </wsdl:operation>
  </wsdl:binding>
- <wsdl:service name="StockQuoteService">
- <wsdl:port name="StockQuoteServiceHttpSoap11Endpoint" binding="tns:StockQuoteServiceSoap11Binding">
  <soap:address location="http://localhost:8080/axis2/services/StockQuoteService.StockQuoteServiceHttpSoap11Endpoint/" /> 
  </wsdl:port>
- <wsdl:port name="StockQuoteServiceHttpSoap12Endpoint" binding="tns:StockQuoteServiceSoap12Binding">
  <soap12:address location="http://localhost:8080/axis2/services/StockQuoteService.StockQuoteServiceHttpSoap12Endpoint/" /> 
  </wsdl:port>
- <wsdl:port name="StockQuoteServiceHttpEndpoint" binding="tns:StockQuoteServiceHttpBinding">
  <http:address location="http://localhost:8080/axis2/services/StockQuoteService.StockQuoteServiceHttpEndpoint/" /> 
  </wsdl:port>
  </wsdl:service>
  </wsdl:definitions>

 这个WSDL文件对我们写客户端程序访问WEB服务非常有用，后面会用到。

三、部署WEB服务

  阅读上面的WSDL文件，需要得到关键的几个量，如访问地址，请求结构等。

  客户端代码如下：

package samples.quickstart.service.pojo;
import javax.xml.stream.FactoryConfigurationError;
import javax.xml.stream.XMLOutputFactory;
import javax.xml.stream.XMLStreamException;
import javax.xml.stream.XMLStreamWriter;
import org.apache.axiom.om.OMAbstractFactory;
import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMFactory;
import org.apache.axiom.om.OMNamespace;
import org.apache.axis2.AxisFault;
import org.apache.axis2.Constants;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.client.ServiceClient;
public class StockQuoteServiceClient {
	private static String toEpr = "http://localhost:8080/axis2/services/StockQuoteService.StockQuoteServiceHttpSoap12Endpoint/";
	public static void main(String[] args) throws Exception {
		Options options = new Options();
		options.setTo(new EndpointReference(toEpr));
		options.setAction("urn:update");
		//options.setTransportInProtocol(Constants.TRANSPORT_HTTP);
		//options.setProperty(Constants.Configuration.ENABLE_REST,Constants.VALUE_TRUE);
		ServiceClient clientSender = new ServiceClient();
		//sender.engageModule(Constants.MODULE_ADDRESSING);
		clientSender.setOptions(options);
		//先设置一个值
		clientSender.sendRobust(getUpdateLoad());
		//再获取该值
		options.setAction("urn:getPrice");
		OMElement result = clientSender.sendReceive(getPriceload());
		//打印完整的response
		System.out.println(result);
		OMElement returnElement=result.getFirstElement();
		System.out.println("The price is "+returnElement.getText());
//		try {
//			XMLStreamWriter writer = XMLOutputFactory.newInstance()
//					.createXMLStreamWriter(System.out);
//			result.serialize(writer);
//			writer.flush();
//		} catch (XMLStreamException e) {
//			e.printStackTrace();
//		} catch (FactoryConfigurationError e) {
//			e.printStackTrace();
//		}
	}

	private static OMElement getUpdateLoad() {
		OMFactory fac = OMAbstractFactory.getOMFactory();
		OMNamespace omNs = fac.createOMNamespace(
				"http://quickstart.samples/xsd", "example1");
		OMElement update=fac.createOMElement("update",omNs);
		OMElement symbol = fac.createOMElement("symbol", omNs);
			symbol.setText("yuan");
		OMElement price = fac.createOMElement("price", omNs);
			price.setText("12358.421");
		update.addChild(symbol);
		update.addChild(price);
		return update;
	}
	private static OMElement getPriceload() {
		OMFactory fac = OMAbstractFactory.getOMFactory();
		OMNamespace omNs = fac.createOMNamespace(
				"http://quickstart.samples/xsd", "example1");
		OMElement getPrice=fac.createOMElement("getPrice",omNs);
		OMElement symbol = fac.createOMElement("symbol", omNs);
			symbol.setText("yuan");
		getPrice.addChild(symbol);
		return getPrice;
	}
}

 程序运行结果如下：

log4j:WARN No appenders could be found for logger (org.apache.axis2.client.Options).
log4j:WARN Please initialize the log4j system properly.
<ns:getPriceResponse xmlns:ns="http://quickstart.samples/xsd"><ns:return>12358.421</ns:return></ns:getPriceResponse>
The price is 12358.421