spring boot 使用 webservice
使用 java 自带的 jax-ws
依赖
如果是jdk1.8,不需要引入任何依赖，如果大于1.8
<dependency><groupId>javax.jws</groupId><artifactId>javax.jws-api</artifactId><version>1.1</version>
</dependency>
<dependency><groupId>javax.xml.ws</groupId><artifactId>jaxws-api</artifactId>
</dependency>
定义服务接口
使用 @WebService 注解
@WebService
@SOAPBinding(style = SOAPBinding.Style.RPC)
public interface HumanService {@WebMethodpublic boolean addHuman(Human human);@WebMethodpublic boolean deleteHuman(String name);@WebMethodpublic Human get(String name);/*** 不能处理List, 只能处理数组* @return*/@WebMethodpublic Human[] getAll();}
实现
package com.example.demoweb.webservice.impl;import com.example.demoweb.model.Human;
import com.example.demoweb.webservice.HumanService;
import org.springframework.util.CollectionUtils;import javax.jws.WebService;
import java.util.*;/*** @Author: xiaodong.zheng* @Date: 2024/3/7 15:36*/
@WebService(endpointInterface = "com.example.demoweb.webservice.HumanService",serviceName = "HumanService",targetNamespace = "human.ns" //随便写，不过在客户端调用时会用到
)
public class HumanServiceImpl implements HumanService {private Map<String, Human> data = new HashMap<>();@Overridepublic boolean addHuman(Human human) {data.put(human.getName(), human);return true;}@Overridepublic boolean deleteHuman(String name) {data.remove(name);return true;}@Overridepublic Human get(String name) {return data.get(name);}@Overridepublic Human[] getAll() {if (CollectionUtils.isEmpty(data)) {return null;}Human[] hs = new Human[data.size()];int i = 0;for (Map.Entry<String, Human> entry : data.entrySet()) {hs[i] = entry.getValue();i++;}return hs;}
}
暴露端口
@SpringBootApplication
public class DemoWebApplication {public static final String WS_HUMAN = "http://localhost:8888/ws/hh";public static void main(String[] args) {//注意webservice服务发布会优先于spring容器启动，不然 使用依赖注入会失败！！Endpoint.publish(WS_HUMAN, new HumanServiceImpl());SpringApplication.run(DemoWebApplication.class, args);}}
访问 http://localhost:8888/ws/hh?wsdl
webservice客户端调用
动态调用
@RestController
public class HumanWebServiceClientController {@GetMapping("/index")public String invoke() throws MalformedURLException {//public static final String WS_HUMAN = "http://localhost:8888/ws/hh";URL wsdlURL = new URL(WS_HUMAN + "?wsdl");//默认localPart=实现类+ServiceQName qname = new QName("human.ns", "HumanService");Service service = Service.create(wsdlURL, qname);HumanService humanService = service.getPort(HumanService.class);Human human = new Human();human.setName("tom");human.setAge(12);boolean b = humanService.addHuman(human);System.out.println("add human: " + b);Human[] all = humanService.getAll();System.out.println("get all data: " + JSON.toJSONString(all));return "success";}
}
依赖注入调用
使用 @WebServiceClient 注解, 调用者客户端：
@Component
@WebServiceClient(targetNamespace = "human.ns", wsdlLocation = WS_HUMAN + "?wsdl",name = "HumanService")
public class HumanServiceClient extends Service implements HumanService {public final static QName SERVICE = new QName("human.ns", "HumanService");public HumanServiceClient() throws MalformedURLException {super(new URL(WS_HUMAN + "?wsdl"), SERVICE);}@Overridepublic boolean addHuman(Human human) {return super.getPort(HumanService.class).addHuman(human);}@Overridepublic boolean deleteHuman(String name) {return super.getPort(HumanService.class).deleteHuman(name);}@Overridepublic Human get(String name) {return super.getPort(HumanService.class).get(name);}@Overridepublic Human[] getAll() {return super.getPort(HumanService.class).getAll();}
}
调用
@RestController
public class HumanWebServiceClientController {@Autowiredprivate HumanServiceClient humanServiceClient;@GetMapping("/index2")public String invoke2() throws MalformedURLException {Human human = new Human();human.setName("tom");human.setAge(13);boolean b = humanServiceClient.addHuman(human);System.out.println("add human: " + b);Human[] all = humanServiceClient.getAll();System.out.println("get all data: " + JSON.toJSONString(all));return "success";}}结果：
add human: true
get all data: [{"age":13,"name":"tom"}]
good luck!
