Node.js_node.js의 버퍼링 및 스트리밍 모듈에 대한 자세한 소개

버퍼 모듈

js는 원래 브라우저용으로 설계되었기 때문에 유니코드로 인코딩된 문자열을 잘 처리할 수 있지만 바이너리 데이터를 잘 처리할 수 없습니다. 이는 Node.js에 문제가 됩니다. Node.js는 종종 바이너리 형식으로 네트워크를 통해 데이터를 보내고 받도록 설계되었기 때문입니다. 예:

- TCP 연결을 통해 데이터를 보내고 받습니다.
- 이미지 또는 압축 파일에서 바이너리 데이터를 읽습니다.
- 파일 시스템에서 데이터를 읽고 씁니다.
- 네트워크에서 바이너리 데이터 스트림 처리

버퍼 모듈은 원시 데이터를 Node.js에 저장하는 방법을 제공하므로 바이너리 데이터를 js의 컨텍스트에서 사용할 수 있습니다. Node.js의 I/O 작업으로 이동된 데이터를 처리해야 할 때마다 Buffer 모듈을 사용할 수 있습니다.

클래스: 버퍼

Buffer 클래스는 바이너리 데이터를 직접 처리하는 데 사용되는 전역 변수 유형입니다. 다양한 방법으로 구축할 수 있습니다.

원본 데이터는 Buffer 클래스의 인스턴스에 저장됩니다. 버퍼 인스턴스는 정수 배열과 유사합니다

1.new Buffer(size): 8비트 바이트 크기의 새로운 버퍼를 할당합니다.
2.new Buffer(array): 8비트 바이트 배열을 사용하여 새로운 버퍼를 할당합니다.
3.new Buffer(str, [encoding]):encoding 문자열 유형 - 사용할 인코딩 방법, 매개변수는 선택사항입니다.

4. 클래스 메소드: Buffer.isEncoding(encoding): 주어진 인코딩 인코딩이 유효하면 true를 반환하고, 그렇지 않으면 false를 반환합니다.
5. 클래스 메소드: Buffer.isBuffer(obj): 이 obj가 Buffer인지 테스트합니다. Return Boolean
6. 클래스 메소드 : Buffer.concat(list, [totalLength]) : list {Array} 배열 형태, Buffer 배열, 연결하는데 사용됩니다. totalLength {Number} 유형 위 버퍼 배열에 포함된 모든 버퍼의 총 크기입니다.
버퍼 인스턴스를 얻기 위해 파일을 읽는 것 외에도 다음과 같이 직접 구성할 수도 있습니다.

코드 복사 코드는 다음과 같습니다.

var bin = 새 버퍼([ 0x48, 0x65, 0x6c, 0x6c, 0x6c ]);

버퍼는 문자열과 유사합니다. .length 속성을 사용하여 바이트 길이를 얻는 것 외에도 [index] 메서드를 사용하여 지정된 위치에서 바이트를 읽을 수도 있습니다.

코드 복사 코드는 다음과 같습니다.

빈[0]; // => 0x48;

버퍼와 문자열은 서로 변환될 수 있습니다. 예를 들어 바이너리 데이터는 지정된 인코딩을 사용하여 문자열로 변환될 수 있습니다.

코드 복사 코드는 다음과 같습니다.

var str = bin.toString('utf-8') // => "안녕하세요"

.slice 메서드는 새 버퍼를 반환하지 않지만 아래와 같이 원래 버퍼의 중간 위치에 대한 포인터를 반환하는 것과 비슷합니다.

코드 복사 코드는 다음과 같습니다.

1.[ 0x48, 0x65, 0x6c, 0x6c, 0x6c ]
2. ^ ^ ^
3. |
4. bin bin.slice(2)

쓰기 버퍼

코드 복사 코드는 다음과 같습니다.

var buffer = new Buffer(8);//8바이트 메모리가 할당된 버퍼 생성
console.log(buffer.write('a','utf8'));//출력 1

그러면 문자 "a"가 버퍼에 기록되고 노드는 인코딩 후 버퍼에 기록된 바이트 수를 반환합니다. 여기서 문자 a의 UTF-8 인코딩은 1바이트를 차지합니다.

버퍼 복사

Node.js는 Buffer 개체의 전체 내용을 다른 Buffer 개체에 복사하는 방법을 제공합니다. 기존 Buffer 객체 사이에서만 복사가 가능하므로 반드시 생성해야 합니다.

코드 복사 코드는 다음과 같습니다.

buffer.copy(bufferToCopyTo)

그 중 bufferToCopyTo는 복사할 대상 Buffer 객체입니다. 아래 예:

코드 복사 코드는 다음과 같습니다.

var buffer1 = 새 버퍼(8);
buffer1.write('만나서 반가워요','utf8');
var buffer2 = 새 버퍼(8);
buffer1.copy(버퍼2);
console.log(buffer2.toString());//만나서 반가워요

스트림 모듈

UNIX 계열 운영체제에서는 스트림이 표준 개념이다. 다음과 같은 세 가지 주요 스트림이 있습니다.

1.표준 입력
2.표준 출력
3.표준오차

읽기 가능한 스트림

버퍼가 Node.js가 원시 데이터를 처리하는 방식이라면 스트림은 일반적으로 Node.js가 데이터를 이동하는 방식입니다. Node.js의 스트림은 읽기 가능하거나 쓰기 가능합니다. Node.js의 많은 모듈은 HTTP 및 파일 시스템을 포함한 스트림을 사용합니다.

classmates.txt 파일을 생성하고 이 데이터를 사용하기 위해 파일에서 이름 목록을 읽는다고 가정해 보겠습니다. 데이터가 스트림이므로 이는 파일 읽기를 마치기 전에 처음 몇 바이트부터 시작하여 데이터에 대해 작업을 수행할 수 있음을 의미합니다. 이는 Node.js의 일반적인 패턴입니다.

코드 복사 코드는 다음과 같습니다.

var fs = require('fs');
var stream = fs.ReadStream('classmates.txt');
stream.setEncoding('utf8');
stream.on('데이터', 함수(청크) {
console.log('일부 데이터 읽기')
});
stream.on('close', function () {
console.log('모든 데이터를 읽었습니다.')
});

위의 예에서는 새로운 데이터가 수신되면 이벤트 데이터가 트리거됩니다. 파일 읽기가 완료되면 닫기 이벤트가 트리거됩니다.

쓰기 가능한 스트림

분명히 데이터를 쓸 수 있는 쓰기 가능한 스트림을 만들 수도 있습니다. 즉, 간단한 스크립트를 사용하여 스트림을 사용하여 파일을 읽은 다음 다른 파일에 쓸 수 있습니다.

코드 복사 코드는 다음과 같습니다.

var fs = require('fs');
var readableStream = fs.ReadStream('classmates.txt');
var writableStream = fs.writeStream('names.txt');
readableStream.setEncoding('utf8');
readableStream.on('data', 함수(청크) {
writableStream.write(청크);
});
readableStream.on('close', function () {
writableStream.end();
});

데이터 이벤트가 수신되면 이제 쓰기 가능한 스트림에 데이터가 기록됩니다.

readable.setEncoding(encoding): 반환: this

readable.resume(): 위와 동일합니다. 이 메서드를 사용하면 읽기 가능한 스트림이 데이터 이벤트를 계속 발생시킬 수 있습니다.

readable.pause(): 위와 동일합니다. 이 메서드를 사용하면 흐름 모드의 스트림이 데이터 이벤트 발생을 중지하고 비흐름 모드로 전환하며 사용 가능한 후속 데이터를 내부 버퍼에 남겨둡니다.
클래스: stream.Writable

쓰기 가능한 스트림 인터페이스는 대상에 쓰는 데이터를 추상화한 것입니다.

1.writable.write(청크, [인코딩], [콜백]):

쓸 내용의 {String Buffer} 데이터
인코딩 {String} 인코딩, 청크가 문자열인 경우
콜백 데이터 블록이 작성된 후 {Function} 콜백
반환: {Boolean} 데이터가 완전히 처리된 경우 true입니다.

이 메서드는 기본 시스템에 데이터를 쓰고 데이터가 처리된 후 지정된 콜백을 호출합니다.

2.writable.cork(): 모든 쓰기를 강제로 유지합니다.

보유된 데이터는 .uncork() 또는 .end()가 호출될 때 기록됩니다.

3.writable.end([청크], [인코딩], [콜백])

청크 {String | Buffer} 선택 사항, 기록할 데이터
인코딩 {String} 인코딩, 청크가 문자열인 경우
콜백 {함수} 선택 사항, 스트림 종료 후 콜백
end()를 호출한 후 write()를 호출하면 오류가 발생합니다.

코드 복사 코드는 다음과 같습니다.

// 'hello'를 쓰고 'world!'로 끝납니다.
http.createServer(함수(req, res) {
res.write('안녕하세요, ');
res.end('world!');
// 이제 더 이상 쓸 수 없습니다
});