摘要：程序執(zhí)行完畢管道流管道提供了一個(gè)輸出流到輸入流的機(jī)制。當(dāng)有用戶連接了就觸發(fā)一個(gè)內(nèi)部事件，通過非阻塞事件驅(qū)動(dòng)機(jī)制，讓程序宏觀上也是并行的。使用，一個(gè)內(nèi)存的服務(wù)器，可以同時(shí)處理超過萬用戶的連接。沒有行列的概念。

這是小生跟著視頻學(xué)習(xí)的總結(jié)，文末貼的有地址，很容易上手，自己都跟著敲了一遍，覺得不錯(cuò)，
值得總結(jié)安利一下，歡迎糾錯(cuò)……

引入 http 模塊

   var http = require("http");

創(chuàng)建服務(wù)器

接下來我們使用 http.createServer() 方法創(chuàng)建服務(wù)器，并使用 listen 方法綁定 8888 端口。 函數(shù)通過 request, response 參數(shù)來接收和響應(yīng)數(shù)據(jù)。

var http = require("http"); 
http.createServer(function (request, response) {
// 發(fā)送 HTTP 頭部
// HTTP 狀態(tài)值: 200 : OK
//設(shè)置 HTTP 頭部，狀態(tài)碼是 200，文件類型是 html，字符集是 utf8 response.writeHead(200,{"Content-Type":"text/html;charset=UTF-8"});
// 發(fā)送響應(yīng)數(shù)據(jù) "Hello World"
res.end("哈哈哈哈，我買了一個(gè) iPhone" + (1+2+3) + "s"); }).listen(8888 );
// 終端打印如下信息
console.log("Server running at http://127.0.0.1:8888/");

運(yùn)行程序

node server.js

2.1 HTTP 模塊的使用

//引用模塊
var http = require("http");
//創(chuàng)建一個(gè)服務(wù)器，回調(diào)函數(shù)表示接收到請求之后做的事情
var server = http.createServer(function(req,res){ //req 參數(shù)表示請求，res 表示響應(yīng)
// 設(shè)置一個(gè)響應(yīng)頭
res.writeHead(200,{"Content-Type":"text/htm l;c harset=UTF8"});

console.log("服務(wù)器接收到了請求" + req.url);

res.end(); // End 方法使 Web 服務(wù)器停止處理腳本并返回當(dāng)前結(jié)果
});
//監(jiān)聽端口
server.listen(3000,"127.0.0.1");

2.2、URL 模塊的使用

url.parse() 解析 URL
url.format(urlObject) //是上面 url.parse() 操作的逆向操作
url.resolve(from, to) 添加或者替換地址

url.parse()

url.format()

url.resolve()

三、 Nodejs 自啟動(dòng)工具 supervisor

supervisor 會(huì)不停的 watch 你應(yīng)用下面的所有文件，發(fā)現(xiàn)有文件被修改，就重新載入程序文件這樣就實(shí)現(xiàn)了部署，修改了程序文件后馬上就能看到變更后的結(jié)果。麻麻再也不用擔(dān)心我的重啟 nodejs 了!

首先安裝 supervisor

   npm install -g supervisor

使用 supervisor 代替 node 命令啟動(dòng)應(yīng)用

fs.stat 檢測是文件還是目錄

fs.stat("hello.js", (error, stats) =>{ 
    if (error){
        console .log(error) 
    } else {
        console .log(stats)
        console .log(`文件: ${stats.isFile()}` )
        console .log(`目錄: ${stats.isDirectory()}` ) 
    }
})

fs.mkdir 創(chuàng)建目錄

const fs = require("fs")
fs.mkdir("logs", (error) => { 
    if (error){
        console .log(error)
    } else {
        console .log("成功創(chuàng) 建目錄:logs" )
    }
})

fs.writeFile 創(chuàng)建寫入文件

fs.writeFile("logs/hello.log", "您好 ~ 
", (error) => {
    if(error) {
        console .log(error)
    } else {
        console .log("成功寫入文件" )
    }
})

fs.appendFile 追加文件

 fs.appendFile("logs/hello.log", "hello ~ 
", (error) => { 
     if(error) {
        console .log(error) } 
    else {
        console .log("成功寫入文件" ) 
    }
})

fs.readFile 讀取文件

const fs = require("fs")
fs.readFile("logs/hello.log", "utf8", (error, data) =>{ 
    if (error) {
        console .log(error) 
    } else {
        console .log(data) 
    }
})

fs.readdir 讀取目錄

const fs = require("fs")
fs.readdir("logs", (error, files) => { 
    if (error) {
        console .log(error)
    } else {
        console .log(files)
    } 
})

fs.rename 重命名

const fs = require("fs")
fs.rename("js/hello.log", "js/greeting.log", (error) =>{
    if (error) {
        console .log(error)
    } else {
        console .log(" 重命名成功" )
    } 
})

fs.rmdir 刪除目錄

fs.rmdir("logs", (error) =>{
    if (error) {
        console .log(error)
    } else { 
        console.log("成功的刪除了目錄:logs")
    } 
})

fs.unlink 刪除文件

fs.unlink(`logs/${file}`, (error) => { 
   if (error) {
       console .log(error)
   } else {
       console.log(`成功的刪除了文件: ${file}`) 

})

10. fs.createReadStream 從文件流中讀取數(shù)據(jù)

const fs = require("fs")
var fileReadStream = fs.createReadStream("data.json")
let count=0;
var str="";
fileReadStream.on("data", (chunk) => {

console.log(`${ ++count } 接收到:${chunk.length}`);
str += chunk; 

})
fileReadStream.on("end", () => {

console.log("--- 結(jié)束 ---"); 
console.log(count );
console.log(str ); 

})
fileReadStream.on("error", (error) => {

console .log(error)

})

 
 
11. fs.createWriteStream 寫入文件

var fs = require("fs");
var data = "我是從數(shù)據(jù)庫獲取的數(shù)據(jù)，我要保存起來";
// 創(chuàng)建一個(gè)可以寫入的流，寫入到文件 output.txt 中
var writerStream = fs.createWriteStream("output.txt");
// 使用 utf8 編碼寫入數(shù)據(jù)
writerStream .write(data ,"UTF8" ); // 標(biāo)記文件末尾
writerStream .end();
// 處理流事件 --> finish 事件
writerStream.on("finish", function() {
/finish - 所有數(shù)據(jù)已被寫入到底層系統(tǒng)時(shí)觸發(fā)。/

console .log("寫入完成。" );

});
writerStream.on("error", function(err){

console.log(err.stack); 

});
console .log("程序執(zhí)行完畢" );

12. 管道流 管道提供了一個(gè)輸出流到輸入流的機(jī)制。
通常我們用于從一個(gè)流中獲取數(shù)據(jù)并將數(shù)據(jù)傳遞到另外一個(gè)流中。

![](https://user-gold-cdn.xitu.io/2018/12/14/167acf76097adf62?w=552&h=426&f=png&s=31527)
如上面的圖片所示，我們把文件比作裝水的桶，而水就是文件里的內(nèi)容，我們用一根管子(pipe )連接兩個(gè)桶使得水從一個(gè)桶流入另一個(gè)桶，這樣就慢慢的實(shí)現(xiàn)了大文件的復(fù)制過程。以下實(shí)例我們通過讀取一個(gè)文件內(nèi)容并將內(nèi)容寫入到另外一個(gè)文件中。

var fs = require("fs");
// 創(chuàng)建一個(gè)可讀流
var readerStream = fs.createReadStream("input.txt"); // 創(chuàng)建一個(gè)可寫流
var writerStream = fs.createWriteStream("output.txt");
// 管道讀寫操作
// 讀取 input.txt 文件內(nèi)容，并將內(nèi)容寫入到 output.txt 文件中
readerStream.pipe(writerStream );
console.log("程 序執(zhí)行完畢" );

### 四、 Nodejs 創(chuàng)建一個(gè) WEB 服務(wù)器。
1. server.js

// 引入http模塊
var http = require("http");
// 引入fs模塊
var fs = require("fs");
// 引入path模塊
var path = require("path");
// 引入url模塊
var url = require("url");
// 引入自定義的解析模塊;
var mime = require("./model/getMimeFile.js");
http.createServer(function (req,res) {

var pathName = url.parse(req.url).pathname;

res.writeHead(200, {"Content-Type": " " + mime.getMime(fs, path.extname(pathName))+ "; charset=utf-8"});

if(pathName == "/") pathName = "/index/html";
if(pathName !== "/favicon.ico") {
    // 文件操作去讀取static下面的index.html
    fs.readFile("static/"+pathName,function (err,data) {
        if(err){
            fs.readFile("static/404.html",function (err,data404) {
                res.write(data404);
                res.end();
            })
        } else {
            // console.log(data);
            res.write(data);
            res.end();
        }
    })
}

}).listen("8002");

2.  getMimeFile.js 

exports.getMime = function (fs,extname) {

var data = fs.readFileSync("./mime.json");
var Mimes = JSON.parse(data.toString())
return Mimes[extname] || "text/html";

}

### 五、 Nodejs 的非阻塞 I/O、異步、事件驅(qū)動(dòng)
1. Nodejs的單線程 非阻塞I/O事件驅(qū)動(dòng)

在 Java、PHP 或者.net 等服務(wù)器端語言中，會(huì)為每一個(gè)客戶端連接創(chuàng)建一個(gè)新的線程。
而每個(gè)線程需要耗費(fèi)大約 2MB 內(nèi)存。也就是說，理論上，一個(gè)8GB 內(nèi)存的服務(wù)器可以同時(shí) 連接的最大用戶數(shù)為 4000 個(gè)左右。
要讓 Web 應(yīng)用程序支持更多的用戶，就需要增加服務(wù)器 的數(shù)量，而 Web 應(yīng)用程序的硬件成本當(dāng)然就上升了。
Node.js 不為每個(gè)客戶連接創(chuàng)建一個(gè)新的線程，而僅僅使用一個(gè)線程。
當(dāng)有用戶連接了,就觸發(fā)一個(gè)內(nèi)部事件，通過非阻塞 I/O、事件驅(qū)動(dòng)機(jī)制，讓 Node.js 程序宏觀上也是并行的。
使用 Node.js，一個(gè) 8GB 內(nèi)存的服務(wù)器，可以同時(shí)處理超過 4 萬用戶的連接。

2. Nodejs 回調(diào)處理異步

//正確的處理異步:
function getData(callback){ //模擬請求數(shù)據(jù)

var result=""; 
setTimeout(function (){
    result="這是請求到的 數(shù)據(jù)"; 
    callback(result);
},200); 

}
getData(function(data){

console.log(data);

})

3. Nodejs events 模塊處理異步

// 引入 events 模塊
var events = require("events");
var EventEmitter = new events.EventEmitter() ; /實(shí)例化事件對象/
EventEmitter.on("toparent",function(){

console.log("接收到了廣播事件");

})
setTimeout(function (){

console.log("廣播");
EventEmitter.emit("toparent"); /*發(fā)送廣播*/ 

},1000)

### 六、 Nodejs的 ejs 模板引擎 

1. 路由      
官方解釋:       
路由(Routing)是由一個(gè) URI(或者叫路徑)和一個(gè)特定的 HTTP 方法(GET、POST 等)組成 的，涉及到應(yīng)用如何響應(yīng)客戶端對某個(gè)網(wǎng)站節(jié)點(diǎn)的訪問。


![](https://user-gold-cdn.xitu.io/2018/12/14/167ad0dc9d1bfc6c?w=800&h=468&f=png&s=47406)

2.  初識(shí) EJS 模塊引擎
 
文檔：  https://www.npmjs.com/package/ejs     
安裝 ：  

    npm install ejs –save     /     cnpm install ejs --save

 Nodejs中使用：
 
 
    ejs.renderFile(filename, data, options, function(err, str){ 
        str => Rendered HTML string
    });
    
EJS 常用標(biāo)簽

 * <%%>流程控制標(biāo)簽
 * <%=%>輸出標(biāo)簽(原文輸出HTML標(biāo)簽) 
 * <%-%>輸出標(biāo)簽(HTML會(huì)被瀏覽器解析)

在客戶端和服務(wù)器之間進(jìn)行請求-響應(yīng)時(shí)，兩種最常被用到的方法是:GET 和 POST。

GET - 從指定的資源請求數(shù)據(jù)。(一般用于獲取數(shù)據(jù))

POST - 向指定的資源提交要被處理的數(shù)據(jù)。(一般用于提交數(shù)據(jù))**

獲取 GET 傳值:

   var urlinfo = url.parse(req.url,true); 
   urlinfo.query();
獲取 POST 傳值:

postData += postDataChunk;

try {
    postData = JSON.parse(postData); 
} 
catch (e) { }
req.query = postData;
console.log(querystring .parse(postData));

## 七、 MongoDb 數(shù)據(jù)庫介紹、安裝、使用

   1. 數(shù)據(jù)庫和文件的主要區(qū)別

2. NoSql 介紹    

3. 什么時(shí)候建議使用 NoSql

4. NoSql 和傳統(tǒng)數(shù)據(jù)庫簡單對比

![](https://user-gold-cdn.xitu.io/2018/12/24/167df3506d17fbb7?w=535&h=348&f=png&s=59755)

5. mongodb的使用方法     
 i. [mongodb的安裝方法](https://docs.mongodb.com/manual/tutorial/install-mongodb-on-os-x/)；     
 ii.  開啟 mongodb服務(wù):要管理數(shù)據(jù)庫，必須先開啟服務(wù),然后進(jìn)行數(shù)據(jù)庫的相關(guān)操作      
 iii. mongodb的常用指令 

     查詢 (find)    
     增加 (insert)  
     修改 (update)  
     刪除（remove）

查看所有數(shù)據(jù)庫列表    show dbs
使用數(shù)據(jù)庫、創(chuàng)建 數(shù)據(jù)庫    use student  (student代表 data_base_name);

插入(增加)一條數(shù)據(jù)    db.student.insert({“name”:”xiaoming”});
db.表名.insert({"name":"zhangsan"}); student 集合名稱(表)

顯示當(dāng)前的數(shù)據(jù)集合(mysql 中叫表)    show collections
刪除數(shù)據(jù)庫，刪除當(dāng)前所在的數(shù)據(jù)庫    db.dropDatabase();
刪除集合，刪除指定的集合 刪除表     db.user.drop()；

1、查詢所有記 錄
db.userInfo.find();
相當(dāng)于:select* from userInfo;

2、查詢 age > 22 的記錄 db.userInfo.find({age: {$gt: 22}});
相當(dāng)于:select * from userInfo where age >22;

3、查詢 age < 22 的記錄
db.userInfo.find({age: {$lt: 22}}); 
相當(dāng)于:select * from userInfo where age <22; 

4、查詢 age >= 25 的記錄
db.userInfo.find({age: {$gte: 25}}); 
相當(dāng)于:select * from userInfo where age >= 25;

5、查詢 age <= 25 的記錄 
db.userInfo.find({age: {$lte: 25}});

6. 按照年齡排序 1 升序 -1 降序 
升序: db.userInfo.find().sort({age: 1}); 
降序: db.userInfo.find().sort({age: -1});

7. 查詢前 5 條數(shù)據(jù) db.userInfo.find().limit(5 ); 
   相當(dāng)于:selecttop 5 * from userInfo;

修改數(shù)據(jù)  
查找名字叫做小明的，把年齡更改為 16 歲:
db.student.update({"name":"小明"},{$set:{"ag e":16}});

刪除數(shù)據(jù)
db.collectionsNames.remove( { "borough": "Manhattan" } )
db.users.remove({age: 132});

```

npm install express –save 

demo:
    var express=require("express");  /*引入 express*/
    var app=newexpress(); /*實(shí)例化express 賦值給app*/
    //配置路由 匹配 URl 地址實(shí)現(xiàn)不同的功能
    app.get("/",function(req,res){ 
        res.send("首頁");
    }) 
    app.get("/search",function(req,res){
        res.send("搜索"); //?keyword=華為手機(jī)&enc=utf-8&suggest=1.his.0.0&wq
    })
    app.get("/login",function(req,res){ 
        res.send("登錄");
    }) 
    app.get("/register",function(req,res){
        res.send("注冊");
    }) 
    app.listen(3000,"127.0.0.1");

當(dāng)用 get 請求訪問一個(gè)網(wǎng)址的時(shí)候，做什么事情:
app.get("網(wǎng)址",function(req,res){

});

當(dāng)用 post 訪問一個(gè)網(wǎng)址的時(shí)候，做什么事情:
app.post("網(wǎng)址",function(req,res){

});
// user 節(jié)點(diǎn)接受 PUT 請求
app.put("/user", function (req, res) {
    res.send("Got a PUT request at /user"); 
});

// user 節(jié)點(diǎn)接受 DELETE 請求 
app.delete("/user", function (req, res) {
   res.send("Got a DELETE request at /user"); 
});

動(dòng)態(tài)路由配置:
"/user/:id "
app.get( ,function(req,res){ 
    var id = req.params["id"];
    res.send(id); 
});
路由的正則匹配:(了解)
 app.get("/ab*cd", function(req, res) { 
    res.send("ab*cd");
});

路由里面獲取 Get 傳值
/news?id=2&sex=nan

app.get("/news, function(req, res) { 
    console.log(req.query);
});

i. npm install ejs --save-dev   // 安裝

ii. Express 中 ejs 的使用:

var express = require("express");
var app = express();
app.set("view engine","ejs");
app.get("/",function(req,res){ });
res.render("news",{
    "news" : ["我是小新聞啊","我也是啊","哈哈哈哈"]
}); app.listen(3000);

iii. 指定模板位置 ，默認(rèn)模板位置在 views
 
 app.set("views", __dirname + "/views");
 
iv. Ejs 后綴修改為 Html
這是一個(gè)小技巧，看著.ejs 的后綴總覺得不爽，使用如下方法，可以將模板文件的后綴換成我們習(xí)慣的.html。

1.在 app.js 的頭上定義 ejs:,代碼如下:
var ejs = require("ejs");
2.注冊 html 模板引擎代碼如下: 
app.engine("html",ejs.__express);
3.將模板引擎換成 html代碼如下:
app.set("view engine", "html");
4.修改模 板文件的后綴為 .html。

app.use(express.static("public"));

app.use("/static", express.static("public"));

body-parser    獲取post提交的數(shù)據(jù)  

var express = require("express")
var bodyParser = require("body-parser")
var app = express()
// parse application/x-www-form-urlencoded
app.use(bodyParser.urlencoded({ extended: false }))
// parse application/json
app.use(bodyParser.json())
app.use(function (req, res) { 
    res.setHeader("Content-Type", "text/plain") 
    res.write("you posted:
")
    res.end(JSON.stringify(req.body, null, 2))
})