好程序员web前端培训分享node学习笔记系列之39
一、url模块的基本使用
url.parse
url.format
url.resolve

const url = require("url");
​
const path = "https://www.baidu.com/s?wd=%20node%20request%20post%E8%AF%B7%E6%B1%82&rsv_spt=1&rsv_iqid=0xb9778e3c000b4a9e&issp=1&f=8&rsv_bp=1&rsv_idx=2&ie=utf-8&rqlang=cn&tn=baiduhome_pg&rsv_enter=1&rsv_dl=tb&oq=request%2520post%25E8%25AF%25B7%25E6%25B1%2582&inputT=1575&rsv_t=3da2Tn%2F7uIuHWTsROFo6yvwMvultNv5wmOTlrQiVQ6KLFbNtnrLXkdd9HWuhNlyq7zNM&rsv_pq=feaadbf200091d61&rsv_sug3=35&rsv_sug2=0&rsv_sug4=2259";
const urlObject = url.parse(path,true);
//console.log(url.format(urlObject));
​
​
console.log(url.resolve("/a/b/c","d"));
console.log(url.resolve("/a/b/c","/d"));
二、queryString模块的基本使用
queryString.escape()
queryString.parse()
queryString.stringify()
queryString.unescape()

const qs = require("querystring");
​
var str = "namealley#age20";
var obj = qs.parse(str,"#","*");
//console.log(qs.stringify(obj,"@","!"))
​
​
var str = "name=alley=sex=19"
var key = qs.escape("name=alley=sex");
console.log(qs.unescape(key))

三、events模块的基本使用
on:绑定事件
once:只执行一次事件
emit:执行匹配的事件
prependListener：将当前事件放到队列的最前面
removeALLListeners:移除所有事件
removeListener:移除指定事件监听
defaultMaxListeners：events默认的绑定事件只能绑定10个如果想绑定多个需要配置

const EventEmitter = require("events");
class MyEventEmitter extends EventEmitter{};
const myEventEmitter = new MyEventEmitter();
​
​
​
/*

on:事件订阅
emit：事件触发
removeListener：移除一个时间
removeAllListeners：移除所有事件
once:只绑定一次函数

​
*/
​
​
function fn1(val){

console.log(111,val)

}
​
function fn2(val){

console.log(222,val)

}
​
function fn3(val){

console.log(333,val)

}
​
myEventEmitter.once("handle",fn1)
myEventEmitter.once("handle",fn2)
myEventEmitter.once("handle",fn3)
​
//myEventEmitter.removeListener("handle",fn1)
//myEventEmitter.removeAllListeners("handle")
myEventEmitter.emit("handle","alley")
myEventEmitter.emit("handle","alley")

四、File System模块基本使用
得到文件与目录的信息：stat
创建一个目录：mkdir
创建文件并写入内容：writeFile,appendFile
读取文件的内容：readFile readFileSync
列出目录的东西：readdir
重命名目录与文件：rename
删除目录与文件：rmdir,unlink

const fs = require("fs");
const path = require("path");
fs.stat("./index.js",(err,data)=>{

console.log(data.isDirectory());

})
​
var data = fs.statSync("./index.js");
console.log(data.isFile())
​
​
fs.mkdir(path.resolve(__dirname,"./demo"),(err)=>{});
​
fs.writeFile(path.resolve(__dirname,"./demo/index.txt"),"abc",(err)=>{})
​
fs.readFile(path.resolve(__dirname,"./demo/index.txt"),(err,data)=>{

console.log(data+"");

})
​
​
fs.rename(path.resolve(__dirname,"./demo/index.txt"),path.resolve(__dirname,"./demo/list.txt"),(err)=>{})
​
​
fs.readdir(path.resolve(__dirname,"../../随堂案例"),(err,list)=>{

console.log(list)

})
​
​
fs.unlink(path.resolve(__dirname,"./demo/list.txt"),()=>{})
​
​
fs.rmdir(path.resolve(__dirname,"./demo"),(err)=>{})
/*

stat:判断文件类型
    isFile：判断是否是一个文件
    isDirectory:判断是否是一个文件夹

​

mkdir：创建文件夹

​

writeFile(path,content,callback)：创建并写入
    path：路径
    content:内容
    callback：回调

readFile(path,callback(err,data)):读操作

​

rename:重命名文件或者文件夹
    oldPath
    newpath

​

readdir:列出文件夹中所有文件

​

unlink:删除文件

​

rmdir:删除文件夹

*/

五、stream文件流
fs.createReadStream():创建可读文件流 参数1：已有文件
fs.createWriteStream():创建可写文件流 参数1：文件名称
pipe:管道

​
//链式使用pipe
const fs = reqiure("fs");
//压缩模块
const zlib = require("zlib");
​
const read = fs.createReadStream("");
const write = fs.createWriteStream("");
//先进行压缩然后在给write文件 16进制
read.pipe(zlib.createGzip()).pipe(write);

六、path模块的基本使用
path.join
path.resolve

const path = require("path");
​
/*

join:路径拼接
resolve:将参数转换为绝对路径

​
*/
console.log(path.join("/a","b","c"));
console.log(path.join(__dirname,"./index.js"));
console.log(path.resolve(__dirname,"./index.js"));

七、process
process.env
process.argv

console.log(process.env)
​
var arr = process.argv;
​
if(arr.indexOf("-v") !== -1){

console.log("1.11.1");

}else{

console.log("help....")

}

八、http模块
http.createServer
http.get
http.post
request
cheerio小爬虫

createServer

const http = require("http");
​
const server = http.createServer((req,res)=>{
​

//console.log(req.url,req.method)
console.log(req.headers)
// res.statusCode = 404;
// res.setHeader("content-type","text/plain;charset=utf8");

​

res.writeHead(200,{"content-type":"text/plain;chartset=utf8"})
res.write("我最近很好")
res.write("不用你担心")
res.write("再见")
res.end("NodeJS")

})
​
server.listen(9000,()=>{

console.log("server address:localhost:9000")

})
http.get

const http = require("http");
​
const path = "http://www.mobiletrain.org/?pinzhuanbdtg=biaoti";(网页)
http.get(path,(res)=>{

var str = "";
//因为数据接收是一块一块接收的 类似于流水一样
res.on("data",(data)=>{
    str += data;
})

​

res.on("end",()=>{
    console.log(str);
})

})
​
​
​
var path = "http://m.maoyan.com/ajax/movieOnInfoList?token=";//接口
​
http.get(path,(res)=>{

var str = "";

​

res.on("data",(data)=>{
    str += data;
})

​

res.on("end",()=>{
    console.log(JSON.parse(str));
})

})
request

const request = require("request");
const qs = require("querystring");
​
const options = {

url: "https://app2.motie.com/category/detail?free=0&finish=0&group=1&sortId=&page=1&pageSize=10",
method: "POST",
headers: {
    "os": "wap"
},
body: qs.stringify({
    free: 0,
    finish: 0,
    group: 1,
    sortId: "",
    page: 1,
    pageSize: 10,
})

}
​
​
request(options, (err, res, body) => {

console.log(JSON.parse(body));

})
​
​
/*

1、cnpm install request -S

​
​

request(options,callback(err,res,body))

​

err:错误
res:整个响应体
body：响应的数据

​
​

options = {
    method:""，
    url:""，
    headers:{},
    body:{请求的参数}
}

*/
小爬虫

const http = require("http");
//可以让我们以jQuery语法来进行dom查找 并不是对dom操作
const cheerio = require("cheerio");
const fs = require("fs");
const path = require("path");
const url = "http://www.mobiletrain.org/?pinzhuanbdtg=biaoti";
​
http.get(url,(res)=>{
​

var str = "";

​

res.on("data",(data)=>{
    str += data;
})

​
​

res.on("end",()=>{
    //将str封装到$符号中去
   var $ = cheerio.load(str);
   var banner_up_left = $(".banner_up_left>a");
   var arr = [];
    for(var i=0;i<banner_up_left.length;i++){
        var obj = {};
        obj.id = i;
        obj.text = banner_up_left.eq(i).find("span").text();
        arr.push(obj);
    }
   
    fs.readFile(path.join(__dirname,"./data/index.json"),(err,data)=>{
       var dataList = JSON.parse(data+"")
     
        if(!dataList.data){
            dataList.data = [];
        }

​

      
        dataList.data = arr;
        
        fs.writeFile(path.join(__dirname,"./data/index.json"),JSON.stringify(dataList),(err)=>{})
    })
})

​
})

九、路由
什么是路由？
路由的作用
前端路由与后端路由
路由核心属性
supervisor

const http = require("http");
const path = require("path");
const fs = require("fs");
const url = require("url");
const server = http.createServer((req, res) => {

const { pathname, query } = url.parse(req.url, true);

​

if (pathname == "/") {

​

    fs.readFile(path.join(__dirname, "./public/index.html"), (err, data) => {
        res.writeHead(200, { "contentType": "text/html;charset=utf8" });
        res.end(data);
    })

​

} else if (pathname == "/order") {
    fs.readFile(path.join(__dirname, "./public/html/order.html"), (err, data) => {
        res.writeHead(200, { "contentType": "text/html;charset=utf8" });
        res.end(data);
    })
} else if (pathname == "/list") {
    fs.readFile(path.join(__dirname, "./public/html/list.html"), (err, data) => {
        res.writeHead(200, { "contentType": "text/html;charset=utf8" });
        res.end(data);
    })
} else if (pathname == "/css/index.css") {
    fs.readFile(path.join(__dirname, "./public/css/index.css"), (err, data) => {
        res.writeHead(200, { "content-type": "text/css;charset=utf8" });
        res.end(data);
    })
} else if (pathname == "/js/index.js") {
    fs.readFile(path.join(__dirname, "./public/js/index.js"), (err, data) => {
        res.writeHead(200, { "content-type": "application/x-javascript;charset=utf8" });
        res.end(data);
    })
} else if (/\/img\/(.*)\.(jpg|png|gif)/.test(pathname)) {
    fs.readFile(path.join(__dirname, "./public/img/" + RegExp.$1 + "." + RegExp.$2), (err, data) => {
        res.writeHead(200, { "content-type": "image/" + RegExp.$2 });
        res.end(data);
    })
} else if (pathname == "/users/register") {
    let { username, password } = query;
    fs.readFile(path.join(__dirname, "./public/data/user.json"), (err, data) => {
        let userData = JSON.parse(data.toString());
        var bStop = true;
        for (var i = 0; i < userData.data.length; i++) {
            if (userData.data[i].username == username) {
                bStop = false;
                break;
            }
        }

​

        if (bStop) {
            userData.data.push({ username, password });

​

            fs.writeFile(path.join(__dirname, "./public/data/user.json"), JSON.stringify(userData), (err) => {
                if (!err) {
                    res.writeHead(200, { "content-Type": "application/json;charset=utf-8" })
                    res.end(JSON.stringify({
                        code: 200,
                        errMsg: "",
                        data: {
                            code: 1,
                            info: "注册成功"
                        }
                    }))
                }

​

            })

​

        } else {
            res.writeHead(200, { "content-Type": "application/json;charset=utf-8" })
            res.end(JSON.stringify({
                code: 200,
                errMsg: "",
                data: {
                    code: 0,
                    info: "用户名重复"
                }
            }))
        }

​
​

    })

​

}

})
​
server.listen(9000, () => {

console.log("server address:127.0.0.1:9000")

})
十、封装路由级静态资源处理
​
const url = require("url");
const fs = require("fs");
const path = require("path");
const qs = require("querystring")
//收集事件
const routerMap = {

get:{},
post:{}

}
​
const router = function(req,res){

//给res添加一个json方法
res.json = function(obj){
    res.end(JSON.stringify(obj))
}

​

//处理静态资源
handleStatic(req,res);

​
​

//获取用户请求的方式
var method = req.method.toLowerCase();
//获取用户请求的地址
var {pathname,query} = url.parse(req.url,true);

​

if(method === "get"){
    if(routerMap.get[pathname]){
        //将query的值赋值给req.query
        req.query = query;
        routerMap.get[pathname](req,res)
    }else{
        res.end("404")
    }

​
​

}else if(method === "post"){
    if(routerMap.post[pathname]){
        var str = "";

​

        //获取post传递的参数
        req.on("data",(data)=>{
            str += data;
        })

​

        req.on("end",()=>{
           req.body = qs.parse(str);
           routerMap.post[pathname](req,res)
        })
        
    }
}

}
​
//注册事件
router.get = function(path,callback){

routerMap.get[path] = callback;

}
//注册事件
router.post = function(path,callback){

routerMap.post[path] = callback;

}
​
​
​
//处理所有的静态资源访问
function handleStatic(req,res){

var {pathname} = url.parse(req.url,true);
//获取文件的后缀
var ext = pathname.substring(pathname.lastIndexOf("."));

​

if(pathname ==="/"){
    res.writeHead(200,{"content-type":"text/html;charset=utf8"});
    res.end(getFile(path.join(__dirname,"../public/index.html")))
}else if(ext === ".css"){
    res.writeHead(200,{"content-type":"text/css;charset=utf8"});
    res.end(getFile(path.join(__dirname,"../public",pathname)));
}else if(ext === ".js"){
    res.writeHead(200,{"content-type":"application/x-javascript;charset=utf8"});
    res.end(getFile(path.join(__dirname,"../public",pathname)));

​

}else if(/.*\.(jpg|png|gif)/.test(ext)){
    res.writeHead(200,{"content-type":`image/${RegExp.$1};charset=utf8`});
    res.end(getFile(path.join(__dirname,"../public",pathname)));
}else if(ext === ".html"){
    res.writeHead(200,{"content-type":"text/html;charset=utf8"});
    res.end(getFile(path.join(__dirname,"../public",pathname)));
}

}
​
​
function getFile(filePath){

return fs.readFileSync(filePath);

}
​
module.exports = router;
十一、mongoodb级mongoose的基本使用
1、mongodb安装

下载地址:https://www.mongodb.com/download-center/community
下一步傻瓜式安装
配置环境变量
启动mongod --dbpath c:datadb 开启数据库服务器 (开启)
终端末尾显示27017代表成功

2、关系型数据库与非关系数据库区别

优点：
1）成本：nosql数据库简单易部署，基本都是开源软件，不需要像使用oracle那样花费大量成本购买使用，相比关系型数据库价格便宜。
2）查询速度：nosql数据库将数据存储于缓存之中，关系型数据库将数据存储在硬盘中，自然查询速度远不及nosql数据库。
3）存储数据的格式：nosql的存储格式是key,value形式、文档形式、图片形式等等，所以可以存储基础类型以及对象或者是集合等各种格式，而数据库则只支持基础类型。
4）扩展性：关系型数据库有类似join这样的多表查询机制的限制导致扩展很艰难。
缺点：
1）维护的工具和资料有限，因为nosql是属于新的技术，不能和关系型数据库10几年的技术同日而语。
2）不提供对sql的支持，如果不支持sql这样的工业标准，将产生一定用户的学习和使用成本。
3）不提供关系型数据库对事物的处理。
3、mongodb常用命令

mongod --dbpath c:datadb 开启数据库服务器 (开启)
27017----》mongodb的端口号 http:80 || 8080 https:443

mongo 进入数据库服务器
show dbs 查看数据库服务器中有多少数据库
use 数据库名称 创建/切换数据库 如果数据库中没有表的情况下 数据库并不会真正的创建
db || db.getName() 查看当前使用的数据库
db.dropDatabase() 删除数据库

表的操作
db.createCollection("表名称") 创建表
db.getCollectionNames() 获取数据库中所有的表
db.getCollection('表名称') 使用某一张表
db.表名.drop() 删除某一张表

增
db.表名.save({字段})

删
db.表名.remove({}) 删除所有
db.表名.remove({字段}) 删除指定字段

改
db.表名.update({字段},{$set:{字段}})
db.表名.update({字段},{$inc:{字段(数字)}})

查
db.表名.find() 查找所有数据
db.表名.find({age:19}) 查找指定字段
db.表名.find({age:{$gt:22}}) 大于22的数据
db.表名.find({age:{$lt:22}}) 小于22的数据
db.表名.find({age:{$gte:22}}) 大于等于22的数据
db.表名.find({age:{$lte:22}) 小于等于22的数据
db.表名.find({age:{$gte:30,$lte:22})大于等于30小于等于22的数据
db.表名.find({name:/alley/}) 模糊查询 找到数据中有alley的数据
db.表名.find({age:/^alley/}) 查找首字符是alley
db.表名.find({age:/alley$/}) 查找尾字符是alley
db.表名.find({},{name:1,_id:0}) 只显示name这个字段
db.表名.find().sort({age:1}) 正序
db.表名.find().sort({age-1}) 降序
db.表名.find().limit(n) 显示多少条数据
db.表名.find().skip(n) 跳过多少条数据
db.表名.find().skip(n).limit(m) 跳过多少条 显示多少条
db.表名.findOne({}) 查找一条数据
db.表名.find().count() 查询表中有多少条数据