Spring boot +Apache CXF 实现webservice

2018-03-26

添加依赖

<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>1.4.5.RELEASE</version>
		<relativePath /> <!-- lookup parent from repository -->
	</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>

<!-- CXF webservice -->
<dependency>
	<groupId>org.apache.cxf</groupId>
	<artifactId>cxf-spring-boot-starter-jaxws</artifactId>
	<version>3.1.7</version>
</dependency>
<!-- CXF webservice -->

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-test</artifactId>
	<scope>test</scope>
</dependency>

webservice 服务端

接口

@WebService(name = "CommonService", // 暴露服务名称
      targetNamespace = "http://service.webservice.com/"// 命名空间,一般是接口的包名倒序
      )
public interface CommonService {
   @WebMethod
   @WebResult(name = "String", targetNamespace = "")
   public String sayHello(@WebParam(name = "userName") String name);

}

实现类

@WebService(serviceName = "CommonService", // 与接口中指定的name一致
      targetNamespace = "http://service.webservice.com/", // 与接口中的命名空间一致,一般是接口的包名倒
      endpointInterface = "com.webservice.CommonService"// 接口地址
)
@Component
public class CommonServiceImp implements CommonService {

   @Override
   public String sayHello(String name) {
      return "Hello ," + name;
   }

}

配置

@Configuration
public class CxfConfig {

   @Autowired
   CommonService commonService;

   @Bean
   public ServletRegistrationBean dispatcherServlet() {
      return new ServletRegistrationBean(new CXFServlet(), "/services/*");
   }
   @Bean(name = Bus.DEFAULT_BUS_ID)
   public SpringBus springBus() {
      return new SpringBus();
   }
   /**
    * Publishes this endpoint at the given address
    **/
   @Bean
   public Endpoint endpoint() {
      EndpointImpl endpoint = new EndpointImpl(springBus(), commonService);
      endpoint.publish("/CommonService");
      return endpoint;
   }
}

启动webservice 服务端

@SpringBootApplication
public class Application {

   public static void main(String[] args) {
      SpringApplication.run(Application.class, args);
   }
}

访问webservice服务

webservice 客户端调用

private static String        addr="http://127.0.0.1:9000/dwjk/services/CommonService?wsdl";
 private static String methodName = "sayHello";
 private static String namespace="http://service.webservice.com/"
 @Test
 public void sayHello() {
     String param = "liuwang";
     CxfClient.invoke(endpointAddr,namespace,methodName,param);
 }

/**
  * @param wsURL
  * @param namespace
  * @param method
  * @param params
  */
 public static Object[] invoke(String wsURL, String namespace, String method,
                             Object... params) {
     Object[] result;
     long start = System.currentTimeMillis();
     logger.info("【计时】webservice被调用,URL:" + String.valueOf(wsURL));
     ClassLoader cl = Thread.currentThread().getContextClassLoader();
     JaxWsDynamicClientFactory clientFactory = JaxWsDynamicClientFactory
             .newInstance();
     try {
         logger.info("【计时】webservice准备完成 "
                 + (System.currentTimeMillis() - start));
         Client client = clientFactory.createClient(wsURL);
         //设置超时单位为毫秒
         HTTPConduit http = (HTTPConduit) client.getConduit();
         HTTPClientPolicy httpClientPolicy = new HTTPClientPolicy();
         httpClientPolicy.setConnectionTimeout(wsConnectionTimeout); //连接超时
         httpClientPolicy.setAllowChunking(false); //取消块编码
         httpClientPolicy.setReceiveTimeout(receiveTimeout); //响应超时
         http.setClient(httpClientPolicy);
         if (StringUtils.isNotBlank(namespace)) {
             QName qName = new QName(namespace, method);
             return result = client.invoke(qName, params);
         } else {
             return  result = client.invoke(method, params);
         }
     } catch (Exception e) {
         logger.error("调用失败" + "接口：" + wsURL + "方法：" + method);
         throw new RuntimeException("调用webService获取结果出错", e);
     } finally {
         Thread.currentThread().setContextClassLoader(cl);
         logger.info("【计时】webservice结束 "
                 + (System.currentTimeMillis() - start));
     }
 }

拦截器

编写中。。。。