Node.js基础笔记

1
2
3
npm install 包名 
--registry=https://registry.npm.taobao.org

1
2
3
4
npm install -g cnpm 
--registry=https://registry.npm.taobao.org
cnpm install 包名  

1
2
3
4
console.log('hello node.js!')
var age = 18
console.log(global.age)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
//显示Node运行程序的参数,argv是一个数组，第一个成员描述node.exe位置，第二个参数执行的js脚本文件
console.log(process.argv)  

//platform显示当前操作系统
console.log(process.platform)
for(var i = 0 ; i < 10000000000 ; i++){
    var num = 10
}

//uptime方法,获取Node程序运行开始到当前的时间（秒）
console.log(process.uptime())

//结束node程序的运行
process.exit() 

1
2
3
4
5
6
7
8
9
var userName = process.argv[2]
var userPwd = process.argv[3]
if(userName != 'admin' || userPwd != '888'){
    console.log('您输入的用户名、密码错误，系统5秒后即将关闭！')
    setTimeout(function(){
        process.exit()
    },5000)
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
function eat(food){
    console.log('我是张三！')
    food()
}
function food1(){
    console.log('我要吃火锅！')
}
function food2(){
    console.log('我要吃西餐！')
}
//eat是主函数，内部的参数就是回调函数
eat(food1)
eat(food2)

1
2
3
4
5
6
7
8
var fs = require('fs')
//IO操作异步读取方法作为主函数，后续处理的方法作为回调函数
fs.readFile('products.txt',function(err,result){
    console.log('错误内容:',err)
    console.log('文件读取完成！内容：',result)
})
console.log('文件读取后续操作。。。。。。。')

1
2
3
4
5
6
7
8
9
10
11
12
13
14
# 回调地狱
do1(function() {
  do2(function() {
    do3(function() {
      do4(function() {
        do5(function() {
          do6()
        }); 
	 console.log(‘xxxx’)
      });
    });
  });
});

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
## Installation
npm install anywhere -g

## Execution
$ anywhere
// or with port
$ anywhere -p 8000
// or start it but silent(don't open browser)
$ anywhere -s
// or with hostname
$ anywhere -h localhost -p 8888
// or with folder
$ anywhere -d ~/git/anywhere
// or enable html5 history
$ anywhere -f /index.html

## Help
$ anywhere --help
Usage:
  anywhere --help // print help information
  anywhere // 8000 as default port, current folder as root
  anywhere 8888 // 8888 as port
  anywhere -p 8989 // 8989 as port
  anywhere -s // don't open browser
  anywhere -h localhost // localhost as hostname
  anywhere -d /home // /home as root
  anywhere -f /index.html  // Enable html5 history,the index is /index.html

## Visit
http://localhost:8000

1
2
3
4
var os = require('os')
console.log(process.uptime())       //获取程序运行时间
console.log(os.uptime())            //获取服务器开机时间

1
2
3
4
5
6
exports.name='tom';
exports.age=12;
exports.display=function(){
    console.log(‘I am a person');
};

1
2
3
4
5
6
7
8
var user = {
	name:'tom';
    age:12;
	display:function(){
   		console.log(‘I am a person');
   	};
module.exports = user;

1
2
3
4
5
6
7
//加载模块
var person1 = require('./1_myModule')
var person2 = require('./2_myModule')
//使用模块
person1.showInfo()
person2.showInfo()

1
2
3
4
5
6
7
8
var name = require('./nav/index.js')
console.log(name)
//1.核心模块加载时不需要添加路径
var os = require('os')
//2.非核心模块加载时，如果模块保存在node_modules文件夹下时，也不需要添加路径
var newAdd = require('newAdd')
console.log(newAdd(5,8))

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
## add.js
//定义模块内容,导出模块数据
module.exports = function(num1,num2){
    return parseInt(num1) + parseInt(num2)
}

## sub.js
//定义模块内容,导出模块数据
module.exports = function(num1,num2){
    return num1 - num2
}

## mul.js
//定义模块内容,导出模块数据
module.exports = function(num1,num2){
    return num1 * num2
}

## div.js
//定义模块内容,导出模块数据
module.exports = function(num1,num2){
    return num1 / num2
}

## index.js
//加载运算模块
var add = require('./calculate/add')
var sub = require('./calculate/sub')
var mul = require('./calculate/mul')
var div = require('./calculate/div')
//接受输入参数
var num1 = process.argv[2]
var num2 = process.argv[3]
var option = process.argv[4]
var result = 0    //保存运算结果
switch(option){
    case '+':result = add(num1,num2);break;
    case '-':result = sub(num1,num2);break;
    case '*':result = mul(num1,num2);break;
    case '/':result = div(num1,num2);break;
    default:console.log('运算符不正确!');process.exit();
}
console.log('运算结果：',result)

1
2
事件实例对象.on(‘event_name’,响应方法);

1
2
事件实例对象.emit(‘event_name’);

1
2
3
4
5
6
7
8
9
10
11
//1.导入事件模块
var events = require('events')
//2.实例事件对象
var event_emmiter = new events.EventEmitter()
//3.注册事件
event_emmiter.on('e_Test',function(){
    console.log('事件触发了，触发时间：',new Date().toLocaleTimeString())
})
//4.触发事件
event_emmiter.emit('e_Test')

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
## emp.js

console.log('当前运行的文件名：',__filename)
var emp = {
    name:'tom',
    salary:1000,
    work:function(){
        console.log('我开工了。。。。。。')
        console.log('今天老板不在，玩会手机,爽！')
    }
}
module.exports = emp
=======================================================
## boss.js

var boss = {
    name:'大富豪',
    manager:function(emp){
        console.log('有人偷懒，要处罚！')
        emp.salary -= 100
    }
}
module.exports = boss
=======================================================
## index.js

//非事件管理员工
var emp = {
    name:'tom',
    salary:1000,
    work:function(){
        console.log('我开工了。。。。。。')
        console.log('今天老板不在，玩会手机,爽！')
    }
}
var boss = {
    name:'大富豪',
    manager:function(emp){
        console.log('有人偷懒，要处罚！')
        emp.salary -= 100
    }
}
emp.work()
console.log('处罚前薪资：',emp.salary)
boss.manager(emp)
console.log('处罚后薪资：',emp.salary)
=======================================================
## index.js

//带事件机制的管理员工
var emp = require('./emp')
var boss = require('./boss')
var events = require('events')
var event_emmiter = new events.EventEmitter()

//注册事件，让boss管理emp
event_emmiter.on('e_playPhone',boss.manager)
emp.work()
console.log('违规之前工资:',emp.salary)
event_emmiter.emit('e_playPhone',emp)
console.log('违规之后工资:',emp.salary)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
## fire.js

var fire = {
    address:'观前街',
    level:3,
    startFire:function(){
        console.log('着火了！')
    }
}
module.exports = fire
===============================================================
## fightFire.js

var fightFire = {
    fight:function(fire){
        switch(fire.level){
            case 1:console.log('小火，吐口水就灭了！');break;
            case 2:console.log('中火,去个中队可以搞定!');break;
            case 3:console.log('大火，全体出动！');break;
            default:console.log('地狱烈火，赶紧撤退！')
        }
    }
}
module.exports = fightFire
===============================================================
## index.js

var events = require('events')
var ee = new events.EventEmitter()
var fire = require('./1_fire')
var fightFire = require('./2_fightFire')
//事件注册
ee.on('e_fire',fightFire.fight)
fire.startFire()
ee.emit('e_fire',fire)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
// 导入核心模块 path
var path = require('path')
// basename 方法获取完整文件名
console.log(path.basename('E:/nodejsDemo2/emp.js'))
// dirname 方法获取完整文件夹
console.log(path.dirname('E:/nodejsDemo2/emp.js'))
// extname 方法获取文件的扩展名，包含小数点（注意）
console.log(path.extname('E:/nodejsDemo2/emp.js'))
// 1. 连接字符串方式拼接,需要手动添加分隔符
console.log(__dirname + '\boss.js')
// 2. path 的 join 方式拼接，自动添加分隔符,可以返回上一级
console.log(path.join(__dirname,'..','boss.js'))
var strPath = 'E:/nodejsDemo2/emp.js'
console.log(path.parse(strPath).base)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
var fs = require('fs')

fs.stat('emp.js',function(err,status){
    if(err){
        console.log('发生错误，错误信息：',err)
    }else{
        console.log(status)
    }
})

var student = {
    name:'alex',
    age:28,
    sex:true,
    address:'人民路18号'
}

//覆盖式写文件
fs.writeFile('stuInfo.txt',JSON.stringify(student),function(err){
    if(err){
        console.log('文件写入失败，原因：',err)
    }else{
        console.log('文件写入成功！')
    }
})

//追加式写文件
fs.appendFileSync('newstuInfo.txt','tom 18 true 人民路18号rn',function(err){
    if(err){
        console.log('文件写入失败，原因：',err)
    }else{
        console.log('文件写入成功！')
    }
})

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
// 浏览器中的 Javascript 是没有文件操作的能力的
// 但是 Node 中的 JavaScript 具有文件操作的能力

// fs 是 file-system 的简写，就是文件系统的意思
// 在 Node 中如果想要进行文件操作，就必须引入 fs 这个核心模块
// 在 fs 这个核心模块中，就提供了所有的文件操作相关的 API
// 例如：fs.readFile 就是用来读取文件的

// 1. 使用 require 方法加载 fs 核心模块
var fs = require('fs')

// 2. 读取文件
//    第一个参数就是要读取的文件路径
//    第二个参数是一个回调函数
//          成功
//              data  数据
//              error null
//          失败
//              data  undefined 没有数据
//              error 错误对象

fs.readFile('./data/hello.txt',function(error,data){
  // 文件中存储的其实都是二进制数据 0 和 1
  //  为什么看到的不是二进制，是由于二进制转换为了十六进制了
  //  可以通过 toString 方法把其转化为我们能认识的字符
  // console.log(data.toString());

  //  错误判断
  if(error){
    console.log('读取文件失败')
  }else{
    console.log(data.toString());
  }
})

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
// 第一个参数：文件路径
// 第二个参数：文件内容
// 第三个参数：回调函数
//   error
//      成功：
//          文件写入成功
//          error 是 null
//      失败：
//          文件写入失败
//          error 就是错误对象
fs.writeFile('./data/你好.md','大家好，给大家介绍一下，我是Node.js',function(error){
  // 判断
  if(error){
    console.log('写入失败');
  }else{
    console.log('写入成功');
  }
})

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
var fs = require('fs')
//try把可能存在错误的代码包裹起来
try{
    var content = fs.readFileSync('stuInfo2.txt','utf-8')
    console.log('文件读取成功！')
    fs.writeFileSync('stuInfo1.txt',content)
}
//一旦出现错误，保证程序正常运行
catch(err)
{
    console.log('本次错误信息：',err.message)
}
console.log('文件复制成功！')
console.log('我啥时运行?')

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
//获取并显示当前项目目录中的所有的文件，不包含文件夹
var fs = require('fs')
//获取指定位置下的所有文件和子文件夹
fs.readdir(__dirname, function (err, result) {
    if (err) {
        console.log('读取错误！信息：', err.message)
    } else {
        //循环遍历所有的文件和子文件夹
        for (let i = 0; i < result.length; i++) {
            //查看每一个文件或文件夹的状态
            fs.stat(result[i], function (e, status) {
                if (e) {
                    console.log('文件读取错误，信息：',err.message)
                } else {
                    //如果循环访问到的是文件的话就输出显示，文件夹的话就忽略
                    if (status.isFile()) {
                        console.log(result[i] + '是文件')
                    }
                }
            })
        }
    }
})

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
## readStream.js

var fs = require('fs')
//创建读取文件流对象
var fread = fs.createReadStream('stuInfo.txt')
var content = ''
//注册读取事件
fread.on('data',function(result){
    //把读取的到的数据进行拼接
    content += result
})
//注册读取完成事件
fread.on('end',function(){
    console.log('文件的内容是：',content)
})
=====================================================
## writeStream.js

var fs = require('fs')
//创建文件输出流对象
var fwrite = fs.createWriteStream('stuInfo2.txt','utf-8')
fwrite.write('我学习了NodeJS!')
//结束文件流输出工作
fwrite.end()    
fwrite.on('finish',function(err){
    if(err){
        console.log('写文件失败，错误信息；',err.message)
    }else{
        console.log('写入完成！')
    }
})

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
var fs = require('fs')
var path = require('path')

//递归：自我调用，内容变化，变化会导致调用结束
//递归获取指定文件夹下的所有文件和子文件夹信息
function getInfo(filePath){
   var fileInfos =  fs.readdirSync(filePath)        //获取当前文件夹filePath下所有的文件和子文件夹
   for(var i = 0 ; i < fileInfos.length ; i++){
       var absPath = path.join(filePath,fileInfos[i])
        var stats = fs.statSync(absPath)        //获取指定文件或文件夹的状态
        if(stats.isDirectory()){
            console.log('文件夹：',absPath)
            getInfo(absPath)
        }else{
            console.log('文件：',absPath)
        }
   }
}
getInfo(__dirname)
//stat方法的使用，建议采用绝对路径
// fs.stat(path.join(__dirname,'node_modules','jquery','dist','jquery.js'),function(err,status){
//     console.log(status.isDirectory())
// })

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
var fs = require('fs')
//1.读取文件
fs.readFile('emp.txt', function (err, content) {
    //2.修改内容
    var newContent = ''
    content = content.toString('utf-8')
    var contents = content.split('rn')
    for (var i = 0; i < contents.length; i++) {
        var reg = /d+/gi
        var tax = parseInt(contents[i].match(reg)) * 0.05
        newContent += contents[i] + ' ' + tax + 'rn'
    }
    console.log(newContent)
    //3.覆盖文件
    fs.writeFile('emp.txt',newContent,function(err){
        if(err){
            console.log('修改失败！')
        }else{
            console.log('修改完成！')
        }
    })
})

1
2
3
4
5
http.get(url,function(result){
	result.on(‘data’,function(){  //接受数据 })
   	result.on(‘end’,function(){  //处理接收到的数据  })
})

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
var http = require('http')
var cheerio = require('cheerio')
http.get('http://search.jumei.com/?filter=0-11-1&search=%E9%9D%A2%E8%86%9C',function(res){
    var fullContent = ''
    res.on('data',function(content){
        fullContent += content          //接受数据
    })
    res.on('end',function(){
        // console.log(fullContent)
        var $ = cheerio.load(fullContent)
        $('.s_l_name a').each(function(index,item){
            console.log($(item).text().trim())
        })
    })
})

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
var http = require('http')
http.createServer(function (req, res) {
    console.log('有用户来访！')
    res.setHeader('content-Type','text/html;charset=utf-8')
    var ulHtml = ` <ul>
                        <li>1</li>
                        <li>2</li>
                        <li>3</li>
                        <li>4</li>
                    </ul>
                 `
    res.end(ulHtml)
})
.listen(3000, function (err) {
    if (err) {
        console.log('服务器发生错误，无法监听！')
    }
    else {
        console.log('服务器开始监听。。。。。。。')
    }
})

1
2
3
4
5
6
7
8
9
var url = require('url')
var str_url = 'http://www.wedn.net:8080/admin/users.html?name=zhaojy&age=18#profile'
var myUrl = url.parse(str_url)
console.log(myUrl.pathname)
console.log(myUrl.search)
var url1 = 'http://www.163.com'
var url2 = 'books/newbook.html'
console.log(url.resolve(url1,url2))  //拼接url的部分

1
2
3
4
5
6
7
8
9
10
11
12
13
var url = require('url')
var qs = require('querystring')
var str_url = 'http://www.wedn.net:8080/admin/users.html?name=zhaojy&age=18#profile'
var myUrl = url.parse(str_url)
var strqs = myUrl.search
//1.传统字符串函数解析
// console.log(strqs.slice(1).split('&')[0].split('=')[0])
// console.log(strqs.slice(1).split('&')[0].split('=')[1])
// console.log(strqs.slice(1).split('&')[1].split('=')[0])
// console.log(strqs.slice(1).split('&')[1].split('=')[1])
//2.qs模块解析
console.log(qs.parse(strqs.slice(1)))

1
2
http://localhost:3000/user?name=tom&email=tom@163.com

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
## get.js

var http = require('http')
var url = require('url')
var qs = require('querystring')
http.createServer(function (req, res) {
    console.log('有用户来访！')
    //处理请求
    console.log(req.url)
    if (req.url != '/favicon.ico') {
        var str_qs = url.parse(req.url).search.slice(1)
        var userName = qs.parse(str_qs).name
        var userEmail = qs.parse(str_qs).email
        console.log('name:',userName)
        console.log('email:',userEmail)
        //响应输出
        res.setHeader('content-Type', 'text/html;charset=utf-8')
        res.end('hello')
    }
})
    .listen(3000, function (err) {
        if (err) {
            console.log('服务器发生错误，无法监听！')
        }
        else {
            console.log('服务器开始监听。。。。。。。')
        }
    })

1
2
3
req.on(‘data’,callback);		//接收参数时
req.on(‘end’,callback);		//接收参数结束时

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
## post.js

var http = require('http')
var url = require('url')
var qs = require('querystring')
http.createServer(function (req, res) {
    console.log('有用户来访！')
    //处理请求
    console.log(req.url)
    if (req.url != '/favicon.ico') {
        var fullcontent = ''
        req.on('data',function(content){
            fullcontent += content
        })
        req.on('end',function(){
            console.log('post传参：',fullcontent)
        })
        //响应输出
        res.setHeader('content-Type', 'text/html;charset=utf-8')
        res.end('hello')
    }
})
    .listen(3000, function (err) {
        if (err) {
            console.log('服务器发生错误，无法监听！')
        }
        else {
            console.log('服务器开始监听。。。。。。。')
        }
    })

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
## register.html

<form action="http://localhost:3000/register" method="POST">
    <input type="text" name="userName">
    <input type="password" name="userPwd">
    <input type="submit" value="注册">
</form>

## login.html

<form action="http://localhost:3000/login" method="POST">
    <input type="text" name="username">
    <input type="password" name="userPwd">
    <input type="submit" value="登陆">
</form>
================================================================
## demo.js

var http = require('http')
var url = require('url')
var qs = require('querystring')
var fs = require('fs')
var path = require('path')
//创建服务器
http.createServer(function (req, res) {
    res.setHeader('content-type', 'text/html;charset=utf-8')
    if (req.url != '/favicon.ico') {
        var fullcontent = ''
        //接受用户post传入的数据
        req.on('data', function (content) {
            fullcontent += content
        })
        //完成接受用户post传入的数据
        req.on('end', function () {
            var objqs = qs.parse(fullcontent)   //解析新注册的数据，并转换成json对象
            //1.读取文件
            fs.readFile(path.join(__dirname, 'user.json'), function (err, users) {
                var usersData = JSON.parse(users)   //把json文件中的用户数据字符串转换成对象
                usersData.users.push(objqs)         //把新注册的用户数据添加到已有的用户数组中
                //把修改后的数据保存到原来的用户文件里
                fs.writeFile(path.join(__dirname, 'user.json'),
                    JSON.stringify(usersData), function (err) {
                        if (err) {
                            res.statusCode = 200
                            res.end('<script>alert("注册失败！")</script>')
                        } else {
                            res.statusCode = 200
                            res.end('<script>location.href="index.html";</script>')
                        }
                    })
            })
        })
    }

}).listen(3000)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
var http = require('http')
var url = require('url')
var fs = require('fs')
var path = require('path')
http.createServer(function (req, res) {
    console.log('有用户来访！')
    if (req.url != '/favicon.ico') {
        var filePath = path.join(__dirname,'static',url.parse(req.url).pathname.slice(1)) //获取静态网页的名称
        fs.readFile(filePath, function (err, htmlcontent) {
            if (err) {
                console.log('错误信息：', err.message)
            }
            console.log(htmlcontent.toString('utf-8'))
            res.setHeader('content-Type', 'text/html;charset=utf-8')
            res.end(htmlcontent.toString('utf-8'))
        })
    }
   
}).listen(3000)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
var http = require('http')
var fs = require('fs')
var url = require('url')
var qs = require('querystring')
var path = require('path')

http.createServer(function(req,res){
    res.setHeader('content-type','text/html;charset=utf-8')
    if(req.url != '/favicon.ico'){
        //提取查询的价格
        var price = qs.parse(url.parse(req.url).search.slice(1)).price
        //读取文件
        fs.readFile('products.json',function(err,content){
            if(err){
                console.log('文件读取出现异常！')
                res.end('查询失败！')
            }else{
                // var queryProducts = [] //保存符合查询条件的商品
                var strProductHTML = '<ul>'
                var products = JSON.parse(content) //把读取到的产品数据字符串转换成JSON对象
                for(var i = 0 ; i < products.length ; i++){
                    if(products[i].price < price){
                        // queryProducts.push(products[i])     //过滤商品数据
                        strProductHTML += `<li>${products[i].name}</li>`
                    }
                }
                strProductHTML += '</ul>'
                res.statusCode = 200
                res.end(strProductHTML)
            }
        })
    }
}).listen(3000,'127.0.0.1',function(err){
    console.log('开始监听')
})

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
## product.html

<form action="http://localhost:3000/addProduct" method="POST">
    <input type="text" name="pId" id="">
    <input type="text" name="pName" id="">
    <input type="text" name="pPrice" id="">
    <input type="text" name="pDate" id="">
    <input type="submit" value="入库">
</form>
====================================================================
## product.js

var http = require('http')
var fs = require('fs')
var url = require('url')
var qs = require('querystring')
var path = require('path')

http.createServer(function (req, res) {
    console.log('有客户访问')
    res.setHeader('content-type', 'text/html;charset=utf-8')
    if (req.url != '/favicon.ico') {
        var fullContent = ''
        req.on('data', function (content) {
            fullContent += content
        })
        req.on('end', function () {
            var newProduct = qs.parse(fullContent)
            //1.读取现有文件
            fs.readFile('products.json', function (err, products) {
                if (err) {
                    console.log('文件读取错误！')
                    res.statusCode = 500
                    res.end('商品入库失败！')
                } else {
                    //2.数据添加
                    var products = JSON.parse(products.toString())
                    console.log('products',products)
                    products.push(newProduct)
                    //3.写入新文件
                    fs.writeFile('products.json', JSON.stringify(products), function (err) {
                        if (err) {
                            console.log('文件记录失败！')
                            res.statusCode = 500
                            res.end('商品入库失败！')
                        }else{
                            res.statusCode = 200
                            res.end('商品入库成功！')
                        }
                    })
                }
            })
        })
    }
}).listen(3000, 'localhost', function (err) {
    console.log('开始监听')
})

1
2
ejs.renderFile( filename , data , callback)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
## page.ejs

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>EJS模板页面</title>
</head>
<body>
    <h1>这是EJS渲染的页面</h1>
</body>
</html>
=========================================================
## demo.js

var http = require('http')
var fs = require('fs')
var url = require('url')
var qs = require('querystring')
var path = require('path')
var ejs = require('ejs')

http.createServer(function (req, res) {
    res.setHeader('content-type', 'text/html;charset=utf-8')
    if (req.url != '/favicon.ico') {
        //判断用户请求是否是针对page1.ejs模板文件
        if (req.url == '/page1') {
            fs.readFile('view/page1.ejs', function (err, content) {
                if (err) {
                    console.log('ejs文件加载失败！')
                    res.end('网页不存在！')
                } else {
                    res.end(content)
                }
            })
            // ejs.renderFile('view/page1.ejs',{},function(err,content){
            //     if(err){
            //         console.log('ejs文件加载失败！')
            //         res.end('网页不存在！')
            //     }else{
            //         res.end(content)
            //     }
            // })
        }
    }
}).listen(3000, '127.0.0.1', function (err) {
    console.log('开始监听')
})

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
## page.ejs

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>EJS模板页面</title>
</head>
<body>
    <h1>这是EJS渲染的页面</h1>
    <h3><%=title%></h3>
    <p><%=content%></p>
    <%
        var now = new Date('2009-1-1')
        var year = now.getFullYear()
        if(year % 4 == 0 && year % 100 != 0 || year % 400 == 0){
    %>
            <span>闰年</span>
    <%
        }
        else{
    %>
            <span>不是闰年</span>
    <%        
        }
    %>
    <ul>
        <%
            for(var i = 0 ; i < names.length ;i++){
        %>
        <li><%=names[i]%></li>
        <%        
            }
        %>

    </ul>
</body>
</html>
================================================================
## demo.js

var http = require('http')
var fs = require('fs')
var url = require('url')
var qs = require('querystring')
var path = require('path')
var ejs = require('ejs')

http.createServer(function (req, res) {
    res.setHeader('content-type', 'text/html;charset=utf-8')
    if (req.url != '/favicon.ico') {
        //判断用户请求是否是针对page1.ejs模板文件
        if (req.url == '/page1') {
            ejs.renderFile('view/page1.ejs',
            {title:'我是EJS的标题',content:'我是EJS的内容',names:['tom','jack','mary']},
            function(err,content){
                if(err){
                    console.log('ejs文件加载失败！')
                    res.end('网页不存在！')
                }else{
                    res.end(content)
                }
            })
        }
    }
}).listen(3000, '127.0.0.1', function (err) {
    console.log('开始监听')
})

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>互联网大神名录</title>
    <style>
        ...
    </style>
</head>
<body>
    <ul>
        <%
            for(var i = 0 ; i < godsInfo.gods.length; i++){
        %>
        <li>
            <img src="<%=godsInfo.gods[i].face%>" alt="">
            <h3><%=godsInfo.gods[i].name%></h3>
            <p><%=godsInfo.gods[i].intr%></p>
        </li>
        <%        
            }
        %>
    </ul>
</body>
</html>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
var http = require('http')
var fs = require('fs')
var url = require('url')
var qs = require('querystring')
var path = require('path')
var ejs = require('ejs')

http.createServer(function (req, res) {
    res.setHeader('content-type', 'text/html;charset=utf-8')
    if (req.url != '/favicon.ico') {
        //判断用户请求是否是针对page1.ejs模板文件
        if (req.url == '/myGods') {
            var myGodsData = null
            // myGodsData = JSON.parse(fs.readFileSync('myGods.json').toString()) //同步方式获取数据
            //1.读取myGods.json的数据
            fs.readFile('myGods.json', function (err, content) {
                myGodsData = JSON.parse(content.toString())
                //2.渲染EJS模板页面
                ejs.renderFile('view/myGods.ejs',
                    { godsInfo: myGodsData },
                    function (err, content) {
                        if (err) {
                            console.log('ejs文件加载失败！')
                            res.end('网页不存在！')
                        } else {
                            res.end(content)
                        }
                    })
            })
           
        }else{
            // 处理非ejs文件的其他静态资源文件，例如图片等
            console.log('imgPath:',req.url)
            // 读取图片文件内容,并通过响应对象，向客户端发出
            fs.readFile('public/images' + req.url,function(err,content){
                if(err){
                    console.log('err:',err.message)
                }else{
                    console.log('content',content)
                    res.setHeader('content-type','image/jpg')
                    res.end(content)
                }
            })
        }
    }
}).listen(3000, '127.0.0.1', function (err) {
    console.log('开始监听')
})

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
var http = require('http')
var fs = require('fs')
var url = require('url')
var qs = require('querystring')
var path = require('path')
var ejs = require('ejs')

http.createServer(function (req, res) {
    res.setHeader('content-type', 'text/html;charset=utf-8')
    if (req.url != '/favicon.ico') {
        if(req.url == '/page1'){
            ejs.renderFile('view/page1.ejs',
            {title:'我是EJS的标题',content:'我是EJS的内容',names:['tom','jack','mary']},
            function(err,content){
                res.end(content)
            })
        }else if(req.url == '/page2'){
            ejs.renderFile('view/page2.ejs',{name:[]},function(err,content){
                res.end(content)
            })
        }else{
            res.statusCode = 404
            res.end('无此网页，访问错误！')
        }
    }
}).listen(3000, '127.0.0.1', function (err) {
    console.log('开始监听')
})

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
## routes.js

var App = {
    page1:function(req,res){
        res.end('我是第一个页面')
    },
    page2:function(req,res){
        res.end('我是第二个页面')
    },
    login:function(req,res){},
    register:function(req,res){},
    query:function(req,res){}
}
module.exports = App
=============================================
## index.js

var http = require('http')
var fs = require('fs')
var url = require('url')
var qs = require('querystring')
var path = require('path')
var App = require('./model/routes') //导入自定义路由模块

http.createServer(function (req, res) {
    res.setHeader('content-type', 'text/html;charset=utf-8')
    if (req.url != '/favicon.ico') {
        var path = url.parse(req.url).pathname.slice(1)   
        try {
            App[path](req,res)
        } catch (err) {
            res.statusCode = 404
            res.end('网页不存在，请检查！')
        }
    }
}).listen(3000, '127.0.0.1', function (err) {
    console.log('开始监听')
})

1
2
3
alter user ‘root’@’localhost’ identified with mysql_native_password by ‘密码’; 
flush privileges;

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
var mysql = require('mysql')
//创建数据库连接对象,设置数据库连接参数
var connection = mysql.createConnection({
    host:'localhost',
    port:3306,
    database:'myserver',
    user:'root',
    password:'123456'
})
//连接数据库
connection.connect(function(err){
    if(err){
        console.log('数据库连接失败！',err.message)
    }else{
        console.log('数据库连接成功！')
        //操作数据库的代码段
        console.log('数据库的增删改查。。。。。。')
        //关闭连接
        connection.end()    
    }
})

1
2
3
4
connection.query ( 查询语句 , 回调函数(err,results,fields){
	处理查询后的后续操作
})；

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
//连接数据库
connection.connect(function(err){
    if(err){
        console.log('数据库连接失败！',err.message)
    }else{
        console.log('数据库连接成功！')
        //操作数据库的代码段
        connection.query('select * from emp',function(err,results){
            if(err){
                console.log('数据库查询失败！',err.message)
            }else{
                console.log('数据查询结果：',results)
            }
        })
        //关闭连接
        connection.end()    
    }
})

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
var http = require('http')
var mysql = require('mysql')

http.createServer(function(req,res){
    res.setHeader('content-type','text/html;charset=utf-8')
    if(req.url != '/favicon.ico'){
        //连接数据库，获取数据，响应对象发送数据
        var connection = mysql.createConnection({
            host:'localhost',
            port:3306,
            database:'myserver',
            user:'root',
            password:'123456'
        })
        connection.connect(function(err){
            if(err){
                console.log('数据库连接失败！')
                res.end(JSON.stringify({code:500,message:'无法查询数据！'}))
            }else{
                connection.query('select * from emp',function(err,results){
                    if(err){
                        console.log('数据库查询失败',err.message)
                    }else{
                        res.end(JSON.stringify({code:200,message:'查询完成',data:results}))
                    }
                })
            }
            connection.end()
        })
    }
}).listen(3000,function(){
    console.log('开始监听。。。')
})