當(dāng)前位置：首頁(yè) > 编程资源 > 编程问答 >内容正文

编程问答

CXF客户端笔记

發(fā)布時(shí)間：2024/4/17 编程问答 35 豆豆

生活随笔收集整理的這篇文章主要介紹了 CXF客户端笔记小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

https://cwiki.apache.org/CXF20DOC/

CXF客戶端筆記

本文由淘寶網(wǎng)女裝冬裝 http://www.lnjie.com整理。

服務(wù)端

?? 從網(wǎng)絡(luò)上找了很多入門(mén)的例子，但大部分都是有這樣或那樣的問(wèn)題，搞的頭大。
?? 這里根據(jù)自己搭建的過(guò)程，整理出一個(gè)實(shí)際例子。
?? 環(huán)境：jdk1.5+，eclipse3.4，Tomcat5.5，cxf-2.1.4
?? 以下沒(méi)有用到任何插件來(lái)生成
?? 服務(wù)端
???? 一、server 端:
????????? 接口:WebServiceSample
????????

import hs.cxf.bean.ReqBean;
import hs.cxf.bean.RespBean;
import hs.cxf.bean.UserDTO;
import javax.jws.WebParam;
import javax.jws.WebResult;
import javax.jws.WebService;

/**
?* WebService接口定義類(lèi).
?*
?* 使用@WebService將接口中的所有方法輸出為Web Service.
?* 可用annotation對(duì)設(shè)置方法、參數(shù)和返回值在WSDL中的定義.
?*/
@WebService
public interface WebServiceSample {

??? /**
???? * 一個(gè)簡(jiǎn)單的方法,返回一個(gè)字符串
???? *
???? * @param hello
???? * @return
???? */
??? String say(String hello);

??? /**
???? * 稍微復(fù)雜一些的方法,傳遞一個(gè)對(duì)象給服務(wù)端處理
???? *
???? * @param user
???? * @return
???? */
??? String sayUserName(@WebParam(name = "user") UserDTO user);

??? /**
???? * 通過(guò)對(duì)象來(lái)交互
???? */
??? @WebResult(name = "RespBean")
??? RespBean action(@WebParam(name = "ReqBean") ReqBean req);

}

?? 實(shí)現(xiàn)類(lèi)：WebServiceSampleImpl
??

import javax.jws.WebService;
import hs.cxf.bean.ReqBean;
import hs.cxf.bean.RespBean;
import hs.cxf.bean.UserDTO;

/**
?* @Title:
?*
?* @Description:
?*
?* @Copyright: Copyright (c) 2009 FFCS All Rights Reserved
?*
?* @author zhengzhi 2009-3-16 上午11:22:23
?* @version 1.00.000
?*
?*/
@WebService(endpointInterface="hs.cxf.server.WebServiceSample")
public class WebServiceSampleImpl implements WebServiceSample {
??? public String sayUserName(UserDTO user) {
??????? return "hello " + user.getName();
??? }

??? public String say(String hello) {

??????? return "hello " + hello;
??? }

??? public RespBean action(ReqBean req) {
??????? RespBean respBean = new RespBean();
??????? respBean.setExp(req.getExp());
??????? respBean.setRespId(req.getSeqId());
??????? return respBean;
??? }

}

? 實(shí)體類(lèi)：UserDTO，ReqBean，RespBean
?

UserDTO
@XmlAccessorType(XmlAccessType.FIELD)??
@XmlType(name = "User")??
public class UserDTO {??
?
??? protected Integer id;??
?
??? protected String name;??
??? //get和set方法，這里不寫(xiě)出
}
ReqBean
@XmlAccessorType(XmlAccessType.FIELD)??
@XmlType(name = "ReqBean")??
public class ReqBean {
??? private String exp;
??? private String seqId;
?????? //get和set方法，這里不寫(xiě)出
}

RespBean
@XmlAccessorType(XmlAccessType.FIELD)??
@XmlType(name = "RespBean")??
public class RespBean {
??? private String respId;
??? private String exp;
?????? //get和set方法，這里不寫(xiě)出
}

?二、Spring 配置
??????

<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:serviceFactory>??
??????????? <ref bean="jaxWsServiceFactoryBean"/>??
??????? </jaxws:serviceFactory>??
??? </jaxws:endpoint>??
</beans>?

三.web.xml配置

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE web-app PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN" "http://java.sun.com/dtd/web-app_2_3.dtd">
<web-app id="WebApp_ID">
??? <display-name>cxfTest</display-name>
??? <context-param>
??????? <param-name>contextConfigLocation</param-name>
??????? <param-value>WEB-INF/beans.xml</param-value>
??? </context-param>
??? <listener>
??????? <listener-class>
??????????? org.springframework.web.context.ContextLoaderListener??
??????? </listener-class>
??? </listener>
??? <servlet>
??????? <servlet-name>CXFServlet</servlet-name>
??????? <servlet-class>
??????????? org.apache.cxf.transport.servlet.CXFServlet??
??????? </servlet-class>
??????? <load-on-startup>1</load-on-startup>
??? </servlet>
??? <servlet-mapping>
??????? <servlet-name>CXFServlet</servlet-name>
??????? <url-pattern>/ws/*</url-pattern>
??? </servlet-mapping>
</web-app>

這里要注意，cxf 教程上提到需要的包并不完整，還需要導(dǎo)入:jdom，stax-api-1.0-2.jar,jaxws-api.jar 這些包
?我使用的包如下：

aopalliance-1.0.jar
asm-2.2.3.jar
commons-logging-1.1.1.jar
cxf-2.1.4.jar
geronimo-activation_1.1_spec-1.0.2.jar
geronimo-annotation_1.0_spec-1.1.1.jar
geronimo-javamail_1.4_spec-1.3.jar
geronimo-servlet_2.5_spec-1.2.jar
geronimo-ws-metadata_2.0_spec-1.1.2.jar
jaxb-api-2.1.jar
jaxb-impl-2.1.9.jar
jaxen-core.jar
jaxen-jdom.jar
jaxws-api.jar
jdom.jar
jetty-6.1.9.jar
jetty-util-6.1.9.jar
neethi-2.0.4.jar
saaj-api-1.3.jar
saaj-impl-1.3.2.jar
saxpath.jar
spring-beans-2.0.8.jar
spring-context-2.0.8.jar
spring-core-2.0.8.jar
spring-web-2.0.8.jar
stax-api-1.0-2.jar
wsdl4j-1.6.2.jar
wstx-asl-3.2.6.jar
xalan.jar
xml-resolver-1.2.jar
XmlSchema-1.4.3.jar

然后啟動(dòng)tomcat，輸入http://IP:端口/模塊名/ws 查看你生成的服務(wù)端，可使用xmlspy來(lái)進(jìn)行測(cè)試。

客戶端

生成了服務(wù)端，現(xiàn)在把服務(wù)端的wsdl保存到本地(直接把Http://xxx/ws/xxx?wsdl 另存為wsdl文件) 。
?? 我們要根據(jù)服務(wù)端的wsdl來(lái)生成客戶端調(diào)用的文件，這樣需要用到CXF BIN目錄下wsdl2java.bat 。
?? wsdl2java 參數(shù)如下：

wsdl2java -fe <frontend name>* -db <data binding name>* -wv <[wsdl version]>*
-p <[wsdl namespace =]Package Name>* -sn <service-name> -b <binding-name>*
-catalog <catalog-file-name> -d <output-directory> -compile
-classdir <compile-classes-directory> -impl -server -client -all
-autoNameResolution -defaultValues<=class name for DefaultValueProvider> -ant
-nexclude <schema namespace [= java packagename]>*? -exsh <(true, false)>
-dns <(true, false)> -dex <(true, false)> -validate -keep
-wsdlLocation <wsdlLocation attribute> -xjc<xjc arguments> -noAddressBinding -h
-v -verbose -quiet <wsdlurl>

? 具體可參考官方網(wǎng)站：
?? http://cwiki.apache.org/CXF20DOC/wsdl-to-java.html

? 我們?cè)诿钚邢螺斎?wsdl2java -p hs.cxf.client? HelloWorld.wsdl 來(lái)指定生成的客戶端包目錄。

?客戶端調(diào)用代碼

try {
??????????? JaxWsProxyFactoryBean? factory = new JaxWsProxyFactoryBean ();
??????????? factory.setServiceClass(WebServiceSample.class);
??????????? factory.setAddress("http://127.0.0.1:9080/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);
???????????????
??????????????? //通過(guò)對(duì)象來(lái)交互
??????????????? 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();
??????? }

運(yùn)行此代碼，查看結(jié)果即可

依賴包如下:

cxf-2.1.4.jar
jaxb-api-2.1.jar
geronimo-annotation_1.0_spec-1.1.1.jar
geronimo-ws-metadata_2.0_spec-1.1.2.jar
jaxws-api.jar
stax-api-1.0-2.jar
jaxb-impl-2.1.9.jar
geronimo-activation_1.1_spec-1.0.2.jar
xml-resolver-1.2.jar
XmlSchema-1.4.3.jar
wsdl4j-1.6.2.jar
saaj-api-1.3.jar
jsr173_1.0_ri.jar

其中jsr從bean下載:http://ftpna2.bea.com/pub/downloads/jsr173.jar (注意解壓)

SOAP

基于CXF2.0前2個(gè)學(xué)習(xí)筆記，對(duì)原先服務(wù)端與客戶端進(jìn)行修改，實(shí)現(xiàn)在SOAP Header里面添加自定義的數(shù)據(jù)進(jìn)行認(rèn)證

在做之前，先要理解如下的信息
攔截器(Interceptor)簡(jiǎn)單說(shuō)明
????? Interceptor是CXF架構(gòu)中一個(gè)很有特色的模式。你可以在不對(duì)核心模塊進(jìn)行修改的情況下，動(dòng)態(tài)添加很多功能。這對(duì)于CXF這個(gè)以處理消息為中心的服務(wù)框架來(lái)說(shuō)是非常有用的，CXF通過(guò)在Interceptor中對(duì)消息進(jìn)行特殊處理，實(shí)現(xiàn)了很多重要功能模塊，例如：日志記錄，Soap消息處理，消息的壓縮處。簡(jiǎn)單的說(shuō)，可以在收到請(qǐng)求后，還未進(jìn)行業(yè)務(wù)處理前，進(jìn)行處理。或者在請(qǐng)求包發(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ì)長(zhǎng)。小隊(duì)長(zhǎng)有調(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會(huì)根據(jù)這些后備小分隊(duì)，組建自己的小分隊(duì)實(shí)例，完成具體的作戰(zhàn)功能任務(wù)。
AbstractAttributedInterceptorProvider
?? InterceptorProvider實(shí)現(xiàn)的抽象類(lèi)，由于這個(gè)類(lèi)來(lái)繼承了HashMap，我們可以像這個(gè)類(lèi)中存儲(chǔ)一些屬性信息。
AbstractBasicInterceptorProvider
?? 與AbstractAttributedInterceptorProvider不同，這個(gè)Interceptor只是簡(jiǎn)單實(shí)現(xiàn)了InterceptorProvider的功能，并不提供對(duì)其屬性存儲(chǔ)的擴(kuò)展。
Message
?? 由于Interceptor是針對(duì)Message來(lái)進(jìn)行處理的，當(dāng)你打開(kāi)Message這個(gè)類(lèi)文件時(shí)，你會(huì)發(fā)現(xiàn)在Message中定義了很多常量，同時(shí)你還可以從Message中獲取到很多與Message操作相關(guān)的信息。可以獲取設(shè)置的對(duì)象有InterceptorChain Exchange Destination，還有獲取設(shè)置Content的泛型接口，是不是感覺(jué)Message和Bus差不多，都成了大雜貨鋪，一切與消息處理相關(guān)的信息都可以放在Message中。

理解了Interceptor功能，下面的修改就很簡(jiǎn)單了

服務(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)值，簡(jiǎ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ù)端的配置就告一段落了，接下來(lái)是客戶端的修改
客戶端
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 {

??? /**
???? * 測(cè)試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);

??????????????? // 通過(guò)對(duì)象來(lái)交互
??????????????? 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();
??????? }
? ??}

??? /**
???? * 測(cè)試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);
???????
???
??????? // 通過(guò)對(duì)象來(lái)交互
??????? 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)行測(cè)試了

總結(jié)

以上是生活随笔為你收集整理的CXF客户端笔记的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。

上一篇： WCF 调用webservice
下一篇： servers