[node.js] File-System(promise, async/await)

📌 file-system

: node의 모듈이라 commonJS 방식으로 불러 올 수 있음 

const fs = require('fs');

✅ readFile

: 파일을 읽을 때 사용하는 메소드  

 

파일을 읽는 것도 시간이 필요한 작업이므로 -> callback 사용

fs.readFile('파일위치','유니코드포맷',callback(err, data) {})

err : 파일 읽기가 잘 안되었을 때, error 코드 반환 

data: 파일 읽기가 잘 되었을 때, 읽은 data 반환

const fs = require('fs');
fs.readFile('readme.txt', 'utf-8', (err, data) => {
  if (err) {
    console.log(err);
  } else {
    console.log(data);
  }
});

 

✅ writeFile

: 파일을 읽을 때 사용하는 메소드

fs.writeFile('파일위치, data, '유니코드포맷, callback(err) {})

writeFile은 data는 없고, 쓰기가 잘 안되었을 때 err 반환

const fs = require('fs');
const str = '파일 쓰기가 정상적으로 되는지 테스트 합니다.';
fs.writeFile('readme.txt', str, 'utf-8', (err) => {
  if (err) {
    console.log(err);
  } else {
    console.log('writefile succeed');
  }
});

 

📌 file-system with Promise

• callback 방식은 사용 및 코드 가독성이 떨어지기 때문에 FS는 애초에 promise방식의 기능을 제공
• 기존 메소드명 뒤에 sync를 붙이면 promise 방식을 사용하여 동기적으로 작동
• 단, sync가 붙은 메소드는 더 이상 callback 함수가 필요 없으므로 안써줘도됨

📍 1,2,3,4번을 순서대로 출력하기 위한 기존 callback 방식 코드

const fs = require('fs');
fs.readFile('./readme.txt', (err, data) => {
  if (err) {
    throw err;
  }
  console.log('1번', data.toString());
  fs.readFile('./readme.txt', (err, data) => {
    if (err) {
      throw err;
    }
    console.log('2번', data.toString());
    fs.readFile('./readme.txt', (err, data) => {
      if (err) {
        throw err;
      }
      console.log('3번', data.toString());
      fs.readFile('./readme.txt', (err, data) => {
        if (err) {
          throw err;
        }
        console.log('4번', data.toString());
      });
    });
  });
});

 

📍promise 방식으로 구현

const fs = require('fs');

let data = fs.readFileSync('./readme.txt');
console.log('1번', data.toString());
data = fs.readFileSync('./readme.txt');
console.log('2번', data.toString());
data = fs.readFileSync('./readme.txt');
console.log('3번', data.toString());
data = fs.readFileSync('./readme.txt');
console.log('4번', data.toString());

 

🔫 하지만, sync가 붙은 코드는 서버 상에서 작동 할 때 정상적으로 작동하지 않는 경우 빈번 

-> fs 쓸 때는 fs.promise를 호출하여 사용해야함 

fs.promise 스스로 성공 여부를 판단하여 resolve, reject를 반환

 

📌 promise 

promise는 일종의 class 이므로 new 사용 

const promise = new Promise(function(resolve, reject) {});

• resolve, reject라는 2개의 매개변수를 콜백함수로 받아서 사용
• promise가 할당되면 이 promise는 resolve 또는 reject 함수가 callback이 될 때 까지 무한 대기
• resolve: promise가 정상적으로 이행 되었을 경우 사용 / then으로 받음
• reject: promise가 정상적으로 이행되지 않았을 경우 사용 / catch로 받음
• resolve, reject 는 데이터를 매개변수로 보낼 수 있음 

resolve, reject가 사용되지 않으면 promise는 해당 콜백이 나올 때 까지 pending 상태가 되어 기다림

 

📍 위의 기본 코드를 fs.promise로 변환

const fs = require('fs').promises;
fs.readFile('./readme.txt')
  .then((data) => {
    console.log('1번', data.toString());
    return fs.readFile('./readme.txt');
  })
  .then((data) => {
    console.log('2번', data.toString());
    return fs.readFile('./readme.txt');
  })
  .then((data) => {
    console.log('3번', data.toString());
    return fs.readFile('./readme.txt');
  })
  .then((data) => {
    console.log('4번', data.toString());
  })
  .catch((err) => {
    throw err;
  });

 

📌 async/await

function 앞에 async를 붙이면 해당 함수는 항상 Promise 반환

async가 붙은 함수에서 return을 쓰면 아래와 동일한 역할을 함 

async function f1() {
  return 1;
}
function f2() {
  return Promise.resolve(1);
}

async가 붙은 함수 내부에는 await 사용 가능 

await는 promise가 결과(resolve, reject)를 가져다 줄 때 까지 기다림

(단, async는 함수에 붙여야 하므로 별도의 함수 내부에 기능을 정의하고 해당 함수를 외부에서 한번 사용해 줘야함)

 

📍코드 예시

const fs = require('fs').promises;

async function main() {
  let data = await fs.readFile('./readme.txt');
  console.log('1번', data.toString());
  data = await fs.readFile('./readme.txt');
  console.log('2번', data.toString());
  data = await fs.readFile('./readme.txt');
  console.log('3번', data.toString());
  data = await fs.readFile('./readme.txt');
  console.log('4번', data.toString());
}

main();

 

📌 routing

: 네트워크 상에서 데이터를 보낼 때 최적의 경로를 선택하는 과정 

 

✅ file-system으로 DB구현

database.json 파일 생성 후 코드 작성

getPosts() : database.json에서 데이터를 읽어서 변수로 변환해주는 함수

savePosts(): 변경 사항을 database.json에 저장하는 함수

const fs = require('fs');

async function getPosts() {
  const jsonPosts = await fs.promises.readFile('database.json', 'utf-8');
  return JSON.parse(jsonPosts).posts;
}

async function savePosts(posts) {
  const content = {
    posts,
  };
    return fs.promises.writeFile('database.json’, JSON.stringify(content), 'utf-8');
}