Node.js 是一个基于 Chrome V8 引擎的 JavaScript 运行环境。 Node.js 使用了一个事件驱动、非阻塞式 I/O 的模型，使其轻量又高效。 Node.js 的包管理器 npm，是全球最大的开源库生态系统。

安装、简易教程：http://www.runoob.com/nodejs/nodejs-tutorial.html
官方文档：http://nodejs.cn/api/

一、nodejs大致功能模块

这里写图片描述

二、部分用法示例

1、简单重要的使用命令

使用淘宝 NPM 镜像
npm install -g cnpm –registry=https://registry.npm.taobao.org

安装模块
cnpm install [模块名]

运行js文件
node [js文件名]

2、示例：请求参数获取

//router.js

function route(pathname) {
    pathname = pathname.substring(1, pathname.length);
    console.log("About to route a request for " + pathname);
    //var strs = pathname.split('&');
    //for (var i = 0; i < strs.length; i++) {
    //    console.log(strs[i]);
    //}
    if (pathname == 'testFun') {
        console.log('filename: ' + __filename);
        console.log('dirname: '+__dirname);
        testFun();
    }
}
function testFun() {
    //for (var i = 0; i < 100000; i++) {
    //    console.log("testFun "+i);
    //}
    // 输出当前目录
    console.log('当前目录: ' + process.cwd());

    // 输出当前版本
    console.log('当前版本: ' + process.version);

    // 输出内存使用情况
    console.log(process.memoryUsage());
}

exports.route = route;

//server1.js

var http = require("http");
var url = require("url");

function start(route) {
    function onRequest(request, response) {
        var pathname = url.parse(request.url).pathname;
        if (pathname != '/favicon.ico') {
            console.log("Request for " + pathname + " received.");
            route(pathname);
        }

        response.writeHead(200, { "Content-Type": "text/plain" });
        response.write("Hello World");
        response.end();
    }

    http.createServer(onRequest).listen(8888);
    console.log("Server has started.");
}

exports.start = start;

//index.js

var server = require("./server1");
var router = require("./router");

server.start(router.route);//启动service,传入router处理函数

Date.prototype.Format = function (fmt) { //author: meizz
    var o = {
        "M+": this.getMonth() + 1, //月份
        "d+": this.getDate(), //日
        "h+": this.getHours(), //小时
        "m+": this.getMinutes(), //分
        "s+": this.getSeconds(), //秒
        "q+": Math.floor((this.getMonth() + 3) / 3), //季度
        "S": this.getMilliseconds() //毫秒
    };
    if (/(y+)/.test(fmt)) fmt = fmt.replace(RegExp.$1, (this.getFullYear() + "").substr(4 - RegExp.$1.length));
    for (var k in o)
        if (new RegExp("(" + k + ")").test(fmt)) fmt = fmt.replace(RegExp.$1, (RegExp.$1.length == 1) ? (o[k]) : (("00" + o[k]).substr(("" + o[k]).length)));
    return fmt;
}

function printHello() {
    console.warn("nodejs服务正常运行中! " + new Date().Format("yyyy-MM-dd hh:mm:ss"));
}
printHello();
// 两秒后执行以上函数
setInterval(printHello, 10000);

在代码这文件目录执行cmd命令：node index.js
这里写图片描述

打开浏览器，请求：http://localhost:8888/test/001
效果：
这里写图片描述

3、示例：express使用

//express_demo.js

//express_demo.js 文件
/**
使用淘宝 NPM 镜像
npm install -g cnpm --registry=https://registry.npm.taobao.org
 *
cnpm install body-parser --save
cnpm install cookie-parser --save
cnpm install multer --save
 */


var express = require('express');
var app = express();
var bodyParser = require('body-parser');
var cookieParser = require('cookie-parser')
var fs = require("fs");
var util = require('util');

//// 创建 application/x-www-form-urlencoded 编码解析
//var urlencodedParser = bodyParser.raw({ extended: false })

app.use(cookieParser())
app.use(express.static('Content'));
app.use(bodyParser());

//  主页输出 "Hello World"
app.get('/', function (req, res) {
    console.log("主页 GET 请求");
    console.log("Cookies: ", req.cookies);
    //res.send('Hello GET');
    // 输出 JSON 格式
    response = {
        first_name: req.query.first_name,
        last_name: req.query.last_name
    };
    console.log(response);
    res.send(JSON.stringify(response));
})


//  POST 请求
app.post('/', function (req, res) {
    console.log("主页 POST 请求");
    //res.send('Hello POST');
    // 输出 JSON 格式
    //请求json格式：  {"first_name":"pkm","last_name":"test1"}  类型 application/json
    response = {
        first_name: req.body.first_name,
        last_name: req.body.last_name
    };


    console.log("准备写入文件");
    fs.writeFile('input.txt', util.inspect(req), function (err) {
        if (err) {
            return console.error(err);
        }
        console.log("数据写入成功！");

    });
    console.log(res);
    res.end(JSON.stringify(response));
})


var server = app.listen(8888, function () {

    var host = server.address().address
    var port = server.address().port

    console.log("应用实例，访问地址为 http://%s:%s", host, port)

})

cmd执行：node express_demo.js
这里写图片描述

在浏览器请求：http://localhost:8888/?first_name=a&last_name=b
浏览器显示：
这里写图片描述
命令行显示：

4、示例：RESTFul API使用

//users.json

{
"user1":{
"name": "mahesh",
"password" : "password1",
"profession" : "teacher",
"id": 1
},
"user2": {
"name": "suresh",
"password" : "password2",
"profession" : "librarian",
"id": 2
},
"user3": {
"name" : "ramesh",
"password" : "password3",
"profession": "clerk",
"id": 3
}
}

//service_REST.js

/**
安装需要的模块
cnpm install express --save
cnpm install body-parser --save
cnpm install cookie-parser --save
cnpm install multer --save
 */

var express = require('express');
var app = express();
var fs = require("fs");

//添加的新用户数据
var user = {
    "user4": {
        "name": "mohit",
        "password": "password4",
        "profession": "teacher",
        "id": 4
    }
}

app.get('/listUsers', function (req, res) {
    fs.readFile(__dirname + "/" + "users.json", 'utf8', function (err, data) {
        console.log(data);
        res.end(data);
    });
})

app.get('/addUser', function (req, res) {
    // 读取已存在的数据
    fs.readFile(__dirname + "/" + "users.json", 'utf8', function (err, data) {

        //console.log(data);
        var dataJson = JSON.parse(data.trim());
        console.log(data.length);
        dataJson["user4"] = user["user4"];
        console.log(dataJson);
        res.end(JSON.stringify(dataJson));
    });
})
//http://localhost:8888/getUser/3
app.get('/getUser/:id', function (req, res) {
    // 首先我们读取已存在的用户
    fs.readFile(__dirname + "/" + "users.json", 'utf8', function (err, data) {
        data = JSON.parse(data.trim());
        var user = data["user" + req.params.id]
        console.log(user);
        res.end(JSON.stringify(user));
    });
})
//http://localhost:8888/deleteUser/3
app.get('/deleteUser/:id', function (req, res) {

    // First read existing users.
    fs.readFile(__dirname + "/" + "users.json", 'utf8', function (err, data) {
        data = JSON.parse(data.trim());
        delete data["user" + req.params.id];

        console.log(data);
        res.end(JSON.stringify(data));
    });
})
var server = app.listen(8888, function () {

    var host = server.address().address
    var port = server.address().port

    console.log("应用实例，访问地址为 http://%s:%s", host, port)

})

cmd执行：node service_REST.js
这里写图片描述

浏览器访问：http://localhost:8888/listUsers
这里写图片描述
浏览器访问：http://localhost:8888/addUser

浏览器访问：http://localhost:8888/getUser/2
这里写图片描述
浏览器访问：http://localhost:8888/deleteUser/2

5、示例：Mysql操作

//mysql表初始化sql语句:

SET NAMES utf8;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
--  Table structure for `websites`
-- ----------------------------
DROP TABLE IF EXISTS `websites`;
CREATE TABLE `websites` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` char(20) NOT NULL DEFAULT '' COMMENT '站点名称',
  `url` varchar(255) NOT NULL DEFAULT '',
  `alexa` int(11) NOT NULL DEFAULT '0' COMMENT 'Alexa 排名',
  `country` char(10) NOT NULL DEFAULT '' COMMENT '国家',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8;

-- ----------------------------
--  Records of `websites`
-- ----------------------------
BEGIN;
INSERT INTO `websites` VALUES ('1', 'Google', 'https://www.google.cm/', '1', 'USA'), ('2', '淘宝', 'https://www.taobao.com/', '13', 'CN'), ('3', '菜鸟教程', 'http://www.runoob.com/', '4689', 'CN'), ('4', '微博', 'http://weibo.com/', '20', 'CN'), ('5', 'Facebook', 'https://www.facebook.com/', '3', 'USA');
COMMIT;

SET FOREIGN_KEY_CHECKS = 1;

//service_mysql.js

/**
安装Mysql模块
cnpm install mysql
*/

function GetConnection() {
    var mysql = require('mysql');
    var connection = mysql.createConnection({
        host: '192.168.9.117',
        user: 'root',
        password: 'ycf.com',
        database: 'ycf_stock'
    });
    return connection;
}

function test2() {
    var connection = GetConnection();
    connection.connect();

    var sql = 'SELECT * FROM websites';
    //查
    connection.query(sql, function (err, result) {
        if (err) {
            console.log('[SELECT ERROR] - ', err.message);
            return;
        }

        console.log('--------------------------SELECT----------------------------');
        console.log(result);
        console.log('------------------------------------------------------------\n\n');
    });

    connection.end();
}

//test2();

function test3() {
    var connection = GetConnection();
    connection.connect();

    var addSql = 'INSERT INTO websites(name,url,alexa,country) VALUES(?,?,?,?)';
    var addSqlParams = ['测试网站', 'http://www.test.com', '1222', 'CN'];
    //增
    connection.query(addSql, addSqlParams, function (err, result) {
        if (err) {
            console.log('[INSERT ERROR] - ', err.message);
            return;
        }

        console.log('--------------------------INSERT----------------------------');
        console.log('INSERT ID:',result.insertId);        
        console.log('INSERT ID:', result);
        console.log('-----------------------------------------------------------------\n\n');
    });


    connection.end();
}
//test3();

function test4() {
    var connection = GetConnection();
    connection.connect();

    var modSql = 'UPDATE websites SET name = ?,url = ? WHERE Id = ?';
    var modSqlParams = ['测试网站6', 'http://www.test6.com', 6];
    //改
    connection.query(modSql, modSqlParams, function (err, result) {
        if (err) {
            console.log('[UPDATE ERROR] - ', err.message);
            return;
        }
        console.log('--------------------------UPDATE----------------------------');
        console.log('UPDATE affectedRows', result.affectedRows);
        console.log('-----------------------------------------------------------------\n\n');
    });

    connection.end();
}
//test4();

function test5() {
    var connection = GetConnection();
    connection.connect();

    var delSql = 'DELETE FROM websites where id=?';
    var delSqlParams = [6];
    //删
    connection.query(delSql, delSqlParams, function (err, result) {
        if (err) {
            console.log('[DELETE ERROR] - ', err.message);
            return;
        }

        console.log('--------------------------DELETE----------------------------');
        console.log('DELETE affectedRows', result.affectedRows);
        console.log('-----------------------------------------------------------------\n\n');
    });

    connection.end();
}
//test5();

可分别去掉test2()~test5()的注释，调用mysql增删改查功能。

mysql最终数据显示：

这里写图片描述

三、学习小结

nodejs适合高并发，低负载，弱逻辑，适合dataAPI，响应比.Net，java快，但生产环境出问题可能不好查，要有自己的log系统或其他方案去做这个支持，不适合开发web前端应用、逻辑复杂的场景都不太适合

四、nodejs进程守护工具forever的使用

为什么在使用forever?因为nodejs是单进程应用，一旦有异常未处理好，整个进程退出，就无法正常工作了。forever就是守护进程不退出的。

命令行使用安装forever
npm install forever -g
//如果要在程序代码中使用forever，安装forever-monitor
npm install forever-monitor

详细使用方法：https://github.com/foreverjs/forever

设置日志环境变量：
set FOREVER_ROOT=F:\nodejs\log
用forever启动并守护nodejs服务
forever start –uid “nodeapp1” -l ./log.txt -a service_excatch.js

可加参数 -w 文件改动监听并自动重启(可以用，但不建议这么用，需要时手动 forever restartall 就行了)

显示所有运行的node app
forever list

停止所有运行的node App
forever stopall

停止其中一个node App
forever stop app.js
或 forever stop [id]

启动所有
forever restartall

学习nodejs部分基础内容入门小结

Node.js 是一个基于 Chrome V8 引擎的 JavaScript 运行环境。 Node.js 使用了一个事件驱动、非阻塞式 I/O 的模型，使其轻量又高效。 Node.js 的包管理器 npm，是全球最大的开源库生态系统。

一、nodejs大致功能模块

二、部分用法示例

1、简单重要的使用命令

2、示例：请求参数获取

3、示例：express使用

4、示例：RESTFul API使用

5、示例：Mysql操作

三、学习小结

四、nodejs进程守护工具forever的使用

热门文章

最新文章

相关课程

相关电子书

相关实验场景

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

学习nodejs部分基础内容入门小结

Node.js 是一个基于 Chrome V8 引擎的 JavaScript 运行环境。 Node.js 使用了一个事件驱动、非阻塞式 I/O 的模型，使其轻量又高效。 Node.js 的包管理器 npm，是全球最大的开源库生态系统。

一、nodejs大致功能模块

二、部分用法示例

1、简单重要的使用命令

2、示例：请求参数获取

3、示例：express使用

4、示例：RESTFul API使用

5、示例：Mysql操作

三、学习小结

四、nodejs进程守护工具forever的使用

热门文章

最新文章

相关课程

相关电子书

相关实验场景