优雅天平

<!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();   
   //错误处理…   
     }
  }
}