springboot整合webservice采用CXF技术

阳光穿透心脏的1/2处 2022-05-22 11:41 201阅读 0赞

第一步新建一个springboot项目

导入关于XCF的包，代码如下：

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

<?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>com.example</groupId>
    	<artifactId>demo</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<packaging>jar</packaging>
    
    	<name>demo</name>
    	<description>Demo project for Spring Boot</description>
    
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>2.0.3.RELEASE</version>
    		<relativePath/> 
    	</parent>
    
    	<properties>
    		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    		<java.version>1.8</java.version>
    	</properties>
    
    	<dependencies>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter</artifactId>
    		</dependency>
    
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    		<dependency>
    			<groupId>org.apache.cxf</groupId>
    			<artifactId>cxf-spring-boot-starter-jaxws</artifactId>
    			<version>3.2.5</version>
    		</dependency>
    	</dependencies>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    		</plugins>
    	</build>
    
    
    </project>

注意：包冲突问题，我前面用的是3.1.7版本的包，跟我导入springboot包发生冲突了，所以换成最新的版本了

如图：

![70][]

服务接口：

![70 1][]

package com.example.demo.WebService;
    
    import javax.jws.WebMethod;
    import javax.jws.WebParam;
    import javax.jws.WebResult;
    import javax.jws.WebService;
    
    /**
     * WebService接口
     * @作者 Administrator
     * @创建日期 2018/6/23 0023
     * @创建时间 11:21.
     */
    @WebService(name = "CommonService", // 暴露服务名称
            targetNamespace = "http://www.WebService.demo.example.com")   //命名空间,一般是接口的包名倒序
    public interface CommonService {
        @WebMethod
        @WebResult(name = "String",targetNamespace = "")
        public String HelloWorld(@WebParam(name = "HelloName") String name);
    }

接口实现：

![70 2][]

package com.example.demo.WebService;
    
    import org.springframework.stereotype.Component;
    
    import javax.jws.WebService;
    
    /**接口实现
     * @作者 Administrator
     * @创建日期 2018/6/23 0023
     * @创建时间 11:26.
     */
    @WebService(serviceName = "CommonService",//与前面接口一致
            targetNamespace = "http://www.WebService.demo.example.com",  //与前面接口一致
            endpointInterface = "com.example.demo.WebService.CommonService")  //接口地址
    @Component
    public class CommonServiceImpl implements CommonService {
        @Override
        public String HelloWorld(String name) {
            return "Hello World!!! --->"+name;
        }
    }

配置cxf服务发布,默认服务在Host:port/services/\*\*\*路径下：

package com.example.demo.config;
    
    import com.example.demo.WebService.CommonService;
    import org.apache.cxf.Bus;
    import org.apache.cxf.jaxws.EndpointImpl;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Bean;
    
    import javax.xml.ws.Endpoint;
    
    
    /**
     * @作者 Administrator
     * @创建日期 2018/6/23 0023
     * @创建时间 11:31.
     */
    @Configuration
    public class WebConfig {
        @Autowired
        private Bus bus;
    
        @Autowired
        CommonService service;
    
        /*jax-ws*/
        @Bean
        public Endpoint endpoint() {
            EndpointImpl endpoint = new EndpointImpl(bus, service);
            endpoint.publish("/CommonService");
            return endpoint;
        }
    }

![70 3][]

这里相当于把Commonservice接口发布在了路径/services/CommonService下,wsdl文档路径为  
http://localhost:8080/services/CommonService?wsdl

![70 4][]

![70 5][]

创建基于cxf的客服端调用webservice接口（非使用wsdl文档生成java类）

import org.apache.cxf.endpoint.Client;
    import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
    import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
    
    import com.leftso.webservice.CommonService;
    
    public class CxfClient {
    	public static void main(String[] args) {
    		cl1();
    	}
    
    	/**
    	 * 方式1.代理类工厂的方式,需要拿到对方的接口
    	 */
    	public static void cl1() {
    		try {
    			// 接口地址
    			String address = "http://localhost:8080/services/CommonService?wsdl";
    			// 代理工厂
    			JaxWsProxyFactoryBean jaxWsProxyFactoryBean = new JaxWsProxyFactoryBean();
    			// 设置代理地址
    			jaxWsProxyFactoryBean.setAddress(address);
    			// 设置接口类型
    			jaxWsProxyFactoryBean.setServiceClass(CommonService.class);
    			// 创建一个代理接口实现
    			CommonService cs = (CommonService) jaxWsProxyFactoryBean.create();
    			// 数据准备
    			String userName = "Leftso";
    			// 调用代理接口的方法调用并返回结果
    			String result = cs.sayHello(userName);
    			System.out.println("返回结果:" + result);
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    
    	/**
    	 * 动态调用方式
    	 */
    	public static void cl2() {
    		// 创建动态客户端
    		JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
    		Client client = dcf.createClient("http://localhost:8080/services/CommonService?wsdl");
    		// 需要密码的情况需要加上用户名和密码
    		// client.getOutInterceptors().add(new ClientLoginInterceptor(USER_NAME,
    		// PASS_WORD));
    		Object[] objects = new Object[0];
    		try {
    			// invoke("方法名",参数1,参数2,参数3....);
    			objects = client.invoke("sayHello", "Leftso");
    			System.out.println("返回数据:" + objects[0]);
    		} catch (java.lang.Exception e) {
    			e.printStackTrace();
    		}
    	}
    }

[70]: /images/20220522/75b754bbca014a24846cce2ebd8573e6.png
[70 1]: /images/20220522/95d764d1fc8a4514b22a8e3392ab6624.png
[70 2]: /images/20220522/f978fd24563a417fa8a6bd7cf5c97337.png
[70 3]: /images/20220522/4428793552da4f6e8fee73869f6cbca6.png
[70 4]: /images/20220522/2e2f8370179f40b0866f3711b11cfb2f.png
[70 5]: /images/20220522/6e36b9dae99841b4a5798c9fc0158c24.png