當(dāng)前位置：首頁(yè) > 人文社科 > 生活经验 >内容正文

生活经验

Spring整合CXF，发布RSETful 风格WebService

發(fā)布時(shí)間：2023/11/27 生活经验 22 豆豆

生活随笔收集整理的這篇文章主要介紹了 Spring整合CXF，发布RSETful 风格WebService 小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

這篇文章是承接之前CXF整合Spring的這個(gè)項(xiàng)目示例的延伸，所以有很大一部分都是一樣的。關(guān)于發(fā)布CXF WebServer和Spring整合CXF這里就不再多加贅述了。如果你對(duì)Spring整合CXF WebService不了解，具體你可以參看這兩篇文章：

http://www.cnblogs.com/hoojo/archive/2011/03/30/1999563.html

http://www.cnblogs.com/hoojo/archive/2012/07/13/2590593.html

如果你不了解restful風(fēng)格的WebService，你可以參考：

http://www.oracle.com/technetwork/articles/javase/index-137171.html

SpringMVC對(duì)RESTful的支持：

http://www.cnblogs.com/hoojo/archive/2011/06/10/2077422.html

使用 Jersey框架，搭建RESTful WebService（這個(gè)也比較簡(jiǎn)單）

http://www.ibm.com/developerworks/cn/web/wa-aj-tomcat/

官方文檔：http://jersey.java.net/nonav/documentation/latest/user-guide.html#d4e8

其中，比較常用的RESTful框架就有Jersey、Spring REST、CXF RESTful，這些都可以很好的整合Spring框架，發(fā)布也相當(dāng)?shù)暮?jiǎn)單。且簡(jiǎn)單、易用、易上手，文檔也比較豐富。

開發(fā)環(huán)境：
System：Windows
JavaEE Server：tomcat6
JavaSDK： jdk6+
IDE：eclipse、MyEclipse 6.6
?
開發(fā)依賴庫(kù)：
JDK6、 JavaEE5、CXF-2.3.3、Spring 3.0.4
Email：hoojo_@126.com
Blog：http://blog.csdn.net/IBM_hoojo
http://hoojo.cnblogs.com/
http://hoojo.blogjava.net

下面我們就接著http://www.cnblogs.com/hoojo/archive/2011/03/30/1999563.html這篇文章，開始我們CXF RESTful WebService的旅程，enjoy~！^_*

準(zhǔn)備工作

首先，你需要添加相關(guān)的jar包

其中，jsr331-api-1.1.1.jar是必須的，利用CXF發(fā)布REST服務(wù)得用到它，在cxf的lib庫(kù)中可以找到這個(gè)jar。

下載地址：http://www.apache.org/dyn/closer.cgi?path=/cxf/2.3.11/apache-cxf-2.3.11.zip

其它的jar包都是非必須的！

JavaEntity

package com.hoo.entity;

import java.util.Map;

import javax.xml.bind.annotation.XmlRootElement;

/**

 * <b>function:</b> MapBean 封裝Map集合元素

 * @author hoojo

 * @createDate 2012-7-20 下午01:22:31

 * @file MapBean.java

 * @package com.hoo.entity

 * @project CXFWebService

 * @blog http://blog.csdn.net/IBM_hoojo

 * @email hoojo_@126.com

 * @version 1.0

*/

@XmlRootElement

public class MapBean {

    private Map<String, User> map;

    //@XmlElement(type = User.class)

    public Map<String, User> getMap() {

        return map;

    public void setMap(Map<String, User> map) {

        this.map = map;

package com.hoo.entity;

import java.util.HashMap;

import java.util.List;

import javax.xml.bind.annotation.XmlRootElement;

/**

 * <b>function:</b> Users Entity

 * @author hoojo

 * @createDate 2011-3-18 上午09:27:31

 * @file Users.java

 * @package com.hoo.entity

 * @project CXFWebService

 * @blog http://blog.csdn.net/IBM_hoojo

 * @email hoojo_@126.com

 * @version 1.0

*/

@XmlRootElement(name = "UserInfos")

public class Users {

    private List<User> users;

    private User[] userArr;

    private HashMap<String, User> maps;

   // getter/setter

package com.hoo.entity;

import java.io.Serializable;

import javax.xml.bind.annotation.XmlRootElement;

/**

 * <b>function:</b>User Entity

 * @author hoojo

 * @createDate Dec 16, 2010 10:20:02 PM

 * @file User.java

 * @package com.hoo.entity

 * @project AxisWebService

 * @blog http://blog.csdn.net/IBM_hoojo

 * @email hoojo_@126.com

 * @version 1.0

*/

@XmlRootElement(name = "UserInfo")

public class User implements Serializable {

    private static final long serialVersionUID = 677484458789332877L;

    private int id;

    private String name;

    private String email;

    private String address;

    //getter/setter

    @Override

    public String toString() {

        return this.id + "#" + this.name + "#" + this.email + "#" + this.address;

一、定義你的WebService的接口RESTSample.java，代碼如下

package com.hoo.service;

import java.io.IOException;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import javax.ws.rs.Consumes;

import javax.ws.rs.DELETE;

import javax.ws.rs.GET;

import javax.ws.rs.POST;

import javax.ws.rs.PUT;

import javax.ws.rs.Path;

import javax.ws.rs.PathParam;

import javax.ws.rs.Produces;

import javax.ws.rs.core.Context;

import javax.ws.rs.core.MediaType;

import com.hoo.entity.MapBean;

import com.hoo.entity.User;

import com.hoo.entity.Users;

/*

     注釋（Annotation）：在 javax.ws.rs.* 中定義，是 JAX-RS (JSR 311) 規(guī)范的一部分。

    @Path：定義資源基 URI。由上下文根和主機(jī)名組成，資源標(biāo)識(shí)符類似于 http://localhost:8080/RESTful/rest/hello。

    @GET：這意味著以下方法可以響應(yīng) HTTP GET 方法。

    @Produces：以純文本方式定義響應(yīng)內(nèi)容 MIME 類型。

    @Context： 使用該注釋注入上下文對(duì)象，比如 Request、Response、UriInfo、ServletContext 等。

    @Path("{contact}")：這是 @Path 注釋，與根路徑 “/contacts” 結(jié)合形成子資源的 URI。

    @PathParam("contact")：該注釋將參數(shù)注入方法參數(shù)的路徑，在本例中就是聯(lián)系人 id。其他可用的注釋有 @FormParam、@QueryParam 等。

    @Produces：響應(yīng)支持多個(gè) MIME 類型。在本例和上一個(gè)示例中，APPLICATION/XML 將是默認(rèn)的 MIME 類型。

*/

/**

 * <b>function:</b> CXF RESTful風(fēng)格WebService

 * @author hoojo

 * @createDate 2012-7-20 下午01:23:04

 * @file RESTSampleSource.java

 * @package com.hoo.service

 * @project CXFWebService

 * @blog http://blog.csdn.net/IBM_hoojo

 * @email hoojo_@126.com

 * @version 1.0

*/

@Path(value = "/sample")

public interface RESTSample {

    @GET

    @Produces(MediaType.TEXT_PLAIN)

    public String doGet();

    @GET

    @Produces(MediaType.TEXT_PLAIN)

    @Path("/request/{param}")

    public String doRequest(@PathParam("param") String param,

            @Context HttpServletRequest servletRequest, @Context HttpServletResponse servletResponse);

    @GET

    @Path("/bean/{id}")

    @Produces({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON })

    public User getBean(@PathParam("id") int id);

    @GET

    @Path("/list")

    @Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })

    public Users getList();

    @GET

    @Path("/map")

    @Produces({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON })

    public MapBean getMap();

/*

        @Consumes：聲明該方法使用 HTML FORM。

        @FormParam：注入該方法的 HTML 屬性確定的表單輸入。

        @Response.created(uri).build()： 構(gòu)建新的 URI 用于新創(chuàng)建的聯(lián)系人（/contacts/{id}）并設(shè)置響應(yīng)代碼（201/created）。

        您可以使用 http://localhost:8080/Jersey/rest/contacts/<id> 訪問(wèn)新聯(lián)系人

*/

    @POST

    @Path("/postData")

    public User postData(User user) throws IOException;

    @PUT

    @Path("/putData/{id}")

    @Consumes(MediaType.APPLICATION_XML)

    public User putData(@PathParam("id") int id, User user);

    @DELETE

    @Path("/removeData/{id}")

    public void deleteData(@PathParam("id") int id);

二、RESTSample接口的實(shí)現(xiàn)，這里我們只是簡(jiǎn)單的實(shí)現(xiàn)下，并不是涉及實(shí)際的具體業(yè)務(wù)

package com.hoo.service;

import java.io.IOException;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import javax.ws.rs.DELETE;

import javax.ws.rs.GET;

import javax.ws.rs.POST;

import javax.ws.rs.PUT;

import javax.ws.rs.Path;

import javax.ws.rs.PathParam;

import javax.ws.rs.Produces;

import javax.ws.rs.core.Context;

import javax.ws.rs.core.MediaType;

import javax.ws.rs.core.Request;

import javax.ws.rs.core.UriInfo;

import com.hoo.entity.MapBean;

import com.hoo.entity.User;

import com.hoo.entity.Users;

/*

     注釋（Annotation）：在 javax.ws.rs.* 中定義，是 JAX-RS (JSR 311) 規(guī)范的一部分。

    @Path：定義資源基 URI。由上下文根和主機(jī)名組成，資源標(biāo)識(shí)符類似于 http://localhost:8080/RESTful/rest/hello。

    @GET：這意味著以下方法可以響應(yīng) HTTP GET 方法。

    @Produces：以純文本方式定義響應(yīng)內(nèi)容 MIME 類型。

    @Context： 使用該注釋注入上下文對(duì)象，比如 Request、Response、UriInfo、ServletContext 等。

    @Path("{contact}")：這是 @Path 注釋，與根路徑 “/contacts” 結(jié)合形成子資源的 URI。

    @PathParam("contact")：該注釋將參數(shù)注入方法參數(shù)的路徑，在本例中就是聯(lián)系人 id。其他可用的注釋有 @FormParam、@QueryParam 等。

    @Produces：響應(yīng)支持多個(gè) MIME 類型。在本例和上一個(gè)示例中，APPLICATION/XML 將是默認(rèn)的 MIME 類型。

*/

/**

 * <b>function:</b> CXF RESTful風(fēng)格WebService

 * @author hoojo

 * @createDate 2012-7-20 下午01:23:04

 * @file RESTSampleSource.java

 * @package com.hoo.service

 * @project CXFWebService

 * @blog http://blog.csdn.net/IBM_hoojo

 * @email hoojo_@126.com

 * @version 1.0

*/

@Path(value = "/sample")

public class RESTSampleSource implements RESTSample {

    @Context

    private UriInfo uriInfo;

    @Context

    private Request request;

    @GET

    @Produces(MediaType.TEXT_PLAIN)

    public String doGet() {

        return "this is get rest request";

    @GET

    @Produces(MediaType.TEXT_PLAIN)

    @Path("/request/{param}")

    public String doRequest(@PathParam("param") String param,

            @Context HttpServletRequest servletRequest, @Context HttpServletResponse servletResponse) {

        System.out.println(servletRequest);

        System.out.println(servletResponse);

        System.out.println(servletRequest.getParameter("param"));

        System.out.println(servletRequest.getContentType());

        System.out.println(servletResponse.getCharacterEncoding());

        System.out.println(servletResponse.getContentType());

        return "success";

    @GET

    @Path("/bean/{id}")

    @Produces({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON })

    public User getBean(@PathParam("id") int id) {

        System.out.println("####getBean#####");

        System.out.println("id:" + id);

        System.out.println("Method:" + request.getMethod());

        System.out.println("uri:" + uriInfo.getPath());

        System.out.println(uriInfo.getPathParameters());

        User user = new User();

        user.setId(id);

        user.setName("JojO");

        return user;

    @GET

    @Path("/list")

    @Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })

    public Users getList() {

        System.out.println("####getList#####");

        System.out.println("Method:" + request.getMethod());

        System.out.println("uri:" + uriInfo.getPath());

        System.out.println(uriInfo.getPathParameters());

        List<User> list = new ArrayList<User>();

        User user = null;

        for (int i = 0; i < 4;i ++) {

            user = new User();

            user.setId(i);

            user.setName("JojO-" + i);

            list.add(user);

        Users users = new Users();

        users.setUsers(list);

        return users;

    @GET

    @Path("/map")

    @Produces({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON })

    public MapBean getMap() {

        System.out.println("####getMap#####");

        System.out.println("Method:" + request.getMethod());

        System.out.println("uri:" + uriInfo.getPath());

        System.out.println(uriInfo.getPathParameters());

        Map<String, User> map = new HashMap<String, User>();

        User user = null;

        for (int i = 0; i < 4;i ++) {

            user = new User();

            user.setId(i);

            user.setName("JojO-" + i);

            map.put("key-" + i, user);

        MapBean bean = new MapBean();

        bean.setMap(map);

        return bean;

/*

        @Consumes：聲明該方法使用 HTML FORM。

        @FormParam：注入該方法的 HTML 屬性確定的表單輸入。

        @Response.created(uri).build()： 構(gòu)建新的 URI 用于新創(chuàng)建的聯(lián)系人（/contacts/{id}）并設(shè)置響應(yīng)代碼（201/created）。

        您可以使用 http://localhost:8080/Jersey/rest/contacts/<id> 訪問(wèn)新聯(lián)系人

*/

    @POST

    @Path("/postData")

    @Produces({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON })

    public User postData(User user) throws IOException {

        System.out.println(user);

        user.setName("jojo##12321321");

        return user;

    @PUT

    @Path("/putData/{id}")

    @Produces({ MediaType.APPLICATION_XML })

    public User putData(@PathParam("id") int id, User user) {

        System.out.println("#####putData#####");

        System.out.println(user);

        user.setId(id);

        user.setAddress("hoojo#gz");

        user.setEmail("hoojo_@126.com");

        user.setName("hoojo");

        System.out.println(user);

        return user;

    @DELETE

    @Path("/removeData/{id}")

    public void deleteData(@PathParam("id") int id) {

        System.out.println("#######deleteData#######" + id);

三、配置我們的WebService，修改applicationContext-server.xml。這里主要是添加jaxrs標(biāo)簽的支持，修改頭部文件如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:jaxws="http://cxf.apache.org/jaxws"
    xmlns:jaxrs="http://cxf.apache.org/jaxrs"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    http://www.springframework.org/schema/context
    http://www.springframework.org/schema/context/spring-context-3.0.xsd
    http://cxf.apache.org/jaxws 
    http://cxf.apache.org/schemas/jaxws.xsd
    http://cxf.apache.org/jaxrs
    http://cxf.apache.org/schemas/jaxrs.xsd">
特別注意上面加粗帶下劃線的部分，這是新增加的配置。我們發(fā)布restful WebService需要用到它。然后在配置文件中添加如下配置
<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="restSample" class="com.hoo.service.RESTSampleSource"/>

<jaxrs:server id="restServiceContainer" address="/rest">
    <jaxrs:serviceBeans>
        <ref bean="restSample" />
    </jaxrs:serviceBeans>
    <jaxrs:extensionMappings>
        <entry key="json" value="application/json" />
        <entry key="xml" value="application/xml" />
    </jaxrs:extensionMappings>
    <jaxrs:languageMappings>
           <entry key="en" value="en-gb"/>  
    </jaxrs:languageMappings>
</jaxrs:server>
這樣服務(wù)器端就完成了CXF RESTful WebService的發(fā)布，啟動(dòng)你的tomcat。然后在瀏覽器中服務(wù)地址：http://localhost:8000/CXFWebService/ （其實(shí)這里請(qǐng)求的是CXFServlet，你可以看看上一篇Spring整合CXF文章的web.xml的配置）

你就可以看到我們這里剛剛發(fā)布的RESTSample rest的WebService

?

你也可以看看里面的xml，也就是WebService的wsdl文件內(nèi)容。我們找一個(gè)GET方式的WebService的方法，在瀏覽器中調(diào)用一下試試

http://localhost:8000/CXFWebService/rest/sample/bean/123
這個(gè)url對(duì)應(yīng)到下面這個(gè)方法
@GET
@Path("/bean/{id}")
@Produces({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON })
public User getBean(@PathParam("id") int id)
結(jié)果如下

一篇xml文檔內(nèi)容。

四、編寫客戶端代碼，調(diào)用RESTful WebService

package com.hoo.client;

import java.io.IOException;

import javax.ws.rs.core.MediaType;

import org.apache.cxf.jaxrs.client.WebClient;

import org.junit.After;

import org.junit.Before;

import org.junit.Test;

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.hoo.entity.MapBean;

import com.hoo.entity.User;

import com.hoo.entity.Users;

import com.hoo.service.RESTSample;

/**

 * <b>function:</b> RESTful風(fēng)格WebService

 * @author hoojo

 * @createDate 2012-7-20 下午03:31:03

 * @file RSETServiceClient.java

 * @package com.hoo.client

 * @project CXFWebService

 * @blog http://blog.csdn.net/IBM_hoojo

 * @email hoojo_@126.com

 * @version 1.0

*/

public class RSETServiceClient {

    private static WebClient client;

    @Before

    public void init() {

        // 手動(dòng)創(chuàng)建webClient對(duì)象，注意這里的地址是發(fā)布的那個(gè)/rest地址

        //String url = "http://localhost:8000/CXFWebService/rest/";

        //client = WebClient.create(url);

        // 從Spring Ioc容器中拿webClient對(duì)象

        ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext-client.xml");

        client = ctx.getBean("webClient", WebClient.class);

    @After

    public void destory(){

    @Test

    public void testGet() {

        System.out.println(client.path("sample").accept(MediaType.TEXT_PLAIN).get(String.class));

    @Test

    public void testRequest() {

        System.out.println(client.path("sample/request/234234").accept(MediaType.TEXT_PLAIN).get(String.class));

    @Test

    public void testBean() {

        User user = client.path("sample/bean/{id}", 25).accept(MediaType.APPLICATION_XML).get(User.class);

        System.out.println(user);

    @Test

    public void testList() {

        System.out.println(client.path("sample/list").accept(MediaType.APPLICATION_XML).get(Users.class).getUsers());

    @Test

    public void testMap() {

        System.out.println(client.path("sample/map").accept(MediaType.APPLICATION_XML).get(MapBean.class).getMap());

    @Test

    public void testDeleteData() {

        client.path("sample/removeData/23").delete();

    @Test

    public void testPostData() {

        User user = new User();

        user.setId(21432134);

        user.setAddress("hoojo#gz");

        user.setEmail("hoojo_@126.com");

        user.setName("hoojo");

        System.out.println(client.path("sample/postData").accept(MediaType.APPLICATION_XML).post(user, User.class));

    @Test

    public void testPutData() {

        User user = new User();

        user.setId(21432134);

        System.out.println(client.path("sample/putData/1").accept(MediaType.APPLICATION_XML).put(user).getEntity());

如果你喜歡用Spring的方式，還需要在applicationContext-client.xml中增加如下配置

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

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

    xmlns:context="http://www.springframework.org/schema/context"

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

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

    xsi:schemaLocation="http://www.springframework.org/schema/beans

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

    http://www.springframework.org/schema/context

    http://www.springframework.org/schema/context/spring-context-3.0.xsd

    http://cxf.apache.org/jaxws

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

    <bean id="webClient" class="org.apache.cxf.jaxrs.client.WebClient" factory-method="create">

        <constructor-arg type="java.lang.String" value="http://localhost:8000/CXFWebService/rest/" />

    </bean>

</beans>

這種是利用WebClient對(duì)象來(lái)調(diào)用WebService，還有一種方法也可以調(diào)用WebService，代碼如下：

// 手動(dòng)創(chuàng)建

//RESTSample sample = JAXRSClientFactory.create("http://localhost:8000/CXFWebService/rest", RESTSample.class);

// 從Spring Ioc容器中拿webClient對(duì)象

ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext-client.xml");

RESTSample sample = ctx.getBean("restSampleBean", RESTSample.class);

System.out.println(sample);

System.out.println(sample.doGet());

//System.out.println(sample.doRequest("haha", null, null));

System.out.println(sample.getBean(22));

System.out.println(sample.getList());

System.out.println(sample.getMap().getMap());

User user = new User();

user.setId(21432134);

user.setAddress("hoojo#gz");

user.setEmail("hoojo_@126.com");

user.setName("hoojo");

System.out.println(sample.postData(user));

System.out.println(sample.putData(111, user));

sample.deleteData(2);

這種方式相對(duì)比WebClient要簡(jiǎn)單，直接使用接口中的方法即可。同樣如果你要整合到Spring可以在applicationContext-client.xml中增加配置如下：

<bean id="restSampleBean" class="org.apache.cxf.jaxrs.client.JAXRSClientFactory" factory-method="create">

    <constructor-arg type="java.lang.String" value="http://localhost:8000/CXFWebService/rest/" />

    <constructor-arg type="java.lang.Class" value="com.hoo.service.RESTSample" />

</bean>

執(zhí)行以上方法可以看到控制臺(tái)打印結(jié)果如下：

client console

org.apache.cxf.jaxrs.client.ClientProxyImpl@1cf7491

this is get rest request

22#JojO#null#null

com.hoo.entity.Users@16eb6bc

{key-0=0#JojO-0#null#null, key-1=1#JojO-1#null#null, key-2=2#JojO-2#null#null, key-3=3#JojO-3#null#null}

21432134#jojo##12321321#hoojo_@126.com#hoojo#gz

111#hoojo#hoojo_@126.com#hoojo#gz

server console

####getBean#####

id:22

Method:GET

uri:sample/bean/22

{id=[22]}

####getList#####

Method:GET

uri:sample/list

{}

####getMap#####

Method:GET

uri:sample/map

{}

21432134#hoojo#hoojo_@126.com#hoojo#gz

#####putData#####

21432134#hoojo#hoojo_@126.com#hoojo#gz

111#hoojo#hoojo_@126.com#hoojo#gz

#######deleteData#######2

就這樣，整合restful WebService成功。

轉(zhuǎn)載于:https://www.cnblogs.com/hoojo/archive/2012/07/23/2605219.html

總結(jié)

以上是生活随笔為你收集整理的Spring整合CXF，发布RSETful 风格WebService的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。