優(yōu)雅天平

package com.hellking.webservice;
import java.net.*;
import java.io.*;
import java.util.*;

import javax.xml.soap.*;

public class JAXMDelegate implements BookBusiness
{
 SOAPConnection con =null;//到服務(wù)端的連接
 EndpointLocator locator=new EndpointLocator();//服務(wù)定位器
 Collection allbook;//cache
 DTOEngine dto;//數(shù)據(jù)轉(zhuǎn)換對(duì)象
 
 public JAXMDelegate()
 {
  allbook=new ArrayList();
  dto=new SOAPToBeanEngine();
  try
  {
   SOAPConnectionFactory scf = SOAPConnectionFactory.newInstance();
           con = scf.createConnection();//生成一個(gè)用于SOAP調(diào)用的連接
        }
        catch(Exception e)
        {
         e.printStackTrace();
        }
    }
    //構(gòu)造SOAP消息
    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();
   //AttachmentPart attachment = message.createAttachmentPart();
   SOAPBody body = envelope.getBody();
    Name bodyName=envelope.createName(
"books",target,"http://hellking.webservice.com");
   SOAPBodyElement gpp=body.addBodyElement(bodyName);
   //如果category不空，那么構(gòu)建一個(gè)按類(lèi)別查找的SOAP消息
   if(category!=null)
   {
    gpp.addChildElement("category").addTextNode(category);
   }
   //如果name不空，那么構(gòu)建一個(gè)按圖書(shū)名字查找的SOAP消息
   if(name!=null)
   {
    gpp.addChildElement("name").addTextNode(name);
   } 
   msg.saveChanges();
   //msg.writeTo(new FileOutputStream("e://d.msg"));
   return msg;
  }
  catch(Exception e)
  {
   e.printStackTrace();
   return null;//一般要進(jìn)行錯(cuò)誤處理，這里省略
  }
  
 }
 //按類(lèi)別查找書(shū)，業(yè)務(wù)代表方法
 public Collection getBookByCategory(String category)
 {
  try
  {
   SOAPMessage msg=createMessage("GetBookByCategory",null,category); 
         String endpoint=locator.getBookByCategory_Endpoint();
       SOAPMessage reply=con.call(msg,new URL(endpoint));
       reply.writeTo(System.out);
       dto.init(reply);//初始化數(shù)據(jù)轉(zhuǎn)換器
       return dto.getResult();//返回?cái)?shù)據(jù)轉(zhuǎn)換結(jié)果
      
     }
     catch(Exception ex)
     {
      ex.printStackTrace();      
      return null;  //一般要進(jìn)行錯(cuò)誤處理，這里省略。    
     }
  }
 //查詢所有的圖書(shū)，業(yè)務(wù)代表方法  
    public Collection getAllBooks()
    {
     /**
*allbook為JAXMDelegate的cache，由于Web服務(wù)調(diào)用代價(jià)比較高，
*故使用它來(lái)減少不必要的遠(yuǎn)程調(diào)用。如果allbook為空，那么調(diào)用對(duì)應(yīng)的Web服務(wù)
*來(lái)獲得數(shù)據(jù)，并且把調(diào)用結(jié)果保存在allbook中，如果不為空，那么直接返回allbook
*中的數(shù)據(jù)。
*/
     if(allbook.size==0)
     {      
      try
      {
       SOAPMessage msg=createMessage("GetAllBooks",null,null);
       String endpoint=locator.getAllBooks_Endpoint();
       SOAPMessage reply=con.call(msg,new URL(endpoint));
       reply.writeTo(new FileOutputStream("e://out.msg"));
       dto.init(reply); //初始化數(shù)據(jù)轉(zhuǎn)換器
       Collection re=dto.getResult();  //獲得轉(zhuǎn)換結(jié)果        
       allbook=re;
       return re; //返回?cái)?shù)據(jù)轉(zhuǎn)換結(jié)果
      }
      catch(Exception e)
      {
       e.printStackTrace();

       return null; //一般要進(jìn)行錯(cuò)誤處理，這里省略
      }   
   }
   else
   return allbook;     
    }
    //按圖書(shū)名字查找某本圖書(shū)，業(yè)務(wù)代表方法
    public BookVO getTheBookDetail(String name)
    {
     try
     {
      SOAPMessage msg=createMessage("GetBookDetail",name,null);
      String endpoint=locator.getTheBookDetail_Endpoint();
      SOAPMessage reply=con.call(msg,new URL(endpoint));
      reply.writeTo(System.out);
      dto.init(reply); //初始化數(shù)據(jù)轉(zhuǎn)換器
      Collection ret=dto.getResult();      
      if(ret.size()==1)
      {
       return (BookVO)ret.iterator().next();
      }
      else
       return null;                   
     }
     catch(Exception e)
     {
      e.printStackTrace();
      return null; //一般要進(jìn)行錯(cuò)誤處理，這里省略
     }    
  } 
}