震驚~~都2023年了竟然還有人用webservice！

1、springboot集成webservice

maven添加依賴

        <!--通過cxf實現(xiàn)webservice-->
? ? ? ? <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web-services</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.cxf</groupId>
            <artifactId>cxf-rt-frontend-jaxws</artifactId>
            <version>3.5.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.cxf</groupId>
            <artifactId>cxf-rt-transports-http</artifactId>
            <version>3.5.1</version>
        </dependency>
? ? ? ? <!--解析xml-->
        <dependency>
            <groupId>org.dom4j</groupId>
            <artifactId>dom4j</artifactId>
            <version>2.1.3</version>
        </dependency>

添加配置文件

@Configuration
public class CxfConfig {

? ? //自定義攔截器 用于處理返回數(shù)據(jù)格式
    @Autowired
    private CxfOutterceptor cxfOutterceptor;

    @Bean
    public ServletRegistrationBean disServlet() {
        ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new CXFServlet(), "/webService/*");
        return servletRegistrationBean;
    }

    @Bean(name = Bus.DEFAULT_BUS_ID)
    public SpringBus springBus() {
        return new SpringBus();
    }

    @Bean
    public Endpoint endpoint() {
        EndpointImpl endpoint = new EndpointImpl(springBus(), new AccountServiceImpl());
        //發(fā)布一個名為AccountService的webservice服務(wù)，可以多個
? ? ? ? endpoint.publish("/AccountService");
        endpoint.getOutInterceptors().add(cxfOutterceptor);
        return endpoint;
    }


}

自定義攔截器

@Component
public class CxfOutterceptor extends AbstractPhaseInterceptor<Message> {

    public CxfOutterceptor() {
        super(Phase.PRE_STREAM);
    }

    public CxfOutterceptor(String phase) {
        super(phase);
    }

    @Override
    public void handleMessage(Message message) throws Fault {
        try {
            OutputStream os = message.getContent(OutputStream.class);
            CachedStream cs = new CachedStream();
            message.setContent(OutputStream.class, cs);
            message.getInterceptorChain().doIntercept(message);
            CachedOutputStream csnew = (CachedOutputStream) message.getContent(OutputStream.class);
            InputStream in = csnew.getInputStream();
            String xml = IOUtils.toString(in);

            StringBuffer stringBuffer = new StringBuffer();

            //去掉外層包裝
            Document document = DocumentHelper.parseText(xml);
            Element rootElement = document.getRootElement();
            List<Element> elements1 = rootElement.elements();
            if(elements1!=null && elements1.size()>0){
                Element element = elements1.get(0);
                List<Element> elements = element.elements();
                if(elements!=null && elements.size()>0){
                    Element aReturn = elements.get(0).element("return");
                    String name = aReturn.getName();
                    String adata = aReturn.getData().toString();

                    stringBuffer = new StringBuffer(adata);

                }
            }

            //這里對xml做處理，處理完后同理，寫回流中
            IOUtils.copy(new ByteArrayInputStream(stringBuffer.toString().getBytes()), os);

            cs.close();
            os.flush();

            message.setContent(OutputStream.class, os);

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private class CachedStream extends CachedOutputStream {

        public CachedStream() {

            super();

        }

        protected void doFlush() {

            //currentStream.flush();

        }

        protected void doClose(){

        }

        protected void onWrite(){

        }

    }

}

通過cxf實現(xiàn)wenservice服務(wù)返回結(jié)果是有一層固定包裝的，類似下圖，return標(biāo)簽里才是結(jié)果，如何完全自定義返回的結(jié)果數(shù)據(jù)呢？就需要上面的攔截器去掉外層的包裝。

service類

@WebService(name = "AccountService",
        targetNamespace = "http://server.webservice.kaka.com"
)
public interface AccountService {

    @WebMethod
    public String sendMessage(@WebParam(name = "username",targetNamespace="http://server.webservice.kaka.com") String username);

    @WebMethod
    public boolean getFlag(@WebParam(name = "username",targetNamespace="http://server.webservice.kaka.com") String username);

    @WebMethod
    public String queryUsers();

}

實現(xiàn)類

@WebService(serviceName = "AccountService",
? ? ? ? //名命空間可任意寫 要跟service里的保持一致
        targetNamespace = "http://server.webservice.kaka.com",
? ? ? ? //接口類的全路徑
        endpointInterface = "com.kaka.webService.AccountService"
)
@Component
@Slf4j
public class AccountServiceImpl implements AccountService {

    @Override
    public String sendMessage(String username) {
        return "=====Hello! " + username + "=====";
    }

    @Override
    public boolean getFlag(String username) {
        return false;
    }

}

接下來啟動服務(wù)，瀏覽器訪問ip:端口/webservice/AccountService?wsdl

即可看到wsdl信息

2、postman測試

Headers添加

key:Content-type

value:text/xml;charset=utf-8

然后Body選擇raw，XML

<?xml version="1.0" encoding="utf-8"?>
<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/">
    <soap:Body>
        <sendMessage xmlns="http://server.kaka.com">
            <username>測試啊</username>
　　　　</sendMessage>
    </soap:Body>
</soap:Envelope>

如果使用了上面的自定義攔截器，則調(diào)用的返回結(jié)果為：文章來源地址http://www.zghlxwxcb.cn/news/detail-597046.html