[NodeJS] HTTP 모듈로 서버 만들기(REST API)

노드는 서버가 아닌 서버를 실행시켜주는 엔진이다.

 

바로 만들어보자.

const http = require('http');

const server = http.createServer((req, res) => {
    res.write('<h1>I am Hungry</h1>');
    res.write('<h1>Enough</h1>');
    res.end('<h1>I am Hungry Enough</h1>');
})
    .listen(8080);

server.on('listening', () => {
    console.log('8080번 포트에서 서버 대기 중');
});
server.on('error', (error) => {
    console.error(error);
})

이제 localhost:8080을 접속해보자.

서버를 만들어서 8080 포트에 프로세스를 띄운 이후 클라이언트에 요청을 보내 응답까지 완료한 상황이다.

이렇게 HTML을 보내줬는데 문자열인지 HTML인지 구분하지 못하는 경우도 있다. 이럴 경우에는 알려줘야한다.

res.writeHead(200, { 'Content-Type' : 'text/html, charset=utf-8'});

위와 같이 코드 한줄을 추가해주면 된다.

HTML 코드를 이렇게 적는 행위는 비효율적이므로 따로 HTML 파일에 작성하여 fs를 이용하자.

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

const server = http.createServer(async (req, res) => {
    try{
        res.writeHead(200, { 'Content-Type' : 'text/html, charset=utf-8'});
        const file = await fs.readFile('./data.html');
        res.end(file);
    } catch (err) {
        console.error(err);
        res.writeHead(200, { 'Content-Type' : 'text/html, charset=utf-8'});
        res.end(err.message);
    }
})
    .listen(8081);

server.on('listening', () => {
    console.log('8080번 포트에서 서버 대기 중입니다.');
});
server.on('error', (error) => {
    console.error(error);
});

data.html에 적힌 HTML 코드를 읽어서 활용한다.

비동기 방식인 async를 사용할 때에는 에러처리를 해주자.

 

REST API

• 서버의 자원을 정의하고 자원에 대한 주소를 지정하는 방법.
• HTTP 요청 메서드로 user, get, put post, patch , delete 등이 있다
• 클라이언트가 누구든 HTTP 프로토콜로 소통이 가능하다.

https://github.com/ZeroCho/nodejs-book/tree/master/ch4/4.2

 

GET, PUT, DELETE를 사용해보자.

http.createServer(async (req, res) => {
  try {
    if (req.method === 'GET') {
      if (req.url === '/') {
        const data = await fs.readFile(path.join(__dirname, 'restFront.html'));
        res.writeHead(200, { 'Content-Type': 'text/html; charset=utf-8' });
        return res.end(data);
      } else if (req.url === '/about') {
        const data = await fs.readFile(path.join(__dirname, 'about.html'));
        res.writeHead(200, { 'Content-Type': 'text/html; charset=utf-8' });
        return res.end(data);
      } else if (req.url === '/users') {
        res.writeHead(200, { 'Content-Type': 'application/json; charset=utf-8' });
        return res.end(JSON.stringify(users));
      }
      // /도 /about도 /users도 아니면
      try {
        const data = await fs.readFile(path.join(__dirname, req.url));
        return res.end(data);
      } catch (err) {
        // 주소에 해당하는 라우트를 못 찾았다는 404 Not Found error 발생
      }
    } else if (req.method === 'POST') {
      if (req.url === '/user') {
        let body = '';
        // 요청의 body를 stream 형식으로 받음
        req.on('data', (data) => {
          body += data;
        });
        // 요청의 body를 다 받은 후 실행됨
        return req.on('end', () => {
          console.log('POST 본문(Body):', body);
          const { name } = JSON.parse(body);
          const id = Date.now();
          users[id] = name;
          res.writeHead(201, { 'Content-Type': 'text/plain; charset=utf-8' });
          res.end('등록 성공');
        });
      }
    } else if (req.method === 'PUT') {
      if (req.url.startsWith('/user/')) {
        const key = req.url.split('/')[2];
        let body = '';
        req.on('data', (data) => {
          body += data;
        });
        return req.on('end', () => {
          console.log('PUT 본문(Body):', body);
          users[key] = JSON.parse(body).name;
          res.writeHead(200, { 'Content-Type': 'text/plain; charset=utf-8' });
          return res.end(JSON.stringify(users));
        });
      }
    } else if (req.method === 'DELETE') {
      if (req.url.startsWith('/user/')) {
        const key = req.url.split('/')[2];
        delete users[key];
        res.writeHead(200, { 'Content-Type': 'text/plain; charset=utf-8' });
        return res.end(JSON.stringify(users));
      }
    }
    res.writeHead(404);
    return res.end('NOT FOUND');
  } catch (err) {
    console.error(err);
    res.writeHead(500, { 'Content-Type': 'text/plain; charset=utf-8' });
    res.end(err.message);
  }
})
  .listen(8082, () => {
    console.log('8082번 포트에서 서버 대기 중입니다');
  });

다만 이런식으로 http만을 사용해서 구현하면 코드의 가독성이 떨어진다.

코드에 응답 페이지들을 추가하면서 이해해보자.

쿠키와 세션 역시 이와 비슷하므로 생략하겠다.