nodejs复习05

stream

可读流

• fs.pause()方法会使处于流动模式的流中止触发data事件，切换到非流动模式并让后续数据流在内部缓冲区

var fs = require('fs')

var rs = fs.createReadStream('2.txt');

rs.setEncoding('utf8')

//当一个数据快能够从流中被读出触发
rs.on('readable', function () {
    console.log('readable event');
})

//读取数据块时操做
rs.on('data', function (chunk) {
    console.log('data event');
    rs.pause();  //中止
    setTimeout(function () {
        rs.resume() //恢复
        console.log(chunk);
    }, 3000)
})

//数据接收发生错误时
rs.on('error', function (err) {
    console.log('error event');
})

//没有更多数据可以提供时
rs.on('end', function () {
    console.log('end event');
})

//底层数据源(如数据源文件描述符)被关闭时触发
//注意不是全部流都会触发
rs.on('close', function () {
    console.log('close event');
})

• 可读流有两种模式: 流动模式和暂停模式，暂停模式必须明确调用stream.read(size)方法，默认流动模式
• read发明合法用语从内部缓存区中读取并返回数据；没有设置size则一次返回全部缓冲区数据
• read方法仅在暂停模式时被调用，流动模式会自动调用

//暂停模式，无需再设置data事件，readable会被调用两次
rs.on('readable', function () {
    console.log('readable event');
    var chunk

    while((chunk = rs.read()) !== null) {
        console.log(chunk)
    }
})

使用可读流发送数据

• 可读流在接收者么哦呦读取数据以前会缓存全部压入的数据

var stream = require('stream')
var rs = new stream.Readable

rs.push('Stream')  //发送数据
rs.push('Readable')
rs.push('Push()')
rs.push('Pipe()')
rs.push('\n')
rs.push(null)  //通知发送数据完毕
rs.pipe(process.stdout)  //pipe方法导出数据

pipe方法

• 使用pipe时回自动调用data/end事件

//复制文件
var readable = fs.createReadStream('a.js');
var writeable = fs.createWriteStream('c.js');
readable.pipe(writeable)

unpipe方法

• 会解除以前调用pipe所设定的流;

var readable = fs.createReadStream('a.js');
var writeable = fs.createWriteStream('c.js');
readable.pipe(writeable)

//指定了目标c.js文件会变空白
readable.unpipe(writeable);
writeable.end()


//指定了目标但没有创建导流, 不会影响
setTimeout(function (){
    readable.unpipe(writeable);
    writeable.end()
}, 100)

可写流

• ws.write方法向底层系统写入数据，并在数据被处理完毕后调用回调函数；若是数据滞留在内部则返回false

var fs = require('fs')

var ws = fs.createWriteStream('1.txt');
ws.write('stream-');
ws.write('writable-');
ws.write('file-');
ws.end('end\n')

二者共同使用

var fs = require('fs')

var rs = fs.createReadStream('a.js');
var ws = fs.createWriteStream('1.txt');

rs.setEncoding('utf8')

rs.on('data', function (chunk) {
    if(ws.write(chunk) === false) rs.pause()
})

ws.on('drain', function () {
    rs.resume()
})

//ws.end被调用且全部数据已经被写入底层系统
ws.on('finish', function() {
    console.log('ws finish');
})

rs.on('end', function () {
    ws.end()
})

http

http服务器

var http = require('http')
var url = require('url')

http.createServer(function (req, res) {
        var pathname = url.parse(req.url).pathname
        if(pathname === '/') {
            res.writeHead(200, {'Content-Type': 'text/html'})
            res.write('<h3>Nodejs-Http</h3>')
        res.end('<p>Create Basic HTTP Server!</p>')
        } else {
            res.writeHead(301, {'Location':'/'})
            res.end()
        }
}).listen(3000)

• setHeader/getHeader: setHeader方法用于读取一个在队列中但没有被发送至客户端的header
• writeHeade方法只能在当前请求中使用一次，必须在write/end以前调用

http客户端

var http = require('http')

var options = {
    hostname: '127.0.0.1',
    port: 3000,
    path: '/',
    method: 'get'
}


var req = http.request(options, function (res) {
    console.log('STATUS: ' + res.statusCode);
    console.log('HEADERS: ' + JSON.stringify(res.headers));
    res.setEncoding('utf8')
    var body = ''
    res.on('data', function (chunk) {
        body += chunk
    })
    res.on('end', function () {
        console.log('BODY: ' + body);
    })
})

req.on('error', function (err) {
    console.log('err: ' + err);
})

req.write('data\n')

req.end()

• 简化get调用: http.get(url, callback)

util

格式化字符串

util.format(format. args)

%s
%d
%j