优雅天平

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;//到服务端的连接
 EndpointLocator locator=new EndpointLocator();//服务定位器
 Collection allbook;//cache
 DTOEngine dto;//数据转换对象
 
 public JAXMDelegate()
 {
  allbook=new ArrayList();
  dto=new SOAPToBeanEngine();
  try
  {
   SOAPConnectionFactory scf = SOAPConnectionFactory.newInstance();
           con = scf.createConnection();//生成一个用于SOAP调用的连接
        }
        catch(Exception e)
        {
         e.printStackTrace();
        }
    }
    //构造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不空，那么构建一个按类别查找的SOAP消息
   if(category!=null)
   {
    gpp.addChildElement("category").addTextNode(category);
   }
   //如果name不空，那么构建一个按图书名字查找的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;//一般要进行错误处理，这里省略
  }
  
 }
 //按类别查找书，业务代表方法
 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);//初始化数据转换器
       return dto.getResult();//返回数据转换结果
      
     }
     catch(Exception ex)
     {
      ex.printStackTrace();      
      return null;  //一般要进行错误处理，这里省略。    
     }
  }
 //查询所有的图书，业务代表方法  
    public Collection getAllBooks()
    {
     /**
*allbook为JAXMDelegate的cache，由于Web服务调用代价比较高，
*故使用它来减少不必要的远程调用。如果allbook为空，那么调用对应的Web服务
*来获得数据，并且把调用结果保存在allbook中，如果不为空，那么直接返回allbook
*中的数据。
*/
     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); //初始化数据转换器
       Collection re=dto.getResult();  //获得转换结果        
       allbook=re;
       return re; //返回数据转换结果
      }
      catch(Exception e)
      {
       e.printStackTrace();

       return null; //一般要进行错误处理，这里省略
      }   
   }
   else
   return allbook;     
    }
    //按图书名字查找某本图书，业务代表方法
    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); //初始化数据转换器
      Collection ret=dto.getResult();      
      if(ret.size()==1)
      {
       return (BookVO)ret.iterator().next();
      }
      else
       return null;                   
     }
     catch(Exception e)
     {
      e.printStackTrace();
      return null; //一般要进行错误处理，这里省略
     }    
  } 
}