当前位置:   article > 正文

Restify实践_restifyclient.createjsonclient

restifyclient.createjsonclient

在项目里面,我网站用的是2层结构:UI + WebService(REST API),这样的好处是UI和后端可以完全分离。UI我用的是expressJs,后端Service层用的也是expressJs。今天看到一个轻量级的、专为REST API定制的框架,restify(详细文档:http://mcavage.github.io/node-restify)。restify应该是基于connect的,和expressJs用法也差不多,只不过,有少许区别,好处是,他支持server、client两种!server可以是一个http server、json server、string server(区别是返回的body类型是application/plain, application/json, ...)。而且他还支持带version支持的RESTFUL API(使用header: accept-version: ~1控制)。下面就是使用代码:


  1. var restify = require('restify')
  2. , routes = require('./routes');
  3. var server = restify.createServer({
  4. name: 'CER Web Service',
  5. versions: ['1.0.0']
  6. });
  7. server.use(restify.pre.userAgentConnection()); // work around for curl
  8. server.use(restify.acceptParser(server.acceptable));
  9. server.use(restify.queryParser());
  10. server.use(restify.bodyParser());
  11. // static files: /, /index.html, /images...
  12. server.get(/^\/((.*)(\.)(.+))*$/, restify.serveStatic({ directory: 'public', default: "index.html" }));
  13. // testing the service
  14. server.get('/test', function (req, res, next) {
  15. res.send("testing...");
  16. next();
  17. });
  18. server.get('/products', routes.product_list);
  19. server.get('/sendEmail', routes.sendEmail);
  20. server.get('/:productId/top_crash/week/:weekId', routes.top_crash);
  21. server.get('/:productId/weekly_crash/week/:weekId', routes.weekly_crash);
  22. server.get('/:productId/weekly_crash_per_user/week/:weekId', routes.weekly_crash_per_user);
  23. server.get('/:productId/related_products', routes.related_product_list);
  24. server.get('/:productId/weeks', routes.week_list);
  25. server.get('/:productId/fix_rate/week/:weekId', routes.fix_rate);
  26. server.get('/:productId/os_breakdown/week/:weekId', routes.os_breakdown);
  27. server.get('/:productId/bucket/week/:weekId', routes.bucket);
  28. server.listen(8080, function () {
  29. console.log('%s listening at %s', server.name, server.url);
  30. });

第一步是创建server对象,你可以传入你所支持的版本数组,versions!(不用使用version属性,因为有bug,在调用server.toString()的时候,会crash)。接着就是一些中间件:

1. pre.userAgentConnection():这个是为处理keep-alive的curl命令的。

2. acceptParser():返回支持信息,比如json, plain等。


接下来就是路由功能了:

1. serveStatic:这个需要讲一下,和expressJs不同,对于静态文件的获取,expressJs是调用use(),并传入一个static()中间件的,但是restify要求,一定要映射到一个路径上去,所以只能使用get。

2. 最后一个参数next()不能省略。

3. 之后的一些get,都和expressJs一模一样了,完全相同。


从expressJs移植到restify很方便,对于我来说,只是修改了app.js,然后删除了一些无用的目录即可。


接下来看看client端,以前我是使用http.get()来访问页面的,现在可以使用restify提供的client类:


  1. var http = require('http')
  2. , util = require('util')
  3. , assert = require('assert')
  4. , restify = require('restify');
  5. var jsonClient = restify.createJsonClient({
  6. url: "http://localhost:8080",
  7. version: "1.0.0"
  8. });
  9. module.exports = {
  10. host: "http://localhost:8080",
  11. products: "/products",
  12. relatedProducts: "/{productId}/related_products",
  13. weeks: "/{productId}/weeks",
  14. weeklyCrashCount: "/{productId}/weekly_crash/week/{weekId}",
  15. weeklyCrashCountPerUser: "/{productId}/weekly_crash_per_user/week/{weekId}",
  16. topCrashCommands: "/{productId}/top_crash/week/0",
  17. fixRate: "/{productId}/fix_rate/week/{weekId}",
  18. osBreakdown: "/{productId}/os_breakdown/week/{weekId}",
  19. bucket: "/{productId}/bucket/week/{weekId}",
  20. getRequestUrl: function (url, keyValues) {
  21. for (var key in keyValues) { url = url.replace("{" + key + "}", keyValues[key]); }
  22. return url;
  23. },
  24. getCall: function (url, callback) {
  25. jsonClient.get(url, function (err, req, res, obj) {
  26. if (err) {
  27. console.log(err);
  28. callback(err, res.statusCode);
  29. }
  30. else {
  31. callback(undefined, obj);
  32. }
  33. });
  34. }
  35. };

我先是创建了一个jsonClient,然后告诉他,版本是1.0.0,当然也可以传入*表示所有版本通吃。在getCall()里面,我调用jsonClient.get(),其callback的最后一个参数会传给我一个对象,哈哈,这个就是json对象!方便吧!


其实,你看看restify的实现,也超简单的,就是从服务器端拿到数据,然后用JSON.parse()将他转换成js的对象而已。





本文内容由网友自发贡献,转载请注明出处:https://www.wpsshop.cn/w/weixin_40725706/article/detail/977191
推荐阅读
相关标签
  

闽ICP备14008679号