温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

怎么使用axis调用WebService及Java WebService调用工具类

发布时间:2023-04-26 11:51:20 来源:亿速云 阅读:127 作者:iii 栏目:开发技术

这篇文章主要介绍“怎么使用axis调用WebService及Java WebService调用工具类”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“怎么使用axis调用WebService及Java WebService调用工具类”文章能帮助大家解决问题。

    WebService 简介

    概述

    能使得运行在不同机器上的不同应用无须借助附加的、专门的第三方软件或硬件,就可相互交换数据或集成。依据 WebService 规范实施的应用之间,无论它们所使用的语言、平台或内部协议是什么,都可以相互交换数据。

    也就是说可以实现多语言、跨平台数据交互。

    使用 axis 调用 WebService

    引入依赖

    pom.xml 依赖如下:

    <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>
    <dependency>
        <groupId>axis</groupId>
        <artifactId>axis-wsdl4j</artifactId>
        <version>1.5.1</version>
    </dependency>
    <dependency>
        <groupId>commons-discovery</groupId>
        <artifactId>commons-discovery</artifactId>
        <version>0.2</version>
    </dependency>

    WebService 调用工具类

    package com.micromaple.common.utils;
    
    import com.google.common.collect.Lists;
    import lombok.extern.slf4j.Slf4j;
    import org.apache.axis.client.Call;
    import org.apache.axis.client.Service;
    import org.apache.axis.encoding.XMLType;
    import org.apache.axis.encoding.ser.BeanDeserializerFactory;
    import org.apache.axis.encoding.ser.BeanSerializerFactory;
    import org.apache.axis.message.SOAPHeaderElement;
    import org.apache.axis.types.Schema;
    import org.apache.commons.collections.MapUtils;
    
    import javax.xml.namespace.QName;
    import javax.xml.rpc.ParameterMode;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    
    /**
     * WebService - 工具类
     * Title: WebServiceUtils
     * Description:
     *
     * @author Micromaple
     * @version 1.0.0
     * @date 2022/7/1 12:14
     */
    @Slf4j
    public class WebServiceUtils {
    	// 接口调用地址
    	private static String url = "http://127.0.0.1:8080/webservice.asmx";
    	// 命名空间
    	private static String namespace = "http://tempuri.org/";
    	
        /**
         * WebService - 调用接口
         *
         * @param methodName 函数名
         * @param params     参数
         * @param clazz      返回对象class
         * @return 返回结果(Object)
         */
        public static <T> T call(String methodName, Map<String, String> params, Class<T> clazz) {
            // log.info("调用 WebService 发送参数==>" + MapperUtils.mapToJson(params));
            String soapActionURI = namespace + methodName;
            try {
                Service service = new Service();
    
                SOAPHeaderElement header = new SOAPHeaderElement(namespace, methodName);
                header.setNamespaceURI(namespace);
    
                Call call = (Call) service.createCall();
                call.setTargetEndpointAddress(url);
    
                call.setOperationName(new QName(namespace, methodName));
    
                // 添加参数
                List<String> parameterList = Lists.newArrayList();
                if (params != null) {
                    Set<String> paramsKey = params.keySet();
                    for (String key : paramsKey) {
                        call.addParameter(new QName(namespace, key), XMLType.XSD_STRING, ParameterMode.IN);
                        String pValue = MapUtils.getString(params, key);
                        header.addChildElement(key).setValue(pValue);
                        parameterList.add(pValue);
                    }
                }
                call.setUseSOAPAction(true);
                call.setSOAPActionURI(soapActionURI);
                call.addHeader(header);
    
                // 进行序列化  实体类也要序列化 implements Serializable
                call.registerTypeMapping(clazz, new QName(namespace, soapActionURI),
                        new BeanSerializerFactory(clazz, new QName(namespace, soapActionURI)),
                        new BeanDeserializerFactory(clazz, new QName(namespace, soapActionURI)));
                // 设置输出的类
                call.setReturnClass(clazz);
                // 接口返回结果
                T result = (T) call.invoke(parameterList.toArray());
                log.info("调用 WebService 接口返回===>" + result);
                return result;
            } catch (Exception e) {
                log.error("调用 WebService 接口错误信息==>" + e.getMessage());
            }
            return null;
        }
    
        /**
         * WebService - 接口调用
         *
         * @param methodName 函数名
         * @param params     参数
         * @return 返回结果(String)
         */
        public static String call(String methodName, Map<String, String> params) {
            // log.info("调用 WebService 发送参数==>" + MapperUtils.mapToJson(params));
            String soapActionURI = namespace + methodName;
            try {
                Service service = new Service();
    
                SOAPHeaderElement header = new SOAPHeaderElement(namespace, methodName);
                header.setNamespaceURI(namespace);
    
                Call call = (Call) service.createCall();
                call.setTargetEndpointAddress(url);
    
                call.setOperationName(new QName(namespace, methodName));
    
                // 添加参数
                List<String> parameterList = Lists.newArrayList();
                if (params != null) {
                    Set<String> paramsKey = params.keySet();
                    for (String key : paramsKey) {
                        call.addParameter(new QName(namespace, key), XMLType.XSD_STRING, ParameterMode.IN);
                        String pValue = MapUtils.getString(params, key);
                        header.addChildElement(key).setValue(pValue);
                        parameterList.add(pValue);
                    }
                }
                call.setUseSOAPAction(true);
                call.setSOAPActionURI(soapActionURI);
                call.addHeader(header);
                // 设置返回类型
                call.setReturnType(new QName(namespace, methodName), String.class);
                // 接口返回结果
                String result = (String) call.invoke(parameterList.toArray());
                log.info("调用 WebService 接口返回===>" + result);
                return result;
            } catch (Exception e) {
                log.error("调用 WebService 接口错误信息==>" + e.getMessage());
            }
            return null;
        }
    
        /**
         * WebService - 调用接口
         *
         * @param methodName 函数名
         * @param params     参数
         * @return 返回结果(String)
         */
        public static String call2(String methodName, Map<String, String> params) {
            // log.info("调用 WebService 发送参数==>" + MapperUtils.mapToJson(params));
            String soapActionURI = namespace + methodName;
            try {
                Service service = new Service();
    
                SOAPHeaderElement header = new SOAPHeaderElement(namespace, methodName);
                header.setNamespaceURI(namespace);
    
                Call call = (Call) service.createCall();
                call.setTargetEndpointAddress(url);
    
                call.setOperationName(new QName(namespace, methodName));
    
                // 添加参数
                List<String> parameterList = Lists.newArrayList();
                if (params != null) {
                    Set<String> paramsKey = params.keySet();
                    for (String key : paramsKey) {
                        call.addParameter(new QName(namespace, key), XMLType.XSD_STRING, ParameterMode.IN);
                        String pValue = MapUtils.getString(params, key);
                        header.addChildElement(key).setValue(pValue);
                        parameterList.add(pValue);
                    }
                }
                call.setUseSOAPAction(true);
                call.setSOAPActionURI(soapActionURI);
                call.addHeader(header);
                // 设置返回类型
                call.setReturnType(XMLType.XSD_SCHEMA);
                // 接口返回结果
                Schema schemaResult = (Schema)call.invoke(parameterList.toArray());
                String result = "";
                for(int i = 0; i<schemaResult.get_any().length; i++){
                    result = result + schemaResult.get_any()[i];
                }
                log.error("调用 WebService 接口返回===>" + result);
                return result;
            } catch (Exception e) {
                log.error("调用 WebService 接口错误信息==>" + e.getMessage());
            }
            return null;
        }
    }
    • 第一个方法为返回对象的方式,区别在于需要定义返回对象,属性值需要跟 WebService 中的返回对象保持一致。

    • 第二个方法适用于调用 WebService后,返回的值为 String 类型。

    参数详解:

    • methodName:函数名。需要调用的 WebService 的函数名称。

    • params:参数。调用 WebService 时需传入的参数。

    关于“怎么使用axis调用WebService及Java WebService调用工具类”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注亿速云行业资讯频道,小编每天都会为大家更新不同的知识点。

    向AI问一下细节

    免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

    AI