Java小白翻身 - webservice教程4

@Override
public User getUser(String username, String password) {
    return new User(username,password);
}

package com.example.server.bean;

public class User {

    private String username;
    private String password;

    public User(String username, String password) {
        this.username = username;
        this.password = password;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }
}

//创建动态客户端
JaxWsDynamicClientFactory factory = JaxWsDynamicClientFactory.newInstance();
Client client = factory.createClient("http://localhost:8080/webservice/api?wsdl");
// 需要密码的情况需要加上用户名和密码
//client.getOutInterceptors().add(new ClientLoginInterceptor(USER_NAME,PASS_WORD));
HTTPConduit conduit = (HTTPConduit) client.getConduit();
HTTPClientPolicy httpClientPolicy = new HTTPClientPolicy();
httpClientPolicy.setConnectionTimeout(2000);  //连接超时
httpClientPolicy.setAllowChunking(false);    //取消块编码
httpClientPolicy.setReceiveTimeout(120000);     //响应超时
conduit.setClient(httpClientPolicy);
//client.getOutInterceptors().addAll(interceptors);//设置拦截器
try{
    Object[] objects = new Object[0];
    // invoke("方法名",参数1,参数2,参数3....);
    objects = client.invoke("getUser","jack","123");

    Method[] methods = objects[0].getClass().getMethods();
    for (int i = 0; i < methods.length; i++) {
        System.out.println(methods[i].getName());
        Object invoke = methods[i].invoke(objects[0]);
        System.out.println(invoke);
    }

}catch (Exception e){
    e.printStackTrace();
}

public static void main(String[] args) throws Exception {
    //创建动态客户端
    JaxWsDynamicClientFactory factory = JaxWsDynamicClientFactory.newInstance();
    Client client = factory.createClient("http://localhost:8080/webservice/loginApi?wsdl");

    HTTPConduit conduit = (HTTPConduit) client.getConduit();
    HTTPClientPolicy httpClientPolicy = new HTTPClientPolicy();
    httpClientPolicy.setConnectionTimeout(2000);  //连接超时
    httpClientPolicy.setAllowChunking(false);    //取消块编码
    httpClientPolicy.setReceiveTimeout(120000);     //响应超时
    conduit.setClient(httpClientPolicy);

    Object[] objects = client.invoke("userLogin");

    if(objects != null && objects.length > 0){
        Method[] methods = objects[0].getClass().getMethods();
        for (int i = 0; i < methods.length; i++) {
            //System.out.println(methods[i].getName());

            if(methods[i].getName().equals("getEntry")){
                Object entry = methods[i].invoke(objects[0]); //实际上是 UserLoginResponse.Return.Entry
                Method iteratorMethod = entry.getClass().getMethod("iterator");

                //反射调用迭代方法
                Object iteratorBean = iteratorMethod.invoke(entry);

                Method hasNextMethod = iteratorBean.getClass().getMethod("hasNext");
                hasNextMethod.setAccessible(true);

                while(Boolean.parseBoolean(hasNextMethod.invoke(iteratorBean).toString()) == true){
                    Method nextMethod = iteratorBean.getClass().getMethod("next");
                    nextMethod.setAccessible(true);
                    Object entryBean = nextMethod.invoke(iteratorBean);
                    Method getKeyMethod = entryBean.getClass().getMethod("getKey");
                    Method getValueMethod = entryBean.getClass().getMethod("getValue");
                    Object value = getValueMethod.invoke(entryBean);
                    value = new String(value.toString().getBytes("GBK"), "UTF-8");

                    System.out.println(getKeyMethod.invoke(entryBean) + "=" +  value);
                }

            }

        }
    }

}