Java开发webService接口
Java开发webService接口
服务端
- maven
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
<!-- 解析WebService JAR包 CXF -->
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-spring-boot-starter-jaxws</artifactId>
<version>3.2.4</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-transports-http-jetty</artifactId>
<version>3.2.4</version>
</dependency>
<!-- 解析WebService JAR包 CXF end-->
<!-- https://mvnrepository.com/artifact/org.jdom/jdom2 -->
<dependency>
<groupId>org.jdom</groupId>
<artifactId>jdom2</artifactId>
<version>2.0.6</version>
</dependency>
<!-- https://mvnrepository.com/artifact/dom4j/dom4j -->
<dependency>
<groupId>dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>1.6.1</version>
</dependency>
接口
1
2
3
4
5
6
7
8
//命名空间一般为包名的倒序，最后一定要加斜杠
@WebService(targetNamespace = "http://webservice.msunsoft.com/")
public interface PatientService {
//生命对外接口方法和参数
@WebMethod
String sendPatientMsg(@WebParam(name = "name") String name);
}
实现类
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
/**
* webservice接口实现类
* qinfen
命名空间要和接口的命名空间保持一致
endpointInterface指明实现类所实现的接口
*/
@WebService(serviceName = "PatientService",
targetNamespace = "http://webservice.msunsoft.com/",
endpointInterface = "com.msunsoft.webService.PatientService")
@Component
public class PatientServiceImpl implements PatientService {
@Override
public String sendPatientMsg(String name) {
return "hello"+name;
}
}
配置类
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
/**
* cxf配置
* qinfen
*/
@Configuration
public class CxfConfig {
/**
* 注入servlet bean name不能dispatcherServlet 否则会覆盖dispatcherServlet
* @return
*/
@Bean(name = "cxfServlet")
public ServletRegistrationBean cxfServlet() {
return new ServletRegistrationBean(new CXFServlet(),"/services/*");
}
@Bean(name = Bus.DEFAULT_BUS_ID)
public SpringBus springBus() {
return new SpringBus();
}
//注入对外开放接口
@Bean
public PatientService patientService() {
return new PatientServiceImpl();
}
@Bean(name = "WebServiceDemoEndpoint")
public Endpoint endpoint() {
EndpointImpl endpoint = new EndpointImpl(springBus(), patientService());
endpoint.publish("/patient");
return endpoint;
}
}
生成的接口地址为：
http://localhost:82/services/patient?wsdl因为springboot整合了shiro，这个webservice路径没有添加到可以过滤的路径上面去。
filterChainDefinitionMap.put("/services/**", "anon");
客户端
- 例1：
1
2
3
4
5
6
7
8
9
10
11
12
13
public class Client {
public static void main(String args[]) throws Exception{
JaxWsDynamicClientFactory dcf =JaxWsDynamicClientFactory.newInstance();
org.apache.cxf.endpoint.Client client =dcf.createClient("http://localhost:82/services/patient?wsdl");
//sendPatientMsg 为接口中定义的方法名称 张三为传递的参数 返回一个Object数组
Object[] objects=client.invoke("sendPatientMsg","张三");
//输出调用结果
System.out.println("*****"+objects[0].toString());
}
}
- 例2：
1
2
3
4
5
6
7
8
9
10
11
public static void main(String[] args){
try {
String param = "张三";
String webUrl = "http://localhost:82/services/patient?wsdl";
String methodName = "sendPatientMsg";
String xmlDoc = WebServiceClient.callWebSV(webUrl, methodName, param);
System.out.println(xmlDoc);
} catch (Exception e) {
e.printStackTrace();
}
}
xml解析工具
- maven
1
2
3
4
5
6
7
8
9
10
11
12
<!-- https://mvnrepository.com/artifact/org.jdom/jdom2 -->
<dependency>
<groupId>org.jdom</groupId>
<artifactId>jdom2</artifactId>
<version>2.0.6</version>
</dependency>
<!-- https://mvnrepository.com/artifact/dom4j/dom4j -->
<dependency>
<groupId>dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>1.6.1</version>
</dependency>
- 工具类
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
package com.msunsoft.common.jdom;
import java.io.StringReader;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import org.w3c.dom.Attr;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.NamedNodeMap;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import org.xml.sax.InputSource;
/**
*
* xml转换类.
*
* @author jiacl 2015/09/22.
*
*/
public class XmlUtil {
/** 返回值(MAP) */
private Map<String,String> xmlMap = null;
/** 返回值(LIST) */
private List<Map<String,String>> listXmlMap = null;
/** 中间变量 */
private Map<String,String> tempMap = null;
/**
* xml字符串转化map
*
* @param protocolXML xml字符串
*
*/
public void parse(String protocolXML) {
try {
DocumentBuilderFactory factory = DocumentBuilderFactory
.newInstance();
DocumentBuilder builder = factory.newDocumentBuilder();
Document doc = builder.parse(new InputSource(new StringReader(
protocolXML)));
Element root = doc.getDocumentElement();
xmlMap = new HashMap<String, String>();
parseElement(root);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* xml字符串转化List
*
* @param protocolXML xml字符串
*
*/
public void parseList(String protocolXML) {
try {
DocumentBuilderFactory factory = DocumentBuilderFactory
.newInstance();
DocumentBuilder builder = factory.newDocumentBuilder();
Document doc = builder.parse(new InputSource(new StringReader(
protocolXML)));
Element root = doc.getDocumentElement();
listXmlMap = new ArrayList<Map<String,String>>();
tempMap = new HashMap<String, String>();
parseElementList(root);
if (!tempMap.isEmpty()) {
listXmlMap.add(tempMap);
}
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* xml字符串转化map递归方法
*
* @param element xml元素
*
*/
private void parseElement(Element element) {
String tagName = element.getNodeName();
NodeList children = element.getChildNodes();
// element元素的所有属性所构成的NamedNodeMap对象，需要对其进行判断
NamedNodeMap map = element.getAttributes();
// 如果该元素存在属性
if (null != map) {
for (int i = 0; i < map.getLength(); i++) {
// 获得该元素的每一个属性
Attr attr = (Attr) map.item(i);
String attrName = attr.getName();
String attrValue = attr.getValue();
}
}
for (int i = 0; i < children.getLength(); i++) {
Node node = children.item(i);
// 获得结点的类型
short nodeType = node.getNodeType();
if (nodeType == Node.ELEMENT_NODE) {
// 是元素，继续递归
parseElement((Element) node);
} else if (nodeType == Node.TEXT_NODE) {
// 递归出口
xmlMap.put(tagName, node.getNodeValue());
}
}
}
/**
* xml字符串转化List递归方法
*
* @param element xml元素
*
*/
private void parseElementList(Element element) {
String tagName = element.getNodeName();
NodeList children = element.getChildNodes();
// element元素的所有属性所构成的NamedNodeMap对象，需要对其进行判断
NamedNodeMap map = element.getAttributes();
// 如果该元素存在属性
if (null != map) {
for (int i = 0; i < map.getLength(); i++) {
// 获得该元素的每一个属性
Attr attr = (Attr) map.item(i);
String attrName = attr.getName();
String attrValue = attr.getValue();
}
}
if (children.getLength() == 0) {
if (tempMap.containsKey(tagName)) {
listXmlMap.add(tempMap);
tempMap = new HashMap<String, String>();
}
// 递归出口
tempMap.put(tagName, "");
}
for (int i = 0; i < children.getLength(); i++) {
Node node = children.item(i);
// 获得结点的类型
short nodeType = node.getNodeType();
if (nodeType == Node.ELEMENT_NODE) {
// 是元素，继续递归
parseElementList((Element) node);
} else if (nodeType == Node.TEXT_NODE) {
if (tempMap.containsKey(tagName)) {
listXmlMap.add(tempMap);
tempMap = new HashMap<String, String>();
}
// 递归出口
tempMap.put(tagName, node.getNodeValue());
}
}
}
/**
* @return the xmlMap
*/
public Map<String, String> getXmlMap() {
return xmlMap;
}
/**
* @return the listXmlMap
*/
public List<Map<String, String>> getListXmlMap() {
return listXmlMap;
}
public static String getXmlStrUseName(Map<String, Object> map, int init) {
StringBuffer str = new StringBuffer("");
if(init == 0) {
str.append("<?xml version=\"1.0\" encoding=\"utf-8\"?>");
}
if(map != null) {
for(String key : map.keySet()) {
if(map.get(key) instanceof Map) {
str.append("<").append(key).append(">");
str.append(getXmlStrUseName((Map)map.get(key), 1));
str.append("</").append(key).append(">");
}else {
str.append("<").append(key).append(">");
str.append(map.get(key));
str.append("</").append(key).append(">");
}
}
}
return str.toString();
}
}
- 案例
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
public void replaceOrInsertSysDept() throws Exception {
String param = "参数";
String webUrl = "http://IP/HISWebService/Dict/DeptSetting.svc?wsdl";
String methodName = "GetDept";
String xmlDoc = WebServiceClient.callWebSV(webUrl, methodName, param);
System.out.println(xmlDoc);
XmlUtil xmlUtil = new XmlUtil();
xmlUtil.parseList(xmlDoc);
List<Map<String, String>> listXmlMap = xmlUtil.getListXmlMap();
System.out.println(listXmlMap);
listXmlMap.forEach(m -> {
//根据科室id查sys_dept,如果存在，执行更新，如果不存在执行添加。使用MySQL的replace into
System.out.println(m.toString());
sysDeptMapper.replaceOrInsert(m);
});
}
本文由作者按照 CC BY 4.0 进行授权