使用axis调用WebService,Java WebService调用工具类

使用axis调用WebService,Java WebService调用工具类Java调用WebService工具类。导入即使用。

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

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 时需传入的参数。

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

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/181009.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • java 内存分析工具 生成 dump_java内存检测工具

    java 内存分析工具 生成 dump_java内存检测工具jmap-heap1234查看进程号为1234的Java程序的整个jvm内存状态jmap-histo1234查找进程号为1234的java程序的jvm堆中对象详细占用情况jmap-dump:format=b,file=/my.dump1234导出1234进程的java程序的整个JVM信息jhat-J-Xmx1024M/my.dump,启动web服务查看jmap导出的jav…

  • PS磨皮滤镜降噪插件套装Imagenomic Professional Plugin Suite有什么功能

    PS磨皮滤镜降噪插件套装Imagenomic Professional Plugin Suite有什么功能ImagenomicProfessionalPluginSuitemac版是一款PS磨皮降噪滤镜插件套装,其中包含noiseware降噪插件、portraiture3磨皮滤镜和Realgrain胶片效果滤镜插件,各有各的功能,可以轻松完成磨皮、添加胶片效果、降噪等。PS磨皮滤镜降噪套装官方介绍Portraiture3 皮肤修饰 自动皮肤平滑,愈合和增强效果插件 Noiseware 消除噪音 屡获殊荣的插件和独立的照片降噪 Realgrain

  • pytest-allure_苹果11验机报告

    pytest-allure_苹果11验机报告前言allure是一个report框架,支持java的Junit/testng等框架,当然也可以支持python的pytest框架,也可以集成到Jenkins上展示高大上的报告界面。mac环境:

  • docker安装elasticsearch 7.6.2「建议收藏」

    docker安装elasticsearch 7.6.2「建议收藏」小伙伴们,你们好呀!我是老寇!安装elasticsearch的教程数不胜数,本文的安装方式是经过自己测试的,因此分享给有需要的小伙伴,一来是避免小伙伴少走弯路,二来方便后面知识的整合。本文是基于ES7.6.2的版本进行安装的,话不多说,我们开始吧。目录一、提前条件二、安装过程1.拉取镜像2.启动容器3.配置文件4.设置密码5.退出容器6.重启容器7.谷歌插件一、提前条件谷歌插件:elasticsearch-head服务器:centos7.5(

  • selenium python面试题_selenium面试题

    selenium python面试题_selenium面试题selenium中如何判断元素是否存在?selenium中没有提供原生的方法判断元素是否存在,一般我们可以通过定位元素+异常捕获的方式判断。#判断元素是否存在try:dr.find_element_by_id(‘none’)exceptNoSuchElementException:print’elementdoesnotexist’selenium中hidden或者是display=…

  • Java8-Stream API

    Java8-Stream API

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号