调用webservice服务(二) 学习笔记/cxf拦截器

        新建CXF_HOME      C:\ProgramFiles(my)\apache-cxf-2.7.2
 
        在CLASSPATH          %CXF_HOME%\lib
 
        在PATH中添加           %CXF_HOME%\bin

cxf   拦截器
    为了在webservice请求过程中动态操作请求和响应数据。
拦截器分类：
1.按位置：服务器端拦截器，客户端拦截器
2.按消息方向：入拦截器，出拦截器
3.按定义者分：系统拦截器，自定义拦截器

日志拦截器的实现

(1)服务端
         Endpoint publish = Endpoint.publish(address, new HelloImpl());
         //服务端日志入拦截器
         EndpointImpl impl=(EndpointImpl) publish;
         List<Interceptor<? extends Message>> inInterceptors = impl.getInInterceptors();
         inInterceptors.add(new LoggingInInterceptor());
        
         //服务端日志出拦截器
         List<Interceptor<? extends Message>> outInterceptors = impl.getOutInterceptors();
         outInterceptors.add(new LoggingOutInterceptor());
  
(2)客户端  
        HelloImplService factory=new HelloImplService();
     Hello helloImplPort = factory.getHelloImplPort();
     
     //发送请求的客户端对象
     Client client = ClientProxy.getClient(helloImplPort);
     
     //客户端出拦截器
     List<Interceptor<? extends Message>> outInterceptors = client.getOutInterceptors();
     outInterceptors.add(new LoggingOutInterceptor());
     
     //客户端入拦截器
     List<Interceptor<? extends Message>> inInterceptors = client.getInInterceptors();
     inInterceptors.add(new LoggingInInterceptor());
     
     
     /*int sum = helloImplPort.sum(10, 20);
     System.out.println("sum:"+sum);*/
     System.out.println(helloImplPort.sayHello("yanzhaojun"));
  
自定义拦截器
     服务器端：
         String address="http://172.31.255.104:8087/csf_client/Hello";
         Endpoint publish = Endpoint.publish(address, new HelloImpl());
         //服务端日志入拦截器
         EndpointImpl impl=(EndpointImpl) publish;
         List<Interceptor<? extends Message>> inInterceptors = impl.getInInterceptors();
         inInterceptors.add(new LoggingInInterceptor());
         inInterceptors.add(new CheckUserInterceptor());
        
        
         //服务端日志出拦截器
        /* List<Interceptor<? extends Message>> outInterceptors = impl.getOutInterceptors();
         outInterceptors.add(new LoggingOutInterceptor());*/
        
         System.out.println("发布webService成功!");

       拦截器：
            public class CheckUserInterceptor extends AbstractPhaseInterceptor<SoapMessage>{

 /**
  * @param phase
  */
 public CheckUserInterceptor() {
  super(Phase.PRE_PROTOCOL);//准备协议化的时候拦截
 }

 /* (non-Javadoc)
  * @see org.apache.cxf.interceptor.Interceptor#handleMessage(org.apache.cxf.message.Message)
  */
 @Override
 public void handleMessage(SoapMessage msg) throws Fault {
  // TODO Auto-generated method stub
  Header header = msg.getHeader(new QName("hq"));
  if(header!=null){
   Element hq = (Element) header.getObject();
   String name = hq.getElementsByTagName("name").item(0).getTextContent();
   
   String password = hq.getElementsByTagName("password").item(0).getTextContent();
      if("yanzhaojun".equals(name)&&"123456".equals(password)){
       System.out.println("server: handleMessage()...通过拦截器");
       return ;
      }
  }
  //不能通过
  System.out.println("server 没有通过拦截器");
  throw new Fault(new RuntimeException("请求需要一个正确的你用户名和密码!"));
  
  
 }
   
}

客户端：
    HelloImplService factory=new HelloImplService();
     Hello helloImplPort = factory.getHelloImplPort();
     
     //发送请求的客户端对象
     Client client = ClientProxy.getClient(helloImplPort);
     
     //客户端出拦截器
     List<Interceptor<? extends Message>> outInterceptors = client.getOutInterceptors();
     outInterceptors.add(new LoggingOutInterceptor());
     
     //自定义出拦截器
     outInterceptors.add(new AddUserInterceptor("yanzhaojun", "123456"));
     
     //客户端入拦截器
     /*List<Interceptor<? extends Message>> inInterceptors = client.getInInterceptors();
     inInterceptors.add(new LoggingInInterceptor());*/
     
     
     /*int sum = helloImplPort.sum(10, 20);
     System.out.println("sum:"+sum);*/
     System.out.println(helloImplPort.sayHello("yanzhaojun"));

拦截器： 
     public class AddUserInterceptor extends AbstractPhaseInterceptor<SoapMessage>{

 private String name ;
 private String password;
 /**
  * @param phase
  */
 public AddUserInterceptor(String name,String password) {
  super(Phase.PRE_PROTOCOL);//准备协议化的时候拦截
  // TODO Auto-generated constructor stub
  this.name=name;
  this.password=password;
 }

 /* (non-Javadoc)
  * @see org.apache.cxf.interceptor.Interceptor#handleMessage(org.apache.cxf.message.Message)
  */
 @Override
 public void handleMessage(SoapMessage msg) throws Fault {
  // TODO Auto-generated method stub
  List<Header> headers = msg.getHeaders();
  
  Document document = DOMHelper.createDocument();
  Element root = document.createElement("hq");
  
  Element name = document.createElement("name");
  name.setTextContent(this.name);
  root.appendChild(name);
  
  Element pass = document.createElement("password");
  pass.setTextContent(this.password);
  root.appendChild(pass);
  
  
  headers.add(new Header(new QName("hq"), root));
  
  System.out.println("client :handlerMessage()");
 }

}  

使用jquery来发送请求（自己拼接soap请求消息，拿到soap响应消息以后需要自己去解析）

     function clickaa(){
       var name=document.getElementById("username").value;
       var data='<soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"><soap:Body><ns2:sayHello xmlns:ns2="'" rel="nofollow">http://test.hq.com/"><arg0>'+
       name+'</arg0></ns2:sayHello></soap:Body></soap:Envelope>';
      
       var xmlhttp;
       if (window.XMLHttpRequest){// code for IE7+, Firefox, Chrome, Opera, Safari
         xmlhttp=new XMLHttpRequest();
         }
       else{// code for IE6, IE5
         xmlhttp=new ActiveXObject("Microsoft.XMLHTTP");
         }
      
       xmlhttp.onreadystatechange=function(){
         if(xmlhttp.readyState==4&&xmlhttp.status==200){
          var resA=xmlhttp.responseXML;
          alert(resA);
          var dd=resA.getElementsByTagName("return")[0];
          alert(dd.firstChild.data);
         }
       };
       //打开连接
       xmlhttp.open("POST","http://172.31.255.104:8087/csf_client/Hello",true);        //设置请求头        xmlhttp.setRequestHeader("Content-type", "");        //发送请求        xmlhttp.send(data);       }