基于CXF2.0前2個(gè)學(xué)習(xí)筆記，對原先服務(wù)端與客戶端進(jìn)行修改，實(shí)現(xiàn)在SOAP Header里面添加自定義的數(shù)據(jù)進(jìn)行認(rèn)證
在做之前，先要理解如下的信息
攔截器(Interceptor)簡單說明
Interceptor是CXF架構(gòu)中一個(gè)很有特色的模式。你可以在不對核心模塊進(jìn)行修改的情況下，動(dòng)態(tài)添加很多功能。這對于CXF這個(gè)以處理消息為中心的服務(wù)框架來說是非常有用的，CXF通過在Interceptor中對消息進(jìn)行特殊處理，實(shí)現(xiàn)了很多重要功能模塊，例如：日志記錄，Soap消息處理，消息的壓縮處。簡單的說，可以在收到請求后，還未進(jìn)行業(yè)務(wù)處理前，進(jìn)行處理。或者在請求包發(fā)送前，進(jìn)行報(bào)文的處理。
幾個(gè)的API的介紹
Interceptor
定義兩個(gè)方法，一個(gè)處理消息 handleMessage， 一個(gè)是處理錯(cuò)誤 handleFault。
InterceptorChain
單個(gè)的Interceptor功能有限，CXF要實(shí)現(xiàn)一個(gè)SOAP消息處理，需要將許許多多的Interceptor組合在一起使用。因此設(shè)計(jì)了 InterceptorChain，在我看了InterceptorChain就像是一個(gè)Interceptor的小隊(duì)長。 小隊(duì)長有調(diào)配安置Interceptor的權(quán)力（add，remove），也有控制消息處理的權(quán)力（doInterceptor，pause，resume，reset，abort），同時(shí)也有交付錯(cuò)誤處理的權(quán)力（ {get|set}FaultObserver）。更有意思的是為靈活控制Interceptor的處理消息順序（doInterceptStartingAt，doInterceptorStartingAfter），這也是InterceptorChain比較難理解的地方。
Fault
定義了CXF中的錯(cuò)誤消息。
InterceptorProvider
這里定義了Interceptor的后備保障部隊(duì)。我們可以在InterceptorProvider中設(shè)置In，Out，InFault，OutFault 后備小分隊(duì)，添加我們所希望添加的Interceptor。而InterceptorChain會根據(jù)這些后備小分隊(duì)，組建自己的小分隊(duì)實(shí)例，完成具體的作戰(zhàn)功能任務(wù)。
AbstractAttributedInterceptorProvider
InterceptorProvider實(shí)現(xiàn)的抽象類，由于這個(gè)類來繼承了HashMap，我們可以像這個(gè)類中存儲一些屬性信息。
AbstractBasicInterceptorProvider
與AbstractAttributedInterceptorProvider不同，這個(gè)Interceptor只是簡單實(shí)現(xiàn)了InterceptorProvider的功能，并不提供對其屬性存儲的擴(kuò)展。
Message
由于Interceptor是針對Message來進(jìn)行處理的，當(dāng)你打開Message這個(gè)類文件時(shí)，你會發(fā)現(xiàn)在Message中定義了很多常量，同時(shí)你還可以從Message中獲取到很多與Message操作相關(guān)的信息。可以獲取設(shè)置的對象有InterceptorChain Exchange Destination，還有獲取設(shè)置Content的泛型接口，是不是感覺Message和Bus差不多，都成了大雜貨鋪，一切與消息處理相關(guān)的信息都可以放在Message中。
理解了Interceptor功能，下面的修改就很簡單了
服務(wù)端修改
1.新建一個(gè)攔截器(Interceptor)
package hs.cxf.soapHeader;
import javax.xml.soap.SOAPException;
import javax.xml.soap.SOAPHeader;
import javax.xml.soap.SOAPMessage;
import org.apache.cxf.binding.soap.SoapMessage;
import org.apache.cxf.binding.soap.saaj.SAAJInInterceptor;
import org.apache.cxf.interceptor.Fault;
import org.apache.cxf.phase.AbstractPhaseInterceptor;
import org.apache.cxf.phase.Phase;
import org.w3c.dom.NodeList;
/** *//**
*
* @Title:獲取soap頭信息
*
* @Description:
*
* @Copyright:
*
* @author zz
* @version 1.00.000
*
*/
public class ReadSoapHeader extends AbstractPhaseInterceptor<SoapMessage> 
{
private SAAJInInterceptor saa = new SAAJInInterceptor();
public ReadSoapHeader() {
super(Phase.PRE_PROTOCOL);
getAfter().add(SAAJInInterceptor.class.getName());
}
public void handleMessage(SoapMessage message) throws Fault {
SOAPMessage mess = message.getContent(SOAPMessage.class);
if (mess == null) {
saa.handleMessage(message);
mess = message.getContent(SOAPMessage.class);
}
SOAPHeader head = null;
try {
head = mess.getSOAPHeader();
} catch (SOAPException e) {
e.printStackTrace();
}
if (head == null) {
return;
}
try {
//讀取自定義的節(jié)點(diǎn)
NodeList nodes = head.getElementsByTagName("tns:spId");
NodeList nodepass = head.getElementsByTagName("tns:spPassword");
//獲取節(jié)點(diǎn)值，簡單認(rèn)證
if (nodes.item(0).getTextContent().equals("wdw")) {
if (nodepass.item(0).getTextContent().equals("wdwsb")) {
System.out.println("認(rèn)證成功");
}
} else {
SOAPException soapExc = new SOAPException("認(rèn)證錯(cuò)誤");
throw new Fault(soapExc);
}
} catch (Exception e) {
SOAPException soapExc = new SOAPException("認(rèn)證錯(cuò)誤");
throw new Fault(soapExc);
}
}
}
2.配置文件中新增攔截器配置
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:jaxws="http://cxf.apache.org/jaxws"
xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd">
<import resource="classpath:META-INF/cxf/cxf.xml" />
<import resource="classpath:META-INF/cxf/cxf-extension-soap.xml" />
<import resource="classpath:META-INF/cxf/cxf-servlet.xml" />
<bean id="jaxWsServiceFactoryBean"
class="org.apache.cxf.jaxws.support.JaxWsServiceFactoryBean">
<property name="wrapped" value="true" />
<property name="dataBinding" ref="aegisBean" />
</bean>
<bean id="aegisBean"
class="org.apache.cxf.aegis.databinding.AegisDatabinding" />
<jaxws:endpoint id="CollectiveServices"
implementor="hs.cxf.server.WebServiceSampleImpl" address="/HelloWorld">
<jaxws:inInterceptors>
<!-- 日志攔截器 -->
<bean class="org.apache.cxf.interceptor.LoggingOutInterceptor"/>
<!-- 自定義攔截器 -->
<bean class="hs.cxf.soapHeader.ReadSoapHeader"/>
</jaxws:inInterceptors>
<jaxws:serviceFactory>
<ref bean="jaxWsServiceFactoryBean"/>
</jaxws:serviceFactory>
</jaxws:endpoint>
</beans>
服務(wù)端的配置就告一段落了，接下來是客戶端的修改
客戶端
1.同樣新增一個(gè)Interceptor
package hs.cxf.client.SoapHeader;
import java.util.List;
import javax.xml.namespace.QName;
import org.apache.cxf.binding.soap.SoapHeader;
import org.apache.cxf.binding.soap.SoapMessage;
import org.apache.cxf.binding.soap.interceptor.AbstractSoapInterceptor;
import org.apache.cxf.headers.Header;
import org.apache.cxf.helpers.DOMUtils;
import org.apache.cxf.interceptor.Fault;
import org.apache.cxf.phase.Phase;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
/** *//**
*
* @Title:在發(fā)送消息前，封裝Soap Header 信息
*
* @Description:
*
* @Copyright:
*
* @author zz
* @version 1.00.000
*
*/
public class AddSoapHeader extends AbstractSoapInterceptor {
private static String nameURI="http://127.0.0.1:8080/cxfTest/ws/HelloWorld";
public AddSoapHeader(){
super(Phase.WRITE);
}
public void handleMessage(SoapMessage message) throws Fault {
String spPassword="wdwsb";
String spName="wdw";
QName qname=new QName("RequestSOAPHeader");
Document doc=DOMUtils.createDocument();
//自定義節(jié)點(diǎn)
Element spId=doc.createElement("tns:spId");
spId.setTextContent(spName);
//自定義節(jié)點(diǎn)
Element spPass=doc.createElement("tns:spPassword");
spPass.setTextContent(spPassword);
Element root=doc.createElementNS(nameURI, "tns:RequestSOAPHeader");
root.appendChild(spId);
root.appendChild(spPass);
SoapHeader head=new SoapHeader(qname,root);
List<Header> headers=message.getHeaders();
headers.add(head);
System.out.println(">>>>>添加header<<<<<<<");
}
}
2.客戶端調(diào)用程序修改
package hs.cxf.client;
import hs.cxf.client.SoapHeader.AddSoapHeader;
import java.util.ArrayList;
import javax.xml.bind.JAXBElement;
import javax.xml.namespace.QName;
import org.apache.cxf.endpoint.Client;
import org.apache.cxf.frontend.ClientProxy;
import org.apache.cxf.interceptor.Interceptor;
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
import org.apache.cxf.transport.http.HTTPConduit;
import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
/** *//**
* @Title:
*
* @Description:
*
* @Copyright:
*
* @author zz
* @version 1.00.000
*
*/
public class TestClient {
/** *//**
* 測試1
*/
@SuppressWarnings("unchecked")
public void testSend1() {
try {
JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
ArrayList<Interceptor> list = new ArrayList<Interceptor>();
// 添加soap header
list.add(new AddSoapHeader());
// 添加soap消息日志打印
list.add(new org.apache.cxf.interceptor.LoggingOutInterceptor());
factory.setOutInterceptors(list);
factory.setServiceClass(WebServiceSample.class);
factory.setAddress("http://127.0.0.1:8080/cxfTest/ws/HelloWorld");
Object obj = factory.create();
System.out.println(obj == null ? "NULL" : obj.getClass().getName());
if (obj != null) {
WebServiceSample ws = (WebServiceSample) obj;
String str = ws.say("test");
System.out.println(str);
str = ws.say("1111");
System.out.println(str);
User u = new User();
JAXBElement<String> je = new JAXBElement<String>(new QName(
"http://bean.cxf.hs", "name"), String.class, "張三");
u.setName(je);
str = ws.sayUserName(u);
System.out.println(str);
// 通過對象來交互
ReqBean req = new ReqBean();
req.setExp(new JAXBElement<String>(new QName(
"http://bean.cxf.hs", "exp"), String.class,
"<exp>111<exp>"));
req.setSeqId(new JAXBElement<String>(new QName(
"http://bean.cxf.hs", "seqId"), String.class,
"12345678"));
RespBean resp = ws.action(req);
System.out.println("resp_id:" + resp.getRespId().getValue());
System.out.println("resp_exp:" + resp.getExp().getValue());
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
/** *//**
* 測試2
*/
@SuppressWarnings("unchecked")
public void testSend2() {
String webServiceUrl = "http://127.0.0.1:8080/cxfTest/ws/HelloWorld";
String webServiceConTimeout = "60000";
String webServiceRevTimeout = "60000";
JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
ArrayList<Interceptor> list = new ArrayList<Interceptor>();
// 添加soap header 信息
list.add(new AddSoapHeader());
// 添加soap消息日志打印
list.add(new org.apache.cxf.interceptor.LoggingOutInterceptor());
factory.setOutInterceptors(list);
factory.setServiceClass(WebServiceSample.class);
factory.setAddress(webServiceUrl);
WebServiceSample service = (WebServiceSample) factory.create();
//超時(shí)時(shí)間設(shè)置
Client clientP = ClientProxy.getClient(service);
HTTPConduit http = (HTTPConduit) clientP.getConduit();
HTTPClientPolicy httpClientPolicy = new HTTPClientPolicy();
httpClientPolicy.setConnectionTimeout(Integer
.valueOf(webServiceConTimeout));
httpClientPolicy.setReceiveTimeout(Integer
.valueOf(webServiceRevTimeout));
httpClientPolicy.setAllowChunking(false);
http.setClient(httpClientPolicy);
// 通過對象來交互
ReqBean req = new ReqBean();
req.setExp(new JAXBElement<String>(new QName(
"http://bean.cxf.hs", "exp"), String.class,
"<exp>111<exp>"));
req.setSeqId(new JAXBElement<String>(new QName(
"http://bean.cxf.hs", "seqId"), String.class,
"12345678"));
System.out.println(">>>>>>發(fā)送消息<<<<<<<<<");
RespBean resp = service.action(req);
System.out.println("resp_id:" + resp.getRespId().getValue());
System.out.println("resp_exp:" + resp.getExp().getValue());
}
/** *//**
* @param args
*/
public static void main(String[] args) {
TestClient tc = new TestClient();
tc.testSend1();
System.out.println(">>>>>>>>>>>>2<<<<<<<<<<<<<");
tc.testSend2();
System.out.println(">>>>>>>>>>>>END<<<<<<<<<<<<<");
}
}
到這里就結(jié)束了，可以進(jìn)行測試了