Node 知识点 02

it2022-05-05 107

Stream 流

什么是流？ Node中为什么要有流这个概念？使用场景？流指的是数据流，指的是数据是分片传输数据可以实现非阻塞gulp 【流式操作】

案例：打包压缩包

流程：

读取文件创建压缩包将读取的数据流写入压缩包输出压缩包 vconst fs = require('fs') // 读取xxx.txt文件 const zlib = require('zlib') // 创建压缩包 // const inp = fs.createReadStream( 路径 ) const inp = fs.createReadStream( './xxx.txt' ) //读取数据路径 const gzip = zlib.createGzip() // 创建压缩包 // const outp = fs.createWriteStream(路径) const outp = fs.createWriteStream( './xxx.txt.gz' ) inp .pipe( gzip ) .pipe( outp )

自定义模块

// 1. 创建模块 const name = { id: 1, name: 'zhangsan' } const str = 'sdaf' // 2. 导出模块 // module.exports = name 只能导出一个 module.exports = { // 批量导出 name, str } //3. 模块的导入 // const { name,str } = require(路径) const { name,str } = require('./02-name.js') console.log( name.name , str )

第三方模块：

我们一般都是从npmjs.com这个网站拉取

使用流程：

1. 安装

npm init -y

先创建package.json 文件

npm/cnpm i request -S/-D

-S --save 生产环境

-D --save-dev dev development的简写开发环境

2. 使用

request这个模块是做数据请求

3. Node中数据请求存在跨域吗?

不存在

const request = require('request') request('https://m.lagou.com/listmore.json',( a,b,c ) => { console.log( 'a',a ) // error console.log( 'b',b ) // response 返回所有结果 console.log( 'c',c ) // body 数据 string })

HTTP

Node.js读取文件都是二进制流

Buffer

binary

const fs = require( 'fs' ) fs.readFile('./yyb.txt',( error, docs ) => { console.log( docs.toString() ) }) 会出现乱码 fs.readFile('./yyb.txt','utf8',( error, docs ) => { console.log( docs.toString() ) }) 加上UTF-8编码则不会出现乱码

http模块

http.get http.request 业务：从nowapi中找一个免费接口，进行数据请求

HTTP.GET

后端服务器有两种类型

web服务器【静态服务器】api服务器【暴露接口】

请求头部报文

1. general 请求基本信息

2. response Headers 响应头

3. request Headers 请求头

4. 携带参数

query string paramters get请求

form data post 请求

WEB静态服务器

引入第三方类库爬数据

http模块

爬虫去某一个网站爬取一段数据 -> 数据清洗 -> 后端服务器 -> 发送前端 -> 渲染数据不是所有网站都可以爬取反爬虫爬虫：后端渲染的网站

Node.js中event模块

Node.js中事件的发布 + 事件的订阅表示一个任务的执行

api服务器

Node.js中api服务器的创建，我们使用一个第三方库 express

后端解决跨域问题：

1. 设置请求头

2. 使用中间件 const express = require('express'); const app = express() //得到一个对象 const port = 8000; const host = '10.31.158.80'; //创建接口 app.get('/user', (req, res, next) => { //回调函数我们称之为：中间件具有特定功能的一个函数 console.log(req.headers.origin) res.setHeader('Access-Control-Allow-Origin', '*'); // 设置请求头跨域 res.json({ id: 1, name: 'zhangsan', class: '1905' }) }) app.get('/demo', (req, res, next) => { //回调函数我们称之为：中间件具有特定功能的一个函数 console.log(req.headers.origin) res.setHeader('Access-Control-Allow-Origin', '*'); // 设置请求头跨域 res.json({ id: 1, name: 'zhangsan', class: '1905' }) }) // 创建api服务器，并监听这个服务器 app.listen(port, host, () => { console.log(`服务器运行在http://${host}:${port}`) })

使用第三方的包一次性结果所有跨域问题

第三方的包 cors

const express = require( 'express' ) const app = express() // 得到一个app对象 const port = 3000 const host = 'localhost' const cors = require( 'cors' )//引入第三方的包 // 创建接口 //第三方的包 app.use(cors({ "origin": "*", "methods": "GET,HEAD,PUT,PATCH,POST,DELETE", "preflightContinue": false, "optionsSuccessStatus": 200 })) app.get( '/user', ( req,res,next ) => { // 回调函数我们称之为：中间件具有特定功能的一个函数 res.json({ id: 1, name: 'zhangsan', class: '1905' }) }) app.get( '/demo', ( req,res,next ) => { // 回调函数我们称之为：中间件具有特定功能的一个函数 res.json({ id: 2, name: 'zhangsan', class: '1905' }) }) // 创建api服务器，并监听这个服务器 app.listen( port,host,() => { console.log( `The server is running at : http://${ host }:${ port }` ) })

专利

最新回复(0)