SpringBoot 基于cxf 发布WebService服务并用WebService服务调用

青旅半醒 2022-05-16 07:45 304阅读 0赞

先创建两个spring boot 项目，分别用于服务端和客户端，这里就不进行说明了

**一：服务端**

修改pom.xml文件，添加依赖

<?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.fus</groupId>
    	<artifactId>fus-interface-service</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<packaging>jar</packaging>
    
    	<name>fus-interface-service</name>
    	<description>Demo project for Spring Boot</description>
    
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>1.5.9.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-web</artifactId>
    		</dependency>
    
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    		
    		
    		<dependency>
    			<groupId>org.apache.httpcomponents</groupId>
    			<artifactId>httpclient</artifactId>
    			<version>4.5.4</version>
    		</dependency>
    
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>fastjson</artifactId>
    			<version>1.1.41</version>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-devtools</artifactId>
    			<optional>true</optional> 
    		</dependency>
    
    		
    		<dependency>
    			<groupId>org.apache.cxf</groupId>
    			<artifactId>cxf-spring-boot-starter-jaxws</artifactId>
    			<version>3.1.11</version>
    		</dependency>
    		
    
    		<dependency>
    			<groupId>org.scala-lang</groupId>
    			<artifactId>scala-library</artifactId>
    			<version>2.11.0</version>
    		</dependency>
    	</dependencies>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    		</plugins>
    	</build>
    
    
    </project>

新建服务端接口

package com.fus.webservice;
    
    import javax.jws.WebMethod;
    import javax.jws.WebParam;
    import javax.jws.WebResult;
    import javax.jws.WebService;
    
    /**
     * webservice测试接口
     * @author fushuai
     * @date 2018.8.17
     */
    @WebService(name = "TestService", // 暴露服务名称
    targetNamespace = "http://service.fus.com"// 命名空间,一般是接口的包名倒序
    )
    public interface TestService {
        
        @WebMethod
        @WebResult(name = "String", targetNamespace = "")
        String sendMessage(@WebParam(name = "username") String username);
    }

新建服务端实现接口

package com.fus.webservice;
    
    import javax.jws.WebService;
    
    import org.springframework.stereotype.Component;
    
    /**
     * webservice测试接口实现
     * @author fushuai
     * @date 2018.8.17
     */
    @WebService(serviceName = "TestService", // 与接口中指定的name一致
    targetNamespace = "http://service.fus.com", // 与接口中的命名空间一致,一般是接口的包名倒
    endpointInterface = "com.fus.webservice.TestService"// 接口地址
    )
    @Component
    public class TestServiceImpl implements TestService {
    
        @Override
        public String sendMessage(String username) {
            System.out.println("服务端运行");
            return "hello hahah"+username;
        }
    
    }

新建cxf配置

package com.fus.webservice;
    
    import javax.xml.ws.Endpoint;
    
    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;
    /**
     * cxf配置
     * @author fushuai
     * @date 2018.8.17
     */
    @Configuration
    public class CxfConfig {
        
        @Autowired
        private Bus bus;
        
        @Autowired
        private TestService testService;
        
        @Bean
        public Endpoint endpoint(){
            EndpointImpl endpoint = new EndpointImpl(bus, testService);
            endpoint.publish("/TestService");
            return endpoint;
        }
    }

默认服务在Host:port/services/*\**路径下   
将TestService接口发布在了路径/services/TestService下，运行访问（[http://localhost:8080/services/TestService?wsdl][http_localhost_8080_services_TestService_wsdl]）路径，看见这个界面说明发布成功，

![70][]

二**：客户端**

package webservice;
    
    import org.apache.cxf.endpoint.Client;
    import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
    import org.junit.Test;
    
    /**
     * webservice客户端
     * @author fushuai
     * @date 2018.8.17
     */
    public class WebServiceTest {
    
        @Test
        public void testSend1() {
    
            // 创建动态客户端
            JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
            Client client = dcf.createClient("http://localhost:8080/services/TestService?wsdl");
    
            // 需要密码的情况需要加上用户名和密码
            // client.getOutInterceptors().add(new ClientLoginInterceptor(USER_NAME,PASS_WORD));
            Object[] objects = new Object[0];
            try {
    
                // invoke("方法名",参数1,参数2,参数3....);
                objects = client.invoke("sendMessage", "wyjfxcf");
                System.out.println("返回数据:" + objects[0]);
            } catch (java.lang.Exception e) {
            	System.out.println(111);
                e.printStackTrace();
            }
        }
    }

运行结果：

八月 17, 2018 5:22:41 下午 org.apache.cxf.common.jaxb.JAXBUtils logGeneratedClassNames
    信息: Created classes: com.fus.service.ObjectFactory, com.fus.service.SendMessage, com.fus.service.SendMessageResponse
    返回数据:hello hahahwyjfxcf

客户端代码下载：[https://gitee.com/xzcvr/fus-interface-client/tree/master/][https_gitee.com_xzcvr_fus-interface-client_tree_master]

服务端代码下载：[https://gitee.com/xzcvr/wyj-interface-service-master][https_gitee.com_xzcvr_wyj-interface-service-master]

[http_localhost_8080_services_TestService_wsdl]: http://localhost:8080/services/TestService?wsdl
[70]: /images/20220516/72288233b55b433f838fb47805575bb6.png
[https_gitee.com_xzcvr_fus-interface-client_tree_master]: https://gitee.com/xzcvr/fus-interface-client/tree/master/
[https_gitee.com_xzcvr_wyj-interface-service-master]: https://gitee.com/xzcvr/wyj-interface-service-master