springboot整合cxf

怼烎@ 2021-12-18 23:13 297阅读 0赞

#  代码结构 #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hsXzE4MDM_size_16_color_FFFFFF_t_70][]

# 配置类  #

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;
    
    import com.asiainfo.group.webservice.HelloService;
    
    @Configuration
    public class CxfConfig {
    	@Autowired
        private Bus bus;
    
        @Autowired
        HelloService helloService;
    
        //默认是service
        /*@Bean
        public ServletRegistrationBean dispatcherServlet() {
            return new ServletRegistrationBean(new CXFServlet(), "/soap/*");
        }*/
    
        
        @Bean
        public Endpoint endpoint() {
            EndpointImpl endpoint = new EndpointImpl(bus, helloService);
            endpoint.publish("/hello");
            return endpoint;
        }
    
    }

# webservice接口  #

import javax.jws.WebMethod;
    import javax.jws.WebParam;
    import javax.jws.WebResult;
    import javax.jws.WebService;
    
    @WebService
    public interface HelloService {
    	//标注该方法为webservice暴露的方法,用于向外公布，它修饰的方法是webservice方法，去掉也没影响的，类似一个注释信息
    	@WebMethod
        public String getUsername(@WebParam(name = "userId") String userId);
    
        @WebMethod
        @WebResult(name="String",targetNamespace="")
        public String getUserAge(@WebParam(name = "userId") String userId);
    
    }

# webservice接口实现 #

import javax.jws.WebService;
    
    import org.springframework.stereotype.Component;
    
    import com.asiainfo.group.webservice.HelloService;
    
    
    
    @WebService(serviceName="helloService",//对外发布的服务名
    targetNamespace="http://webservice.group.asiainfo.com",//指定你想要的名称空间，通常使用使用包名反转
    endpointInterface="com.asiainfo.group.webservice.HelloService")//服务接口全路径, 指定做SEI（Service EndPoint Interface）服务端点接口
    @Component
    public class HelloServiceImpl implements HelloService{
    
    	@Override
    	public String getUsername(String userId) {
    		
    		return userId+"：zhangsan";
    	}
    
    	@Override
    	public String getUserAge(String userId) {
    		
    		return userId+"：18";
    	}
    
    }

# cxf客户端动态调用  #

import javax.xml.namespace.QName;
    
    import org.apache.cxf.endpoint.Client;
    import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
    
    
    public class CxfClient {
    
    	
    
        public static void main(String[] args) throws Exception {
        	String wsdl="http://localhost:8080/services/hello?wsdl";
        	//最后的斜杠不能少
        	String targetNamespace = "http://webservice.group.asiainfo.com/";
            String methodName ="getUsername";
            String userId="100001";
            Object[] params=new Object[]{userId};
            
            // 创建动态客户端
            JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
            Client client = dcf.createClient(wsdl);
            
            // 需要密码的情况需要加上用户名和密码
            // client.getOutInterceptors().add(new ClientLoginInterceptor(USER_NAME, PASS_WORD));
            Object[] objects;
                
            objects = client.invoke(new QName(targetNamespace, methodName), params);
            System.out.println("返回数据:" + objects[0]);
            
        }
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hsXzE4MDM_size_16_color_FFFFFF_t_70]: /images/20211219/6f24e6fc2d1943d88cdbbe78629c7873.png