Полное руководство по Erlang: от основ конкурентности к практическим примерам кода

Erlang — это не просто язык программирования. Это целая экосистема, созданная компанией Ericsson для построения отказоустойчивых, распределенных, высоконагруженных систем с «горячим» обновлением кода на лету. Если ваша задача — чаты, телеком, банковские транзакции, очереди сообщений или микросервисы, где время бесперебойной работы измеряется годами, то Erlang и его виртуальная машина BEAM — ваш выбор. Это руководство познакомит вас с философией языка и ключевыми концепциями через практические примеры.

Фундаментальные принципы Erlang: конкурентность и отказоустойчивость. В отличие от традиционных языков, где потоки (threads) тяжелы и разделяют память, Erlang использует легковесные процессы (processes). Они изолированы, не разделяют память, общаются исключительно через асинхронную передачу сообщений (message passing). Каждый процесс имеет свой собственный «почтовый ящик». Виртуальная машина BEAM может эффективно управлять миллионами таких процессов. Второй краеугольный камень — философия «пусть он падает» (let it crash). Вместо того чтобы перегружать код проверками на каждую возможную ошибку, вы создаете деревья процессов-супервизоров (supervisors), которые следят за рабочими процессами и перезапускают их в случае аварии.

Синтаксис: простота и функциональность. Erlang — функциональный язык с динамической типизацией. Переменные начинаются с заглавной буквы и могут быть присвоены только один раз (single assignment). Это облегчает рассуждение о коде. Основные структуры данных: атомы (неизменяемые константы, например, `ok`, `error`), кортежи (tuples) — `{ok, Result}`, списки (lists) — `[1,2,3]`, и словари (maps) — `#{name => "Bob", age => 25}`.

Пример 1: Простой процесс и обмен сообщениями.
-module(echo).
-export([start/0, loop/0]).

start() ->
 Pid = spawn(echo, loop, []), % Создаем новый процесс
 Pid ! {hello, self()},  % Отправляем ему сообщение
 receive  % Ждем ответ в почтовом ящике текущего процесса
 Response ->
 io:format("Получен ответ: ~p~n", [Response])
 end.

loop() ->
 receive  % Процесс ждет сообщение
 {hello, From} ->  % Если получил кортеж с атомом hello и PID отправителя
 From ! "Hello back!", % Отправляем ответ обратно
 loop();  % Рекурсивно вызываем себя для обработки следующих сообщений
 stop ->
 ok  % Завершаем процесс
 end.
Здесь `spawn` создает процесс, `!` отправляет сообщение, `receive` блокируется, пока не придет нужное сообщение.

Пример 2: Супервизор для отказоустойчивости.
-module(my_supervisor).
-behaviour(supervisor). % Указываем, что модуль реализует поведение супервизора
-export([start_link/0, init/1]).

start_link() ->
 supervisor:start_link({local, ?MODULE}, ?MODULE, []).

init([]) ->
 SupFlags = #{strategy => one_for_one, % Стратегия: перезапускать упавший дочерний процесс
 intensity => 3,  % Макс 3 перезапуска за 5 секунд
 period => 5},
 ChildSpec = #{id => worker,
 start => {my_worker, start_link, []},
 restart => permanent, % Всегда перезапускать
 shutdown => 2000,
 type => worker},
 {ok, {SupFlags, [ChildSpec]}}.
Этот супервизор будет вечно перезапускать процесс `my_worker`, если тот падает (но не чаще 3 раз за 5 секунд).

Пример 3: Работа с сетью — простой TCP-сервер (упрощенно).
-module(simple_server).
-export([start/1]).

start(Port) ->
 {ok, ListenSocket} = gen_tcp:listen(Port, [binary, {active, false}]),
 accept_connections(ListenSocket).

accept_connections(ListenSocket) ->
 {ok, Socket} = gen_tcp:accept(ListenSocket),
 spawn(fun() -> handle_client(Socket) end), % Для каждого клиента — новый изолированный процесс
 accept_connections(ListenSocket). % Возвращаемся к ожиданию нового подключения

handle_client(Socket) ->
 case gen_tcp:recv(Socket, 0) of
 {ok, Data} ->
 gen_tcp:send(Socket, Data), % Эхо-сервер
 handle_client(Socket);
 {error, closed} ->
 ok
 end.
Здесь видна мощь конкурентности: каждый клиент обслуживается в своем процессе, блокировка одного не влияет на других.

Ключевые инструменты экосистемы: OTP. OTP (Open Telecom Platform) — это набор библиотек и паттернов, которые делают разработку на Erlang промышленной. Он включает готовые поведения (behaviours): `gen_server` для клиент-серверных взаимодействий, `gen_statem` для конечных автоматов, `gen_event` для обработчиков событий. Использование OTP — это best practice.

Сборка и управление: Rebar3. Современный инструмент для управления зависимостями, компиляции, тестирования и релиза Erlang-проектов. Проект описывается в `rebar.config`, а команды типа `rebar3 compile`, `rebar3 shell`, `rebar3 eunit` становятся вашими основными.

Erlang требует смены парадигмы мышления. Вы проектируете систему как набор взаимодействующих независимых акторов, а не как монолит с общим состоянием. Это инвестиция, которая окупается беспрецедентной надежностью и горизонтальной масштабируемостью. Начните с простых процессов и обмена сообщениями, затем освойте OTP-поведения, и вы откроете для себя язык, на котором построены WhatsApp, RabbitMQ, части AWS и многие финансовые системы, где ошибка стоит миллионов.