HTTP сервер на Node.js: http.createServer с примерами

http.createServer() создаёт веб-сервер из одной функции, обработчика запросов. Node вызывает её на каждый входящий запрос с двумя объектами: req (метод, URL и заголовки, которые прислал клиент) и res (то, что вы отправляете в ответ). Задайте в res код статуса и заголовки, затем вызовите res.end() с телом ответа. server.listen(3000) начинает принимать соединения на порту 3000.

const http = require('http');

const server = http.createServer((req, res) => {
    console.log(req.method, req.url);
    res.statusCode = 200;
    res.setHeader('Content-Type', 'text/plain');
    res.end(`You asked for ${req.method} ${req.url}`);
});

// GET /hello?name=Ada
server.listen(3000, () => {
    console.log('Listening on port 3000');
});

Первый запрос получает ответ You asked for GET /hello?name=Ada, а в Console выводятся тот же метод и URL. Отправьте DELETE /anything из строки запроса: ответит тот же обработчик, потому что у простого сервера http нет маршрутов. Каждый запрос проходит через одну функцию.

Отправить JSON и задать код статуса

res.writeHead(status, headers) задаёт код статуса и заголовки одним вызовом. Для JSON укажите Content-Type: application/json и отправьте результат JSON.stringify(): res.end() принимает только строку или Buffer.

const http = require('http');

const users = [
    { id: 1, name: 'Ada' },
    { id: 2, name: 'Linus' },
];

function sendJson(res, status, data) {
    res.writeHead(status, { 'Content-Type': 'application/json' });
    res.end(JSON.stringify(data));
}

const server = http.createServer((req, res) => {
    const url = new URL(req.url, 'http://localhost');
    const limit = Number(url.searchParams.get('limit')) || users.length;

    if (req.method === 'GET' && url.pathname === '/users') {
        return sendJson(res, 200, users.slice(0, limit));
    }
    sendJson(res, 404, { error: 'Not found' });
});

// GET /users?limit=1
server.listen(3000);

GET /users?limit=1 возвращает [{"id":1,"name":"Ada"}]. req.url это путь вместе со строкой запроса, поэтому new URL(req.url, 'http://localhost') делит его на pathname и searchParams (база нужна только потому, что URL требует абсолютный адрес). Отправьте GET /nothing, и статус станет 404.

Маршруты через switch

Небольшому API хватит switch по методу и пути. Соберите ключ вроде 'GET /users' и дайте каждому маршруту свой case:

const http = require('http');

const users = [{ id: 1, name: 'Ada' }];

function sendJson(res, status, data) {
    res.writeHead(status, { 'Content-Type': 'application/json' });
    res.end(JSON.stringify(data));
}

function readBody(req) {
    return new Promise((resolve, reject) => {
        let data = '';
        req.on('data', (chunk) => {
            data += chunk;
        });
        req.on('end', () => resolve(data));
        req.on('error', reject);
    });
}

const server = http.createServer(async (req, res) => {
    const { pathname } = new URL(req.url, 'http://localhost');

    switch (`${req.method} ${pathname}`) {
        case 'GET /users':
            return sendJson(res, 200, users);

        case 'POST /users': {
            let body;
            try {
                body = JSON.parse(await readBody(req));
            } catch {
                return sendJson(res, 400, { error: 'Body must be JSON' });
            }
            const user = { id: users.length + 1, name: body.name };
            users.push(user);
            return sendJson(res, 201, user);
        }

        default:
            sendJson(res, 404, { error: `No route for ${req.method} ${pathname}` });
    }
});

// GET /users
server.listen(3000);

Отправьте POST /users с телом {"name": "Grace"}: в ответ придёт 201 с {"id":2,"name":"Grace"}, а GET /users теперь покажет обоих пользователей. Отправьте тот же POST с телом hello, и получите 400 с {"error":"Body must be JSON"}.

Прочитать тело POST запроса

Node не разбирает тело за вас. req это readable stream: тело приходит кусками через события data, а когда оно получено целиком, срабатывает end. readBody() выше собирает куски в строку и возвращает промис, так что обработчик может сделать await. Поскольку req поддерживает асинхронную итерацию, этот цикл делает то же самое:

let data = '';
for await (const chunk of req) data += chunk;
const body = JSON.parse(data);

Настоящий сервер ещё ограничивает размер (перестаёт читать и отвечает 413, когда data.length превышает лимит) и проверяет req.headers['content-type'] перед вызовом JSON.parse.

Частые ошибки

Забыли res.end(). Ветка, которая задаёт статус, но не завершает ответ, заставляет клиента ждать, пока не истечёт таймаут.

Заголовок после тела. Как только выполнился res.end() или первый res.write(), заголовки уже отправлены, и res.setHeader() бросает ERR_HTTP_HEADERS_SENT. Пишите return, когда отправляете ответ раньше времени, как в примерах.

Сравнение req.url с путём. req.url включает строку запроса, поэтому req.url === '/users' ложно для /users?limit=1. Сравнивайте pathname.

Когда лучше взять Express

Модуля http хватает для health check, приёмника вебхуков или чтобы понять, как работает HTTP. Когда нужны параметры маршрута вроде /users/:id, разбор JSON в теле, middleware и обработка ошибок, вы в итоге пишете свой маленький фреймворк. Express и есть такой фреймворк, построенный на тех же объектах req и res; в маршрутизации в Express показан тот же API с app.get() и app.post().