優(yōu)雅天平

<!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企業(yè)應(yīng)用開(kāi)發(fā)</books:name>
    <books:publisher>電子工業(yè)出版社</books:publisher>
    <books:price>60</books:price>
    <books:category>計(jì)算機(jī)類(lèi)</books:category>
    <books:description>非常好的介紹J2EE企業(yè)應(yīng)用開(kāi)發(fā)的書(shū)</books:description>
    <books:author>陳亞強(qiáng)</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;//圖書(shū)名字
   private String publisher;//圖書(shū)出版社
   private float price;//圖書(shū)價(jià)格
   private String isbn;//圖書(shū)ISBN
   private String description;//圖書(shū)的簡(jiǎn)介
   private String category;//圖書(shū)的類(lèi)別
   private Collection authors;//圖書(shū)的作者，因一本書(shū)可以有多個(gè)作者，故把它表示成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，查找所有的書(shū)
     */
    public java.util.Collection getAllBook    () throws RemoteException;
    
    /**
     * @J2EE_METHOD  --  findByCategory，按類(lèi)別查找
     */
    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，查找所有的書(shū)
     */
public java.util.Collection findAllBook    () 
                throws RemoteException, FinderException; 
  
/**
     * @J2EE_METHOD  --  findByCategory，按類(lèi)別查找
     */

    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);//在控制臺(tái)打印收到的消息 
             //調(diào)用其它類(lèi)來(lái)實(shí)現(xiàn)業(yè)務(wù)方法  
            SOAPMessage msg=new XMLBusinessDelegate().listAllBook();
            System.out.println("this is the reply.....");
            msg.writeTo(System.out);
            msg.saveChanges();//注意，在返回消息之前要調(diào)用這個(gè)方法
            return msg;//返回消息
        }
        catch(Exception ex)
        {
         ex.printStackTrace();
           //處理錯(cuò)誤….
         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 消息中讀出的參數(shù)
   SOAPMessage msg=new XMLBusinessDelegate().listByCategory(category);
             msg.saveChanges();
            return msg;//返回處理消息
        }
        catch(Exception ex)
        {
         ex.printStackTrace();
         //處理錯(cuò)誤….
         return null;//如果出錯(cuò)，一般返回SOAPFault，這里簡(jiǎn)化了。
        }
    }

…
public class XMLBusinessDelegate
{
InitialContext init=null;
  BookServiceFacadeHome facadeHome;
OTDEngine otd;//對(duì)象到數(shù)據(jù)的轉(zhuǎn)換器
 public XMLBusinessDelegate()throws NamingException
 {
   init=this.getInitialContext();
otd=new BeanToSOAPEngine(); //生成對(duì)象到數(shù)據(jù)轉(zhuǎn)換器實(shí)例       
 }
 public static InitialContext getInitialContext()  throws javax.naming.NamingException 
   {
      //更據(jù)不同的EJB容器，使用不同的url和連接工廠來(lái)獲得上下文，然后返回…
}
//業(yè)務(wù)方法，按類(lèi)別查找圖書(shū)
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);//調(diào)用業(yè)務(wù)方法
   System.out.println("get result======>>");
   System.out.println(result.size());
     // 使用BeanToSOAPEngine把調(diào)用結(jié)果轉(zhuǎn)換成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的實(shí)例
   msg = mf.createMessage();//從MessageFactory建立一個(gè)空的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();
            //創(chuàng)建body名字空間
         Name bodyName=envelope.createName(type,"books","http://hellking.webservice.com" );
     SOAPBodyElement books=body.addBodyElement(bodyName);//增加body
     
//以下程序把Collection中的BookVO轉(zhuǎn)化成SOAP消息
Iterator it=bookVos.iterator();
      while(it.hasNext())
      {
       BookVO bookvo=(BookVO)it.next(); 
             
               //構(gòu)建book      
       Name bookName=envelope.createName(
"book","books","http://hellking.webservice.com");
    SOAPElement book=books.addChildElement(bookName);
    book.addAttribute(envelope.createName("id"),bookvo.getIsbn());
    
    //構(gòu)建name
Name elName=envelope.createName(
"name","books","http://hellking.webservice.com");
    book.addChildElement(elName).addTextNode(bookvo.getName());
    
    //構(gòu)建publisher
    Name elPublisher=envelope.createName(
"publisher","books","http://hellking.webservice.com");
    book.addChildElement(elPublisher).addTextNode(bookvo.getPublisher());
    
    //構(gòu)建price
    Name elPrice=envelope.createName(
"price","books","http://hellking.webservice.com");
    book.addChildElement(elPrice).addTextNode(
new Float(bookvo.getPrice()).toString());
    
               //構(gòu)建category
    Name elCategory=envelope.createName(
"category","books","http://hellking.webservice.com");
    book.addChildElement(elCategory).addTextNode(bookvo.getCategory());

    //構(gòu)建description
    Name elDescription=envelope.createName(
"description","books","http://hellking.webservice.com");
    book.addChildElement(elDescription).addTextNode(bookvo.getDescription());
    //author本來(lái)就是一個(gè)Collection，故要特別處理
    Collection author_c=bookvo.getAuthors();
    Iterator au_it=author_c.iterator();
    while(au_it.hasNext())
    {
     String strAuth=(String)au_it.next();
     //增加一個(gè)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為目標(biāo)名字空間，name為查詢(xún)某本特定書(shū)的書(shū)字，category為要查詢(xún)的類(lèi)別
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;
  }  
 }
…

//創(chuàng)建名字空間
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;//轉(zhuǎn)換后的結(jié)果，用Collection表示
     //構(gòu)造方法，reply為要轉(zhuǎn)換的SOAP消息
 public SOAPToBeanEngine(SOAPMessage reply)
 {
  this.reply=reply;
 }
 …
 public Collection getResult()
 {
  build();
  return bookVos;
 } 
    //build為具體轉(zhuǎn)換的方法    
    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();   
   //錯(cuò)誤處理…   
     }
  }
}