S2) Unit3. [실습] fs 모듈

📣 fs 모듈을 통해 비동기 구현하기

✔️ fs.readFile("filename", [options], callback)

➰ "filename" 파일을 [options] 을 적용해 읽은 후 callback 함수를 실행한다.

➰ 파일을 비동기적으로 읽어올 수 있다.

➰ 두번째 인자를 "utf8" 로 명시하여 인코딩이 되도록 해줘야 한다.

 

 

1️⃣ callback.js

const fs = require("fs");

const getDataFromFile = function (filePath, callback) {
  // TODO: fs.readFile을 이용해 작성합니다
  fs.readFile(filePath, 'utf8', (err, data) => {
    if(err){
      callback(err, null);
    }
    else{
      callback(null, data);
    }
  });
}

getDataFromFile("README.md", (err, data) => {
// 밑의 내용이 콜백함수로 넘어간다.
  console.log(data);
});

module.exports = {
  getDataFromFile
};

➰ fs.readFile() 은 파일을 읽는 과정에서 에러가 나면 익명의 함수 err을 던지고, 성공하면 data에 그 내용을 담는다.

➰ err가 날아오면 callback 함수에 err를 인자로 주고, 성공하면 callback 함수에 data를 인자로 준다.

 

 

2️⃣ promiseConstructor.js

const fs = require("fs");

const getDataFromFilePromise = filePath => {
  // return new Promise()
  // TODO: Promise 및 fs.readFile을 이용해 작성합니다.
  return new Promise((resolve, reject) => {
    fs.readFile(filePath, "utf8", (err, data) => {
      if(err){
        reject(err);
      }
      else{
        resolve(data);
      }
    });
  })
};

getDataFromFilePromise('README.md').then(data => console.log(data));

module.exports = {
  getDataFromFilePromise
};

➰ Promise를 사용해서 위와 똑같이 작동하는 코드 작성

➰ 에러가 발생하면 reject를, 성공하면 resolve를 실행한다.

 

 

3️⃣ basicChaining.js

const path = require('path');
const { getDataFromFilePromise } = require('./02_promiseConstructor');

const user1Path = path.join(__dirname, 'files/user1.json');
const user2Path = path.join(__dirname, 'files/user2.json');

// HINT: getDataFromFilePromise(user1Path) 및 getDataFromFilePromise(user2Path)를 이용해 작성합니다
const readAllUsersChaining = () => {
  // TODO: 여러개의 Promise를 then으로 연결하여 작성합니다
  let result = [];

  return getDataFromFilePromise(user1Path)
    .then((user1) => {
        result.push(JSON.parse(user1));
        return getDataFromFilePromise(user2Path)
          .then((user2) => {
            result.push(JSON.parse(user2));
            return result;
          })
    })
}

// readAllUsersChaining();

module.exports = {
  readAllUsersChaining
}

➰ 파일을 읽어오는 함수는 fs.readFile이 아닌 callback.js에서 구현한 getDataFromFilePromise를 이용한다.

➰ .then을 사용해서 promise chain을 구현한다.

➰ user1 파일의 내용을 읽어오는데 성공하면, 그 데이터를 user1 이라고 하고 파싱 후 result 배열에 넣어준다.

➰ 위 과정이 모두 성공하면 user2 파일의 내용을 읽어오고 같은 과정을 거친다.

 

 

4️⃣ promiseAll.js

const path = require('path');
const { getDataFromFilePromise } = require('./02_promiseConstructor');

const user1Path = path.join(__dirname, 'files/user1.json');
const user2Path = path.join(__dirname, 'files/user2.json');

const readAllUsers = () => {
  // TODO: Promise.all을 이용해 작성합니다
  let result = [];

  const user1 = getDataFromFilePromise(user1Path).then((data) => JSON.parse(data));
  const user2 = getDataFromFilePromise(user2Path).then((data) => JSON.parse(data));

  return Promise.all([user1, user2]).then((values) => {
    return values;
  });
}

// readAllUsers()

module.exports = {
  readAllUsers
}

➰ promise.all 을 이용하여 데이터를 순회한다.

➰ user1과 user2에 각각 데이터를 읽어와서 성공하면, 파싱 후 그 데이터를 넣어준다.

➰ user1과 user2를 promise.all의 인자로 주어서 순회하게 하고, 그 데이터들은 values에 들어가게 된다.

 

 

5️⃣ asyncAwait.js

const path = require('path');
const { getDataFromFilePromise } = require('./02_promiseConstructor');

const user1Path = path.join(__dirname, 'files/user1.json');
const user2Path = path.join(__dirname, 'files/user2.json');

const readAllUsersAsyncAwait = async() => {
  // TODO: async/await 키워드를 이용해 작성합니다
  let result = [];
  const user1 = await getDataFromFilePromise(user1Path).then((data)=> JSON.parse(data));
  const user2 = await getDataFromFilePromise(user2Path).then((data)=> JSON.parse(data));

  result = [user1, user2];
  return result;
}

readAllUsersAsyncAwait();

module.exports = {
  readAllUsersAsyncAwait
}

➰ readAllUsersAsyncAwait의 콜백함수는 async()가 붙었으므로 Promise를 반환한다.

➰ const user1에 await를 사용했기 때문에 user1 코드의 결과값을 얻어야 다음 코드가 실행된다. -> 비동기적