В этой статье блога мы погрузимся в мир TCP-серверов с использованием Erlang, мощного и параллельного языка программирования. Независимо от того, являетесь ли вы новичком или имеете некоторый опыт работы с Erlang, это руководство познакомит вас с различными методами создания TCP-серверов, дополненное примерами разговорного кода, которые сделают процесс обучения проще и приятнее.

1. Настройка среды:
   Прежде чем мы приступим к кодированию, необходимо настроить среду Erlang. Вам необходимо установить Erlang на свой компьютер и убедиться, что необходимые библиотеки доступны.

2. Начнем с простых TCP-серверов.
   Давайте начнем с простого TCP-сервера, который прослушивает определенный порт и принимает входящие соединения. Мы будем использовать модуль gen_tcp, который предоставляет удобный API для работы в сети TCP.

-module(simple_server).
-export([start/0]).
start() ->
    {ok, ListenSocket} = gen_tcp:listen(0, [binary, {active, false}]),
    io:format("Server listening on port ~p~n", [gen_tcp:port(ListenSocket)]),
    accept_connections(ListenSocket).
accept_connections(ListenSocket) ->
    {ok, Socket} = gen_tcp:accept(ListenSocket),
    spawn(fun() -> handle_connection(Socket) end),
    accept_connections(ListenSocket).
handle_connection(Socket) ->
    % Handle the incoming connection here
    ok = gen_tcp:send(Socket, "Hello, client!"),
    gen_tcp:close(Socket).

В этом примере мы создаем TCP-сервер, который прослушивает динамически назначаемый порт (0) и принимает входящие соединения. Как только соединение установлено, мы запускаем новый процесс для обработки этого соединения.

1. Параллельные TCP-серверы с OTP:
   OTP (Открытая телекоммуникационная платформа) Erlang обеспечивает надежную основу для создания параллельных и отказоустойчивых систем. Давайте рассмотрим, как мы можем использовать OTP для создания параллельного TCP-сервера.

-module(concurrent_server).
-behaviour(gen_server).
-export([start/0, stop/0]).
-export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2, code_change/3]).
start() ->
    gen_server:start_link({local, ?MODULE}, ?MODULE, [], []).
stop() ->
    gen_server:cast(?MODULE, stop).
init([]) ->
    {ok, ListenSocket} = gen_tcp:listen(0, [binary, {active, false}]),
    io:format("Server listening on port ~p~n", [gen_tcp:port(ListenSocket)]),
    accept_connections(ListenSocket),
    {ok, ListenSocket}.
handle_call(_Request, _From, State) ->
    {reply, ok, State}.
handle_cast(stop, State) ->
    {stop, normal, ok, State}.
handle_info(_Info, State) ->
    {noreply, State}.
terminate(_Reason, _State) ->
    ok.
code_change(_OldVsn, State, _Extra) ->
    {ok, State}.
accept_connections(ListenSocket) ->
    {ok, Socket} = gen_tcp:accept(ListenSocket),
    spawn(fun() -> handle_connection(Socket) end),
    accept_connections(ListenSocket).
handle_connection(Socket) ->
    % Handle the incoming connection here
    ok = gen_tcp:send(Socket, "Hello, client!"),
    gen_tcp:close(Socket).

В этом примере мы используем поведение gen_serverдля создания параллельного TCP-сервера. Сервер запускается как процесс gen_server и прослушивает динамически назначенный порт (0). Он обрабатывает входящие соединения в отдельном процессе, что позволяет одновременно обрабатывать несколько клиентов.

1. Обработка клиентских запросов.
   Чтобы создать более сложный TCP-сервер, нам необходимо обрабатывать клиентские запросы и реагировать соответствующим образом. Давайте изменим наш предыдущий пример для обработки клиентских сообщений.

% Server module
-module(message_handler).
-export([start/0]).

start() ->
    {ok, ListenSocket} = gen_tcp:listen(0, [binary, {active, true}]),
    io:format("Server listening on port ~p~n", [gen_tcp:port(ListenSocket)]),
    accept_connections(ListenSocket).

accept_connections(ListenSocket) ->
    {ok, Socket} = gen_tcp:accept(ListenSocket),
    spawn(fun() -> handle_connection(Socket) end),
    accept_connections(ListenSocket).

handle_connection(Socket) ->
    receive
        {tcp, Socket, Data} ->
            io:format("Received data: ~p~n", [Data]),
            handle_request(Socket, Data)
   end.