您的位置:首页 > Web前端 > Node.js

Node.js三大模块,常用内置模块介绍http模块,path模块,querystring模块,events模块,fs模块,stream模块

2019-05-21 15:55 811 查看

Node.js三大模块

Node.js内置模块

  1. 常用模块
  • http模块 功能:创建http server服务
  • 常用方法: 方法一:createServer() 格式http.createServer(function(request,response){})
    var http = require('http'); //引用http模块
    var port=8080;//端口
    var hostname="localhost";//主机
    http.createServer(function(request, response) { //创建一个http服务
    
    response.writeHead(200, {
    'content-type': 'text/html;charset=utf8'  //状态码200表示请求成功,进行头部配置,文件格式为html,编码方式为utf8,如果不设置会出现直接把response.write()里的内容连带标签一起发送
    })
    
    response.write('<p> hello Node.js</p>') //写入要发送的数据
    
    response.end() //通知前端数据发送完成
    
    }.listen(port, hostname, function() { //监听服务器 listen( port , hostname , callback)
    
    console.log(`服务器运行在: http://${hostname}:${port}`)
    
    })
  • 方法二:get() 格式http.get(options[, callback])/http.get(url[,options][, callback])
    //下面看一下运用http.get()搭配Node.js第三方模块cheerio,写一个小的爬虫案例cheerio模块的安装和使用会在下面【Node.js第三方模块】里详细介绍
    
    //使用数据请求一段内容,然后将获得的数据内容用cheerio工具做数据清洗,最后再通过后端服务器发送到前端页面   数据清洗(工具 cheerio)安装教程在【Node.js第三方模块】
    
    //引入http和cheerio模块
    var http = require('http')
    var cheerio = require('cheerio')
    
    // http.get(url/options,callback)
    
    const options = {
    hostname: '主域名名称',
    port: 80,
    path: '路径',
    method: 'get',
    headers: {
    //Request Headers中的数据    可在在控制台Network中Doc寻找到
    }
    };
    // 创建静态服务器
    http.createServer(function(request, response) {
    
    response.writeHead(200, {
    'Content-type': 'text/html;charset=utf8'
    })
    
    var req = http.get(options, function(res) {
    res.setEncoding('utf8');
    let rawData = '';
    res.on('data', (chunk) => { rawData += chunk; });
    res.on('end', () => {
    console.log(rawData)
    try {
    var $ = cheerio.load(rawData) //数据清洗
    $('.bjh-p')//数据清洗 清洗出特定的数据
    response.write('发布到前端筛选后的数据内容')
    response.end()
    } catch (e) {
    console.error(e.message);
    }
    })
    
    }).on('error', (e) => { // get的报错
    console.error(`problem with request: ${e.message}`);
    })
    
    req.end()
    
    }).listen(8001, 'localhost', function() {
    console.log(`服务器运行在: http://localhost:8001`)
    })
  • path模块
      功能:磁盘处理的模块 提供用于处理文件路径和目录路径的实用工具
    • 常用方法 方法:path.join()/path.resolve() 作用类似 将一个目录的名称拼接到一个磁盘路径上
      var path = require( 'path' ) //引入path模块
      //__dirname 表示当前的文件所在的文件夹
      var path = require('path')
      
      console.log(__dirname) //d:\wtf\Thr\blogs_note 当前文件所在文件夹的路径
      
      console.log(path.resolve(__dirname, '../text')) //d:\wtf\Thr\text 拼接路径
      
      console.log(path.join(__dirname, '../text')) //d:\wtf\Thr\text 与resolve方法相同
      
      console.log(path.resolve(__dirname, './text2')) //d:\wtf\Thr\blogs_note\text2 拼接路径
      
      console.log(path.join(__dirname, './text2')) //d:\wtf\Thr\blogs_note\text2 拼接路径
      
      // ../代表操作上一层路径, ./代表操作当前路径
  • querystring模块
      功能:字面上的意思就是查询字符串,一般是对http请求所带的数据进行解析
    • 常用方法 parse : 将String – > Object 格式querystring.parse(str[, sep[, eq[, options]]])
      var qs = require( 'querystring' ) //引入querystring模块
      
      var str = 'http://www.baidu.com:8080/001?a=1&b=2#hash=20' //一段url地址
      
      var obj = qs.parse( str )
      //运行结果
      { 'http://www.baidu.com:8080/001?a': '1', b: '2#hash=20' }
      
      var obj2 = qs.parse( str ,'?', '&' ) // 第二个参数采用?分隔成两个键值对,第三个参数&符号分割键值
      //运行结果
      { 'http://www.baidu.com:8080/001': '', 'a=1': 'b=2#hash=20' }
    • stringify : 将Object -> String 格式querystring.stringify(obj[, sep[, eq[, options]]])
      var qs = require( 'querystring' ) //引入querystring模块
      
      var str = 'http://www.baidu.com:8080/001?a=1&b=2#hash=20' //一段url地址
      
      console.log(qs.stringify(obj))
      //运行结果
      //http%3A%2F%2Fwww.baidu.com%3A8080%2F001=&a%3D1=b%3D2%23hash%3D20
      
      //stringify中 : 将Object  -> String  一些特定的符号会转换成特定的字符
      // %3A -> : ;  %2F -> / ;  %3D -> = ;  %23 -> #   ;   =& -> ?
    • escape&unescape方法:escape方法以对 URL 查询字符串的特定要求进行了优化的方式对给定的 str 执行 URL 百分比编码。unescape querystring.unescape() 方法在给定的 str 上执行 URL 百分比编码字符的解码。
      var qs = require('querystring')
      
      var url = require('url') //引入url模块
      
      var textStr = 'http://www.google.com/001?title=搜索'
      
      var urlObj = url.parse(textStr)
      //urlObj的结果
      Url {
      protocol: 'http:',
      slashes: true,
      auth: null,
      host: 'www.google.com',
      port: null,
      hostname: 'www.google.com',
      hash: null,
      search: '?title=搜索',
      query: 'title=搜索',
      pathname: '/001',
      path: '/001?title=搜索',
      href: 'http://www.google.com/001?title=搜索' }
      var query = urlObj.query // title=索搜
      
      console.log( qs.escape( query ) ) // title%3D%E6%90%9C%E7%B4%A2
      
      console.log( qs.unescape( qs.escape( query ) ) ) //title=搜索
  • events模块
      功能:大多数 Node.js 核心 API 构建于惯用的异步事件驱动架构,其中某些类型的对象(又称触发器,Emitter)会触发命名事件来调用函数(又称监听器,Listener)。
    • 常用方法 on() & emit() on() & emit()
      var Events=reqire=('events'); //引用events模块
      
      class MyEvents extends Events {} //MyEvents采用class继承Events
      
      var myEvents = new MyEvents () //实例化 MyEvents
      
      myEvents.on('event',function(){ //on()用来声明事件
      console.log( 'hello Node.js event' )
      })
      
      myEvents.emit('event') //emit()用来触发事件
  • fs模块
      功能:fs是Node.js中的文件系统,用来操作文件和目录的增删改查
    • 常用方法1,文件模块: fs.writeFile(file, data[, options], callback)创建文件
      var fs = require( 'fs' )//引用fs模块
      
      fs.writeFile('./renamenew/writeFile.txt','hello fs',function( error ) {
      if( error ) throw error //有错就抛错
      })
      //创建一个writeFile.txt文件,第一个参数为存储文件的路径,文件内容为第二个参数'hello fs',第三个参数是错误的回调函数
    • fs.appendFile(path, data[, options], callback) 更改文件内容
      var fs = require( 'fs' )//引用fs模块
      
      fs.appendFile('./renamenew/writeFile.txt','添加内容','utf8',function( error ) {
      if( error ) throw error
      console.log('文件修改成功')
      })
      //修改writeFile.txt文件,第一个参数为存储文件的路径,第二个参数为要更改的内容'添加内容',第三个参数为字符的编码方式,这里为中文编码'utf8',第四个参数是错误的回调函数
      //最终结果1.txt文件的内容为'hello fs添加内容',不会覆盖之前的内容
    • fs.readFile(path[, options], callback) 查找文件
      var fs = require( 'fs' )//引用fs模块
      
      fs.readFile('./renamenew/writeFile.txt', 'utf8', function(error, data) {
      if (error) throw error
      console.log('文件读取成功')
      console.log(data)
      })
      //读取文件内容  data 为获取的读取内容  'hello fs添加内容'
    • fs.unlink(path, callback) 删除文件
      var fs = require( 'fs' )//引用fs模块
      
      fs.unlink('./renamenew/writeFile.txt', function(error) {
      if (error) throw error
      console.log('文件删除成功')
      })
      //删除文件writeFile.txt
  • 常用方法2,目录模块
      fs.mkdir(path[, options], callback) 创建目录 path路径
      var fs = require('fs');
      
      fs.mkdir('./new', function(error) {
      if (error) throw error
      console.log('目录创建成功')
      });
      //在当前文件所在的文件夹里创建一个名为new的新目录
    • fs.rename(oldPath, newPath, callback) 重命名目录
      var fs = require('fs');
      
      fs.rename('./new', './renamenew', function(error) {
      if (error) throw error
      console.log('目录更改成功')
      })
      //把new目录重命名为renamenew
    • fs.readdir(path[, options], callback) 读取目录 读取目录里的内容,包含文件和目录
      var fs = require('fs');
      
      fs.readdir('./renamenew', function(error, data) {
      if (error) throw error
      console.log('目录读取成功')
      console.log(data)
      })
      //把new目录重命名为renamenew
      //运行结果data以数组的形式输出 [ '2.txt', '2.txt.gz', '3.txt', 'folder', 'writeFile.txt' ]
      综合运用 先读取一个目录里的所有文件,然后再读取每个文件里的内容
      var fs = require('fs');
      
      fs.readdir('./renamenew', function(error, data) {
      if (error) throw error
      for(var i=0;i<data.length;i++){
      fs.readFile(`./renamenew/${data[i]}`,'utf8',function(error,contentdata){
      if (error) throw error
      console.log(contentdata)
      })
      }
      })
    • fs.rmdir(path, callback) 删除目录 只能删除空目录,如果目录里有文件或者目录就不能被删除,要先全部删除目录里的文件和目录,才能删除这个目录
      var fs = require('fs');
      
      fs.rmdir('./rmdir', function(error) {
      if (error) throw error
      console.log('目录删除成功')
      })
      //把rmdir目录删除
  • stream模块
      流(stream)是 Node.js 中处理流式数据的抽象接口。 stream 模块用于构建实现了流接口的对象。流的概念,可以想象成有两个水杯,要把水杯1的水倒入水杯2,流的意思就是在两个水杯之间连接一个管道,可以非常方便的让水杯1的水传递给水杯2. pipe()方法 pipe就是管道流的意思
      var fs = require( 'fs' ) //引入文件系统
      var zlib = require('zlib')  // 创建压缩包模块
      
      var readeStream = fs.createReadStream( './renamenew/writeFile.txt' ) //读取writeFile.txt文件里的内容
      
      var writeStream = fs.createWriteStream( './renamenew/writeFile.txt.gz' )
      //把readeStream内容写入writeStream里
      
      var gzip = zlib.createGzip() // 创建空压缩包
      
      readeStream
      .pipe( gzip )
      .pipe( writeStream )
      //通过管道流的方式,连接gzip和writeStream把writeStream里的内容传入gzip里
  • 内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
    标签: