spring-boot整合Cxf的webservice案例

1.运行环境

开发工具：intellij idea

JDK版本：1.8

项目管理工具：Maven 4.0.0

2.Maven Plugin管理

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>spring-boot-ws</groupId>
    <artifactId>spring-boot-ws</artifactId>
    <version>1.0-SNAPSHOT</version>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.6.RELEASE</version>
    </parent>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- CXF webservice -->
        <dependency>
            <groupId>org.apache.cxf</groupId>
            <artifactId>cxf-spring-boot-starter-jaxws</artifactId>
            <version>3.1.11</version>
        </dependency>
    </dependencies>


</project>

3.WebService方法创建

package com.goku.demo.controller;

import org.springframework.stereotype.Component;

import javax.jws.WebMethod;
import javax.jws.WebParam;
import javax.jws.WebService;

/**
 * Created by nbfujx on 2017/11/27.
 */
@Component
@WebService(serviceName = "ExampleService"
        ,targetNamespace="http://controller.demo.goku.com/")
public class ExampleController {

    @WebMethod
    public String echo(@WebParam(name = "para") String para) {
    return "hello"+para;
    }
}

4.CxfConfig配置编写

package com.goku.demo.config;

import com.goku.demo.controller.ExampleController;
import org.apache.cxf.Bus;
import org.apache.cxf.jaxws.EndpointImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.xml.ws.Endpoint;

/**
 * Created by nbfujx on 2017/11/27.
 */
@Configuration
public class CxfConfig {

    @Autowired
    private Bus bus;

    @Autowired
    private ExampleController examplecontroller;

    @Bean
    public Endpoint endpoint() {
        EndpointImpl endpoint = new EndpointImpl(bus,examplecontroller);
        endpoint.publish("/ExampleService");//接口发布在 /NetbarServices 目录下
        return endpoint;
    }

}

5.WsApplication启动类编写

package com.goku.demo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.ServletComponentScan;

/**
 * Created by nbfujx on 2017/10/19.
 */
// Spring Boot 应用的标识
@SpringBootApplication
@ServletComponentScan
public class WsApplication {

    public static void main(String[] args) {
        // 程序启动入口
        // 启动嵌入式的 Tomcat 并初始化 Spring 环境及其各 Spring 组件
        SpringApplication.run(WsApplication.class,args);
    }
}

6.Cxf客户端编写

package test.com.goku.demo.client;


import org.apache.cxf.endpoint.Client;
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;

import com.goku.demo.controller.ExampleController;

/**
 * Created by nbfujx on 2017/11/27.
 */
public class CxfClient {

    public static void main(String[] args) {
        echo();
    }

    public static void echo() {
        // 创建动态客户端
        JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
        Client client = dcf.createClient("http://localhost:8080/services/ExampleService?wsdl");
        Object[] objects = new Object[0];
        try {
            objects = client.invoke("echo", "str");
            System.out.println("echo:" + objects[0]);
        } catch (java.lang.Exception e) {
            e.printStackTrace();
        }
    }
}

7.查看测试结果

先启动cxf服务端，再进行客户端调阅

8.GITHUB地址

https://github.com/nbfujx/springBoot-learn-demo/tree/master/spring-boot-ws

待续