您的位置：首页 > 其它

web service 自定义拦截器

2016-03-01 16:38 513 查看

客户端拦截器：

package com.xh.ws.interceptor;

import java.util.List;
import javax.xml.namespace.QName;
import org.apache.cxf.binding.soap.SoapMessage;
import org.apache.cxf.headers.Header;
import org.apache.cxf.helpers.DOMUtils;
import org.apache.cxf.interceptor.Fault;
import org.apache.cxf.phase.AbstractPhaseInterceptor;
import org.apache.cxf.phase.Phase;
import org.w3c.dom.Document;
import org.w3c.dom.Element;

public class LoginInterceptor extends AbstractPhaseInterceptor<SoapMessage>{

private String name;
private String password;

public LoginInterceptor() {
super(Phase.PRE_PROTOCOL);
}

public LoginInterceptor(String name,String password) {
super(Phase.PRE_PROTOCOL);
this.name=name;
this.password=password;

}

@Override
public void handleMessage(SoapMessage arg0) throws Fault {
/**
* 客户端的head
* <user>
* 		<name>zhangsan</name>
* 		<password>zhangsan</password>
* </user>
*
*/
List<Header> heads=arg0.getHeaders();

Document document=DOMUtils.createDocument();
Element rootEle=document.createElement("user");
Element nameEle=document.createElement("name");
nameEle.setTextContent(name);
Element passwordEle=document.createElement("password");
passwordEle.setTextContent(password);
rootEle.appendChild(nameEle);
rootEle.appendChild(passwordEle);
heads.add(new Header(new QName("user"), rootEle));
System.out.println("Client:handleMessage().....");

}

}

客户端测试代码：

package com.xh.ws.test;

import org.apache.cxf.endpoint.Client;
import org.apache.cxf.frontend.ClientProxy;
import org.apache.cxf.interceptor.LoggingOutInterceptor;

import com.xh.ws.interceptor.LoginInterceptor;
import com.xh.ws.sei.SayHello;
import com.xh.ws.sei.SayHelloImplService;

public class ClientTest {

public static void main(String[] args) {
SayHelloImplService factory=new SayHelloImplService();
SayHello hello=factory.getSayHelloImplPort();
Client client=ClientProxy.getClient(hello);
//添加自定义拦截器
client.getOutInterceptors().add(new LoginInterceptor("zhangsan","123456"));
//添加日志拦截器
client.getOutInterceptors().add(new LoggingOutInterceptor());
System.out.println(hello.sayHello("lili"));
}
}

服务端拦截器：

package com.xh.ws.interceptor;

import javax.xml.namespace.QName;
import org.apache.cxf.binding.soap.SoapMessage;
import org.apache.cxf.headers.Header;
import org.apache.cxf.interceptor.Fault;
import org.apache.cxf.phase.AbstractPhaseInterceptor;
import org.apache.cxf.phase.Phase;
import org.w3c.dom.Element;

public class LoginInterceptor extends AbstractPhaseInterceptor<SoapMessage>{

public LoginInterceptor() {
super(Phase.PRE_INVOKE);
}

@Override
public void handleMessage(SoapMessage arg0) throws Fault {

Header header=arg0.getHeader(new QName("user"));
if(header!=null)
{
/**
* 解析header
*/
Element rootEle=(Element) header.getObject();
Element name=(Element) rootEle.getElementsByTagName("name").item(0);
Element password=(Element) rootEle.getElementsByTagName("password").item(0);
String name_1=name.getTextContent();
String password_1=password.getTextContent();

if("zhangsan".equals(name_1)&&"123456".equals(password_1))
{
return;
}else
{
throw new RuntimeException("用户名或密码不正确！");
}

}

}

}

服务端测试代码：

package com.xh.ws.test;

import javax.xml.ws.Endpoint;

import org.apache.cxf.interceptor.LoggingInInterceptor;
import org.apache.cxf.jaxws.EndpointImpl;

import com.xh.ws.interceptor.LoginInterceptor;
import com.xh.ws.sei.SayHelloImpl;

public class ServerTest {

public static void main(String[] args) {
Endpoint endpoint=Endpoint.publish("http://127.0.0.1:54321", new SayHelloImpl());
EndpointImpl endpointImpl=(EndpointImpl) endpoint;
//添加自定义拦截器
endpointImpl.getInInterceptors().add(new LoginInterceptor());
//添加日志拦截器
endpointImpl.getInInterceptors().add(new LoggingInInterceptor());
System.out.println("发布成功");
}
}

结果：

当正确时：

Client:handleMessage().....
三月 01, 2016 4:14:11 下午 org.apache.cxf.services.SayHelloImplService.SayHelloImplPort.SayHello
信息: Outbound Message
---------------------------
ID: 1
Address: http://127.0.0.1:54321/ Encoding: UTF-8
Http-Method: POST
Content-Type: text/xml
Headers: {Accept=[*/*], SOAPAction=[""]}
Payload: <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"><soap:Header><user><name>zhangsan</name><password>123456</password></user></soap:Header><soap:Body><ns2:sayHello xmlns:ns2="http://sei.ws.xh.com/"><arg0>lili</arg0></ns2:sayHello></soap:Body></soap:Envelope>
--------------------------------------
lili

错误时：

Client:handleMessage().....
三月 01, 2016 4:37:17 下午 org.apache.cxf.services.SayHelloImplService.SayHelloImplPort.SayHello
信息: Outbound Message
---------------------------
ID: 1
Address: http://127.0.0.1:54321/ Encoding: UTF-8
Http-Method: POST
Content-Type: text/xml
Headers: {Accept=[*/*], SOAPAction=[""]}
Payload: <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"><soap:Header><user><name>zhangsan</name><password>1234561</password></user></soap:Header><soap:Body><ns2:sayHello xmlns:ns2="http://sei.ws.xh.com/"><arg0>lili</arg0></ns2:sayHello></soap:Body></soap:Envelope>
--------------------------------------
Exception in thread "main" javax.xml.ws.soap.SOAPFaultException: 用户名或密码不正确！
at org.apache.cxf.jaxws.JaxWsClientProxy.invoke(JaxWsClientProxy.java:161)
at com.sun.proxy.$Proxy34.sayHello(Unknown Source)
at com.xh.ws.test.ClientTest.main(ClientTest.java:21)
Caused by: org.apache.cxf.binding.soap.SoapFault: 用户名或密码不正确！