Java web

Java WSDL 服务调用入门分享

2019-10-03  本文已影响0人  dsjaikdnsajdnua

Java WSDL 服务调用入门分享

第一次自己使用代码直接调用webservice。对于这种网上很难找资料，而且找到了不会用，会用但是会报错的代码。内心是非常痛苦的。要静下心来仔细学习webservice也是不可能的，因为非常赶。所以就把我终于学会调用webservice的关键过程写下

webservice说明

此为不专业的说明，仅做了解用。且代码都是从片段里面截取出来的，仅供思路参考，不能直接拿来用。

webservice应该就是想用于跨平台的交互方式，因为在它复杂的xml里面，规定了调用的方式，参数的对象（强类型）等等信息。而WSDL（Web Services Description Language）应该就是一种针对webservice更加详细的约定，因为WSDL描述了webservice的函数、参数、返回值等说明。

如何调用

CFX生成可直接调用的代码1

思路如下：下载插件 -> 根据给出的xml生成对应的代码 -> 在代码里面找到main方法 -> 模仿main方法自己去调用 -> 封装让接口更加易用

注意：使用git bash可能会有以下问题，可尝试使用自带的CMD：

image.png

你的包名：指的是接下来生成的文件会在XX.XX包下面。比如：我填写的是com.google，那么生成的文件结构如此：package com.google.test;

代码的位置：指的是生成的文件会在XXX路径下面。比如：我填写的是C:\Users\shihu\Documents\wsdl，那么生成的文件就会在C:\Users\shihu\Documents\wsdl文件下。

WSDL的地址：指的是你将要调用的wsdl的地址，一般就是返回一个xml文件。比如：我填写http://webservices.amazon.com/AWSECommerceService/AWSECommerceService.wsdl，那么就是根据该地址返回的xml文件去生成代码。这里我挑选了亚马逊的测试例子。这里有更多的例子，只需要将地址替换即可。

所以，完整的命令可以如下：

wsdl2java -p com.google -d C:\Users\shihu\Documents\wsdl -client -encoding utf-8 -noAddressBinding  http://webservices.amazon.com/AWSECommerceService/AWSECommerceService.wsdl

生成以后的目录结构如下非常多文件，但是别怕下面会大致说明注1：

C:.
└─com
    └─google
            Accessories.java  --dom实体
            Arguments.java    --dom实体
            AWSECommerceService.java  --webservice 的service
            AWSECommerceServicePortType.java --可以获取webservice入口的
            AWSECommerceServicePortType_AWSECommerceServicePortCA_Client.java --入口
            AWSECommerceServicePortType_AWSECommerceServicePortCN_Client.java --入口
            AWSECommerceServicePortType_AWSECommerceServicePortDE_Client.java --入口
            AWSECommerceServicePortType_AWSECommerceServicePortES_Client.java --入口
            ...

额外产物

将返回的数据转化为json

返回之后的是一个dom数据，那么我们如何把他转化为JSON对象呢？

返回的实体大致如下：

@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "", propOrder = {
    "username",
    "password"
})
@XmlRootElement(name = "login")
public class Login {
    @XmlElementRef(name = "username", namespace = "http://sys.ws.xxx.com", type = JAXBElement.class, required = false)
    protected JAXBElement<String> username;
    @XmlElementRef(name = "password", namespace = "http://sys.ws.xxx.com", type = JAXBElement.class, required = false)
    protected JAXBElement<String> password;
    ...

如果你和我情况类似，那么你可以使用以下方法转化为JSON。我封装了2部分，一个是只转化一个，另外一个是转化集合的。其实本质都是一样的。最主要的代码是final String json = mapper.writerWithDefaultPrettyPrinter().writeValueAsString(e);

/**
     * 转化xml对象为json
     * @param tClass
     * @param value
     * @param <E>
     * @return
     */
public static <E extends Object> JSONObject convertToObject(Class<E> tClass, E value){
    List<E> list = new ArrayList<E>();
    list.add(value);
    final List<JSONObject> jsonObjects = convertToObject(tClass, list);
    return jsonObjects.isEmpty()?new JSONObject():jsonObjects.get(0);
}
/**
 * 批量转化xml对象为json
 * @param tClass
 * @param list
 * @param <E>
 * @return
 */
public static <E extends Object> List<JSONObject> convertToObject(Class<E> tClass, List<E> list){
    List<JSONObject> result = new ArrayList<>();
    for(E e : list){
        try {
            final String json = mapper.writerWithDefaultPrettyPrinter().writeValueAsString(e);
            result.add( JSONObject.parseObject(json));
        } catch (JsonProcessingException ex) {
            logger.error(marker,"解析xml对象错误！",e);
        }
    }
    return result;
}

处理SOAP异常

只要服务端有异常：包含程序未捕获的异常、参数校验不通过等，都会返回ServerSOAPFaultException异常，我们主要是处理ServerSOAPFaultException异常。

如何添加头部

有时候，我们需要在SOAP头部（服务器端的XML说明）或者http头部添加验证信息（仅仅是请求的http头部）。那么如何做到呢？

  1. 实现HandlerResolver 接口

  2. 实现SOAPHandler<SOAPMessageContext> 接口

  3. 重写handleMessage方法。

  4. new 一个HandlerResolver，并将实现类放入service

  5. 从service获取endpoint调用

  6. 代码：

    
/**
 * 实现SOAPHandler
 * @return
 */
private class RequesterCredentials implements SOAPHandler<SOAPMessageContext> {
  private Map<String,String> headers;

  public RequesterCredentials(Map<String,String> headers) {
    super();
    this.headers = headers;
  }
  public Set<QName> getHeaders() {
    return null;
  }

  @Override
  public void close(MessageContext context) {
  }

  @Override
  public boolean handleFault(SOAPMessageContext context) {
    // TODO return true
    logger.error("ws错误处理。");
    return true;
  }

  // 处理请求上下文
  @Override
  public boolean handleMessage(SOAPMessageContext context) {
    try {
      Boolean outboundProperty = (Boolean) context.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);

      if (outboundProperty.booleanValue()) {
        SOAPMessage message = context.getMessage();

        SOAPHeader header = message.getSOAPHeader();
        if (header == null) {
            message.getSOAPPart().getEnvelope().addHeader();
            header = message.getSOAPHeader();
        }
        SOAPElement authenticationToken = header.addChildElement("auth", "", "");
        authenticationToken.addChildElement("user").addTextNode("user");
        authenticationToken.addChildElement("password").addTextNode("password");
        authenticationToken.addChildElement("token").addTextNode("token");
      }
    } catch (Exception e) {
        e.printStackTrace();
    }
    return true;
  }
}


/**
 * 实现SOAPHandler
 * @return
 */
public class HeaderHandlerResolver implements HandlerResolver {
  private RequesterCredentials requesterCredentials;

  public HeaderHandlerResolver(RequesterCredentials requesterCredentials){
      this.requesterCredentials=requesterCredentials;
  }
  @Override
  public List getHandlerChain(PortInfo portInfo) {
      return Arrays.asList(requesterCredentials);
  }
}

    /**
 * 放入SOAPHandler，并调用
 * @return
 */
RequesterCredentials  r=new RequesterCredentials (headers);
HeaderHandlerResolver  headerHandlerResolver=new HeaderHandlerResolver (r);
mathService.setHandlerResolver(headerHandlerResolver);
Deposit1ServicePortType port = mathService.getDeposit1ServiceHttpSoap11Endpoint();

将java对象转化为dom对象工具

当我们调用webservice方法的时候，传入的参数并不是普通的java对象，而是dom对象，那么我们如何将java对象转化为dom对象呢？

下面我们观察一下CXF 生成的dom对象的Object属性和普通属性get、set方法：

/**
 * 设置username属性的值。
 *
 * @param value
 *     allowed object is
 *     {@link JAXBElement }{@code <}{@link String }{@code >}
 *
 */
public void setUsername(JAXBElement<String> value) {
    this.username = value;
}
...
/**
 * 设置money属性的值。
 *
 * @param value
 *     allowed object is
 *     {@link Double }
 *
 */
public void setMoney(Double value) {
    this.money = value;
}

为什么要把Object类和java基类分开，因为只有Object的子类（像String）才不是普通的set方法，而基类是普通的set方法。

可以看到是一个JAXBElement包装了一个普通的java类，所有在java类和dom类的类型保持一致的情况下（比如java是String，那么dom也是String），我们可以通过反射，将对应的属性通过get方法，获取到java对象原本的值，然后再通过dom的ObjectFactoryt的create方法，组合成dom需要的类型的值，将转化之后的属性放入dom对象中。

代码如下：

/**
 * 可以转化普通java的属性为dom的属性
 * @param objecrFactory 对象工厂实例
 * @param klass soap的类
 * @param property 对应java类的属性名（soap和java的属性名字和类型需要保持一致）
 * @param value 需要设置的值
 * @param <T> 对象工厂类
 * @param <E> soap的类
 * @param <V> 属性的类
 * @return
 */
public static <T,E,V> JAXBElement<V>  invokeSOAP(T objecrFactory, Class<E> klass, String property , V value){
    try{
        final String methodName = String.format("create%s%s", klass.getSimpleName(),
                property.substring(0, 1).toUpperCase() + property.substring(1));
        return ReflectUtil.invoke(objecrFactory,methodName,value);
    }catch (Exception e){
        logger.error("设置属性失败！",e);
        return null;
    }
}

/**
 * 将一个普通java对象转化为dom对象
 * @param entity java对象
 * @param objecrFactory 创建的dom工厂
 * @param soapClass soap对应的对象class
 * @param <T> 实体的类
 * @param <O> dom对象工厂的类
 * @param <E> soap的类
 */
public static <T,O,E> E convertToSOAP(T entity,O objecrFactory, Class<E> soapClass){
 final E soapInstance = ReflectUtil.newInstance(soapClass);
   try{
    final Class<?> entityClass = entity.getClass();
      final Set<String> methodNames = ReflectUtil.getPublicMethodNames(entityClass);
        for(String methodName: methodNames){
          if(methodName.startsWith("get") && !objectMethods.contains(methodName) && ReflectUtil.getMethodByNameIgnoreCase(soapClass, methodName)!=null){//如果是get方法
            final String property = methodName.substring(3, methodName.length());
            Object value = ReflectUtil.invoke(entity, methodName);
            if(value instanceof BigDecimal){//BigDecimal需要转化为double，并且直接设置属性
              value = ((BigDecimal) value).doubleValue();
              ReflectUtil.invoke(soapInstance,"set"+property,value);
              continue;
            }
            if(value!=null){
              ReflectUtil.invoke(soapInstance,"set"+property,invokeSOAP(objecrFactory, soapClass, property, value));
            }
          }
        }
        return soapInstance;
    }catch (Exception e){
        logger.error("批量设置属性失败！",e);
        return soapInstance;
    }
}

如何在postman中调试

拿到对方接口的第一时间，就是想使用postman进行测试。但是，webservice如何使用postman进行测试呢？

插件.jpg WSDL.jpg 请求体.png

修改请求体之后，我们可以直接通过页面对方法进行调用。点击GO按钮就可以直接发起请求了。对应的响应如下：

插件发起的请求.png

同时，我们可以将请求体复制到postman，然后设置对应的Content-Type，以及请求方法，使用post请求就可以在postman发起webservice请求了。以这里例子为例，需要POST请求；body是xml格式；Content-Typeapplication/soap+xml; charset="UTF-8"；就可以发送请求了。

post请求.png

webservice 网络断开后处理

webservice有一个奇葩的问题。如果对方的webservice服务端是离线的状态（服务器重启/关闭导致我们无法获取到WSDL的xml文件），或导致我们客户端 “启动的时候” 无法初始化webservice的一些东西，或者当我们客户端运行的时候，服务端重启了，服务端重启完毕之后，webservice的一些实例会变成null，这就导致了我们无法正常使用webservice了。我是如何解决这个问题的呢？

切面类：

import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.stereotype.Component;

/**
 * 接口日志
 * @author shihu
 */
@Aspect
@Component
public class WsAspect {

    private Logger logger = LoggerFactory.getLogger(WsAspect.class);
    @Pointcut("execution(public * com.google.ws.WsService.*(..))")
    public void cut(){}
    @Before("cut()")
    public void doBefore(JoinPoint joinPoint){
        WsAspect.initService();// 确保每次进入都验证是否为空
    }
}

总结

因为不熟悉webservice，所以一开始完全就是一头雾水。但是，当CFX自动生成了代码能直接调用之后，整个流程就通了，豁然开朗。但是，之后又为设置header头痛。因为不熟悉，所以完全不知道header还区分soap的header和普通的http的header。而前者，我花了大量的时间去研究，最终都没研究出来（因为服务端压根就没有，所以以后要问清楚，但是完全不懂ws所以也就不存在清不清楚的问题了），最终才得知是设置http的header，这个就简单了，就是处理请求的上下文，在上下文添加header就可以了。

另

上一篇下一篇

猜你喜欢

热点阅读