Webservice如何调用

webservice调用方式：

（1）http方式调用

请求头增加Content-type:text/xml 或application/soap+xml

SOAPAction:方法名

请求body以xml字符串传递，xml格式定义

返回以xml字符串返回，xml某个字段是一个json字符串。

入参如下：

<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:dhcc="http://www.dhcc.com.cn">
   <soapenv:Header/>
   <soapenv:Body>
      <dhcc:方法名>
         <!--Optional:-->
         <dhcc:inputJsonStream><![CDATA[
json串...
]]></dhcc:inputJsonStream>
      </dhcc:方法名>
   </soapenv:Body>
</soapenv:Envelope>

curl -XPOST -H 'Content-Type:text/xml' -d '<xml></xml>'  webserviceurl

 curl -X POST -H 'Content-Type:application/soap+xml' -d @test.xml  webserviceurl，其中xml文件以本地文件的方式传递

   public static String callWebService(String webserviceurl, String method, String sendMsg, String contentType) {
        String retStr = "";
        HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
        CloseableHttpClient closeableHttpClient = httpClientBuilder.build();
        HttpPost httpPost = new HttpPost(webserviceurl);

        // 设置请求和传输超时时间
        RequestConfig requestConfig = RequestConfig.custom()
                .setSocketTimeout(3000)
                .setConnectTimeout(3000).build();
        httpPost.setConfig(requestConfig);

        try {
            httpPost.setHeader("Content-Type", contentType);
            httpPost.setHeader("SOAPAction", method);
            StringEntity data = new StringEntity(sendMsg,
                    Charset.forName("UTF-8"));
            httpPost.setEntity(data);
            CloseableHttpResponse response = closeableHttpClient
                    .execute(httpPost);
            HttpEntity httpEntity = response.getEntity();
            if (httpEntity != null) {
                retStr = EntityUtils.toString(httpEntity, "UTF-8");
                logger.debug("url:{} ret:{}", url, retStr);
                return retStr;
            }

        } catch (Exception e) {
            logger.error("callWebService", e);
        } finally {
            // 释放资源
            try {
                closeableHttpClient.close();
            } catch (IOException e) {
                logger.error("close", e);
            }
        }
        return null;
    }

（2）通过apache的webservice工具调用

Client client = WsClientUtil.getClient(notifyUrl);
        try {
            Object[] objects = client.invoke(method, getjson());
            if (objects != null) {
                result = (String)objects[0];
                log.info(result);
                log.info("耗时:" +(System.currentTimeMillis() - start));
            }
        } catch (Exception e) {
            throw new RuntimeException("WebSocket请求异常");
        }
    }

import org.apache.cxf.endpoint.Client;
import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
import org.apache.cxf.transport.http.HTTPConduit;
import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * 获取Client
 */
public class WsClientUtil {

    private static final JaxWsDynamicClientFactory clientFactory = JaxWsDynamicClientFactory.newInstance();

    private static final Map<String, Client> clientMap = new ConcurrentHashMap(256);

    public static Client getClient(String wsUrl) {
        // 创建动态客户端
//        JaxWsDynamicClientFactory clientFactory = JaxWsDynamicClientFactory.newInstance();
        //根据WebServices接口地址创建client
        if (clientMap.get(wsUrl) == null) {
            synchronized (WsClientUtil.class) {
                if (clientMap.get(wsUrl) == null) {
                    Client client = clientFactory.createClient(wsUrl);
                    HTTPConduit conduit = (HTTPConduit) client.getConduit();
                    HTTPClientPolicy policy = new HTTPClientPolicy();
                    policy.setAllowChunking(false);
                    // 连接服务器超时时间 3秒
                    policy.setConnectionTimeout(5000);
                    // 等待服务器响应超时时间 3秒
                    // 等待服务器响应超时时间 3秒
                    policy.setReceiveTimeout(5000);
                    conduit.setClient(policy);
                    clientMap.put(wsUrl, client);
                    return client;
                }
            }
        }
        return clientMap.get(wsUrl);
    }
}

但今天测试时，使用curl -X POST -H 'Content-Type:application/soap+xml' -d '' 可以通，用java客户端调用就报错。。