ApacheCXF整合RESTfulServices

为什么80%的码农都做不了架构师&＃xff1f;>>>

一、首先还是创建个项目并把包导入去&＃xff0c;弄2个package,分别用于装server和client。记得要把commons-httpclient-3.1.jar也要放入来&＃xff0c;因为Client用http请求的&＃xff1a;

二、在com.yao.server下新建一个类Customer&＃xff0c;我们注意到有一个&＃64;XmlRootElement(name&＃61;"Customer")这个是用来标识Customer是可用来转化为xml的&＃xff1a;

package com.yao.rs.server;import javax.xml.bind.annotation.XmlRootElement;&＃64;XmlRootElement(name&＃61;"Customer") public class Customer {private long id;private String name;&＃64;Overridepublic String toString() {return "Customer [id&＃61;" &＃43; id &＃43; ", name&＃61;" &＃43; name &＃43; "]";}public long getId() {return id;}public void setId(long id) {this.id &＃61; id;}public String getName() {return name;}public void setName(String name) {this.name &＃61; name;}}

三、同理再新建一个类Product&＃xff1a;

package com.yao.rs.server;import javax.xml.bind.annotation.XmlRootElement;&＃64;XmlRootElement(name&＃61;"Product") public class Product {private long id;private String description;public long getId() {return id;}public void setId(long id) {this.id &＃61; id;}public String getDescription() {return description;}public void setDescription(String description) {this.description &＃61; description;}&＃64;Overridepublic String toString() {return "Product [id&＃61;" &＃43; id &＃43; ", description&＃61;" &＃43; description &＃43; "]";}}

四、再新建一个Order类。该类有一个getProduct方法&＃xff0c;通过id返回一个 Product实例。&＃xff1a;该方法有2个注释&＃64;GET和&＃64;Path("products/{productId}/")&＃xff0c;前者表示为用get发起请求&＃xff0c;后者为匹配的路径&＃xff0c;下面的Client会用到这个请求。

package com.yao.rs.server;import java.util.HashMap; import java.util.Map;import javax.ws.rs.GET; import javax.ws.rs.Path; import javax.ws.rs.PathParam;public class Order {private long id;private String description;private Map products &＃61; new HashMap();public Order(){init();}final void init() {Product p &＃61; new Product();p.setId(323);p.setDescription("product 323");products.put(p.getId(), p);}&＃64;GET&＃64;Path("products/{productId}/")public Product getProduct(&＃64;PathParam("productId") int productId){System.out.println("----invoking getProduct with id: " &＃43; productId);Product p &＃61; products.get(new Long(productId));return p;}public long getId() {return id;}public void setId(long id) {this.id &＃61; id;}public String getDescription() {return description;}public void setDescription(String description) {this.description &＃61; description;}&＃64;Overridepublic String toString() {return "Order [id&＃61;" &＃43; id &＃43; ", description&＃61;" &＃43; description &＃43; ", products&＃61;" &＃43; products &＃43; "]";}}

五、新建CustomerService类&＃xff0c;这个类为客户端要调用的。每一个方法都有对应的请求方式与匹配路径&＃xff0c;以便客户端可以匹配调用。

package com.yao.rs.server;import java.util.HashMap; import java.util.Map;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.Response;&＃64;Path("/customerservice/") &＃64;Produces("text/xml")//可以通过修改&＃64;Produces注解来声明暴露接口返回的json还是xml数据格式 public class CustomerService {long currentId &＃61; 123;Map customers &＃61; new HashMap();Map orders &＃61; new HashMap();public CustomerService() {init();}&＃64;GET&＃64;Path("/customers/{id}/")public Customer getCustomer(&＃64;PathParam("id") String id) {System.out.println("----invoking getCustomer, Customer id is: " &＃43; id);long idNumber &＃61; Long.parseLong(id);Customer c &＃61; customers.get(idNumber);return c;}&＃64;PUT&＃64;Path("/customers/")public Response updateCustomer(Customer customer) {System.out.println("----invoking updateCustomer, Customer name is: " &＃43; customer.getName());Customer c &＃61; customers.get(customer.getId());Response r;if (c !&＃61; null) {customers.put(customer.getId(), customer);r &＃61; Response.ok().build();} else {r &＃61; Response.notModified().build();}return r;}&＃64;POST&＃64;Path("/customers/")public Response addCustomer(Customer customer) {System.out.println("----invoking addCustomer, Customer name is: " &＃43; customer.getName());customer.setId(&＃43;&＃43;currentId);customers.put(customer.getId(), customer);return Response.ok(customer).build();}&＃64;DELETE&＃64;Path("/customers/{id}/")public Response deleteCustomer(&＃64;PathParam("id") String id) {System.out.println("----invoking deleteCustomer, Customer id is: " &＃43; id);long idNumber &＃61; Long.parseLong(id);Customer c &＃61; customers.get(idNumber);Response r;if (c !&＃61; null) {r &＃61; Response.ok().build();customers.remove(idNumber);} else {r &＃61; Response.notModified().build();}return r;}&＃64;Path("/orders/{orderId}/")public Order getOrder(&＃64;PathParam("orderId") String orderId) {System.out.println("----invoking getOrder, Order id is: " &＃43; orderId);long idNumber &＃61; Long.parseLong(orderId);Order c &＃61; orders.get(idNumber);return c;}final void init() {Customer c &＃61; new Customer();c.setName("John");c.setId(123);customers.put(c.getId(), c);Order o &＃61; new Order();o.setDescription("order 223");o.setId(223);orders.put(o.getId(), o);}}

六、新建一个source folder名为config&＃xff0c;在里面放置2个文件add_customer.xml和update_customer.xml用于客户端增加与更新的xml文件。如下为其代码&＃xff1a;

6.1 add_customer.xml

Jack

6.2 update_customer.xml

Mary123 七、新建Server启动类&＃xff1a;

package com.yao.rs.server;import org.apache.cxf.jaxrs.JAXRSServerFactoryBean; import org.apache.cxf.jaxrs.lifecycle.SingletonResourceProvider;public class Server {protected Server() throws Exception {JAXRSServerFactoryBean sf &＃61; new JAXRSServerFactoryBean();sf.setResourceClasses(CustomerService.class);sf.setResourceProvider(CustomerService.class, new SingletonResourceProvider(new CustomerService()));sf.setAddress("http://localhost:9000/");sf.create();}public static void main(String args[]) throws Exception {new Server();System.out.println("Server ready...");Thread.sleep(5 * 6000 * 1000);System.out.println("Server exiting");System.exit(0);} } 八、新建客户端类Client:

package com.yao.rs.client;import java.io.File; import java.io.InputStream; import java.net.URL;import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.methods.FileRequestEntity; import org.apache.commons.httpclient.methods.PostMethod; import org.apache.commons.httpclient.methods.PutMethod; import org.apache.commons.httpclient.methods.RequestEntity;import org.apache.cxf.helpers.IOUtils; import org.apache.cxf.io.CachedOutputStream; import org.apache.cxf.resource.URIResolver;public final class Client {private Client() {}public static void main(String args[]) throws Exception {// Sent HTTP GET request to query all customer info/** URL url &＃61; new URL("http://localhost:9000/customers");* System.out.println("Invoking server through HTTP GET to query all* customer info"); InputStream in &＃61; url.openStream(); StreamSource* source &＃61; new StreamSource(in); printSource(source);*/// Sent HTTP GET request to query customer infoSystem.out.println("Sent HTTP GET request to query customer info");URL url &＃61; new URL("http://localhost:9000/customerservice/customers/123");InputStream in &＃61; url.openStream();System.out.println(getStringFromInputStream(in));// Sent HTTP GET request to query sub resource product infoSystem.out.println("\n");System.out.println("Sent HTTP GET request to query sub resource product info");url &＃61; new URL("http://localhost:9000/customerservice/orders/223/products/323");in &＃61; url.openStream();System.out.println(getStringFromInputStream(in));// Sent HTTP PUT request to update customer infoSystem.out.println("\n");System.out.println("Sent HTTP PUT request to update customer info");Client client &＃61; new Client();String inputFile &＃61; client.getClass().getResource("/update_customer.xml").getFile();URIResolver resolver &＃61; new URIResolver(inputFile);File input &＃61; new File(resolver.getURI());PutMethod put &＃61; new PutMethod("http://localhost:9000/customerservice/customers");RequestEntity entity &＃61; new FileRequestEntity(input, "text/xml; charset&＃61;ISO-8859-1");put.setRequestEntity(entity);HttpClient httpclient &＃61; new HttpClient();try {int result &＃61; httpclient.executeMethod(put);System.out.println("Response status code: " &＃43; result);System.out.println("Response body: ");System.out.println(put.getResponseBodyAsString());} finally {// Release current connection to the connection pool once you are// doneput.releaseConnection();}// Sent HTTP POST request to add customerSystem.out.println("\n");System.out.println("Sent HTTP POST request to add customer");inputFile &＃61; client.getClass().getResource("/add_customer.xml").getFile();resolver &＃61; new URIResolver(inputFile);input &＃61; new File(resolver.getURI());PostMethod post &＃61; new PostMethod("http://localhost:9000/customerservice/customers");post.addRequestHeader("Accept" , "text/xml");entity &＃61; new FileRequestEntity(input, "text/xml; charset&＃61;ISO-8859-1");post.setRequestEntity(entity);httpclient &＃61; new HttpClient();try {int result &＃61; httpclient.executeMethod(post);System.out.println("Response status code: " &＃43; result);System.out.println("Response body: ");System.out.println(post.getResponseBodyAsString());} finally {// Release current connection to the connection pool once you are// donepost.releaseConnection();}System.out.println("\n");System.exit(0);}private static String getStringFromInputStream(InputStream in) throws Exception {CachedOutputStream bos &＃61; new CachedOutputStream();IOUtils.copy(in, bos);in.close();bos.close();return bos.getOut().toString();}}

九、启动Server类打印&＃xff1a;

2014-8-22 12:45:34 org.apache.cxf.endpoint.ServerImpl initDestination 信息: Setting the server&＃39;s publish address to be http://localhost:9000/ 2014-8-22 12:45:34 org.eclipse.jetty.server.Server doStart 信息: jetty-8.1.15.v20140411 2014-8-22 12:45:34 org.eclipse.jetty.server.AbstractConnector doStart 信息: Started SelectChannelConnector&＃64;localhost:9000 2014-8-22 12:45:35 org.apache.cxf.wsdl.service.factory.ReflectionServiceFactoryBean buildServiceFromWSDL 信息: Creating Service {http://docs.oasis-open.org/ws-dd/ns/discovery/2009/01}Discovery from WSDL: classpath:/org/apache/cxf/ws/discovery/wsdl/wsdd-discovery-1.1-wsdl-os.wsdl 2014-8-22 12:45:35 org.apache.cxf.endpoint.ServerImpl initDestination 信息: Setting the server&＃39;s publish address to be soap.udp://239.255.255.250:3702 2014-8-22 12:45:35 org.apache.cxf.wsdl.service.factory.ReflectionServiceFactoryBean buildServiceFromClass 信息: Creating Service {http://docs.oasis-open.org/ws-dd/ns/discovery/2009/01}DiscoveryProxy from class org.apache.cxf.jaxws.support.DummyImpl Server ready...

十、启动Client类打印&＃xff1a;

Sent HTTP GET request to query customer info 123JohnSent HTTP GET request to query sub resource product info product 323323Sent HTTP PUT request to update customer info Response status code: 200 Response body: Sent HTTP POST request to add customer Response status code: 200 Response body: 124Jack

同时Server的端口也会打印&＃xff1a;

----invoking getCustomer, Customer id is: 123 ----invoking getOrder, Order id is: 223 ----invoking getProduct with id: 323 ----invoking updateCustomer, Customer name is: Mary ----invoking addCustomer, Customer name is: Jack

十一、最终工程的目录如下&＃xff1a;