zoukankan      html  css  js  c++  java
  • Apache CXF实现Web Service(1)——不借助重量级Web容器和Spring实现一个纯的JAX-WS web service

    废话少说,先在Eclipse中新建一个Java Project

    (可以不是WTP的Dynamic Web Project)

     

    选择Java Project

    再看pom.xml

    我们使用cxf 3.1.4版本,

    <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/maven-v4_0_0.xsd">  
        <modelVersion>4.0.0</modelVersion>  
        <groupId>com.cnblog.richaaaard.cxfstudy</groupId>  
        <artifactId>cxf-test-standalone-ws-helloworld</artifactId>  
        <packaging>war</packaging>  
        <version>1.0-SNAPSHOT</version>  
        <name>cxf-test-standalone-ws-helloworld Maven Webapp</name>  
        <url>http://maven.apache.org</url>  
          
        <properties>  
    <!-- <cxf.version>2.7.18</cxf.version> -->
    <!-- 注意使用2.x.x版本的同学,下面例子中引入cxf-bundle-jaxrs是不必要的,因为jaxws启动一个服务需要类JaxWsServerFactoryBean在cxf-rt-frontend-jaxws.jar中-->
            <cxf.version>3.1.4</cxf.version>        
        </properties>  
          
        <dependencies>  
            <dependency>  
                <groupId>org.apache.cxf</groupId>  
                <artifactId>cxf-rt-frontend-jaxws</artifactId>  
                <version>${cxf.version}</version>  
            </dependency>  
            <dependency>  
                <groupId>org.apache.cxf</groupId>  
                <artifactId>cxf-rt-transports-http</artifactId>  
                <version>${cxf.version}</version>  
            </dependency>  
            <dependency>  
                <groupId>org.apache.cxf</groupId>  
                <artifactId>cxf-rt-transports-http-jetty</artifactId>  
                <version>${cxf.version}</version>  
            </dependency>  
            <dependency>  
                <groupId>org.apache.cxf</groupId>  
                <artifactId>cxf-rt-ws-security</artifactId>  
                <version>${cxf.version}</version>  
            </dependency>  
            <dependency>  
                <groupId>org.apache.cxf</groupId>  
                <artifactId>cxf-rt-ws-policy</artifactId>  
                <version>${cxf.version}</version>  
            </dependency>  
    <!--         <dependency>   -->
    <!--             <groupId>org.apache.cxf</groupId>   -->
    <!--             <artifactId>cxf-bundle-jaxrs</artifactId>   -->
    <!--             <version>${cxf.version}</version>   -->
    <!--         </dependency>   -->
            <dependency>  
                <groupId>javax.ws.rs</groupId>  
                <artifactId>jsr311-api</artifactId>  
                <version>1.1.1</version>  
            </dependency>  
            <dependency>  
                <groupId>org.slf4j</groupId>  
                <artifactId>slf4j-api</artifactId>  
                <version>1.5.8</version>  
            </dependency>  
            <dependency>  
                <groupId>org.slf4j</groupId>  
                <artifactId>slf4j-simple</artifactId>  
                <version>1.5.8</version>  
            </dependency>  
            <dependency>  
                <groupId>commons-httpclient</groupId>  
                <artifactId>commons-httpclient</artifactId>  
                <version>3.0</version>  
            </dependency>  
            <dependency>  
                <groupId>commons-io</groupId>  
                <artifactId>commons-io</artifactId>  
                <version>2.3</version>  
            </dependency>  
            <dependency>  
                <groupId>junit</groupId>  
                <artifactId>junit</artifactId>  
                <version>4.8.1</version>  
                <scope>test</scope>  
            </dependency>  
        </dependencies>  
          
        <build>  
            <finalName>cxfstudy</finalName>  
            <resources>  
                <resource>  
                    <directory>src/main/resources</directory>  
                </resource>  
                <resource>  
                    <directory>src/main/java</directory>  
                    <includes>  
                        <include>**</include>  
                    </includes>  
                    <excludes>  
                        <exclude>**/*.java</exclude>  
                    </excludes>  
                </resource>  
            </resources>  
            <plugins>  
                <plugin>  
                    <groupId>org.mortbay.jetty</groupId>  
                    <artifactId>maven-jetty-plugin</artifactId>  
                    <configuration>  
                        <contextPath>/</contextPath>  
                        <connectors>  
                            <connector implementation="org.mortbay.jetty.nio.SelectChannelConnector">  
                                <port>9000</port>  
                            </connector>  
                        </connectors>  
                    </configuration>  
                </plugin>  
                <plugin>  
                    <groupId>org.apache.maven.plugins</groupId>  
                    <artifactId>maven-compiler-plugin</artifactId>  
                    <configuration>  
                        <source>1.7</source>  
                        <target>1.7</target>  
                    </configuration>  
                </plugin>  
            </plugins>  
        </build>  
      
    </project>  
    

    另外有例子给出的slf4j是slf4j-jdk14 (http://mvnrepository.com/artifact/org.slf4j/slf4j-jdk14)的版本,如果用jdk5以上的同学可以将其替换成slf4j-simple实现。

    CXF Web Service (Annotation)实现,上代码

    CXF支持两种方式发布一个web service,一种是Java Annotation(Bottom up),另外一种是先定义好wsdl和xsd schema然后通过工具生成(Top down),我们这里的例子先介绍Java Annotation。

    首先我们需要定义一个web service接口类HelloWorld,并加上Annotation

    package com.cnblog.richaaaard.cxftest.standalone.ws.helloworld.services;
    
    import javax.jws.WebMethod;
    import javax.jws.WebParam;
    import javax.jws.WebResult;
    import javax.jws.WebService;
    
    @WebService  
    public interface HelloWorld {  
        @WebMethod  
        @WebResult String sayHi(@WebParam String text);  
    }  
    

    在此我们先不介绍 @WebService、 @WebMethod、@WebResult还有@WebParam如何工作的。

    然后我们需要用HelloWorldImpl来实现这个接口类,

    package com.cnblog.richaaaard.cxftest.standalone.ws.helloworld.services;
    
    public class HelloWorldImpl implements HelloWorld {  
    	public String sayHi(String name) {  
            String msg = "Hello " + name + "!";  
            return msg;  
        }  
    }
    

    发布一个Web Service

    我们先用一个最简单的方式,使用javax.xml.ws.Endpoint来发布

    package com.cnblog.richaaaard.cxftest.standalone.ws.helloworld.server;
    
    import javax.xml.ws.Endpoint;
    
    import com.cnblog.richaaaard.cxftest.standalone.ws.helloworld.services.HelloWorldImpl;
    
    public class SimpleServer {  
    	
        public static void main(String[] args) throws Exception {
            
            System.out.println("Starting Server");
        	HelloWorldImpl implementor = new HelloWorldImpl();
        	String address = "http://localhost:9000/ws/HelloWorld";
        	Endpoint.publish(address, implementor);
        }  
    }
    

    注意:这里的address路径是大小写敏感的,如果发布成"http://localhost:9000/ws/helloWorld",而客户端使用/HelloWorld会找不到服务。

    直接Run As..-> Java Application

      

    我们可以在Eclipse中看到一个jetty服务正常运行

    Starting Server
    128 [main] INFO org.apache.cxf.service.factory.ReflectionServiceFactoryBean - Creating Service {http://services.helloworld.ws.standalone.cxftest.richaaaard.cnblog.com/}HelloWorldImplService from class com.cnblog.richaaaard.cxftest.standalone.ws.helloworld.services.HelloWorld
    487 [main] INFO org.apache.cxf.endpoint.ServerImpl - Setting the server's publish address to be http://localhost:9000/ws/HelloWorld
    506 [main] INFO org.eclipse.jetty.server.Server - jetty-8.1.15.v20140411
    554 [main] INFO org.eclipse.jetty.server.AbstractConnector - Started SelectChannelConnector@localhost:9000
    

    此时,我们通过浏览器访问http://localhost:9000/ws/HelloWorld?WSDL

    如何访问我们发布的这个服务呢?

    我们利用jaxws中的JaxWsProxyFactoryBean来消费这个服务

    package com.cnblog.richaaaard.cxftest.standalone.ws.helloworld.client;
    
    import org.apache.cxf.interceptor.LoggingInInterceptor;
    import org.apache.cxf.interceptor.LoggingOutInterceptor;
    import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
    
    import com.cnblog.richaaaard.cxftest.standalone.ws.helloworld.services.HelloWorld;
    
    public class Client {  
        public static void main(String[] args) {  
            JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();  
            factory.getInInterceptors().add(new LoggingInInterceptor());
            factory.getOutInterceptors().add(new LoggingOutInterceptor());
            factory.setServiceClass(HelloWorld.class);  
            factory.setAddress("http://localhost:9000/ws/HelloWorld");  
            HelloWorld helloworld = (HelloWorld) factory.create();  
            String reply = helloworld.sayHi("HI");
            System.out.println("Server said: " + reply);
            System.exit(0);
        }  
    } 
    

      同样右键选择Client.java,Run As.. ->Java Application,我们可以看到运行后台执行的日志最后成功返回“Server said: Hello HI!”

    114 [main] INFO org.apache.cxf.service.factory.ReflectionServiceFactoryBean - Creating Service {http://services.helloworld.ws.standalone.cxftest.richaaaard.cnblog.com/}HelloWorldService from class com.cnblog.richaaaard.cxftest.standalone.ws.helloworld.services.HelloWorld
    531 [main] INFO org.apache.cxf.services.HelloWorldService.HelloWorldPort.HelloWorld - Outbound Message
    ---------------------------
    ID: 1
    Address: http://localhost:9000/ws/HelloWorld
    Encoding: UTF-8
    Http-Method: POST
    Content-Type: text/xml
    Headers: {Accept=[*/*], SOAPAction=[""]}
    Payload: <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"><soap:Body><ns2:sayHi xmlns:ns2="http://services.helloworld.ws.standalone.cxftest.richaaaard.cnblog.com/"><arg0>HI</arg0></ns2:sayHi></soap:Body></soap:Envelope>
    --------------------------------------
    748 [main] INFO org.apache.cxf.services.HelloWorldService.HelloWorldPort.HelloWorld - Inbound Message
    ----------------------------
    ID: 1
    Response-Code: 200
    Encoding: UTF-8
    Content-Type: text/xml;charset=UTF-8
    Headers: {Content-Length=[258], content-type=[text/xml;charset=UTF-8], Server=[Jetty(8.1.15.v20140411)]}
    Payload: <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"><soap:Body><ns2:sayHiResponse xmlns:ns2="http://services.helloworld.ws.standalone.cxftest.richaaaard.cnblog.com/"><return>Hello HI!</return></ns2:sayHiResponse></soap:Body></soap:Envelope>
    --------------------------------------
    Server said: Hello HI!
    

      上面Outbound Message和Inbound Message是我们加的两个Logging Interceptor输出的日志,关于Interceptor的原理和更多使用方式,会专题介绍。

    这样就完成了一个Web Service的发布和消费

    *服务端的扩展

    除了用一个最简单的javax.xml.ws.Endpoint来发布CXF web service,我们还可以使用cxf-rt-frontend-jaxws.jar中的JaxWsServerFactoryBean来发布一个web service,它可以让我们更多的控制web service的行为,比如说加Logging Interceptor之类

    package com.cnblog.richaaaard.cxftest.standalone.ws.helloworld.server;
    
    import org.apache.cxf.interceptor.LoggingInInterceptor;
    import org.apache.cxf.interceptor.LoggingOutInterceptor;
    import org.apache.cxf.jaxws.JaxWsServerFactoryBean;
    
    import com.cnblog.richaaaard.cxftest.standalone.ws.helloworld.services.HelloWorld;
    import com.cnblog.richaaaard.cxftest.standalone.ws.helloworld.services.HelloWorldImpl;
    
    public class Server {  
    	
        public static void main(String[] args) throws Exception {  
        	JaxWsServerFactoryBean factory = new JaxWsServerFactoryBean();  
            factory.setServiceClass(HelloWorld.class);  
            HelloWorldImpl implementor = new HelloWorldImpl();
            factory.setServiceBean(implementor);
            factory.getInInterceptors().add(new LoggingInInterceptor());
            factory.getOutInterceptors().add(new LoggingOutInterceptor());
            factory.setAddress("http://localhost:9000/ws/HelloWorld");  
            factory.create();  
      
            System.out.println("Server start...");  
            Thread.sleep(60 * 1000);  
            System.out.println("Server exit...");  
            System.exit(0);
        }  
    }
    

      

    参考:

    http://blog.csdn.net/kongxx/article/details/7525476

    https://cwiki.apache.org/confluence/display/CXF20DOC/A+simple+JAX-WS+service

  • 相关阅读:
    cgi、wsgi、uwsgi 与 uWSGI
    docker入门
    python模块学习 -openpyxl
    linux考试题
    爬虫-scrapy的中间件
    scrapy框架简单学习
    爬虫中的selenium简单学习及案例
    2.python数据结构的性能分析
    1.数据结构&算法的引言+时间复杂度
    Jenkins—Master/Slave模式
  • 原文地址:https://www.cnblogs.com/richaaaard/p/5011012.html
Copyright © 2011-2022 走看看