스트림은 한꺼번에 모든 것을 메모리에 로드하는 대신 대량의 데이터를 하나씩 처리하여 효율적으로 처리할 수 있게 해주는 Node.js의 강력한 기능입니다. 대용량 파일, 실시간 데이터 또는 네트워크 연결을 처리하는 데 특히 유용합니다. 이 기사에서는 Node.js 스트림에 대해 자세히 알아보고 스트림 유형, 코드 예제와 함께 사용하는 방법, 실제 사용 사례를 다루면서 이해를 강화할 것입니다.
스트림은 시간이 지남에 따라 처리되는 데이터의 시퀀스입니다. Node.js에서 스트림은 EventEmitter의 인스턴스입니다. 즉, 이벤트를 내보내고 응답할 수 있습니다. 스트림을 사용하면 모든 데이터를 한 번에 로드하는 대신 데이터를 청크(작은 조각)로 읽고 쓸 수 있으므로 메모리가 효율적이고 빠릅니다.
Node.js는 네 가지 유형의 스트림을 제공합니다.
예시를 통해 각 스트림 유형을 살펴보겠습니다.
읽기 가능한 스트림을 사용하면 파일이나 네트워크 요청과 같은 소스에서 데이터를 청크 단위로 사용할 수 있습니다.
예: 읽기 가능한 스트림을 사용하여 파일 읽기
const fs = require('fs');
// Create a readable stream
const readableStream = fs.createReadStream('example.txt', 'utf8');
// Listen for 'data' events to read chunks of data
readableStream.on('data', (chunk) => {
console.log('New chunk received:');
console.log(chunk);
});
// Handle 'end' event when the file has been completely read
readableStream.on('end', () => {
console.log('File reading completed.');
});
// Handle any errors
readableStream.on('error', (err) => {
console.error('Error reading file:', err.message);
});
설명:
쓰기 가능한 스트림은 데이터를 파일에 저장하는 등 데이터를 청크 단위로 쓰는 데 사용됩니다.
예: 쓰기 가능한 스트림을 사용하여 파일에 데이터 쓰기
const fs = require('fs');
// Create a writable stream
const writableStream = fs.createWriteStream('output.txt');
// Write chunks of data to the file
writableStream.write('First chunk of data.\n');
writableStream.write('Second chunk of data.\n');
// End the stream
writableStream.end('Final chunk of data.');
// Handle 'finish' event when writing is complete
writableStream.on('finish', () => {
console.log('Data writing completed.');
});
// Handle any errors
writableStream.on('error', (err) => {
console.error('Error writing to file:', err.message);
});
설명:
이중 스트림은 데이터를 읽고 쓸 수 있으며 데이터를 보내고 받아야 하는 네트워크 프로토콜과 같은 작업에 사용됩니다.
예: 맞춤형 이중 스트림
const { Duplex } = require('stream');
// Create a custom duplex stream
const myDuplexStream = new Duplex({
read(size) {
this.push('Reading data...');
this.push(null); // No more data to read
},
write(chunk, encoding, callback) {
console.log(`Writing: ${chunk.toString()}`);
callback();
}
});
// Read from the stream
myDuplexStream.on('data', (chunk) => {
console.log(chunk.toString());
});
// Write to the stream
myDuplexStream.write('This is a test.');
myDuplexStream.end();
설명:
변환 스트림을 사용하면 데이터가 통과할 때 데이터를 수정하거나 변환할 수 있습니다. 특별한 유형의 이중 스트림입니다.
예: 대문자 텍스트로의 간단한 변환 스트림
const { Transform } = require('stream');
// Create a custom transform stream
const toUpperCaseTransform = new Transform({
transform(chunk, encoding, callback) {
this.push(chunk.toString().toUpperCase());
callback();
}
});
// Pipe data through the transform stream
process.stdin.pipe(toUpperCaseTransform).pipe(process.stdout);
설명:
스트림을 사용하는 가장 일반적인 방법 중 하나는 스트림을 함께 "파이프"하는 것입니다. 이는 한 스트림에서 다른 스트림으로 데이터를 전달하는 것을 의미합니다. 파일에서 읽고 다른 파일에 쓰는 등 데이터를 단계별로 처리해야 할 때 유용합니다.
예: 읽기 가능한 스트림을 쓰기 가능한 스트림으로 파이핑
const fs = require('fs');
// Create a readable stream
const readableStream = fs.createReadStream('input.txt');
// Create a writable stream
const writableStream = fs.createWriteStream('output.txt');
// Pipe the readable stream into the writable stream
readableStream.pipe(writableStream);
// Handle 'finish' event when piping is done
writableStream.on('finish', () => {
console.log('File copied successfully.');
});
설명:
실제 애플리케이션에서는 대용량 파일을 서버에 업로드해야 할 수도 있습니다. 전체 파일을 메모리에 로드하는 대신 스트림을 사용하여 파일 업로드를 효율적으로 처리할 수 있습니다.
예: Node.js 및 multer를 사용하여 스트림을 사용하여 파일 업로드
const express = require('express');
const multer = require('multer');
const fs = require('fs');
const app = express();
const upload = multer({ dest: 'uploads/' });
app.post('/upload', upload.single('file'), (req, res) => {
const readableStream = fs.createReadStream(req.file.path);
const writableStream = fs.createWriteStream(`./uploads/${req.file.originalname}`);
// Pipe the uploaded file to the writable stream
readableStream.pipe(writableStream);
writableStream.on('finish', () => {
res.send('File uploaded and saved.');
});
writableStream.on('error', (err) => {
res.status(500).send('Error saving file.');
});
});
app.listen(3000, () => {
console.log('Server is running on port 3000');
});
Explanation:
Example:
readableStream.on('error', (err) => {
console.error('Stream error:', err.message);
});
Example:
writableStream.write(chunk, (err) => {
if (err) console.error('Error writing chunk:', err.message);
});
Streams in Node.js offer a powerful and efficient way to handle data, especially in cases where data comes in large quantities or needs to be processed incrementally. From reading and writing files to handling network requests and processing data in real time, streams allow you to build scalable and performant applications. In this article, we explored the different types of streams, how to use them, and real-world use cases to deepen your understanding of stream-based processing in Node.js.
위 내용은 Node.js의 스트림 이해 — 효율적인 데이터 처리의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
