1. 编程号首页

调用webservice的几种方式_webservice调用wsdl「建议收藏」

编程小号 • • 未分类

调用webservice的几种方式_webservice调用wsdl「建议收藏」程序员日常工作中经常涉及到接口的服务调用，其中webservice服务是比较常见的一种服务提供方式

调用webservice的几种方式_webservice调用wsdl「建议收藏」"

        本人日常工作中经常与不同软件厂商进行接口对接，不同的厂商接口调用方式五花八门，但主要分为两大阵营：http和webservice。本文以Java为例，总结调用webservice服务的几种方式。

        一、利用命令或工具将WebService提供的wsdl文件生成对应的java类，这样就可以像调用本地类一样调用webService提供的接口。这种方法的优点是调用简单，无需自己编写太多的东西。缺点同样很明显，生成的代码过于庞大，不便于阅读，显得很累赘。

        二、AXIS远程调用，代码如下：

import org.apache.axis.Constants;
import org.apache.axis.client.Call;
import org.apache.axis.client.Service;

import javax.xml.namespace.QName;

public class WebServiceTest {

    public static void main(String[] args) {
        //服务地址
        String url = "http://127.0.0.1:8080/service-test/services/gateway?wsdl";
        //命名空间
        String namespaceURI = "http://www.exampletest.com/";
        //方法名
        String method = "invoke";
        try {
            Service service = new Service();
            Call call = (Call) service.createCall();
            call.setTargetEndpointAddress(url);
            //设置要调用的方法
            call.setOperationName(new QName(namespaceURI, method));
            //设置要返回的数据类型
            call.setReturnType(new QName(namespaceURI, method), String.class);
            call.setUseSOAPAction(true);
            call.setSOAPActionURI(namespaceURI + method);
            //设置入参
            call.addParameter(new QName(namespaceURI, "consumer"), Constants.XSD_STRING, javax.xml.rpc.ParameterMode.IN);
            call.addParameter(new QName(namespaceURI, "serviceName"), Constants.XSD_STRING, javax.xml.rpc.ParameterMode.IN);
            call.addParameter(new QName(namespaceURI, "params"), Constants.XSD_STRING, javax.xml.rpc.ParameterMode.IN);

            //调用方法并传递参数
            String resultStr = (String) call.invoke(new Object[]{"test", "queryOrder", "{\"tradeno\":\"1648100061001\",\"mchid\":\"10001\"}"});
            System.out.println("服务调用结果：" + resultStr);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

 对应jar包的maven依赖：

        <dependency>
			<groupId>org.apache.axis</groupId>
			<artifactId>axis</artifactId>
			<version>1.4</version>
		</dependency>
		<dependency>
			<groupId>org.apache.axis</groupId>
			<artifactId>axis-jaxrpc</artifactId>
			<version>1.4</version>
		</dependency>

        该种方式调用简单，一般不需要自己组织请求报文和解析返回报文 。

        三、通过HttpURLConnection进行调用，代码如下：

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;

public class WebServiceTest {

    public static void main(String[] args) throws Exception {
        //服务地址
        String url = "http://127.0.0.1:8080/service-test/services/gateway?wsdl";
        //第一步：创建服务地址
        URL httpUrl = new URL(url);
        //第二步：打开一个通向服务地址的连接
        HttpURLConnection connection = (HttpURLConnection) httpUrl.openConnection();
        //第三步：设置参数
        //3.1发送方式设置：POST必须大写
        connection.setRequestMethod("POST");
        //3.2设置数据格式：content-type，这个根据实际情况来确定
        connection.setRequestProperty("content-type", "application/atom+xml;charset=utf-8");
        //3.3设置输入输出，因为默认新创建的connection没有读写权限，
        connection.setDoInput(true);
        connection.setDoOutput(true);

        //第四步：组织SOAP数据，发送请求
        String soapXML = getXML("test", "queryOrder", "{\"tradeno\":\"1648100061003\",\"mchid\":\"10001\"}");
        //将信息以流的方式发送出去
        OutputStream os = connection.getOutputStream();
        os.write(soapXML.getBytes());
        //第五步：接收服务端响应，打印
        InputStream is = connection.getInputStream();
        InputStreamReader isr = new InputStreamReader(is);
        BufferedReader br = new BufferedReader(isr);

        StringBuilder sb = new StringBuilder();
        String temp = null;
        while(null != (temp = br.readLine())){
            sb.append(temp);
        }
        System.out.println("服务调用结果：" + sb.toString());
        is.close();
        isr.close();
        br.close();
    }

    /**
     * @Author admin
     * @Description 组装xml报文
     * @Date 15:47 2022/5/1
     * @Param [consumer, serviceName, para]
     * @return java.lang.String
     **/
    public static String getXML(String consumer, String serviceName, String paraStr){
        String soapXML = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:dar=\"http://www.darewayhealth.com/\">\n" +
                "   <soapenv:Header/>\n" +
                "   <soapenv:Body>\n" +
                "      <dar:invoke>\n" +
                "         <!--Optional:-->\n" +
                "         <dar:consumerId>" + consumer + "</dar:consumerId>\n" +
                "         <!--Optional:-->\n" +
                "         <dar:serviceName>" + serviceName + "</dar:serviceName>\n" +
                "         <!--Optional:-->\n" +
                "         <dar:params>" + paraStr + "</dar:params>\n" +
                "      </dar:invoke>\n" +
                "   </soapenv:Body>\n" +
                "</soapenv:Envelope>";
        return soapXML;
    }
}

        该种方式一般需要自己组织请求的xml报文，自己解析返回的xml报文。

        四、通过HttpClient进行调用，代码如下：

import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.methods.InputStreamRequestEntity;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.methods.RequestEntity;

import java.io.ByteArrayInputStream;
import java.io.InputStream;

public class WebServiceTest {

    public static void main(String[] args) throws Exception {
        //服务地址
        String url = "http://127.0.0.1:8080/service-test/services/gateway?wsdl";
        HttpClient httpClient = new HttpClient();
        PostMethod postMethod = new PostMethod(url);

        String soap = getXML("test", "queryOrder", "{\"tradeno\":\"1648100061003\",\"mchid\":\"10001\"}");

        try {
            byte[] b = soap.getBytes("utf-8");
            InputStream is = new ByteArrayInputStream(b, 0, b.length);
            RequestEntity re = new InputStreamRequestEntity(is, b.length,
                    "application/atom;charset=utf-8");
            postMethod.setRequestEntity(re);
            httpClient.executeMethod(postMethod);
            String soapResponseData = postMethod.getResponseBodyAsString();
            System.out.println("服务调用结果：" + soapResponseData);
            postMethod.releaseConnection();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * @Author admin
     * @Description 组装xml报文
     * @Date 15:47 2022/5/1
     * @Param [consumer, serviceName, para]
     * @return java.lang.String
     **/
    public static String getXML(String consumer, String serviceName, String paraStr){
        String soapXML = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:dar=\"http://www.darewayhealth.com/\">\n" +
                "   <soapenv:Header/>\n" +
                "   <soapenv:Body>\n" +
                "      <dar:invoke>\n" +
                "         <!--Optional:-->\n" +
                "         <dar:consumerId>" + consumer + "</dar:consumerId>\n" +
                "         <!--Optional:-->\n" +
                "         <dar:serviceName>" + serviceName + "</dar:serviceName>\n" +
                "         <!--Optional:-->\n" +
                "         <dar:params>" + paraStr + "</dar:params>\n" +
                "      </dar:invoke>\n" +
                "   </soapenv:Body>\n" +
                "</soapenv:Envelope>";
        return soapXML;
    }
}

        该方式的特点同方式三。

        五、通过CloseableHttpClient进行调用，代码如下：

import org.apache.http.Consts;
import org.apache.http.HttpEntity;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;

import java.io.IOException;

public class WebServiceTest {

    public static void main(String[] args) throws Exception {
        //服务地址
        String url = "http://127.0.0.1:8080/service-test/services/gateway?wsdl";
        int timeout = 180000;
        CloseableHttpClient httpClient = HttpClients.createDefault();
        RequestConfig defaultRequestConfig = RequestConfig.custom().setConnectTimeout(timeout).setConnectionRequestTimeout(timeout).setSocketTimeout(timeout).build();
        HttpPost httpPost = null;
        CloseableHttpResponse response = null;
        HttpEntity resEntity = null;

        try {
            httpPost = new HttpPost(url);
            httpPost.setConfig(defaultRequestConfig);
            String xmlStr = getXML("test", "queryOrder", "{\"tradeno\":\"1648100061003\",\"mchid\":\"10001\"}");
            httpPost.setEntity(new StringEntity(xmlStr, Consts.UTF_8));
            response = httpClient.execute(httpPost);
            resEntity = response.getEntity();
            String resStr = EntityUtils.toString(resEntity, Consts.UTF_8);
            EntityUtils.consume(resEntity);
            System.out.println("服务调用结果：" + resStr);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if (response != null) {
                    response.close();
                }
            } catch (IOException var21) {
                var21.printStackTrace();
            }
        }
    }

    /**
     * @Author admin
     * @Description 组装xml报文
     * @Date 15:47 2022/5/1
     * @Param [consumer, serviceName, para]
     * @return java.lang.String
     **/
    public static String getXML(String consumer, String serviceName, String paraStr){
        String soapXML = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:dar=\"http://www.darewayhealth.com/\">\n" +
                "   <soapenv:Header/>\n" +
                "   <soapenv:Body>\n" +
                "      <dar:invoke>\n" +
                "         <!--Optional:-->\n" +
                "         <dar:consumerId>" + consumer + "</dar:consumerId>\n" +
                "         <!--Optional:-->\n" +
                "         <dar:serviceName>" + serviceName + "</dar:serviceName>\n" +
                "         <!--Optional:-->\n" +
                "         <dar:params>" + paraStr + "</dar:params>\n" +
                "      </dar:invoke>\n" +
                "   </soapenv:Body>\n" +
                "</soapenv:Envelope>";
        return soapXML;
    }
}

        该方式的特点同方式三。 

        六、使用XFire调用，代码如下：

import org.codehaus.xfire.client.Client;
import java.net.URL;

public class WebServiceTest {

    public static void main(String[] args) {
        try {
            //服务地址
            String url = "http://127.0.0.1:8080/service-test/services/gateway?wsdl";
            //方法名
            String method = "invoke";
            Client client = new Client(new URL(url));
            Object[] result = client.invoke(method, new Object[]{"test", "queryOrder", "{\"tradeno\":\"1648100061003\",\"mchid\":\"10001\"}"});
            System.out.println("服务调用结果：" + result[0]);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

        需要xfire-all-1.2.6.jar包，maven依赖如下：

        <dependency>
			<groupId>org.codehaus.xfire</groupId>
			<artifactId>xfire-all</artifactId>
			<version>1.2.6</version>
		</dependency>

        该方式比较古老了，本文只做介绍，后面都用新版本CXF了。值得一提的是，在测试该方式的时候报了一个错误，如下：

Exception in thread "main" java.lang.NoSuchMethodError: org.apache.ws.commons.schema.XmlSchemaComplexType.getAttributes()Lorg/apache/ws/commons/schema/XmlSchemaObjectCollection;
	at org.codehaus.xfire.wsdl11.parser.WSDLServiceBuilder.hasAttributes(WSDLServiceBuilder.java:662)
	at org.codehaus.xfire.wsdl11.parser.WSDLServiceBuilder.isWrapped(WSDLServiceBuilder.java:582)
	at org.codehaus.xfire.wsdl11.parser.WSDLServiceBuilder.visit(WSDLServiceBuilder.java:392)
	at org.codehaus.xfire.wsdl11.parser.WSDLServiceBuilder.build(WSDLServiceBuilder.java:195)
	at org.codehaus.xfire.client.Client.initFromDefinition(Client.java:264)
	at org.codehaus.xfire.client.Client.<init>(Client.java:236)
	at org.codehaus.xfire.client.Client.<init>(Client.java:246)

        方法不存在，原因其实是包冲突，xfire所依赖的低版本的XmlSchema-1.1.jar与cxf所依赖的高版本的xmlschema-core-2.2.5.jar冲突，删掉高版本的就解决了。

        七、通过CXF调用，代码如下：

import org.apache.cxf.endpoint.Client;
import org.apache.cxf.endpoint.dynamic.DynamicClientFactory;

public class WebServiceTest {

    public static void main(String[] args) {
        //服务地址
        String url = "http://127.0.0.1:8080/service-test/services/gateway?wsdl";
        //方法名
        String method = "invoke";
        try {
            DynamicClientFactory factory = DynamicClientFactory.newInstance();
            Client client = factory.createClient(url);
            Object[] resultObject = client.invoke(method, new Object[]{"test", "queryOrder", "{\"tradeno\":\"1648100061003\",\"mchid\":\"10001\"}"});
            String resultStr = resultObject[0].toString();  //接口调用结果
            System.out.println("服务调用结果：" + resultStr);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

         该种方式一般不需要自己组织请求报文和解析返回报文，比较简单。

        总结，以上七种方式各有特点，推荐使用AXIS方式或CXF方式或者HTTP方式中的其中一种。

今天的文章调用webservice的几种方式_webservice调用wsdl「建议收藏」分享到此就结束了，感谢您的阅读。

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
如需转载请保留出处：https://bianchenghao.cn/72000.html

赞 (0)
编程小号编程小号
0

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注