基于Axis 1.4的Web Service入门

最近有个客户使用的是Axis 1.4创建的Web Service，很久没用了，所以整理下这块的知识。

基于JDK 1.8和Eclipse Mars开发一个简单的Hello world Web Service

public interface HelloService {

  String hello(String name);
}

public class HelloServiceImpl implements HelloService{

  @Override
  public String hello(String name) {
    return String.format("%s, 您好",name);
  }

}

右键单击HelloService的实现类，选择Web Services -> Create Web Service, 经过下面的配置后，一路Next基本就可以创建客户端项目了。

常规调用方式1：

private HelloServiceImplProxy helloServiceImplProxy = new HelloServiceImplProxy();

String helloTerry = helloServiceImplProxy.hello("程英华的博客");

其他方式：以使用HttpClient为例,这里的重点不是请求方式，而是工具SOAP UI 让我们快速的基于wsdl来创建请求，查看响应。这个工具是本人认为是其他方式的重点。

StringBuilder params = new StringBuilder();
params.append("<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:impl=\"http://impl.soap.hello.penguin.org\">\n" +
" <soapenv:Header/>\n" +
" <soapenv:Body>\n" +
" <impl:hello>\n" +
" <impl:name>兰博</impl:name>\n" +
" </impl:hello>\n" +
" </soapenv:Body>\n" +
"</soapenv:Envelope>");

WebServiceClientUtil webServiceClientUtil = new WebServiceClientUtil();
Result<?> result= webServiceClientUtil.createOaSoap(params.toString());

WebServiceClientUtil.java

package org.penguin.hello.util;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.Header;

import org.apache.http.message.BasicHeader;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.penguin.hello.vo.Result;
import org.apache.http.HttpResponse;
import org.apache.http.entity.StringEntity;
import org.apache.http.util.EntityUtils;
import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.tree.DefaultElement;

import java.nio.charset.StandardCharsets;

public class WebServiceClientUtil {
    /**
     * Web Service地址
     */
    private static final String URL = "http://localhost:8080/helloAxis1/services/HelloServiceImpl";

    /**
     * 调用Web Service
     *
     * @param params
     * @return
     */
    public static Result<?> createOaSoap(String params) {
        Result<String> result = Result.ok();
        // 创建HttpClient实例
        CloseableHttpClient httpClient = HttpClients.createDefault();
        // 创建HttpPost实例
        HttpPost httpPost = new HttpPost(URL);
        // 连接超时时间，单位：毫秒
        int connectTimeout = 5000;
        // 读取超时时间，单位：毫秒
        int socketTimeout = 5000;
        RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(connectTimeout)
                .setSocketTimeout(socketTimeout).build();
        httpPost.setConfig(requestConfig);
        // 设置请求头部
        List<Header> headers = new ArrayList<>();
        headers.add(new BasicHeader("SOAPAction", "http://impl.soap.hello.penguin.org/HelloServiceImpl/helloRequest"));
        httpPost.setHeaders(headers.toArray(new Header[0]));
        // 设置请求体
        StringEntity requestEntity = new StringEntity(params, StandardCharsets.UTF_8);
        requestEntity.setContentType("text/xml");
        httpPost.setEntity(requestEntity);
        try {
            // 执行请求并获得响应
            HttpResponse response = httpClient.execute(httpPost);
            // 打印响应状态
            int statusCode = response.getStatusLine().getStatusCode();
            // 获取响应内容
            String responseBody = EntityUtils.toString(response.getEntity());
            String message = null;
            String responseString;
            try {
                Document document = DocumentHelper.parseText(responseBody);
                responseString = ((DefaultElement) ((DefaultElement) document.content().get(0)).content().get(3))
                        .element("helloResponse").element("helloReturn").getText();
                message = responseString;
                result.setResult(message);
            } catch (Exception e) {
                e.printStackTrace();
                statusCode = 400;
                message = e.getMessage();
            }
            result.setCode(statusCode);
            result.setMessage(message);
        } catch (Exception e) {
            result.setCode(400);
            result.setMessage(e.getMessage());
            e.printStackTrace();
        } finally {
            try {
                // 关闭HttpClient连接
                httpClient.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return result;
    }
}