3、一个较为复杂的例子(2)(WebService笔记)

在前面的两个例子中我们说明了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中的keyvalue。于是我们就将一个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());
        }
    }
}

说明:我们使用此类进行测试,能够得到相关的结果即表示测试成功。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容