现代Web开发系列教程_06

作为一个从事多年Java Web开发的程序员,面对现如今NodeJS开发Web后端程序一直十分感兴趣,于是花了点时间研究了下,本篇就主要说一说我在项目中应用NodeJS开发后端的具体步骤。实在是受Java Web后端开发影响太大了,我使用NodeJS开发后端程序还是采用了普通Java MVC分层架构,可能与一般的NodeJS程序员的做法不太一样。

数据访问层

首先定义一个全局唯一的数据访问对象。

src/server/dao/DB.js

"use strict";

const orm = require("orm");
const qOrm = require('q-orm');
const transaction = require('orm-transaction');
const config = require('../config.js');

function defineSchemas(db){
    db.schemas = {
        qUser : db.qDefine("users", {
            id : Number,
            username      : String,
            pwd   : String
        })
    };
}

const DB = qOrm.qConnect({
    host:     config.db.host,
    database: config.db.database,
    user:     config.db.user,
    password: config.db.pwd,
    protocol: 'mysql',
    port:     config.db.port,
    query:    {
        reconnect : true,
        pool: true,
        debug: false
    }
}).then(function (db) {
    db.use(transaction);
    defineSchemas(db);
    return db;
}).fail(function (err) {
    throw err;
});

module.exports = DB;

可以看到DB还是比较简单的,就是按orm的基本用法定义了数据库连接与数据库中的schema, 这里有一点不同的是我比较喜欢返回Promise对象,避免写过多callback,因此采用了q-orm。一般的数据访问层都提供了数据库事务的处理,在NodeJS里,我没找到太多选择,只找到orm-transaction,同样不太喜欢它默认给出的callback用法,简单封装了一个返回Promise的工具方法。

Transaction.js

module.exports = function(db){
    return new Promise(function(resolve, reject){
        db.transaction(function (err, t) {
            if(!err){
                resolve({
                    qCommit : function (){
                        return new Promise(function(resolve2, reject2){
                            t.commit(function(err){
                                if(!err){
                                    resolve2();
                                } else {
                                    reject2(err);
                                }
                            });
                        });
                    },
                    qRollback : function (){
                        return new Promise(function(resolve2, reject2){
                            t.rollback(function(err){
                                if(!err){
                                    resolve2();
                                } else {
                                    reject2(err);
                                }
                            });
                        });
                    }
                });
            } else {
                reject(err);
            }
        });
    });
};

业务Service层

这样简直写一个业务Service层实现,有Java基础的同学一看一定觉得很熟悉。

src/server/service/UserService.js

"use strict";

const DB = require('../dao/DB.js');
const Transaction = require('../dao/Transaction.js');

module.exports = {

    findAll : function *(){
        let db = yield DB;
        let users = yield db.schemas.qUser.qAll();
        return Promise.resolve(users);
    },

    findByUsername : function *(username){
        let db = yield DB;
        let user = yield db.schemas.qUser.qOne({username : username});
        return Promise.resolve(user);
    },

    updateUserPwd : function *(username, pwd){
        let db = yield DB;
        let user = yield db.schemas.qUser.qOne({username : username});
        user.pwd = pwd;
        let transaction = yield Transaction(db);
        try {
            yield user.qSave();
            yield transaction.qCommit();
        } catch (err){
            console.log(err);
            yield transaction.qRollback();
        }
    }
};

因为数据访问层都是返回的Promise,这里就可以很方便使用Generator函数与yield来书写代码逻辑了,避免了JavaScript里大量的callback,Generator函数与yield的用法可以参考阮一峰的异步操作的同步化表达

Controller层

虽然NodeJS里叫这个为route,但我还是习惯按Java的玩法叫它Controller,我使用了koa-router,还是比较好用的。

src\server\controller\UserController.js

"use strict";

const Router = require('koa-router');

const UserService = require('../service/UserService.js');

const UserController = new Router({
  prefix: '/users'
});

UserController.get('/', function *(){
    let users = yield UserService.findAll();
    this.body = users;
});

UserController.get('/:username', function *(){
    let user = yield UserService.findByUsername(this.params.username);
    this.body = user;
});

UserController.post('/:username', function *(){
    yield UserService.updateUserPwd(this.params.username, this.request.body.pwd);
    this.body = {success : true};
});

module.exports = UserController;

中间件容器

我使用koa作为这个小Web项目的中间件容器,简单写一个启动器。

src\server\app.js

const koa = require('koa');
const app = koa();
const json = require('koa-json');
const bodyParser = require('koa-bodyparser');

const UserController = require('./controller/UserController.js');

app.use(json({ pretty: false, param: 'pretty' }));

app.use(bodyParser());

app.use(UserController.routes()).use(UserController.allowedMethods());

app.listen(3000);

最后执行命令node src\server\app.js, 这个小Web项目就跑起来了。

总结

个人感觉使用NodeJS写简单的Web后端程序确实比用Java简单了不少,最关键是不用编译,异常地快。

本篇源代码地址

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏移动开发的那些事儿

BlockCanary源码解析

如上代码中的loop()方法是Looper中的,我们的目的是监测主线程的卡顿问题,因为UI更新界面都是在主线程中进行的,所以在主线程中做耗时操作可能会造成界面卡...

17120
来自专栏Rindew的iOS技术分享

苏宁一面

18940
来自专栏Star先生的专栏

从源码中分析 Hadoop 的 RPC 机制

RPC是Remote Procedure Call(远程过程调用)的简称,这一机制都要面对两个问题:对象调用方式余与序列/反序列化机制。本文给大家介绍从源码中分...

77500
来自专栏IT进修之路

原 JAVA的那些事儿

23070
来自专栏Java面试通关手册

面试必备之深入理解自旋锁

分享一个我自己总结的Java学习的系统知识点以及面试问题,目前已经开源,会一直完善下去,欢迎建议和指导欢迎Star: https://github.com/Sn...

70230
来自专栏岑玉海

hbase源码系列(六)HMaster启动过程

  这一章是server端开始的第一章,有兴趣的朋友先去看一下hbase的架构图,我专门从网上弄下来的。   按照HMaster的run方法的注释,我们可以了解...

61390
来自专栏黑泽君的专栏

day50_BOS项目_02

我们再补上IUserDao和UserDaoImpl的示例代码: IUserDao.java

9120
来自专栏ChaMd5安全团队

Real World CTF国际大赛 部分WP

题目描述里写平台很安全,请不要攻击。 所以尝试抓包,往Cookie的uid进行sqli

16310
来自专栏青玉伏案

ReactiveSwift源码解析(七) Signal的CombineLatest的代码实现

本篇博客我们就来聊一下combineLatest()的使用以及具体的实现方式。在之前的《iOS开发之ReactiveCocoa下的MVVM》的博客中我们已经聊过...

25280
来自专栏熊二哥

快速入门系列--MVC--05行为

    Action执行包含内容比较多,主要有同步/异步Action的概念和执行过程,Authorationfilter, ActionFiltor, Resu...

20170

扫码关注云+社区

领取腾讯云代金券