走在架构师的大道上 Jack.Wang's home

这里说明Resource如何处理GET，POST，PUT和DELETE方法。
1.引言
2.示例程序
3.实现Items Resource
4.实现Item Resource
5.实现Base Resource
6.运行应用
7.客户端应用
8.总结

1.      引言
在开始开发前，我们需要简单介绍一下Restlet框架的Resource概念。REST告诉我们，Resource根据URI进行辨认，同时能够有一种或多种表现（也被称作变量），用以响应方法调用。
在Restlet框架中，服务器连接器（server connectors）收到的调用最终由Resource的实例对象处理。一个Resource负责声明支持的表现方式列表（Variant对象的实例）和实现你想要支持的REST方法。
 GET依赖可更改的“variants”列表和“getRepresentation(Variant)”方法。
 POST依赖“allowPost”方法和“post(Representation)”方法。
 DELETE依赖“allowPut”方法和“put(Representation)”方法。
DELETE依赖“allowDelete”方法和“delete()”方法。
还有，每一个到达的响应由一个专门的Resource实例处理，你不需要操心这些方法的线程安全问题。
我们假设你已经读过“第一步”，并且有了一些元件和应用的概念。

2.示例程序

一个Item列表用来管理创建，读取，更新，和删除活动，如一个典型的CRUD应用。一个Item包含名字和描述。在简短的分析后，我们定义了两个资源：
 Items Resource代表所有可用Item的集合。
 Item Resource代表一个单独的item。
现在，让我们定义用来标志item的Resource URIs。假设我们的应用运行在本机“localhost”并且监听8182端口：
http://localhost:8182/firstResource/items：“items”Resource URI。
http://localhost:8182/firstResource/items/{itemName}：“item”Resource URI，每个{itemName}代表一个Item的名字。
下一步，定义每个Resource允许访问的方法列表。
 “items”Resource响应GET请求并以一个XML文档展示当前注册的所有Item列表。另外，Resource支持通过POST请求创建新的Item。提交的实体包含新的Item的名字和描述，这些是以格式化的Web表单方式提交的。如果Resource成功创建新Item，它返回一个“Success - resource created”状态（HTTP 201状态代码）并且告诉客户端新Resource在哪里可以找到（HTTP "Location" header）。否则，它返回一个“Client error”状态（HTTP 404状态代码）和一个简单的错误信息。
 “item”Resource响应GET请求并以一个XML文档来展示该Resource的名字和描述。也可以通过PUT和DELETE请求更新和删除Resource。
在描述两个Resource对象前，首先编写应用的代码。为简化起见，注册的Item列表做为应用的一个属性简单地保存到内存里，并不保存到一个真实的数据库。不管怎样，我们假设你想邀请你的朋友们同时测试这个应用。因为我们只有一个“FirstResourceApplication”实例在运行，所以不得不考虑线程安全。这也就是为什么你会发现Map对象Items是不不可更改的，它是一个ConcurrentHashMap对象的实例。

代码：

01packagefirstResource;
02
03importjava.util.Map;
04importjava.util.concurrent.ConcurrentHashMap;
05
06importorg.restlet.Application;
07importorg.restlet.Context;
08importorg.restlet.Restlet;
09importorg.restlet.Router;
10
11publicclassFirstResourceApplicationextendsApplication {
12
13   /** The list of items is persisted in memory. */
14   privatefinalMap<String, Item> items;
15
16   publicFirstResourceApplication(Context parentContext) {
17      super(parentContext);
18      // We make sure that this attribute will support concurrent access.
19       items =newConcurrentHashMap<String, Item>();
20    }
21
22   /**
23    * Creates a root Restlet that will receive all incoming calls.
24    */
25    @Override
26   publicsynchronizedRestlet createRoot() {
27      // Create a router Restlet that defines routes.
28       Router router =newRouter(getContext());
29
30      // Defines a route for the resource "list of items"
31       router.attach("/items", ItemsResource.class);
32      // Defines a route for the resource "item"
33       router.attach("/items/{itemName}", ItemResource.class);
34
35      returnrouter;
36    }
37
38   /**
39    * Returns the list of registered items.
40    *
41    * @return the list of registered items.
42    */
43   publicMap<String, Item> getItems() {
44      returnitems;
45    }
46 }

2.      实现Items Resource
  让我们开始编写Items Resource。如上文所述，它允许GET和POST请求。POST请求支持实现“post(Representation)”方法赋予处理消息实体的权限。此外，资源通过“allowPost”方法来确定是否开启POST支持。缺省情况下，资源是不可更改的，拒绝POST、PUT和DELETE方法并返回“Method not allowed”状态（HTTP 405状态代码）。

同样，通过实现“represent(Variant)”方法确定你可以接受GET请求并根据指定的Variant生成实体。在这个例子中，我们只生成“text/xml”这种形式。

代码：

001packagefirstResource;
002
003importjava.io.IOException;
004importjava.util.Collection;
005
006importorg.restlet.Context;
007importorg.restlet.data.Form;
008importorg.restlet.data.MediaType;
009importorg.restlet.data.Request;
010importorg.restlet.data.Response;
011importorg.restlet.data.Status;
012importorg.restlet.resource.DomRepresentation;
013importorg.restlet.resource.Representation;
014importorg.restlet.resource.StringRepresentation;
015importorg.restlet.resource.Variant;
016importorg.w3c.dom.Document;
017importorg.w3c.dom.Element;
018
019/**
020* Resource that manages a list of items.
021*
022*/
023publicclassItemsResourceextendsBaseResource {
024
025   /** List of items. */
026    Collection<Item> items;
027
028   publicItemsResource(Context context, Request request, Response response) {
029      super(context, request, response);
030
031      // Get the items directly from the "persistence layer".
032       items = getItems().values();
033
034      // Declare the kind of representations supported by this resource.
035       getVariants().add(newVariant(MediaType.TEXT_XML));
036    }
037
038    @Override
039   publicbooleanallowPost() {
040      returntrue;
041    }
042
043   /**
044    * Returns a listing of all registered items.
045    */
046    @Override
047   publicRepresentation getRepresentation(Variant variant) {
048      // Generate the right representation according to its media type.
049      if(MediaType.TEXT_XML.equals(variant.getMediaType())) {
050         try{
051             DomRepresentation representation =newDomRepresentation(
052                   MediaType.TEXT_XML);
053            // Generate a DOM document representing the list of
054            // items.
055             Document d = representation.getDocument();
056             Element r = d.createElement("items");
057             d.appendChild(r);
058            for(Item item : items) {
059                Element eltItem = d.createElement("item");
060
061                Element eltName = d.createElement("name");
062                eltName.appendChild(d.createTextNode(item.getName()));
063                eltItem.appendChild(eltName);
064
065                Element eltDescription = d.createElement("description");
066                eltDescription.appendChild(d.createTextNode(item
067                      .getDescription()));
068                eltItem.appendChild(eltDescription);
069
070                r.appendChild(eltItem);
071             }
072             d.normalizeDocument();
073
074            // Returns the XML representation of this document.
075            returnrepresentation;
076          }catch(IOException e) {
077             e.printStackTrace();
078          }
079       }
080
081      returnnull;
082    }
083
084   /**
085    * Handle POST requests: create a new item.
086    */
087    @Override
088   publicvoidpost(Representation entity) {
089      // Parse the given representation and retrieve pairs of
090      // "name=value" tokens.
091       Form. form. =newForm(entity);
092       String itemName = form.getFirstValue("name");
093       String itemDescription = form.getFirstValue("description");
094
095      // Check that the item is not already registered.
096      if(getItems().containsKey(itemName)) {
097          generateErrorRepresentation(
098                "Item " + itemName + " already exists.", "1", getResponse());
099       }else{
100         // Register the new item
101          getItems().put(itemName,newItem(itemName, itemDescription));
102
103         // Set the response's status and entity
104          getResponse().setStatus(Status.SUCCESS_CREATED);
105          Representation rep =newStringRepresentation("Item created",
106                MediaType.TEXT_PLAIN);
107         // Indicates where is located the new resource.
108          rep.setIdentifier(getRequest().getResourceRef().getIdentifier()
109                + "/" + itemName);
110          getResponse().setEntity(rep);
111       }
112    }
113
114   /**
115    * Generate an XML representation of an error response.
116    *
117    * @param errorMessage
118    *            the error message.
119    * @param errorCode
120    *            the error code.
121    */
122   privatevoidgenerateErrorRepresentation(String errorMessage,
123          String errorCode, Response response) {
124      // This is an error