SpringBoot2.1.6 整合CXF 實現Webservice

時間 2019-12-14

標籤 springboot2.1.6 springboot 整合 cxf 實現 webservice 欄目 Spring 简体版

原文原文鏈接

SpringBoot2.1.6 整合CXF 實現Webservice

前言

最近LZ產品須要對接公司內部通信工具，採用的是Webservice接口。產品框架用的SpringBoot2.1.6，因而採用整合CXF的方式實現Webservice接口。在這裏分享下整合的demo。java

代碼實現

項目結構web

直接經過idea生成SpringBoot項目，也能夠在http://start.spring.io生成。過於簡單，這裏不贅述。spring

[1561728847121](apache

)springboot

POM文件引入。這裏引入的版本是3.2.4框架

<dependency>          
    <groupId>org.apache.cxf</groupId>          
    <artifactId>cxf-spring-boot-starter-jaxws</artifactId>                              <version>3.2.4</version>      
</dependency>

接口與接口實現類ide

package com.xiaoqiang.cxf.service;
import com.xiaoqiang.cxf.entity.Student;
import javax.jws.WebMethod;
import javax.jws.WebService;
import java.util.List;

/**
 * IStudentService <br>
 * 〈〉
 *
 * @author XiaoQiang
 * @create 2019-6-27
 * @since 1.0.0
 */
@WebService(targetNamespace = "http://service.cxf.xiaoqiang.com/") //命名通常是接口類的包名倒序
public interface IStudentService {

    @WebMethod  //聲明暴露服務的方法，能夠不寫
    List<Student> getStudentInfo();
}

package com.xiaoqiang.cxf.service.impl;

import com.xiaoqiang.cxf.entity.Student;
import com.xiaoqiang.cxf.service.IStudentService;
import org.springframework.stereotype.Component;
import javax.jws.WebService;
import java.util.ArrayList;
import java.util.List;
/**
 * StudentServiceImpl <br>
 * 〈學生接口實現類〉
 *
 * @author XiaoQiang
 * @create 2019-6-27
 * @since 1.0.0
 */
@WebService(serviceName = "studentService"//服務名
        ,targetNamespace = "http://service.cxf.xiaoqiang.com/" //報名倒敘，而且和接口定義保持一致
        ,endpointInterface = "com.xiaoqiang.cxf.service.IStudentService")//包名
@Component
public class StudentServiceImpl implements IStudentService {

    @Override
    public List<Student> getStudentInfo() {
        List<Student> stuList = new ArrayList<>();
        Student student = new Student();
        student.setAge(18);
        student.setScore(700);
        student.setName("小強");
        stuList.add(student);
        return stuList;

    }
}

配置類spring-boot

package com.xiaoqiang.cxf.config;

import com.xiaoqiang.cxf.service.IStudentService;
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;
/**
 * CxfConfig <br>
 * 〈cxf配置類〉
 * @desription cxf發佈webservice配置
 * @author XiaoQiang
 * @create 2019-6-27
 * @since 1.0.0
 */
@Configuration
public class CxfConfig {

    @Autowired
    private Bus bus;

    @Autowired
    private IStudentService studentService;

    /**
     * 站點服務
     * @return
     */
    @Bean
    public Endpoint studentServiceEndpoint(){
        EndpointImpl endpoint = new EndpointImpl(bus,studentService);
        endpoint.publish("/studentService");
        return endpoint;
    }
}

啓動Application工具

http://ip:端口/項目路徑/services/studentService?wsdl 查看生成的wsdl測試

測試

package com.xiaoqiang.cxf;

import com.xiaoqiang.cxf.entity.Student;
import com.xiaoqiang.cxf.service.IStudentService;
import org.apache.cxf.endpoint.Client;
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import java.util.ArrayList;
import java.util.List;

@RunWith(SpringRunner.class)
@SpringBootTest
public class CxfApplicationTests {
    private Logger logger = LoggerFactory.getLogger(CxfApplication.class);
    @Test
    public void contextLoads() {
    }
    /**
     * 方法一:動態客戶端調用
     */
    @Test
    public void DynamicClient(){

        JaxWsDynamicClientFactory jwdcf = JaxWsDynamicClientFactory.newInstance();
        Client client = jwdcf.createClient("http://localhost:8080/services/studentService?wsdl");
        Object[] objects = new Object[0];

        try {
            objects = client.invoke("getStudentInfo");
            logger.info("獲取學生信息==>{}",objects[0].toString());
            System.out.println("invoke實體："+((ArrayList) objects[0]).get(0).getClass().getPackage());
            for(int i=0 ; i< ((ArrayList)objects[0]).size() ; i++){
                Student student = new Student();
                BeanUtils.copyProperties(((ArrayList) objects[0]).get(0),student);
                logger.info("DynamicClient方式，獲取學生{}信息==> 姓名:{}，年齡:{},分數:{}",i+1,
                        student.getName(),student.getAge(),student.getScore());
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 代理類工廠
     */
    @Test
    public void ProxyFactory(){

        String address = "http://localhost:8080/services/studentService?wsdl";
        //代理工廠
        JaxWsProxyFactoryBean factoryBean = new JaxWsProxyFactoryBean();
        //設置代理地址
        factoryBean.setAddress(address);
        //設置接口類型
        factoryBean.setServiceClass(IStudentService.class);
        //建立一個代理接口實現
        IStudentService studentService = (IStudentService) factoryBean.create();
        List<Student> studentList = studentService.getStudentInfo();
        for(int i=0 ; i< studentList.size() ; i++){
            Student student = studentList.get(i);
            logger.info("ProxyFactory方式，獲取學生{}信息==> 姓名:{}，年齡:{},分數:{}",i+1,
                    student.getName(),student.getAge(),student.getScore());
        }
    }

}