spring boot 使用 webservice

点击全文阅读

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 {    @WebMethod    public boolean addHuman(Human human);    @WebMethod    public boolean deleteHuman(String name);    @WebMethod    public Human get(String name);    /**     * 不能处理List, 只能处理数组     * @return     */    @WebMethod    public 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<>();    @Override    public boolean addHuman(Human human) {        data.put(human.getName(), human);        return true;    }    @Override    public boolean deleteHuman(String name) {        data.remove(name);        return true;    }    @Override    public Human get(String name) {        return data.get(name);    }    @Override    public 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;    }}

暴露端口

@SpringBootApplicationpublic 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客户端调用

动态调用

@RestControllerpublic 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=实现类+Service        QName 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);    }    @Override    public boolean addHuman(Human human) {        return super.getPort(HumanService.class).addHuman(human);    }    @Override    public boolean deleteHuman(String name) {        return super.getPort(HumanService.class).deleteHuman(name);    }    @Override    public Human get(String name) {        return super.getPort(HumanService.class).get(name);    }    @Override    public Human[] getAll() {        return super.getPort(HumanService.class).getAll();    }}

调用

@RestControllerpublic class HumanWebServiceClientController {    @Autowired    private 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: trueget all data: [{"age":13,"name":"tom"}]

good luck!

点击全文阅读