基于WAS CE和Axis2开发Web Service应用

  
CREATE TABLE FLOWER (
	ID 		INTEGER NOT NULL PRIMARY KEY,
	NAME	 	VARCHAR(20),
	DESCRI	 	VARCHAR(100),
	PRICE	                  DOUBLE
	);

INSERT INTO FLOWER VALUES
  (1,'Rose','a kind of beatiful flowers',10);

INSERT INTO FLOWER VALUES
  (2,'Lily','a kind of beatiful flowers',20);
  

<?xml version="1.0" encoding="UTF-8"?>
<connector xmlns="http://geronimo.apache.org/xml/ns/j2ee/connector-1.0"
  configId="AXIS2Datasource"
  parentId="geronimo/j2ee-server/1.0/car">

  <resourceadapter>
    <outbound-resourceadapter>
      <connection-definition>
        <connectionfactory-interface>javax.sql.DataSource
		</connectionfactory-interface>
        <connectiondefinition-instance>
          <name>jdbc/AXIS2Datasource</name>
          <config-property-setting name="UserName"></config-property-setting>
          <config-property-setting
		  name="Password"></config-property-setting>
          <config-property-setting
		  name="DatabaseName">Axis2</config-property-setting>
          <config-property-setting
		  name="CreateDatabase">true</config-property-setting>
          <connectionmanager>
            <xa-transaction>
            <transaction-caching/>
            </xa-transaction>
            <single-pool>
              <max-size>5</max-size>
              <min-size>0</min-size>
              <blocking-timeout-milliseconds>5000
			  </blocking-timeout-milliseconds>
              <idle-timeout-minutes>15</idle-timeout-minutes>
              <match-one/>
            </single-pool>
          </connectionmanager>
        </connectiondefinition-instance>
      </connection-definition>
    </outbound-resourceadapter>
  </resourceadapter>
</connector>

<?xml version="1.0" encoding="UTF-8"?>
<web-app configId="org/apache/axis2"
   xmlns="http://geronimo.apache.org/xml/ns/j2ee/web-1.0"
   xmlns:naming="http://geronimo.apache.org/xml/ns/naming-1.0" 
   xmlns:sec="http://geronimo.apache.org/xml/ns/security-1.0"       
   xmlns:sys="http://geronimo.apache.org/xml/ns/deployment-1.0"
>
<context-root>/axis2</context-root>
<context-priority-classloader>false</context-priority-classloader>
<naming:resource-ref>
	<naming:ref-name>jdbc/DataSource</naming:ref-name>
	<naming:resource-link>jdbc/AXIS2Datasource</naming:resource-link>
</naming:resource-ref>
</web-app>

<web-app>
    ……
	<resource-ref>
		<res-ref-name>jdbc/DataSource</res-ref-name>
		<res-type>javax.sql.DataSource</res-type>
		<res-auth>Container</res-auth>
		<res-sharing-scope>Shareable</res-sharing-scope>
	</resource-ref>
</web-app>

package example.flowershop;
import java.sql.*;
import javax.naming.*;
import javax.sql.DataSource;
import javax.xml.namespace.QName;
import org.apache.axiom.om.*;

public class FlowerService {

	public void message(OMElement in)
	{
		String message = in.getText();
		System.out.println("FlowerShop received message: " + message);
		
		//deal with the message here
	}
	
	public OMElement query(OMElement in) { … }
              public OMElement reserve(OMElement in){ … }
}

public OMElement query(OMElement in){
	int flowerid = Integer.parseInt(in.getText());		
	String info = "Can not query!";
	try {
		//use axis2 datasource we deployed before
		Context initContext = new InitialContext();
		Context envContext  = (Context)initContext.lookup("java:/comp/env");
		DataSource ds = (DataSource)envContext.lookup("jdbc/DataSource");
	      	Connection con = ds.getConnection();
		Statement stmt = con.createStatement();
		ResultSet rs = stmt.executeQuery(
                             "SELECT * FROM FLOWER WHERE ID=" + flowerid );
		while (rs.next())
		{
		     info = "ID=" + rs.getInt("ID") + " NAME=" + rs.getString("NAME") +
		                  " DESCRIPTION=" + rs.getString("DESCRI") + " PRICE=" +
						  
                            rs.getDouble("PRICE");
		}
	} catch(Exception e) { }
				
	//create the OMElement for response
	OMFactory fac = OMAbstractFactory.getOMFactory();
	OMNamespace omNs = fac.createOMNamespace("http://flowershop.com/", "flower");
	OMElement resp = fac.createOMElement("getFlowerInfo", omNs);
	resp.setText(info);
	return resp;      
}

public OMElement reserve(OMElement in)
{
        String flowerid = (in.getFirstChildWithName(new
		QName("flowerid"))).getText();
        String num = (in.getFirstChildWithName(new
		QName("flowernum"))).getText();
        String address = (in.getFirstChildWithName(new
		QName("address"))).getText();
        
        System.out.println("Please send " + num + " flowers(id=" + flowerid + ")
		to " + address + "!");
        String message = "Reserve Failed:";
        //do the reservation here and set response message 
        
	    OMFactory fac = OMAbstractFactory.getOMFactory();
	    OMNamespace omNs = fac.createOMNamespace("http://flowershop.com/",
		"flower");
	    OMElement resp = fac.createOMElement("reserveResponse", omNs);
	    resp.setText(message + "ID=" + flowerid + " NUM=" +num);
	    return resp; 
        
}

   
    |- example
    |        |- flowershop
    |                   |- FlowerService.class
    |- META-INF
    |        |- services.xml

jar cvf FlowerService.aar .

package example.client;

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.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.client.ServiceClient;

public class TestMessage {

	private static EndpointReference targetEPR = new EndpointReference(
			"http://localhost:8080/axis2/services/FlowerService");

	public static OMElement getMessageOMElement() {
		OMFactory fac = OMAbstractFactory.getOMFactory();
		OMNamespace omNs = fac.createOMNamespace("http://flowershop.com/",
				"flower");
		OMElement method = fac.createOMElement("message", omNs);
		method.setText("Your roses are good!");
		return method;
	}

	public static void main(String[] args) {

		try {

			// Make the request message
			Options options = new Options();
			options.setTo(targetEPR);

			ServiceClient sender = new ServiceClient();
			sender.setOptions(options);

			// test message method
			OMElement message = TestMessage.getMessageOMElement();
			sender.fireAndForget(message);
			Thread.sleep(500);

		} catch (Exception axisFault) {
			axisFault.printStackTrace();
		}
	}
}

package example.client;

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.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.client.ServiceClient;

public class TestQuery {

	private static EndpointReference targetEPR = new EndpointReference(
			"http://localhost:8080/axis2/services/FlowerService");

	public static OMElement getQueryOMElement() {
		OMFactory fac = OMAbstractFactory.getOMFactory();
		OMNamespace omNs = fac.createOMNamespace("http://flowershop.com/",
				"flower");
		OMElement method = fac.createOMElement("query", omNs);
		method.setText("1");
		return method;
	}

	public static void main(String[] args) {
		try {
			// Make the request message
			Options options = new Options();
			options.setTo(targetEPR);
			ServiceClient sender = new ServiceClient();
			sender.setOptions(options);
			// test query method
			OMElement query = TestQuery.getQueryOMElement();
			OMElement result = sender.sendReceive(query);
			System.out.println(result);
		} catch (Exception axisFault) {
			axisFault.printStackTrace();
		}
	}
}

    
package example.client;

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.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.client.ServiceClient;
import org.apache.axis2.client.async.AsyncResult;
import org.apache.axis2.client.async.Callback;

public class TestReserve {

	private static EndpointReference targetEPR = new EndpointReference(
			"http://localhost:8080/axis2/services/FlowerService");

	public static OMElement getReserveOMElement() {
		OMFactory fac = OMAbstractFactory.getOMFactory();
		OMNamespace omNs = fac.createOMNamespace("http://flowershop.com/",
				"flower");
		OMElement method = fac.createOMElement("reserve", omNs);

		OMElement id = fac.createOMElement("flowerid", omNs);
		id.setText("1");
		method.addChild(id);

		OMElement num = fac.createOMElement("flowernum", omNs);
		num.setText("99");
		method.addChild(num);

		OMElement address = fac.createOMElement("address", omNs);
		address.setText("IBM ");
		method.addChild(address);

		return method;
	}

	public static void main(String[] args) {

		try {
			// Make the request message
			Options options = new Options();
			options.setTo(targetEPR);
			ServiceClient sender = new ServiceClient();
			sender.setOptions(options);

			// test reserve method using non-Blocking API
			// Callback to handle the response
			OMElement reserve = TestReserve.getReserveOMElement();
			Callback callback = new Callback() {
				public void onComplete(AsyncResult result) {
					System.out.println("From Callback Function:"
							+ result.getResponseEnvelope());
				}

				public void onError(Exception e) {
					e.printStackTrace();
				}
			};
			sender.sendReceiveNonBlocking(reserve, callback);

			// Wait till the callback receives the response.
			while (!callback.isComplete()) {
				Thread.sleep(1000);
			}

		} catch (Exception axisFault) {
			axisFault.printStackTrace();
		}
	}
}

    

FlowerShop received message: Your roses are good!
Please send 99 flowers(id=1) to IBM !

<flower:getFlowerInfo xmlns:flower="http://flowershop.com/"
xmlns:tns="http://ws.apache.org/axis2">ID=1 NAME=Rose 
DESCRIPTION=a kind of beatiful flowers PRICE=10.0</flower:getFlowerInfo>
From Callback Function:<?xml version='1.0'
encoding='utf-8'?><soapenv:Envelope
xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
<soapenv:Header /><soapenv:Body>
<flower:reserveResponse xmlns:flower="http://flowershop.com/"
xmlns:tns="http://ws.apache.org/axis2">Reserve Successful:ID=1 NUM=99
</flower:reserveResponse>
</soapenv:Body>
</soapenv:Envelope>