學習nodejs部分基礎內容入門小結
阿新 • • 發佈：2019-01-08
Node.js 是一個基於 Chrome V8 引擎的 JavaScript 執行環境。 Node.js 使用了一個事件驅動、非阻塞式 I/O 的模型，使其輕量又高效。 Node.js 的包管理器 npm，是全球最大的開源庫生態系統。
一、nodejs大致功能模組
二、部分用法示例
1、簡單重要的使用命令
安裝模組
cnpm install [模組名]
執行js檔案
node [js檔名]
2、示例：請求引數獲取
//router.js
function route(pathname) {
pathname = pathname.substring(1 //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
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
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
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
設定日誌環境變數：
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