Java 调用 WebService 、java调用Soap请求、Java对接soap接口

工作第一次遇到对接soap接口，觉得有必要记录一下，毕竟踩了不少坑，网上帖子很多但大都不全，也不可能完全满足自己的需求，于是就有了下面的代码：

除了只是借鉴，

注意事项：1.http://ip:port/xxx/xxx/soap?wsdl有些soap接口，对面是不需要穿?wsdl对接时要问出清

2. httpPost.setHeader("SOAPAction", SOAPAction); SOAPAction也要问下，或者查看接口文件，有些只要传空字符串

3.拼接报文时要注意格式，/n一类的特殊符号不能有

4.xml解析式注意编号，编号可能存在编码来回切换returnDatabase = convertToUTF8(returnDatabase);

package com.ankang.hospital.utils;import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.hc.client5.http.classic.methods.HttpPost;
import org.apache.hc.client5.http.impl.classic.CloseableHttpClient;
import org.apache.hc.client5.http.impl.classic.CloseableHttpResponse;
import org.apache.hc.client5.http.impl.classic.HttpClientBuilder;
import org.apache.hc.core5.http.HttpEntity;
import org.apache.hc.core5.http.io.entity.EntityUtils;
import org.apache.hc.core5.http.io.entity.StringEntity;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.NodeList;
import org.xml.sax.InputSource;
import org.xml.sax.SAXException;import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import javax.xml.transform.OutputKeys;
import javax.xml.transform.Transformer;
import javax.xml.transform.TransformerException;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.dom.DOMSource;
import javax.xml.transform.stream.StreamResult;
import java.io.*;
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;@Slf4j
public class HttpClientUtil {private static final Logger logger = LoggerFactory.getLogger(HttpClientUtil.class);/*** HttpClient 调用 WebService** @param wsUrl   webService地址，格式：http://ip:port/xxx/xxx/soap?wsdl* @param StrDate 格式的入参StrDate=2023/08/02* @return*/public static String callServiceHC(String wsUrl, String StrDate) {String xml = createSoapContent(StrDate);String returnDatabase = doPostSoap(wsUrl, xml, "");//urn:hl7-org:v3/ZDYFWTYRK// 强制将返回结果转换为 UTF-8 编码returnDatabase = convertToUTF8(returnDatabase);return returnDatabase;}/*** 强制转换整utp-8* @param input* @return*/public static String convertToUTF8(String input) {try {byte[] utf8Bytes = input.getBytes(StandardCharsets.UTF_8);return new String(utf8Bytes, StandardCharsets.UTF_8);} catch (Exception e) {e.printStackTrace();}return input; // 返回原始字符串，如果转换失败}/*** 根据拼接 xml 字符串** @param StrDate* @return*/public static String createSoapContent(String StrDate) {log.info("开始拼接请求报文");//开始拼接请求报文StringBuilder stringBuilder = new StringBuilder();stringBuilder.append("<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:urn=\"urn:hl7-org:v3\">\n");stringBuilder.append("<soapenv:Header/>");stringBuilder.append("<soapenv:Body>");stringBuilder.append("<urn:ZDYFWTYRK>");stringBuilder.append("<urn:req>");//传参actionstringBuilder.append("<urn:action>");stringBuilder.append("Z1901");stringBuilder.append("</urn:action>");//传参rdnstringBuilder.append("<urn:rdn>");stringBuilder.append("SSXWGYGXT");stringBuilder.append("</urn:rdn>");//传参messagestringBuilder.append("<urn:message><![CDATA[");stringBuilder.append("<Request>");stringBuilder.append("<operDate>");stringBuilder.append(StrDate);stringBuilder.append("</operDate>");stringBuilder.append("<hoscode>");stringBuilder.append("A001");stringBuilder.append("</hoscode>");stringBuilder.append("</Request>");stringBuilder.append("]]></urn:message>");stringBuilder.append("</urn:req>");stringBuilder.append("</urn:ZDYFWTYRK>");stringBuilder.append("</soapenv:Body>");stringBuilder.append("</soapenv:Envelope>");logger.debug("拼接后的参数\n" + stringBuilder.toString());return stringBuilder.toString();}/*** HTTPClient 调用 WebService** @param url* @param soap* @param SOAPAction* @return*/public static String doPostSoap(String url, String soap, String SOAPAction) {//请求体String retStr = "";// 创建HttpClientBuilderHttpClientBuilder httpClientBuilder = HttpClientBuilder.create();// HttpClientCloseableHttpClient closeableHttpClient = httpClientBuilder.build();HttpPost httpPost = new HttpPost(url);try {httpPost.setHeader("Content-Type", "text/xml;charset=UTF-8");httpPost.setHeader("SOAPAction", SOAPAction);StringEntity data = new StringEntity(soap, Charset.forName("UTF-8"));httpPost.setEntity(data);CloseableHttpResponse response = closeableHttpClient.execute(httpPost);HttpEntity httpEntity = response.getEntity();if (httpEntity != null) {// 打印响应内容retStr = EntityUtils.toString(httpEntity, "UTF-8");}// 释放资源closeableHttpClient.close();} catch (Exception e) {e.printStackTrace();}return retStr;}public static String analyzeResult(String xmlContent) {try {// 从 xmlContent 字符串解析 XMLDocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();factory.setNamespaceAware(true); // 启用命名空间感知DocumentBuilder builder = factory.newDocumentBuilder();Document doc = builder.parse(new InputSource(new StringReader(xmlContent)));// 获取根元素 (SOAP-ENV:Envelope)Element root = doc.getDocumentElement();// 获取 SOAP-ENV:Body 元素Element body = null;NodeList bodyList = root.getElementsByTagName("SOAP-ENV:Body");if (bodyList.getLength() > 0) {body = (Element) bodyList.item(0);}// 获取带有 'urn:hl7-org:v3' 命名空间的 ZDYFWTYRKResponse 元素Element zdyfwtyrkResponse = (Element) body.getElementsByTagNameNS("urn:hl7-org:v3", "ZDYFWTYRKResponse").item(0);Element zdyfwtyrkResult = (Element) zdyfwtyrkResponse.getElementsByTagNameNS("urn:hl7-org:v3", "ZDYFWTYRKResult").item(0);// 获取 ZDYFWTYRKResult 元素中的 CDATA 内容（实际的结果数据）String cdataContent = zdyfwtyrkResult.getTextContent();// 处理CDATA中的XML内容Document cdataDoc = builder.parse(new InputSource(new StringReader(cdataContent)));// 将Document转换为不带BOM的字符串String cdataXmlString = convertDocumentToStringWithoutBOM(cdataDoc);logger.debug("cdataXmlString结果: " + cdataXmlString);return cdataXmlString;} catch (ParserConfigurationException e) {// 记录异常信息到日志log.error("XML解析器配置错误: " + e.getMessage(), e);} catch (IOException e) {// 记录 IOException 异常信息到日志log.error("发生 IO 异常: " + e.getMessage(), e);} catch (SAXException e) {// 记录 SAXException 异常信息到日志log.error("SAX 解析异常: " + e.getMessage(), e);} catch (TransformerException e) {log.error("XML的转换、解析和转换错误: " + e.getMessage(), e);}return null;}/*** 将 DOM Document 转换为 UTF-8 无 BOM 格式的字符串。** @param doc 要转换的 DOM Document。* @return 不带 BOM 的 UTF-8 字符串表示的文档。*/private static String convertDocumentToStringWithoutBOM(Document doc) throws TransformerException, UnsupportedEncodingException {TransformerFactory transformerFactory = TransformerFactory.newInstance();Transformer transformer = transformerFactory.newTransformer();// 设置编码为 UTF-8 且不带 BOMtransformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8");transformer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, "yes"); // 省略 XML 声明transformer.setOutputProperty(OutputKeys.INDENT, "yes"); // 格式化输出// 创建一个 ByteArrayOutputStream 来保存 XML 内容ByteArrayOutputStream outputStream = new ByteArrayOutputStream();StreamResult result = new StreamResult(new OutputStreamWriter(outputStream, StandardCharsets.UTF_8));// 将 Document 转换为不带 BOM 的字符串transformer.transform(new DOMSource(doc), result);// 将 ByteArrayOutputStream 转换为字符串return outputStream.toString("UTF-8");}public static List<Map<String, String>> resultMap1(String soapResponse) {// 从soapResponse中提取JSON部分int startIndex = soapResponse.indexOf("<list>");int endIndex = soapResponse.indexOf("</list>");String jsonPart = soapResponse.substring(startIndex + "<list>".length(), endIndex);// 将JSON转换为MapObjectMapper objectMapper = new ObjectMapper();try {Map<String, Object> resultMap = objectMapper.readValue(soapResponse, new TypeReference<Map<String, Object>>() {});;List<Map<String, Object>> resultJsonList = (List<Map<String, Object>>) resultMap.get("resultJson");// 转换为 List<Map<String, String>>List<Map<String, String>> resultList = new ArrayList();for (Map<String, Object> item : resultJsonList) {Map<String, String> newMap = new HashMap();for (Map.Entry<String, Object> entry : item.entrySet()) {String key = entry.getKey();String value = entry.getValue().toString();newMap.put(key, value);}// 添加resultCode和resultMsg到转换后的结果newMap.put("resultCode", resultMap.get("resultCode").toString());newMap.put("resultMsg", resultMap.get("resultMsg").toString());resultList.add(newMap);}// 输出转换后的结果for (Map<String, String> item : resultList) {System.out.println("resultCode: " + item.get("resultCode"));System.out.println("resultMsg: " + item.get("resultMsg"));System.out.println("patientName: " + item.get("patientName"));System.out.println("opername: " + item.get("opername"));System.out.println("operdate: " + item.get("operdate"));System.out.println("doctor: " + item.get("doctor"));}return resultList;} catch (IOException e) {// 异常处理e.printStackTrace();}return null;}public static List<Map<String, String>> resultMap(String soapResponse) {// 从soapResponse中提取JSON部分int startIndex = soapResponse.indexOf("<list>");int endIndex = soapResponse.indexOf("</list>");String jsonPart = soapResponse.substring(startIndex + "<list>".length(), endIndex);// 将JSON转换为MapObjectMapper objectMapper = new ObjectMapper();try {Map<String, Object> resultMap = objectMapper.readValue(jsonPart, new TypeReference<Map<String, Object>>() {});List<Map<String, Object>> resultJsonList = (List<Map<String, Object>>) resultMap.get("resultJson");// 转换为 List<Map<String, String>>List<Map<String, String>> resultList = new ArrayList();for (Map<String, Object> item : resultJsonList) {Map<String, String> newMap = new HashMap();for (Map.Entry<String, Object> entry : item.entrySet()) {String key = entry.getKey();String value = entry.getValue().toString();newMap.put(key, value);}resultList.add(newMap);}return resultList;} catch (IOException e) {// 异常处理e.printStackTrace();}return null;}}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/25928.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

A stop job is running for xxxxxx

A stop job is running for xxxxxx

有时候服务器关机时&#xff0c;会有个进程卡在那里&#xff0c;使系统无法关闭 提示&#xff1a; A stop job is running for xxxxxx方法&#xff1a; 设置一个启动/停止的默认超时时间即可 vim /etc/systemd/system.conf DefaultTimeoutStartSec300s DefaultTimeoutStopSe…
阅读更多...
mqtt、tcp、http的区别

mqtt、tcp、http的区别

文章目录 一、MQTT&#xff08;Message Queuing Telemetry Transport&#xff09;1、类型2、用途 二、TCP&#xff08;Transmission Control Protocol&#xff09;1、类型2、用途 三、HTTP&#xff08;Hypertext Transfer Protocol&#xff09;1、类型2、用途 四、主要区别1、类…
阅读更多...
使用Python将图像转换为PDF：一次性解决您的批量转换需求

使用Python将图像转换为PDF：一次性解决您的批量转换需求

导语&#xff1a; 在数字化时代&#xff0c;我们经常需要处理大量的图像文件。将这些图像转换为PDF格式可以方便地存档、分享和打印。本文将介绍如何使用Python编程语言将图像批量转换为PDF&#xff0c;并提供了一个简单易用的图形界面来跟踪转换进度。 准备工作 在开始之前…
阅读更多...
一个Linux驱动工程师必知的内核编译机制

一个Linux驱动工程师必知的内核编译机制

Linux内核的编译主要过程&#xff1a;配置、编译、安装。 配置主要由Kconfig提供图形界面完成编译主要基于Kbuild编译系统&#xff0c;执行make完成编译安装主要也是基于Kbuild提供的脚本&#xff0c;然后执行make完成安装 Kconfig Kconfig用于内核的配置&#xff0c;make m…
阅读更多...
Kafka入门,保姆级教学

Kafka入门,保姆级教学

文章目录 Kafka概念消息中间件对比消息中间件对比-选择建议Kafka常用名词介绍Kafka入门1. Kafka安装配置2.Kafka生产者与消费者关系3.Kafka依赖4.生产者发消息5.消费者接受消息6.Kafka高可用性设计6.1集群Kafka备份机制(Reolication) 7.kafka生产者详解7.1 发送类型7.2参数详解…
阅读更多...
任务12、Quality指令加持,Midjourney生成电影级数码作品

任务12、Quality指令加持,Midjourney生成电影级数码作品

12.1 任务概述 本次实验任务旨在帮助你掌握Midjourney AI绘画中的Quality指令。通过深入介绍Quality指令的概念和作用，我们将解释为什么它在绘画中至关重要。通过测试不同的Quality参数对绘画效果的影响，并提供实战演示，你将学会如何在Midjourney中设置Quality参数以达到更…
阅读更多...
背包问题一维写法（状态压缩）实战，其二（目标和、零一和）

背包问题一维写法（状态压缩）实战，其二（目标和、零一和）

给定一个非负整数数组&#xff0c;a1, a2, ..., an, 和一个目标数&#xff0c;S。现在你有两个符号 和 -。对于数组中的任意一个整数&#xff0c;你都可以从 或 -中选择一个符号添加在前面。 返回可以使最终数组和为目标数 S 的所有添加符号的方法数。 示例&#xff1a; 输…
阅读更多...
解决msvc编译luajit找不到ftelli64的问题

解决msvc编译luajit找不到ftelli64的问题

为避免恶心的版本套版本的msvcxxx&#xff0c;我一直用的是wdk-7600.16385.1&#xff0c;执行msvcbuild.bat编译&#xff0c;报错lib_io.obj : error LNK2019: unresolved external symbol __imp__ftelli64 referenced in function lj_cf_io_method_seek&#xff0c;网上搜索&a…
阅读更多...
node上传文件 + vue3 + elementPlus 组件封装

node上传文件 + vue3 + elementPlus 组件封装

一、node 1.在node环境中安装multer(node.js中间件)包&#xff0c;用于处理 multipart/form-data 类型的表单数据 npm install --save multer 2.userRouter var express require(express); const multer require(multer) const upload multer({ dest: public/avataruplo…
阅读更多...
“实现数字化转型：探索会议OA项目的高级技术与创新应用“

“实现数字化转型：探索会议OA项目的高级技术与创新应用“

文章目录 引言&#xff1a;1.项目背景和需求分析&#xff1a;2.技术选型和架构设计&#xff1a;3.项目实现和功能亮点&#xff1a;3.0 layui实现登录及注册3.1 会议管理模块3.1.1 会议发布3.1.2 我的会议3.1.3 我的审批3.1.4 会议通知3.1.5 待开会议3.1.6 历史会议3.1.7 所有会…
阅读更多...
学生管理系统（升级版）

学生管理系统（升级版）

import java.util.ArrayList; import java.util.Random; import java.util.Scanner;public class Demo_学生管理系统 {public static void main(String[] args) {ArrayList<User> list new ArrayList<>();Scanner sc new Scanner(System.in);while (true) {Syste…
阅读更多...
浅谈新电改背景下电网企业综合能源服务商业模式研究及发展方向

浅谈新电改背景下电网企业综合能源服务商业模式研究及发展方向

安科瑞 华楠 摘要: 新电改方案实施后&#xff0c;由于输配电价的改革和售电侧的放开&#xff0c;电网企业的盈利模式也随之发生了变化。这就要求电网企业转变服务理念与经营方式&#xff0c;来寻求竞争优势。基于“魏朱六要素商业模式”模型&#xff0c;对电网企业综合能源服务…
阅读更多...
每天五分钟机器学习:梯度下降算法和正规方程的比较

每天五分钟机器学习:梯度下降算法和正规方程的比较

本文重点 梯度下降算法和正规方程是两种常用的机器学习算法，用于求解线性回归问题。它们各自有一些优点和缺点，下面将分别对它们进行详细的讨论。 区别 1. 梯度下降算法是一种迭代的优化算法，通过不断迭代调整参数来逼近最优解。它的基本思想是根据目标函数的梯度方向，沿…
阅读更多...
陪诊小程序开发|陪诊系统定制|数字化医疗改善就医条件

陪诊小程序开发|陪诊系统定制|数字化医疗改善就医条件

健康问题这几年成为人们关注的焦点之一&#xff0c;然而看病却是一个非常麻烦的过程&#xff0c;特别是对于那些身处陌生城市或者不熟悉就医流程的人来说。幸运的是现在有了陪诊小程序下&#xff0c;为您提供便捷的助医服务&#xff0c;使得就医过程得更加简单和轻松。 陪诊系统…
阅读更多...
QEMU源码全解析27 —— QOM介绍（16）

QEMU源码全解析27 —— QOM介绍（16）

接前一篇文章&#xff1a;QEMU源码全解析26 —— QOM介绍&#xff08;15&#xff09; 本文内容参考&#xff1a; 《趣谈Linux操作系统》 —— 刘超&#xff0c;极客时间 《QEMU/KVM》源码解析与应用 —— 李强&#xff0c;机械工业出版社 特此致谢&#xff01; 前文讲解了对…
阅读更多...
项目管理和产品管理之间的区别

项目管理和产品管理之间的区别

产品管理和项目管理是两个在企业中至关重要的职能部门&#xff0c;它们各自承担着不同的职责和任务。虽然两者在某些方面存在重叠&#xff0c;但它们的核心目标和方法有很大的不同。本文将对产品管理和项目管理进行详细的比较和分析。 “项目管理和产品管理有什么区别&#xff…
阅读更多...
[国产MCU]-BL602-开发实例-DMA数据传输

[国产MCU]-BL602-开发实例-DMA数据传输

DMA数据传输 文章目录 DMA数据传输1、DMA介绍2、DMA驱动API介绍3、DMA使用示例DMA(Direct Memory Access)是一种内存存取技术，可以独立地直接读写系统内存，而不需处理器介入处理。 在同等程度的处理器负担下，DMA是一种快速的数据传送方式。 BL602的DMA控制器有4组独立专用通…
阅读更多...
赴日IT培训 赴日程序员工作适合什么人？

赴日IT培训 赴日程序员工作适合什么人？

日本作为全球第三大经济体&#xff0c;IT行业发展十分迅速&#xff0c;日本拥有世界领先的科技公司&#xff0c;如索尼、丰田、日立等&#xff0c;这为IT行业提供了广阔的发展平台和良好的职业前景。此外&#xff0c;日本政府对IT行业也给予了充分的政策支持&#xff0c;像是对…
阅读更多...
了解 spring MVC + 使用spring MVC - springboot

了解 spring MVC + 使用spring MVC - springboot

前言 本篇介绍什么是spring MVC &#xff0c;如何使用spring MVC&#xff0c;了解如何连接客户端与后端&#xff0c;如何从前端获取各种参数&#xff1b;如有错误&#xff0c;请在评论区指正&#xff0c;让我们一起交流&#xff0c;共同进步&#xff01; 文章目录 前言1. 什么…
阅读更多...
概念解析 | 利用MIMO雷达技术实现高性能目标检测的关键技术解析

概念解析 | 利用MIMO雷达技术实现高性能目标检测的关键技术解析

注1:本文系“概念解析”系列之一,致力于简洁清晰地解释、辨析复杂而专业的概念。本次辨析的概念是:MIMO雷达目标检测技术 参考资料：何子述, 程子扬, 李军, 等. 集中式 MIMO 雷达研究综述[J]. 雷达学报, 2022, 11(5): 805-829. 利用MIMO雷达技术实现高性能目标检测的关键技术解…
阅读更多...
最新文章

Copyright @ 2022~2023