在前面的两个例子中我们说明了CXF
如何处理基本数据类型和一些集合(如List
)类型数据的,这里我们说明如何处理一些复杂类型的数据。
一、服务端改造(工程WS_Server03
)
1.1 首先我们再HelloWorld.java
接口中新增一个方法。
HelloWorld.java
package org.fkjava.cxf.ws;
import java.util.List;
import java.util.Map;
import javax.jws.WebService;
import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter;
import org.fkjava.cxf.ws.domain.Cat;
import org.fkjava.cxf.ws.domain.User;
import org.fkjava.cxf.ws.util.FkXmlAdapter;
@WebService
public interface HelloWorld {
String sayHi(String name);
List<Cat> getCatsByUser(User user);
//增加一个方法
@XmlJavaTypeAdapter(FkXmlAdapter.class) Map<String, Cat> getAllCats();
}
说明:我们知道CXF
是不能处理Map
这样的类型的,于是要处理这样的类型就必须让程序员手工来处理。首先我们需要使用@XmlJavaTypeAdapter
来修饰CXF不能处理的类型(这里是Map
),然后我们需要提供一个自定义的转换器FkXmlAdapter.java
。
注意:其中XmlJavaTypeAdapter.java
类我们可以查看javaAPI
。
实现类HelloWorldWs.java
package org.fkjava.cxf.ws.impl;
import java.util.Date;
import java.util.List;
import java.util.Map;
import javax.jws.WebService;
import org.fkjava.cxf.ws.HelloWorld;
import org.fkjava.cxf.ws.domain.Cat;
import org.fkjava.cxf.ws.domain.User;
import org.fkjava.cxf.ws.service.UserService;
import org.fkjava.cxf.ws.service.impl.UserServiceImpl;
@WebService(endpointInterface = "org.fkjava.cxf.ws.HelloWorld", serviceName = "HelloWorldWs")
public class HelloWorldWs implements HelloWorld {
@Override
public String sayHi(String name) {
return name + "您好!" + "现在的时间是: " + new Date();
}
@Override
public List<Cat> getCatsByUser(User user) {
//这里我们需要手工new,如果交给spring管理可以将对象注入进来
UserService service = new UserServiceImpl();
return service.getCatByUser(user);
}
//新增方法
@Override
public Map<String, Cat> getAllCats() {
UserService service = new UserServiceImpl();
return service.getAllCats();
}
}
说明:当然这里我们还是使用业务类中的方法来帮我们处理具体的业务。
业务实现类UserServiceImpl.java
package org.fkjava.cxf.ws.service.impl;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.fkjava.cxf.ws.domain.Cat;
import org.fkjava.cxf.ws.domain.User;
import org.fkjava.cxf.ws.service.UserService;
public class UserServiceImpl implements UserService {
static Map<User, List<Cat>> catDb = new HashMap<User, List<Cat>>();
static {
List<Cat> cats1 = new ArrayList<Cat>();
cats1.add(new Cat(1, "Tom1", "黄色"));
cats1.add(new Cat(2, "Jerry1", "黑色"));
catDb.put(new User(1, "大熊", "111", "西安"), cats1);
List<Cat> cats2 = new ArrayList<Cat>();
cats2.add(new Cat(3, "Tom2", "灰色"));
cats2.add(new Cat(4, "Jerry2", "白色"));
catDb.put(new User(2, "小志", "222", "北京"), cats2);
}
@Override
public List<Cat> getCatByUser(User user) {
//理论上应该调用dao,这里我们使用一个HashMap来模拟数据库
return catDb.get(user);
}
@Override
public Map<String, Cat> getAllCats() {
Map<String, Cat> result = new HashMap<String, Cat>();
int i = 1;
for(List<Cat> cats : catDb.values()){
for(Cat cat : cats){
result.put("第" + i++ + "个:", cat);
}
}
return result;
}
}
1.2 自定义转换器
1.2.1 自定义转换器
FkXmlAdapter .java
package org.fkjava.cxf.ws.util;
import java.util.Map;
import javax.xml.bind.annotation.adapters.XmlAdapter;
import org.fkjava.cxf.ws.domain.Cat;
import org.fkjava.cxf.ws.domain.StringCat;
public class FkXmlAdapter extends XmlAdapter<StringCat, Map<String, Cat>> {
@Override
public Map<String, Cat> unmarshal(StringCat v) throws Exception {
return null;
}
@Override
public StringCat marshal(Map<String, Cat> v) throws Exception {
return null;
}
}
说明:自定义转换器必须要继承一个抽象类XmlAdapter.java
,而其中需要给出两个参数,其中第二个参数是CXF
不能处理的java
数据类型,而第一个参数就是我们自己给出的一个数据类型,而这个类型需要我们自己定义,让其能够给CXF
处理。
1.2.2 自定义数据类型
StringCat.java
package org.fkjava.cxf.ws.domain;
import java.util.ArrayList;
import java.util.List;
public class StringCat {
private List<Entry> entries = new ArrayList<StringCat.Entry>();//需要初始化
public List<Entry> getEntries() {
return entries;
}
public void setEntries(List<Entry> entries) {
this.entries = entries;
}
public static class Entry{
private String key ;
private Cat value ;
public Entry(){}
public Entry(String key, Cat value){
this.key = key ;
this.value = value ;
}
public String getKey() {
return key;
}
public void setKey(String key) {
this.key = key;
}
public Cat getValue() {
return value;
}
public void setValue(Cat value) {
this.value = value;
}
}
}
说明:这里我们提供一个Entry
类型对应Map
类型中的键值对,然后在Entry
中给出两个属性分别对应Map
中的key
和value
。于是我们就将一个Map
类型转换成了一个CXF
能够处理的javabean
类型。
1.2.3 完善自定义转换器
上面我们已经给出了自定义数据类型,而自定义转换器就用来处理Map
类型和自定义类型之间的转换工作。
FkXmlAdapter.java
package org.fkjava.cxf.ws.util;
import java.util.HashMap;
import java.util.Map;
import javax.xml.bind.annotation.adapters.XmlAdapter;
import org.fkjava.cxf.ws.domain.Cat;
import org.fkjava.cxf.ws.domain.StringCat;
import org.fkjava.cxf.ws.domain.StringCat.Entry;
public class FkXmlAdapter extends XmlAdapter<StringCat, Map<String, Cat>> {
@Override
public Map<String, Cat> unmarshal(StringCat v) throws Exception {
Map<String, Cat> result = new HashMap<String, Cat>();
for(Entry entry : v.getEntries()){
result.put(entry.getKey(), entry.getValue());
}
return result;
}
@Override
public StringCat marshal(Map<String, Cat> v) throws Exception {
StringCat result = new StringCat();
for(String key : v.keySet()){
result.getEntries().add(new Entry(key, v.get(key)));
}
return result;
}
}
二、客户端改造(工程WS_Client03
)
还是和之前一样,我们首先在客户端生成相关的java
类,然后我们主要改造调用服务掉方法的类MyClient.java
package org.fkjava.cxf.ws.server;
import java.util.List;
import org.fkjava.cxf.ws.Cat;
import org.fkjava.cxf.ws.Entry;
import org.fkjava.cxf.ws.HelloWorld;
import org.fkjava.cxf.ws.StringCat;
import org.fkjava.cxf.ws.User;
import org.fkjava.cxf.ws.impl.HelloWorldWs;
public class MyClient {
public static void main(String[] args) {
HelloWorldWs factory = new HelloWorldWs();
HelloWorld hw = factory.getHelloWorldWsPort();
System.out.println(hw.sayHi("张三"));
User user = new User();
user.setId(30);//只要名字和密码相同则认为是同一个用户,所以这里给30没关系
user.setName("sun");
user.setPassword("1111");
List<Cat> cats = hw.getCatsByUser(user);
for(Cat cat : cats){
System.out.println(cat.getName());
}
StringCat sc = hw.getAllCats();
for(Entry entry : sc.getEntries()){
System.out.println(entry.getKey() + entry.getValue().getName());
}
}
}
说明:我们使用此类进行测试,能够得到相关的结果即表示测试成功。