<!ELEMENT books(book*)>
<!ELEMENT book (name,publisher,price,author+,category,description)>
<!ELEMENT name (#PCDATA)>
<!ELEMENT publisher (#PCDATA)>
<!ELEMENT price (#PCDATA)>
<!ELEMENT author (#PCDATA)>
<!ELEMENT category (#PCDATA)>
<!ELEMENT description (#PCDATA)>
<!ATTLIST book id  CDATA #REQUIRED>

<soap-env:Envelope xmlns:soap-env="http://schemas.xmlsoap.org/soap/envelope/">
    <soap-env:Header/>
    <soap-env:Body>
        <books:GetAllBooks xmlns:books="http://hellking.webservice.com">
           <books:book id="2-1234-4455-4">
				<books:name>J2EE企业应用开发</books:name>
				<books:publisher>电子工业出版社</books:publisher>
				<books:price>60</books:price>
				<books:category>计算机类</books:category>
				<books:description>非常好的介绍J2EE企业应用开发的书</books:description>
				<books:author>陈亚强</books:author>
				<books:author>刘晓华</books:author>
	      </books:book>
</books:GetAllBooks>
   </soap-env:Body>
</soap-env:Envelope>

package com.hellking.webservice;
import java.util.Collection;
public class BookVO implements java.io.Serializable
{
   private String name;//图书名字
   private String publisher;//图书出版社
   private float price;//图书价格
   private String isbn;//图书ISBN
   private String description;//图书的简介
   private String category;//图书的类别
   private Collection authors;//图书的作者，因一本书可以有多个作者，故把它表示成Collection。
public void setName(String name)
   {
   		this.name=name;
  }
public String getName()
  {
   		return this.name;
  }
…其它的getter和setter方法

package com.hellking.webservice.ejb;
import java.rmi.RemoteException;
import javax.ejb.*;

public interface BookServiceFacade extends EJBObject
{
    /**
     * @J2EE_METHOD  --  getAllBook，查找所有的书
     */
    public java.util.Collection getAllBook    () throws RemoteException;
    
    /**
     * @J2EE_METHOD  --  findByCategory，按类别查找
     */
    public java.util.Collection findByCategory    (String category) throws RemoteException;

/**
     * @J2EE_METHOD  --  getBookDetail   ，按名字查找
     */

    public java.util.Collection getBookDetail    (String name) throws RemoteException;
}

package com.hellking.webservice.ejb;

import java.rmi.RemoteException;
import javax.ejb.*;

public interface BookEntityHome extends EJBHome
{
    public BookEntity findByPrimaryKey    (String primaryKey) 
                throws RemoteException, FinderException;
   
    public BookEntity create(String isbn) throws RemoteException, CreateException;
    
    /**
     * @J2EE_METHOD  --  getAllBook，查找所有的书
     */
public java.util.Collection findAllBook    () 
                throws RemoteException, FinderException; 
  
/**
     * @J2EE_METHOD  --  findByCategory，按类别查找
     */

    public java.util.Collection findByCategory    (String category) 
                throws RemoteException, FinderException; 
   
/**
     * @J2EE_METHOD  --  getBookDetail   ，按名字查找
   */
 public BookEntity findByName    (String name) 
                throws RemoteException, FinderException; 
    
}

public SOAPMessage onMessage  (SOAPMessage message)

public class ListAllBook extends JAXMServlet  implements ReqRespListener
{
    public void init    (ServletConfig servletConfig) throws ServletException 
    {
    	super.init(servletConfig);
    }
    public SOAPMessage onMessage    (SOAPMessage message)  
    { 
		System.out.println("from ListAllBook Servlet:receive a message");		
		try
		{
			System.out.println("from ListAllBook Servlet:");
			message.writeTo(System.out);//在控制台打印收到的消息	
             //调用其它类来实现业务方法		
            SOAPMessage msg=new XMLBusinessDelegate().listAllBook();
            System.out.println("this is the reply.....");
            msg.writeTo(System.out);
            msg.saveChanges();//注意，在返回消息之前要调用这个方法
            return msg;//返回消息
        }
        catch(Exception ex)
        {
        	ex.printStackTrace();
           //处理错误….
        	return null;
        }
        
    }
}

public SOAPMessage onMessage  (SOAPMessage message)  
    { 
		try
		{
		    …
			SOAPEnvelope env=message.getSOAPPart().getEnvelope();
			Iterator it=env.getBody().getChildElements(
env.createName("books","GetBookByCategory","http://hellking.webservice.com"));
			SOAPElement books=(SOAPElement)it.next();
			
			Iterator it2=books.getChildElements(
env.createName("category","GetBookByCategory","http://hellking.webservice.com"));
			String category=((SOAPElement)it2.next()).getValue();
              //这里的category是从SOAP 消息中读出的参数
			SOAPMessage msg=new XMLBusinessDelegate().listByCategory(category);
             msg.saveChanges();
            return msg;//返回处理消息
        }
        catch(Exception ex)
        {
        	ex.printStackTrace();
         //处理错误….
        	return null;//如果出错，一般返回SOAPFault，这里简化了。
        }
    }

…
public class XMLBusinessDelegate
{
InitialContext init=null;
	 BookServiceFacadeHome facadeHome;
OTDEngine otd;//对象到数据的转换器
	public XMLBusinessDelegate()throws NamingException
	{
	  init=this.getInitialContext();
otd=new BeanToSOAPEngine(); //生成对象到数据转换器实例       
	}
	public static InitialContext getInitialContext()  throws javax.naming.NamingException 
   {
      //更据不同的EJB容器，使用不同的url和连接工厂来获得上下文，然后返回…
}
//业务方法，按类别查找图书
public SOAPMessage listByCategory(String category)
   {
   		try
		{
			
	   Object objref = init.lookup("ejb/bookservicefacade");		
        facadeHome = (BookServiceFacadeHome)
javax.rmi.PortableRemoteObject.narrow(objref, BookServiceFacadeHome.class); 
			System.out.println("call jboss======>>");
			Collection result=facadeHome.create().findByCategory(category);//调用业务方法
			System.out.println("get result======>>");
			System.out.println(result.size());
		   // 使用BeanToSOAPEngine把调用结果转换成SOAP消息
otd.init(result,"GetAllBooks");
			SOAPMessage ret=otd.getResult();
			return ret;   	   	
	   }
	   catch(Exception e)
	   {
	   		e.printStackTrace();
	   		return null;
	   }
   }	
…	

…
public class BeanToSOAPEngine implements OTDEngine
{
	Collection bookVos;//要处理的信息
	SOAPMessage msg;//待返回的消息
	String type;//type为返回消息的名字空间，如GetBookByCategory
	public BeanToSOAPEngine()
	{		
		try
		{
			MessageFactory mf = MessageFactory.newInstance();//获得MessageFactory的实例
			msg = mf.createMessage();//从MessageFactory建立一个空的Message
		}
		catch(Exception ex)
		{
			ex.printStackTrace();
		}	
	}
	public void init()
	{
this.bookVos=c;
		this.type=type;
	}
	public SOAPMessage getResult()
	{
		build();
		return msg;
	}
	public void build()
	{		
		try
		{			
	        SOAPPart part = msg.getSOAPPart();
	        SOAPEnvelope envelope = part.getEnvelope();
	        SOAPBody body = envelope.getBody();
            //创建body名字空间
	        Name bodyName=envelope.createName(type,"books","http://hellking.webservice.com"	);
		   SOAPBodyElement books=body.addBodyElement(bodyName);//增加body
		   
//以下程序把Collection中的BookVO转化成SOAP消息
Iterator it=bookVos.iterator();
		    while(it.hasNext())
		    {
		    	BookVO bookvo=(BookVO)it.next();	
             
               //构建book	    	
		    	Name bookName=envelope.createName(
"book","books","http://hellking.webservice.com");
				SOAPElement book=books.addChildElement(bookName);
				book.addAttribute(envelope.createName("id"),bookvo.getIsbn());
				
				//构建name
Name elName=envelope.createName(
"name","books","http://hellking.webservice.com");
				book.addChildElement(elName).addTextNode(bookvo.getName());
				
				//构建publisher
				Name elPublisher=envelope.createName(
"publisher","books","http://hellking.webservice.com");
				book.addChildElement(elPublisher).addTextNode(bookvo.getPublisher());
				
				//构建price
				Name elPrice=envelope.createName(
"price","books","http://hellking.webservice.com");
				book.addChildElement(elPrice).addTextNode(
new Float(bookvo.getPrice()).toString());
				
	              //构建category
				Name elCategory=envelope.createName(
"category","books","http://hellking.webservice.com");
				book.addChildElement(elCategory).addTextNode(bookvo.getCategory());

				//构建description
				Name elDescription=envelope.createName(
"description","books","http://hellking.webservice.com");
				book.addChildElement(elDescription).addTextNode(bookvo.getDescription());
				//author本来就是一个Collection，故要特别处理
				Collection author_c=bookvo.getAuthors();
				Iterator au_it=author_c.iterator();
				while(au_it.hasNext())
				{
					String strAuth=(String)au_it.next();
					//增加一个author
					Name elAuth=envelope.createName(
"author","books","http://hellking.webservice.com");
				    book.addChildElement(elAuth).addTextNode(strAuth);
			    }				
			}
			msg.writeTo(System.out);	//打印消息	
		}
		catch(Exception ex)
		{
			ex.printStackTrace();
		}
}
…

package com.hellking.webservice;
import javax.xml.soap.*;
…
public class JAXMDelegate implements BookBusiness
{
	SOAPConnection con =null;
	EndpointLocator locator=new EndpointLocator();
	Collection allbook;//cache	
	public JAXMDelegate()
	{
		allbook=new ArrayList();
		try
		{
			SOAPConnectionFactory scf = SOAPConnectionFactory.newInstance();
        	     con = scf.createConnection();
        }
        catch(Exception e)
        {
        	e.printStackTrace();
        }
    }
…

…
//target为目标名字空间，name为查询某本特定书的书字，category为要查询的类别
public SOAPMessage createMessage(String target,String name,String category) 
    {
    	try
    	{
    		    MessageFactory mf = MessageFactory.newInstance();
	         SOAPMessage msg = mf.createMessage();	
		    	SOAPPart sp = msg.getSOAPPart();
			
			SOAPEnvelope envelope = sp.getEnvelope();			
			//SOAPHeader hdr = envelope.createSOAPHeader();
			
			SOAPBody body = envelope.getBody();
			// AttachmentPart attachment = msg.createAttachmentPart();
msg.saveChanges();
			 …
		}
		catch(Exception e)
		{
			e.printStackTrace();
			return null;
		}		
	}
…

//创建名字空间
Name bodyName=envelope.createName("books",target,"http://hellking.webservice.com");
		 //增加body元素
SOAPBodyElement gpp=body.addBodyElement(bodyName);
			
			if(category!=null)
			{
				//增加category
gpp.addChildElement("category").addTextNode(category);
			}
			
			if(name!=null)
			{
				gpp.addChildElement("name").addTextNode(name);
			}	
			msg.saveChanges();
			return msg;

<?xml version="1.0" encoding="UTF-8"?>
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
 xmlns:xsd="http://www.w3.org/2001/XMLSchema" 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
 <soapenv:Body>
  <GetBookByCategory:books xmlns:GetBookByCategory="http://hellking.webservice.com">
   <GetBookByCategory:category>computer</GetBookByCategory:category>
  </GetBookByCategory:books>
 </soapenv:Body>
</soapenv:Envelope>

import javax.xml.soap.SOAPElement;
import java.io.FileInputStream;
import javax.xml.transform.stream.StreamSource;
…
StreamSource preppedMsgSrc = new StreamSource( 
                 new FileInputStream("e://msgs//book_getBycategory.msg"));
        soapPart.setContent(preppedMsgSrc);

EndpointLocator locator=new EndpointLocator();
…
try
{
	SOAPMessage msg=createMessage("GetBookByCategory",null,category);	
     String endpoint=locator.getBookByCategory_Endpoint();
	SOAPMessage reply=con.call(msg , new URL(endpoint));
    …
}
…

package com.hellking.webservice;
import javax.xml.messaging.*;
…
public class SOAPToBeanEngine implements DTOEngine
{
	SOAPMessage reply;
	Collection bookVos;//转换后的结果，用Collection表示
     //构造方法，reply为要转换的SOAP消息
	public SOAPToBeanEngine(SOAPMessage reply)
	{
		this.reply=reply;
	}
	…
	public Collection getResult()
	{
		build();
		return bookVos;
	} 
    //build为具体转换的方法   	
    public void build()
    {
    	try
    	{
    		
	    	Collection ret=new ArrayList();
	    	//System.out.println(reply.getSOAPPart().getEnvelope().getBody().getElementName());
	    	Iterator child=reply.getSOAPPart().getEnvelope().getBody().getChildElements();①
	    	SOAPElement bookall=(SOAPElement)child.next();②
	    	Iterator books=bookall.getChildElements();③
	    	SOAPEnvelope env=reply.getSOAPPart().getEnvelope();
	    	
	    	SOAPElement temps;	    	
	    	Name name;
	    	
	    	while(books.hasNext())
	    	{
	    		
	    		BookVO bookVo=new BookVO();
	    		temps=(SOAPElement)books.next();
	    		String id=(String)(
	    			(temps.getAttributeValue(
	    				(Name)temps.getAllAttributes().next()
	    				                    )
	    			));
	    		bookVo.setIsbn(id);④
	    		name=env.createName("name","books","http://hellking.webservice.com"	);⑤
	    		bookVo.setName(
	    			((SOAPElement)temps.getChildElements(name).next())
	    			.getValue());
	    		//System.out.println(bookVo.getName());
	    		
	    		name=env.createName("price"	,"books", "http://hellking.webservice.com"	);
	    		bookVo.setPrice(Float.parseFloat(
	    			((SOAPElement)temps.getChildElements(name).next())
	    			.getValue()));
	    		
	    		name=env.createName("category", "books", "http://hellking.webservice.com"		);
	    		bookVo.setCategory(
	    			((SOAPElement)temps.getChildElements(name).next())
	    			.getValue());
	    			
	    		name=env.createName("publisher","books","http://hellking.webservice.com"		);
	    		bookVo.setPublisher(
	    			((SOAPElement)temps.getChildElements(name).next())
	    			.getValue());
	    		
	    		name=env.createName("description","books","http://hellking.webservice.com"		);
	    		bookVo.setDescription(
	    			((SOAPElement)temps.getChildElements(name).next())
	    			.getValue());
	    		//	bookVo.setDescription("kdjfkdjfj");
	    			
	    		name=env.createName("author","books","http://hellking.webservice.com"		);
	    		Collection au=new ArrayList();
	    		Iterator auth=temps.getChildElements(name);
	    		while(auth.hasNext())
	    		{
	    			
	    			SOAPElement tempp=(SOAPElement)auth.next();
	    			
	    			//System.out.println("author:"+tempp.getValue());
	    			au.add(tempp.getValue());
	    		}	    		
	    		bookVo.setAuthors(au);
	    		ret.add(bookVo);	    		
	    	}
	    	bookVos=ret;	      
	    }
	    catch(Exception ex)
	    {
	     	ex.printStackTrace();	  
			//错误处理…  	
	    }
	 }
}

…
public class BookClientGUI 
{
JTable table;//表格
…
int amount;
    Collection books;//表示的数据
     BookBusiness business;	
	JButton search,findAll,findByCategory;
	
	public BookClientGUI()
	{
		business=new JAXMDelegate();//生成一个JAXMDelegate，
		books=business.getAllBooks();//获得所有的图书信息
		//amount=books.size();
		//System.out.println(amount);
	}
	public static void main(String[] args)
	{		
		new BookClientGUI().go();
	}
	public void go()
	{
findByCategory=new JButton("按类别查找");
findByCategory.addMouseListener(new _MouseListener());
…
}
public void showResult()
{
		clearTable();
     	Iterator book_i=books.iterator();
    …
}
public void clearTable()
{
…
}
class _MouseListener extends MouseAdapter
{
		public void mouseClicked(MouseEvent e)
		{
 if(((JButton)e.getSource()).getLabel().equals("按类别查找"))
			{
				 books=business.getBookByCategory((String)jTextField.getText());
				 showResult();
			}
    …
}
}