spring和CXF集成来实现webservices

简介: 最近在负责一个大系统的实施,经过需求分析之后,将系统分为5个子系统,我们采用SOA架构,分模块开发。项目组中最大的一个争议就是,子系统之间的通讯问题,大家提出了两种方案:一、如果5个子系统最后发布为5个war包,那么相互之间就不能直接调用,而是需要通过webservices等通讯方式,那会增加一些开发工作量;二、如果5个子系统合并在一个大工程中,下面放所有的模块,那子系统间的访问很简单,但
最近在负责一个大系统的实施,经过需求分析之后,将系统分为5个子系统,我们采用SOA架构,分模块开发。项目组中最大的一个争议就是,子系统之间的通讯问题,大家提出了两种方案:一、如果5个子系统最后发布为5个war包,那么相互之间就不能直接调用,而是需要通过webservices等通讯方式,那会增加一些开发工作量;二、如果5个子系统合并在一个大工程中,下面放所有的模块,那子系统间的访问很简单,但是日常的开发管理会存在比较大的风险。

从管理的角度来看,我是比较偏向第一种方案,因为这样结构更清晰更简单,开发人员之间的相互影响也较小,还有一个好处就是,可以将不同的子系统发布在不同的应用服务器上,避免了由于某一个子系统崩溃导致整个系统的崩溃。于是,我对webservices的开发技术进行了研究,发现用spring和CXF集成来发布webservice和调用webservice都非常的简单,也加大了我选择第一种方案的决心。下面就简单介绍一个spring和CXF集成的示例。

一、 准备工作。
        1、下载apache-cxf的应用包,地址:http://cxf.apache.org/download.html,我选择的是2.4.1版本。

二、发布webservices
1
 新建web project ,并加入apache-cxf-2.4.1\lib所有包,编写要发布的web service 接口和实现.这一步,与前面一样。

1)创建一个接口类,并加上webservice标记

       import javax.jws.WebService;

@WebService 

public interface HelloWorld {  

     public String sayHello(String text);  

}

2)创建上面这个接口的实现类
       import javax.jws.WebService;  

@WebService(endpointInterface="test.HelloWorld")  

public class HelloWorldImpl implements HelloWorld {  

      public String sayHello(String text) {  

                  return "Hello" + text ;  

    }  

  } 

@WebService 注解表示是要发布的web 服务,endpointInterface的值是该服务类对应的接口。

2. spring-cxf.xml配置发布的web service 

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

    xmlns:jaxws="http://cxf.apache.org/jaxws"

    xsi:schemaLocation="

http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd

http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd">

    <import resource="classpath:META-INF/cxf/cxf.xml" /> 

    <import resource="classpath:META-INF/cxf/cxf-extension-soap.xml" /> 

    <import resource="classpath:META-INF/cxf/cxf-servlet.xml" /> 

 

    <bean id="hello" class="test.HelloWorldImpl" /> 

    <jaxws:endpoint id="helloWorld" implementor="#hello" 

        address="/HelloWorld" /> 

  </beans>

注意:<jaxws:endpoint id="helloWorld" implementor="#hello" 

        address="/HelloWorld" /> 

id:指在spring配置的beanID.

Implementor:指明具体的实现类.

Address:指明这个web service的相对地址,

3. 配置web.xml文件:

<?xml version="1.0" encoding="UTF-8"?> 

<web-app version="2.4" xmlns="http://java.sun.com/xml/ns/j2ee" 

    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 

    xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee   

    http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd"> 

    <context-param> 

        <param-name>contextConfigLocation</param-name> 
                   <!--spring配置文件放在WEB-INF目录下-->

        <param-value>/WEB-INF/spring-cxf.xml</param-value> 

    </context-param> 

    <listener> 

        <listener-class> 

         org.springframework.web.context.ContextLoaderListener 

        </listener-class> 

    </listener> 
          <servlet> 

        <servlet-name>CXFServlet</servlet-name> 

        <servlet-class> 

            org.apache.cxf.transport.servlet.CXFServlet  

        </servlet-class> 

        <load-on-startup>1</load-on-startup> 

    </servlet> 

    <servlet-mapping> 

        <servlet-name>CXFServlet</servlet-name> 

        <url-pattern>/*</url-pattern> 

    </servlet-mapping> 

</web-app> 

4部署到tomcat服务器,输入:http://localhost:8080/<web-app-name>/HelloWorld?wsdl,将显示这个web servicewsdl.

注意:如果web.xml配置<servlet-name>CXFServlet</servlet-name> 

        <url-pattern>/ws/*</url-pattern> 

则访问地址为:http://localhost:8080/<web-app-name>/ws/HelloWorld?wsdl
到此webservices就发布成功了。


三、创建一个客户端来调用webservices
1、 同样新建 java project , 并加入 a pache-cxf-2.0.7\lib 所有包,添加到Build Path
2、将webservice的接口类导出成jar包,也添加到Build Path,主要目的是客户端要用到服务端的HelloWorld这个类。如果不想导入这个jar包也可以,只要在客户端创建一个一摸一样的接口类:HelloWorld,特别要注意以下两点:
    1)接口前面要添加@Webservice的标记,不然会抛出一个 javax.xml.ws.WebServiceException: Could not find wsdl:binding operation info for web method sayHelloWorld.
    2)包路径也要一样,不然会抛出一个ClassCastException: $Proxy29 cannot be cast to...
3、 配置 spring-client.xml

<beans xmlns="http://www.springframework.org/schema/beans"

    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

    xmlns:jaxws="http://cxf.apache.org/jaxws"

    xsi:schemaLocation="

http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd

http://cxf.apache.org/jaxws http://cxf.apache.org/schema/jaxws.xsd">

      <!-- 这个class的包路径和类名和服务端提供web服务的接口一致-->

    <bean id="client" class="test.HelloWorld"

      factory-bean="clientFactory" factory-method="create"/>

   

    <bean id="clientFactory" class="org.apache.cxf.jaxws.JaxWsProxyFactoryBean">
     <!-- 这个class的包路径和类名和服务端提供web服务的接口一致-->

     <property name="serviceClass" value="test.HelloWorld"/>
     <!-- 这个address一定要注意,正确的-->

     <property name="address" value="http://localhost:8080/<web-app-name>/HelloWorld"/>

    </bean>     

</beans>

4.测试:

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

 

import test.HelloWorld;

 

public class Test {  

     

    public static void main(String[] args) {  

 

        ApplicationContext ctx = new ClassPathXmlApplicationContext(  

                "spring-client.xml");  

        HelloWorld client = (HelloWorld) ctx.getBean("client");  

        String result = client.sayHello("Glen!");  

        System.out.println(result);  

    }  

结果输出“Hello,Glen!”,测试通过,至此一个webservice的调用也成功了。
目录
相关文章
|
3月前
|
Java Maven Docker
gitlab-ci 集成 k3s 部署spring boot 应用
gitlab-ci 集成 k3s 部署spring boot 应用
|
5月前
|
资源调度 Java 调度
Spring Cloud Alibaba 集成分布式定时任务调度功能
定时任务在企业应用中至关重要,常用于异步数据处理、自动化运维等场景。在单体应用中,利用Java的`java.util.Timer`或Spring的`@Scheduled`即可轻松实现。然而,进入微服务架构后,任务可能因多节点并发执行而重复。Spring Cloud Alibaba为此发布了Scheduling模块,提供轻量级、高可用的分布式定时任务解决方案,支持防重复执行、分片运行等功能,并可通过`spring-cloud-starter-alibaba-schedulerx`快速集成。用户可选择基于阿里云SchedulerX托管服务或采用本地开源方案(如ShedLock)
151 1
|
1月前
|
XML Java API
Spring Boot集成MinIO
本文介绍了如何在Spring Boot项目中集成MinIO,一个高性能的分布式对象存储服务。主要步骤包括:引入MinIO依赖、配置MinIO属性、创建MinIO配置类和服务类、使用服务类实现文件上传和下载功能,以及运行应用进行测试。通过这些步骤,可以轻松地在项目中使用MinIO的对象存储功能。
|
2月前
|
消息中间件 Java Kafka
什么是Apache Kafka?如何将其与Spring Boot集成?
什么是Apache Kafka?如何将其与Spring Boot集成?
72 5
|
2月前
|
消息中间件 Java Kafka
Spring Boot 与 Apache Kafka 集成详解:构建高效消息驱动应用
Spring Boot 与 Apache Kafka 集成详解:构建高效消息驱动应用
57 1
|
2月前
|
消息中间件 监控 Java
您是否已集成 Spring Boot 与 ActiveMQ?
您是否已集成 Spring Boot 与 ActiveMQ?
59 0
|
3月前
|
前端开发 Java 程序员
springboot 学习十五:Spring Boot 优雅的集成Swagger2、Knife4j
这篇文章是关于如何在Spring Boot项目中集成Swagger2和Knife4j来生成和美化API接口文档的详细教程。
298 1
|
3月前
|
存储 前端开发 Java
Spring Boot 集成 MinIO 与 KKFile 实现文件预览功能
本文详细介绍如何在Spring Boot项目中集成MinIO对象存储系统与KKFileView文件预览工具,实现文件上传及在线预览功能。首先搭建MinIO服务器,并在Spring Boot中配置MinIO SDK进行文件管理;接着通过KKFileView提供文件预览服务,最终实现文档管理系统的高效文件处理能力。
461 11
|
3月前
|
Java Spring
springboot 学习十一:Spring Boot 优雅的集成 Lombok
这篇文章是关于如何在Spring Boot项目中集成Lombok,以简化JavaBean的编写,避免冗余代码,并提供了相关的配置步骤和常用注解的介绍。
141 0
|
5月前
|
消息中间件 安全 Java
Spring Boot 基于 SCRAM 认证集成 Kafka 的详解
【8月更文挑战第4天】本文详解Spring Boot结合SCRAM认证集成Kafka的过程。SCRAM为Kafka提供安全身份验证。首先确认Kafka服务已启用SCRAM,并准备认证凭据。接着,在`pom.xml`添加`spring-kafka`依赖,并在`application.properties`中配置Kafka属性,包括SASL_SSL协议与SCRAM-SHA-256机制。创建生产者与消费者类以实现消息的发送与接收功能。最后,通过实际消息传递测试集成效果与认证机制的有效性。
201 4