CXF-based JAX-WS, JAX-RS (Restful) WebService

Class of CXF publishing service:

div>

l JaxWsServerFactoryBean

•JaxWsServerFactoryBean is used to publish a service, which can be instantiated by default construction.

• Its method is as follows:

•setServiceBean(Object) – set a service object-*

•setAddress(String url) – bind an address和端口- *

•create()  –  在JavaSE环境下，使用jetty发布WebService. – *

•以下是可选方法：

• setServiceClass(Class cls) – 设置服务对象实现的接口类。

l JaxRsServerFactoryBean

•此类用于发布 RESTful风格的webService.

•RESTful 风格是以普通get,post请求为标准的，并可以请求和响应json数据。

４、使用CXF发布一个服务

package cn.leaf.one;

import javax.jws.WebService;

import org.apache.cxf.jaxws.JaxWsServerFactoryBean;

/**

 * 使用CXF发布一个服务

 * 必须要添加WebService注解。否则不会对外暴露任何一个方法

 * @author 王健

 */

@WebService

public class OneService {

public String sayHi(){      ///此方法将会对外公布

return “Good”;

}

public static void main(String[] args) throws Exception {

JaxWsServerFactoryBean bean  //使用 jaxWs对其进行发布

  = new JaxWsServerFactoryBean();

bean.setServiceBean(new OneService());

bean.setServiceClass(OneService.class);

bean.setAddress(“http://localhost:4444/one”);

bean.create(); //内部使用jetty服务器做为支持

System.err.println(“服务启动成功。。 “);

//Thread.sleep(1000*60*60);

//System.exit(0);

}

}

５、获取上面的wsdl文件：  http://localhost:4444/one?wsdl

6、使用wsimport或是wsdl2java生成客户端调用代码，略。

７、发布一个RESTful的webService

package cn.itcast.ws3;

import org.apache.commons.httpclient.HttpClient;

import org.apache.commons.httpclient.methods.GetMethod;

import org.apache.commons.httpclient.methods.PostMethod;

/**

 * 使用URLConnection调用RESTful的服务

 * 此外建议使用httpClient读取，将会更快

 * 使用urlConnection可能没有返回结果

 * @author 王健

 * @version 1.0 2011-11-18

 */

public class UserRsClient {

UserRsClient() throws Exception{

save2();

all();

}

/**

 * 查询所有信息

 * @throws Exception

 */

private void all() throws Exception{

GetMethod get = new GetMethod(“http://localhost:9004/users/all”);

get.setRequestHeader(“accept”,”application/json”);

HttpClient hc = new HttpClient();

hc.getParams().setContentCharset(“UTF-8”); // 设置编码

int code = hc.executeMethod(get);

System .err.println(” 返回的状态码：”+code);

if(code==200){

String str = get.getResponseBodyAsString();

System.err.println(” 返回信息：
“+str);

}

get.releaseConnection();

}

/**

 * 保存一条信息,仍然使用GET方式

 */

private void save() throws Exception{

String name = “Jack”;// 因为是get类型，所以不能包含中文

String age = “35”;

String url = “http://localhost:9004/users/save/”+name+”/”+age;

GetMethod get = new GetMethod(url);

get.setRequestHeader(“accept”,”application/json”);

HttpClient hc = new HttpClient();

hc.getParams().setContentCharset(“UTF-8”); // 设置编码

//.setRequestHeader(“Content”,”text/html;charset=UTF-8″);

int code = hc.executeMethod(get);

System.err.println(” 返回的状态码是：”+code);

if(code==200){

String str = get.getResponseBodyAsString();

System.err.println(” 返回的信息是:
“+str);

}

get.releaseConnection();

}

/**

 * 以下使用POST方式

 */

private void save2() thro ws Exception{

String name = ” 王健”;//因为是get类型，所以不能包含中文

String age = “35”;

String url = “http://localhost:9004/users/add/”;

PostMethod pm = new PostMethod(url);

pm.setRequestHeader(“accept”,”application/json”);

pm.setRequestHeader(“Encoding”,”UTF-8″);

pm.setParameter(“name”,name);

pm.setParameter(“age”,age);

HttpClient hc = new HttpClient();

hc.getParams().setContentCharset(“UTF-8”);// 设置编码,否则会返回中文乱码//TODO:切记

int code = hc.executeMethod(pm);

System.err.println(“Post 方式的返回值是:”+code);

if(code==200){

String ss =  pm.getResponseBodyAsString();

System.err.println(“>>:”+ss);

}

pm.releaseConnection();

}

public static void main(String[] args) throws Exception {

new UserRsClient();

}

}