CXF之動(dòng)態(tài)客戶端實(shí)例

江江385 2013-01-30

展開全文

通常創(chuàng)建一個(gè)web服務(wù)的客戶端包括SEI的java接口和客戶端輸入輸出應(yīng)用的一些java類，這不總是可取的或?qū)嵱玫摹?/p>

CXF支持不同的選擇，允許一個(gè)應(yīng)用連接到服務(wù)而不使用SEI和一些數(shù)據(jù)類。本頁面介紹CXF的動(dòng)態(tài)客戶端工具，有了動(dòng)態(tài)客戶端，CXF就可以在運(yùn)行時(shí)生成SEI和一些Bean類，也允許你通過API調(diào)用操作,即采取對(duì)象或使用反射來應(yīng)用代理。

服務(wù)接口：

[java:firstline[1]] view plain copy print ?

package test.cxf;
import javax.jws.WebParam;
import javax.jws.WebService;
@WebService
public interface HelloWorld {
public Person sayPerson(
@WebParam(name="personName")String personName,
@WebParam(name="address")Address address);
}

服務(wù)實(shí)現(xiàn)類:

[java:firstline[1]] view plain copy print ?

package test.cxf;
import javax.jws.WebService;
@WebService(endpointInterface="test.cxf.HelloWorld")
public class HelloWorldImpl implements HelloWorld {
public Person sayPerson(String personName, Address address) {
Person p = new Person();
p.setPersonName(personName);
p.setAddress(address);
p.setAge(30);
System.out.println("server--" + p.getPersonName());
System.out.println("server--" + p.getAge());
System.out.println("server--" + p.getAddress().getAddress1()+":" + p.getAddress().getAddress2());
return p;
}
}

對(duì)象 Person：

[java:firstline[1]] view plain copy print ?

package test.cxf;
import java.io.Serializable;
import javax.xml.bind.annotation.XmlAccessType;
import javax.xml.bind.annotation.XmlAccessorType;
@XmlAccessorType(XmlAccessType.FIELD)
public class Person implements Serializable{
private String personName;
private Integer age;
private Address address;
public String getPersonName() {
return personName;
}
public void setPersonName(String personName) {
this.personName = personName;
}
public Integer getAge() {
return age;
}
public void setAge(Integer age) {
this.age = age;
}
public Address getAddress() {
return address;
}
public void setAddress(Address address) {
this.address = address;
}
}

對(duì)象Address:

[java:firstline[1]] view plain copy print ?

package test.cxf;
import java.io.Serializable;
import javax.xml.bind.annotation.XmlAccessType;
import javax.xml.bind.annotation.XmlAccessorType;
@XmlAccessorType(XmlAccessType.FIELD)
public class Address implements Serializable{
private String address1;
private String address2;
public String getAddress1() {
return address1;
}
public void setAddress1(String address1) {
this.address1 = address1;
}
public String getAddress2() {
return address2;
}
public void setAddress2(String address2) {
this.address2 = address2;
}
}

異常定義：

[java:firstline[1]] view plain copy print ?

package test.cxf;
import javax.xml.bind.annotation.XmlAccessType;
import javax.xml.bind.annotation.XmlAccessorType;
import javax.xml.ws.WebFault;
@XmlAccessorType(XmlAccessType.FIELD)
@WebFault(name="DynamicClientException")
public class DynamicClientException extends Exception {
public DynamicClientException(){
super();
System.out.println("DynamicClientException!!!");
}
}

服務(wù)端配置：

[java:firstline[1]] view plain copy print ?

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www./schema/beans"
xmlns:xsi="http://www./2001/XMLSchema-instance"
xmlns:jaxws="http://cxf./jaxws"
xsi:schemaLocation="
http://www./schema/beans http://www./schema/beans/spring-beans.xsd
http://cxf./jaxws http://cxf./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="helloworldImpl" class="test.cxf.HelloWorldImpl"/>
<jaxws:endpoint id="helloworldService" implementor="#helloworldImpl" address="/helloworld"/>
</beans>

客戶端調(diào)用-----關(guān)鍵就在這里：

[java:firstline[1]] view plain copy print ?

package test.cxf;
import java.lang.reflect.Method;
import org.apache.cxf.endpoint.Client;
import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
public class ClientObj {
public static void main(String[] args){
JaxWsDynamicClientFactory dynamicClient = JaxWsDynamicClientFactory.newInstance();
Client client = dynamicClient.createClient("http://localhost:8085/cxf-dynamicClientFactory/service/helloworld?wsdl");
Object address = null;
try {
address = Thread.currentThread().getContextClassLoader().loadClass("test.cxf.Address").newInstance();
Method m2 = address.getClass().getMethod("setAddress1",String.class);
Method m3 = address.getClass().getMethod("setAddress2",String.class);
m2.invoke(address, "qqqqqqq");
m3.invoke(address, "ttttttt");
Object[] rspArr = client.invoke("sayPerson", "fhd", address);
if (null != rspArr && rspArr.length > 0) {
Method m4 = rspArr[0].getClass().getMethod("getAge");
Object obj1 = m4.invoke(rspArr[0]);
System.out.println("ggggg:" + (Integer)obj1);
Method m5 = rspArr[0].getClass().getMethod("getPersonName");
Object obj2 = m5.invoke(rspArr[0]);
System.out.println("vvvvv" + (String)obj2);
Method m6 = rspArr[0].getClass().getMethod("getAddress");
Object obj3 = m6.invoke(rspArr[0]);
Method m7 = obj3.getClass().getMethod("getAddress1");
Method m8 = obj3.getClass().getMethod("getAddress2");
Object o1 = m7.invoke(obj3);
Object o2 = m8.invoke(obj3);
System.out.println("ssssss" + (String)o1 + "<<>>" + (String)o2);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}

你可能會(huì)問自己下面這個(gè)問題：“類名'com.acme.Person'從哪里來”？是通過運(yùn)行"wsdl2java'并審查結(jié)果來得到類名。

本站是提供個(gè)人知識(shí)管理的網(wǎng)絡(luò)存儲(chǔ)空間，所有內(nèi)容均由用戶發(fā)布，不代表本站觀點(diǎn)。請(qǐng)注意甄別內(nèi)容中的聯(lián)系方式、誘導(dǎo)購買等信息，謹(jǐn)防詐騙。如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容，請(qǐng)點(diǎn)擊一鍵舉報(bào)。

轉(zhuǎn)藏 分享

QQ空間 QQ好友新浪微博微信

獻(xiàn)花（0） +1

來自：江江385 > 《webservice》

舉報(bào)/認(rèn)領(lǐng)