通过webservice提交xml数据

偏执的太偏执、 2023-02-14 15:45 37阅读 0赞

通过webservice提交xml数据加粗样式

更新啦！！！！

地址：https://www.jianshu.com/p/81430f69d666

  1. //这里调用
  4. public static void main(String[] args) { 
  5.         LinkedHashMap<String, String> objectObjectHashMap = new LinkedHashMap<>();
  6.         objectObjectHashMap.put("areaCode", "1309");
  7.         objectObjectHashMap.put("cityId", "0");
  8.         objectObjectHashMap.put("townId", "0");
  9.         String getHosInfo = WebServiceUtil.callWebService("https://aaa.aaa.aaa.cn/BabyAppVipSer.asmx", "GetHosInfos",                 objectObjectHashMap);
  10.         System.out.println(getHosInfo);
  11.     }
  16.  /** * 调用webService 接口返回字符串 * @param asmxUrl 提供接口的地址 * @param waysName 设置要调用哪个方法 * @param params 请求的参数 * @return */
  17.     public static String callWebService(String asmxUrl, String waysName, LinkedHashMap<String,String> params){ 
  18.         String soapaction = "http://tempuri.org/"; // 域名，这是在server定义的--不知道的可以问接口提供方，他们一并提供这个
  19.         Service service = new Service();
  20.         Object[] obj = new Object[params.size()];
  21.         try{ 
  22.             Call call = (Call) service.createCall();
  23.             call.setTargetEndpointAddress(asmxUrl);
  24.             call.setOperationName(new QName(soapaction, waysName)); // 设置要调用哪个方法
  25.             //设置变量每次循环完成+1
  26.             int flag = 0;
  27.             for (String param : params.keySet()) { 
  28.                 call.addParameter(new QName(soapaction, param), // 设置要传递的参数--要和接口方提供的参数名一致
  29.                         org.apache.axis.encoding.XMLType.XSD_STRING,
  30.                         javax.xml.rpc.ParameterMode.IN);
  31.                 obj[flag] = params.get(param);
  32.                 flag++;
  33.             }
  34.             call.setReturnType(new QName(soapaction, waysName), String.class); // 要返回的数据类型（自定义类型，我这边接口提供方给我返回的是json字符串，所以我用string类型接收。这个地方一定要设置好，不然各种报错很崩溃）
  35.             call.setUseSOAPAction(true);
  36.             call.setSOAPActionURI(soapaction + waysName);
  37.             return (String)call.invoke(obj);// 调用方法并传递参数-传递的参数和设置的参数要对应，顺序不能搞错了
  38.         }catch (Exception ex){ 
  39.             ex.printStackTrace();
  40.         }
  41.         return null;
  42.     }
  46. //pom
  48.  <dependency>
  49.             <groupId>org.apache.axis</groupId>
  50.             <artifactId>axis</artifactId>
  51.             <version>1.4</version>
  52.         </dependency>
  54.         <dependency>
  55.             <groupId>javax.xml.rpc</groupId>
  56.             <artifactId>javax.xml.rpc-api</artifactId>
  57.             <version>1.1.1</version>
  58.         </dependency>
  60.         <dependency>
  61.             <groupId>commons-discovery</groupId>
  62.             <artifactId>commons-discovery</artifactId>
  63.             <version>0.4</version>
  64.         </dependency>
  66.         <dependency>
  67.             <groupId>wsdl4j</groupId>
  68.             <artifactId>wsdl4j</artifactId>
  69.             <version>1.6.3</version>
  70.         </dependency>

/下面是旧的，看上面就可以、、、、、、、、、、、、、、、、、、、

原创1 ： https://blog.csdn.net/qq\_24505127/article/details/53057099
原创2 ： https://blog.csdn.net/qq\_28779071/article/details/82714460
所需maven

  1. <!-- wsdl webService包 -->
  2.         <dependency>
  3.             <groupId>org.apache.axis</groupId>
  4.             <artifactId>axis</artifactId>
  5.             <version>1.4</version>
  6.         </dependency>
  7.         <dependency>
  8.             <groupId>commons-discovery</groupId>
  9.             <artifactId>commons-discovery</artifactId>
  10.             <version>0.2</version>
  11.             <exclusions>
  12.                 <exclusion>
  13.                     <groupId>commons-logging</groupId>
  14.                     <artifactId>commons-logging</artifactId>
  15.                 </exclusion>
  16.             </exclusions>
  17.         </dependency>
  18.         <dependency>
  19.             <groupId>org.apache.axis</groupId>
  20.             <artifactId>axis-jaxrpc</artifactId>
  21.             <version>1.4</version>
  22.         </dependency>
  23.         <dependency>
  24.             <groupId>org.apache.axis</groupId>
  25.             <artifactId>axis-saaj</artifactId>
  26.             <version>1.4</version>
  27.         </dependency>
  28.         <dependency>
  29.             <groupId>wsdl4j</groupId>
  30.             <artifactId>wsdl4j</artifactId>
  31.             <version>1.4</version>
  32.         </dependency>
  34.         <dependency>
  35.             <groupId>commons-httpclient</groupId>
  36.             <artifactId>commons-httpclient</artifactId>
  37.             <version>3.1</version>
  38.         </dependency>
  40. <dependency>
  41.     <groupId>org.jdom</groupId>
  42.     <artifactId>jdom</artifactId>
  43.     <version>2.0.2</version>
  44. </dependency>

调用

  1. // 调用接口
  2.         // 方法一:直接AXIS调用远程的web service
  3.         try { 
  4.             Map<String, Object> map = new LinkedHashMap<>();
  5.             // String endpoint =
  6.             // "http://www.webxml.com.cn/WebServices/TranslatorWebService.asmx";
  7.             // String endpoint =
  8.             // "http://10.110.113.101:8088/ZK_WebService.asmx";
  9.             //String endpoint = "http://10.110.113.101:8088/ZK_WebService.asmx";
  10.             String endpoint = "http://10.110.113.101:8088/ZK_WebService.asmx";
  12.              map.put("ID", "");
  13.              map.put("XM", "");
  14.              map.put("XB", "");
  15.              map.put("CSNY", "");
  16.              map.put("SFZH", "");
  17.              map.put("HF", "");
  18.              map.put("LXDH", "");
  19.              map.put("DWDM", "");
  20.              map.put("PROJECTID", "");
  21.              map.put("JCRQ", "2020-01-01^2020-01-02");
  22.             //
  23. // StringBuffer sb = new StringBuffer();
  24. // sb.append(" <ID></ID> <XM></XM><XB></XB><CSNY></CSNY><SFZH></SFZH> <HF></HF><LXDH></LXDH><DWDM></DWDM><PROJECTID></PROJECTID>");
  25. // sb.append("<ZJRQ>");
  26. // sb.append("2020-01-01^2020-01-02");
  27. // sb.append("</ZJRQ>\n");
  28.             String resultXml = this.invokeByAxis(map, endpoint, "http://tempuri.org/", "ZK_GetStudyID");
  29.             System.err.println(resultXml);
  30.         } catch (Exception e) { 
  31.             System.err.println(e.toString());
  32.             e.printStackTrace();
  33.         }

第一种 axis 方式

  1. /** * axis方式访问webservice * * @param dataMap * 请求的xml的报文 * @param endPoint * webservice的wsdl地址,例如：http://localhost:8080/project/services/ * mainName?wsdl * @param namespace * 调用方法的命名空间 * @param method * 调用的方法名 * @return 返回调用的报文(xml) * @throws IOException * */
  2.     public static String invokeByAxis(Map dataMap, String endPoint, String namespace, String method)
  3.             throws IOException { 
  4.         // 拼接好xml
  5.          String responseXML = "";
  6.          Service service = new Service();
  7.          try { 
  8.          Call call = (Call) service.createCall();
  9.          //设置请求超时时间
  10.          call.setTimeout(5000);
  11.          //webservice接口地址
  12.          call.setTargetEndpointAddress(endPoint);
  13.          //请求方法
  14.          call.setOperationName(method);
  15.          //请求命名空间
  16.          call.setOperationName(new javax.xml.namespace.QName(namespace,
  17.          method));
  18.          call.setReturnType(org.apache.axis.encoding.XMLType.XSD_STRING);//
  19.          设置返回类型
  20.          //是否是soapaction
  21.         // call.setUseSOAPAction(true);
  22.          call.setSOAPActionURI(namespace + "ZK_GetPerson");
  23.          //封装请求参数
  24.          Set<String> set = dataMap.keySet();
  25.          List<Object> objParams = new ArrayList<>();
  26.          for(Iterator<String> it=set.iterator(); it.hasNext();){ 
  27.              String key = it.next();
  28.              Object value = dataMap.get(key);
  29.              objParams.add(value);
  30.              call.addParameter(key,
  31.              org.apache.axis.encoding.XMLType.XSD_STRING,javax.xml.rpc.ParameterMode.IN);
  32.              System.err.println("------------------key ===============" + key);
  33.          }
  34.          call.setReturnType(XMLType.XSD_STRING);
  35.          System.err.println(objParams.toArray());
  36.          System.err.println(call.getTargetEndpointAddress());
  37.          System.err.println(call.getOperationName());
  38.          System.err.println(call.getSOAPActionURI());
  40.          responseXML = (String) call.invoke(objParams.toArray());
  41.          } catch (Exception e) { 
  42.          System.err.println("WebService请求异常！原因: "+e.fillInStackTrace());
  43.          }
  44.         return responseXML;
  45.     }

第二种方法

  1. /** * axis方式访问webservice * * @param dataMap * 请求的xml的报文 * @param endPoint * webservice的wsdl地址,例如：http://localhost:8080/project/services/ * mainName?wsdl * @param namespace * 调用方法的命名空间 * @param method * 调用的方法名 * @return 返回调用的报文(xml) * @throws IOException * */
  2.     public static String invokeByAxis(String dataMap, String endPoint, String namespace, String method)
  3.             throws IOException { 
  4.         // 拼接好xml
  5.         String xmlStr = getXml(method, dataMap, namespace);
  6.         System.out.println(xmlStr);
  7.         String serviceAddress = endPoint; // 服务地址(将XXXX替换成自己项目的地址)
  8.         String charSet = "utf-8";
  9.         String contentType = "text/xml; charset=utf-8";
  10.         String result = "";
  11.         Map<String, Object> responseSoapMap = SoapUtil.responseSoap(xmlStr, serviceAddress, charSet, contentType);
  12.         Integer statusCode = (Integer) responseSoapMap.get("statusCode");
  13.         if (statusCode == 200) { 
  14.             String responseSoap = (String) responseSoapMap.get("responseSoap");
  15.             String targetNodeName = "isSuccess";
  16.             Document doc = XMLUtil.strXmlToDocument(responseSoap);
  17.             result = XMLUtil.getValueByElementName(doc, targetNodeName);
  18.             if (!StringUtils.isEmpty(result)) { 
  19.                 System.out.println(result);
  20.             } else { 
  21.                 System.out.println("没有此节点或者没有值！");
  22.             }
  23.         } else { 
  24.             System.out.println("请求失败！");
  25.         }
  27.         return result;
  28. }
  32. /** * 设置xml * * @param method * 方法名称 * @param paramXml * 参数的xml * @param targetNameSpace * 命名空间 * @return */
  33.     private static String getXml(String method, String paramXml,String targetNameSpace) { 
  34.         // 拼接好xml
  35.         StringBuffer sb = new StringBuffer();
  36.         sb.append(
  37.                 "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n"  +
  38.                 "<soap:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\">\n" +
  39.                 "<soap:Body>\n" +
  40.                 "<ZK_GetPerson xmlns=\"http://tempuri.org/\">" +
  41.                 "<Request>" + paramXml +"</Request>\n" + 
  42.                 "</ZK_GetPerson>" +
  43.                 "</soap:Body>" +
  44.                 "</soap:Envelope>"
  45.                 );
  47.         String xmlStr = sb.toString();
  48.         System.out.println(xmlStr);
  49.         return xmlStr;

第二种方法相关工具

  1. package com.ruoyi.quartz.util;
  3. import java.lang.reflect.InvocationTargetException;
  4. import java.lang.reflect.Method;
  5. import java.util.LinkedList;
  6. import java.util.List;
  7. import com.ruoyi.common.utils.StringUtils;
  8. import com.ruoyi.common.utils.spring.SpringUtils;
  9. import com.ruoyi.quartz.domain.SysJob;
  11. /** * 任务执行工具 * * @author ruoyi */
  12. public class JobInvokeUtil
  13. { 
  14.     /** * 执行方法 * * @param sysJob 系统任务 */
  15.     public static void invokeMethod(SysJob sysJob) throws Exception
  16.     { 
  17.         String invokeTarget = sysJob.getInvokeTarget();
  18.         String beanName = getBeanName(invokeTarget);
  19.         String methodName = getMethodName(invokeTarget);
  20.         List<Object[]> methodParams = getMethodParams(invokeTarget);
  22.         if (!isValidClassName(beanName))
  23.         { 
  24.             Object bean = SpringUtils.getBean(beanName);
  25.             invokeMethod(bean, methodName, methodParams);
  26.         }
  27.         else
  28.         { 
  29.             Object bean = Class.forName(beanName).newInstance();
  30.             invokeMethod(bean, methodName, methodParams);
  31.         }
  32.     }
  33.     /** * 调用任务方法 * * @param bean 目标对象 * @param methodName 方法名称 * @param methodParams 方法参数 */
  34.     private static void invokeMethod(Object bean, String methodName, List<Object[]> methodParams)
  35.             throws NoSuchMethodException, SecurityException, IllegalAccessException, IllegalArgumentException,
  36.             InvocationTargetException
  37.     { 
  38.         if (StringUtils.isNotNull(methodParams) && methodParams.size() > 0)
  39.         { 
  40.             Method method = bean.getClass().getDeclaredMethod(methodName, getMethodParamsType(methodParams));
  41.             method.invoke(bean, getMethodParamsValue(methodParams));
  42.         }
  43.         else
  44.         { 
  45.             Method method = bean.getClass().getDeclaredMethod(methodName);
  46.             method.invoke(bean);
  47.         }
  48.     }
  50.     /** * 校验是否为为class包名 * * @param invokeTarget 名称 * @return true是 false否 */
  51.     public static boolean isValidClassName(String invokeTarget)
  52.     { 
  53.         return StringUtils.countMatches(invokeTarget, ".") > 1;
  54.     }
  56.     /** * 获取bean名称 * * @param invokeTarget 目标字符串 * @return bean名称 */
  57.     public static String getBeanName(String invokeTarget)
  58.     { 
  59.         String beanName = StringUtils.substringBefore(invokeTarget, "(");
  60.         return StringUtils.substringBeforeLast(beanName, ".");
  61.     }
  63.     /** * 获取bean方法 * * @param invokeTarget 目标字符串 * @return method方法 */
  64.     public static String getMethodName(String invokeTarget)
  65.     { 
  66.         String methodName = StringUtils.substringBefore(invokeTarget, "(");
  67.         return StringUtils.substringAfterLast(methodName, ".");
  68.     }
  70.     /** * 获取method方法参数相关列表 * * @param invokeTarget 目标字符串 * @return method方法相关参数列表 */
  71.     public static List<Object[]> getMethodParams(String invokeTarget)
  72.     { 
  73.         String methodStr = StringUtils.substringBetween(invokeTarget, "(", ")");
  74.         if (StringUtils.isEmpty(methodStr))
  75.         { 
  76.             return null;
  77.         }
  78.         String[] methodParams = methodStr.split(",");
  79.         List<Object[]> classs = new LinkedList<>();
  80.         for (int i = 0; i < methodParams.length; i++)
  81.         { 
  82.             String str = StringUtils.trimToEmpty(methodParams[i]);
  83.             // String字符串类型，包含'
  84.             if (StringUtils.contains(str, "'"))
  85.             { 
  86.                 classs.add(new Object[] {  StringUtils.replace(str, "'", ""), String.class });
  87.             }
  88.             // boolean布尔类型，等于true或者false
  89.             else if (StringUtils.equals(str, "true") || StringUtils.equalsIgnoreCase(str, "false"))
  90.             { 
  91.                 classs.add(new Object[] {  Boolean.valueOf(str), Boolean.class });
  92.             }
  93.             // long长整形，包含L
  94.             else if (StringUtils.containsIgnoreCase(str, "L"))
  95.             { 
  96.                 classs.add(new Object[] {  Long.valueOf(StringUtils.replaceIgnoreCase(str, "L", "")), Long.class });
  97.             }
  98.             // double浮点类型，包含D
  99.             else if (StringUtils.containsIgnoreCase(str, "D"))
  100.             { 
  101.                 classs.add(new Object[] {  Double.valueOf(StringUtils.replaceIgnoreCase(str, "D", "")), Double.class });
  102.             }
  103.             // 其他类型归类为整形
  104.             else
  105.             { 
  106.                 classs.add(new Object[] {  Integer.valueOf(str), Integer.class });
  107.             }
  108.         }
  109.         return classs;
  110.     }
  112. 1.11111111111111111111111111
  113.     /** * 获取参数类型 * * @param methodParams 参数相关列表 * @return 参数类型列表 */
  114.     public static Class<?>[] getMethodParamsType(List<Object[]> methodParams)
  115.     { 
  116.         Class<?>[] classs = new Class<?>[methodParams.size()];
  117.         int index = 0;
  118.         for (Object[] os : methodParams)
  119.         { 
  120.             classs[index] = (Class<?>) os[1];
  121.             index++;
  122.         }
  123.         return classs;
  124.     }
  126.     /** * 获取参数值 * * @param methodParams 参数相关列表 * @return 参数值列表 */
  127.     public static Object[] getMethodParamsValue(List<Object[]> methodParams)
  128.     { 
  129.         Object[] classs = new Object[methodParams.size()];
  130.         int index = 0;
  131.         for (Object[] os : methodParams)
  132.         { 
  133.             classs[index] = (Object) os[0];
  134.             index++;
  135.         }
  136.         return classs;
  137.     }
  138. }

2.22222222222222222

  1. package com.ruoyi.common.task;
  3. import java.io.ByteArrayInputStream;
  4. import java.io.IOException;
  5. import java.io.InputStream;
  6. import java.io.StringReader;
  7. import java.io.UnsupportedEncodingException;
  8. import java.util.HashMap;
  9. import java.util.List;
  10. import java.util.Map;
  12. import org.apache.commons.httpclient.HttpClient;
  13. import org.apache.commons.httpclient.methods.InputStreamRequestEntity;
  14. import org.apache.commons.httpclient.methods.PostMethod;
  15. import org.apache.commons.httpclient.methods.RequestEntity;
  16. import org.jdom2.Document;
  17. import org.jdom2.Element;
  18. import org.jdom2.JDOMException;
  19. import org.jdom2.input.SAXBuilder;
  20. import org.xml.sax.InputSource;
  22. /** * soap 工具类 * * @author ruoyi */
  23. public class XMLUtil{ 
  25.     /** * Description: 将字符串类型的XML 转化成Docunent文档结构 * @param parseStrXml 待转换的xml 字符串 * @return */
  26.     public static Document strXmlToDocument(String parseStrXml){ 
  27.             StringReader read = new StringReader(parseStrXml);  
  28.             //创建新的输入源SAX 解析器将使用 InputSource 对象来确定如何读取 XML 输入 
  29.             InputSource source = new InputSource(read);  
  30.             //创建一个新的SAXBuilder 
  31.             SAXBuilder sb = new SAXBuilder();   // 新建立构造器 
  32.             Document doc = null;
  33.             try { 
  34.                 doc = sb.build(source);
  35.             } catch (JDOMException e) { 
  36.                 e.printStackTrace();
  37.             } catch (IOException e) { 
  38.                 e.printStackTrace();
  39.             } 
  40.             return doc;
  42.         }
  47.     /** * <p>Description: 根据目标节点名获取值</p> * @param doc 文档结构 * @param finalNodeName 最终节点名 * @return * * @author huoge */
  48.     public static String getValueByElementName(Document doc,String finalNodeName){ 
  49.         Element root = doc.getRootElement();
  50.         HashMap<String,Object> map=new HashMap<String,Object>();
  51.       //调用getChildAllText方法。获取目标子节点的值 </span>
  52.        Map<String,Object> resultmap=getChildAllText(doc, root,map);   
  53.        String result=(String)resultmap.get(finalNodeName);
  54.        return result;
  55.     }
  59.     /** * <p>Description: 递归获得子节点的值</p> * @param doc 文档结构 * @param e 节点元素 * @param resultmap 递归将值压入map中 * @return * * @author huoge */
  60.     public static Map<String ,Object> getChildAllText(Document doc, Element e,HashMap<String,Object> resultmap)  
  61.     {   
  62.         if (e != null)  
  63.         {   
  64.             if (e.getChildren() != null)   //如果存在子节点
  65.             {   
  66.                 List<Element> list = e.getChildren();   
  67.                 for (Element el : list)    //循环输出
  68.                 {   
  69.                     if(el.getChildren().size() > 0)   //如果子节点还存在子节点，则递归获取
  70.                     {   
  71.                         getChildAllText(doc, el,resultmap);  
  72.                     }  
  73.                     else  
  74.                     {   
  75.                         resultmap.put(el.getName(), el.getTextTrim());  //将叶子节点值压入map
  76.                     }  
  77.                 }  
  78.             }  
  79.         }  
  80.         return resultmap;  
  81.     } 
  82. }

第二种方法的原文链接 ： https://blog.csdn.net/walkcode/article/details/7871021

发表评论

表情：
评论列表 （有 0 条评论，37人围观）

还没有评论，来说两句吧...

相关阅读