🟢 서버사이드 데이터 스트리밍 시스템 구현

// server.js
const http = require('http');
const fs = require('fs');
const { Readable } = require('stream');
const logger = require('./logger'); // 로거 모듈

// 데이터 스트리밍을 위한 가상 데이터 생성
const dataStream = new Readable({
  read(size) {
    const chunk = 'Data chunk 
';
    this.push(chunk);
    this.push(null);
  }
});

http.createServer((req, res) => {
  if (req.method === 'GET' && req.url === '/data-stream') {
    // HTTP 헤더 설정
    res.writeHead(200, {
      'Content-Type': 'text/plain',
      'Transfer-Encoding': 'chunked'
    });

    // 데이터 스트리밍 전송
    dataStream.pipe(res);

    // 클라이언트 종료 시 자원 정리
    req.on('close', () => {
      logger.info('Client disconnected');
      dataStream.destroy();
    });
  } else {
    res.writeHead(404, { 'Content-Type': 'text/plain' });
    res.end('Not Found');
  }
}).listen(3000, () => {
  logger.info('Server running on port 3000');
});

// logger.js (예시)
module.exports = {
  info(message) {
    console.log(`[INFO] ${message}`);
  },
  error(message) {
    console.error(`[ERROR] ${message}`);
  }
};