0Pricing
Elixir & Phoenix: Scalable Backend Development · 강의

동적 감독자와 레지스트리

`DynamicSupervisor`로 프로세스를 동적으로 시작하고 중지하며 `Registry`로 프로세스를 조회하는 방법을 배웁니다.

동적 감독자와 레지스트리은(는) CoddyKit의 무료 Elixir & Phoenix: Scalable Backend Development 강의입니다. 이것은 4개 중 3번째 강의입니다. 아래에서 전체 강의를 무료로 읽을 수 있으며, 내장 코드 에디터와 24/7 AI 튜터와 함께 브라우저에서 직접 실습할 수 있습니다. 이 강의는 Elixir & Phoenix: Scalable Backend Development 학습 경로의 일부이며, 진행 상황이 웹과 CoddyKit 앱에 동기화됩니다. Elixir & Phoenix: Scalable Backend Development 강의에는 총 4개의 강의가 포함되어 있습니다.

이 강의의 일부는 아직 번역되지 않았으며 영어로 표시됩니다.

Dynamic Process Management

In previous lessons, we learned about supervisors for managing a fixed set of processes. But what if your application needs to create or destroy processes on demand, like for each user session or a specific task?

This is where dynamic process management comes in handy. It allows your application to adapt and scale by creating processes only when they are needed.

Introducing DynamicSupervisor

Elixir's DynamicSupervisor is designed precisely for this purpose. Unlike Supervisor, which manages a predefined list of children, a DynamicSupervisor starts with no children.

It provides functions to dynamically add and remove child processes during runtime, giving you flexible control over your application's process tree.

Starting a DynamicSupervisor

To use a DynamicSupervisor, you first need to start it, typically within your application's supervision tree. Here's a basic setup:

defmodule MyApp.DynamicManager do
  use DynamicSupervisor

  def start_link(init_arg) do
    DynamicSupervisor.start_link(__MODULE__, init_arg, name: __MODULE__)
  end

  @impl true
  def init(_init_arg) do
    DynamicSupervisor.init(strategy: :one_for_one)
  end
end

# To run this in an IEx session:
# {:ok, pid} = MyApp.DynamicManager.start_link([])
# IO.puts("DynamicSupervisor started with PID: #{inspect(pid)}")

Adding Children Dynamically

Once your DynamicSupervisor is running, you can add new children using DynamicSupervisor.start_child/2. Each child needs a child specification defining how it should be started.

Let's create a simple GenServer that the supervisor can manage.

defmodule MyApp.Worker do
  use GenServer

  def start_link(id) do
    GenServer.start_link(__MODULE__, id, name: via_tuple(id))
  end

  def init(id) do
    IO.puts("Worker #{id} started!")
    {:ok, id}
  end

  defp via_tuple(id), do: {:via, Registry, {MyApp.Registry, id}}
end

defmodule MyApp.DynamicManager do
  use DynamicSupervisor

  def start_link(init_arg) do
    DynamicSupervisor.start_link(__MODULE__, init_arg, name: __MODULE__)
  end

  @impl true
  def init(_init_arg) do
    DynamicSupervisor.init(strategy: :one_for_one)
  end

  def start_worker(id) do
    child_spec = %{
      id: id,
      start: {MyApp.Worker, :start_link, [id]}
    }
    DynamicSupervisor.start_child(__MODULE__, child_spec)
  end
end

# To run this in an IEx session:
# {:ok, manager_pid} = MyApp.DynamicManager.start_link([])
# {:ok, worker_pid} = MyApp.DynamicManager.start_worker(:user_123)
# IO.puts("Worker PID: #{inspect(worker_pid)}")

Stopping Dynamic Children

Just as you can start children dynamically, you can also stop them. Use DynamicSupervisor.terminate_child/2 with the child's PID.

The supervisor will handle the graceful shutdown of the process.

defmodule MyApp.Worker do
  use GenServer

  def start_link(id) do
    GenServer.start_link(__MODULE__, id, name: {:global, id})
  end

  def init(id) do
    IO.puts("Worker #{id} started!")
    {:ok, id}
  end

  def terminate(_reason, id) do
    IO.puts("Worker #{id} stopping!")
  end
end

defmodule MyApp.DynamicManager do
  use DynamicSupervisor

  def start_link(init_arg) do
    DynamicSupervisor.start_link(__MODULE__, init_arg, name: __MODULE__)
  end

  @impl true
  def init(_init_arg) do
    DynamicSupervisor.init(strategy: :one_for_one)
  end

  def start_worker(id) do
    child_spec = %{id: id, start: {MyApp.Worker, :start_link, [id]}}
    DynamicSupervisor.start_child(__MODULE__, child_spec)
  end

  def stop_worker(worker_pid) do
    DynamicSupervisor.terminate_child(__MODULE__, worker_pid)
  end
end

# To run this in an IEx session:
# {:ok, manager_pid} = MyApp.DynamicManager.start_link([])
# {:ok, worker_pid} = MyApp.DynamicManager.start_worker(:task_A)
# :timer.sleep(100)
# MyApp.DynamicManager.stop_worker(worker_pid)
# :timer.sleep(100)
# IO.puts("Worker process should now be stopped.")

The Need for a Registry

When you start processes dynamically, how do you find them later? If you only have their PIDs, what happens if a process crashes and restarts with a new PID?

We need a way to assign a persistent, meaningful name to a process and look it up reliably, regardless of its current PID. This is where Elixir's Registry comes in.

What is Registry?

The Registry module provides a local, distributed, and fault-tolerant key-value store for associating arbitrary terms (keys) with process identifiers (PIDs).

It's perfect for looking up processes by a name or ID, especially when dealing with dynamic processes or when you want to use a custom name instead of global or local atoms.

Starting and Using Registry

Like other OTP behaviors, Registry needs to be started, typically as part of your application's supervision tree. You can define multiple registries, each with its own scope.

Once started, you can register processes with keys and look them up.

defmodule MyApp.Registry do
  use Registry, keys: :unique, name: __MODULE__
end

defmodule MyApp.WorkerWithRegistry do
  use GenServer

  def start_link(id) do
    GenServer.start_link(__MODULE__, id, name: {:via, Registry, {MyApp.Registry, id}})
  end

  def init(id) do
    IO.puts("Worker #{id} started and registered!")
    {:ok, id}
  end

  def get_state(pid) do
    GenServer.call(pid, :get_state)
  end

  @impl true
  def handle_call(:get_state, _from, state) do
    {:reply, state, state}
  end
end

# To run this in an IEx session:
# {:ok, _} = MyApp.Registry.start_link([]) # Start the registry
# {:ok, worker_pid} = MyApp.WorkerWithRegistry.start_link(:session_1)
# IO.puts("Registered worker PID: #{inspect(worker_pid)}")
#
# {:ok, [pid_found]} = Registry.lookup(MyApp.Registry, :session_1)
# IO.puts("Looked up PID: #{inspect(pid_found)}")
# IO.puts("Worker state: #{MyApp.WorkerWithRegistry.get_state(pid_found)}")

DynamicSupervisor with Registry

Combining DynamicSupervisor with Registry is a powerful pattern. You can dynamically start worker processes, and each worker registers itself with a unique key in the Registry.

This allows other parts of your application to find and interact with specific worker processes without needing their PIDs directly.

defmodule MyApp.UserSession do
  use GenServer

  def start_link(user_id) do
    # Register with Registry using the user_id as key
    GenServer.start_link(__MODULE__, user_id, name: {:via, Registry, {MyApp.SessionsRegistry, user_id}})
  end

  def init(user_id) do
    IO.puts("Session for user #{user_id} started.")
    {:ok, user_id}
  end

  def get_user_id(pid) do
    GenServer.call(pid, :get_user_id)
  end

  @impl true
  def handle_call(:get_user_id, _from, user_id) do
    {:reply, user_id, user_id}
  end
end

defmodule MyApp.SessionsRegistry do
  use Registry, keys: :unique, name: __MODULE__
end

defmodule MyApp.SessionSupervisor do
  use DynamicSupervisor

  def start_link(init_arg) do
    DynamicSupervisor.start_link(__MODULE__, init_arg, name: __MODULE__)
  end

  @impl true
  def init(_init_arg) do
    DynamicSupervisor.init(strategy: :one_for_one)
  end

  def start_session(user_id) do
    child_spec = %{
      id: user_id,
      start: {MyApp.UserSession, :start_link, [user_id]}
    }
    DynamicSupervisor.start_child(__MODULE__, child_spec)
  end
end

# --- Application Entry Point --- (Simulated)
{:ok, _registry_pid} = MyApp.SessionsRegistry.start_link([])
{:ok, _supervisor_pid} = MyApp.SessionSupervisor.start_link([])

# Start a session for user_101
{:ok, session_pid_1} = MyApp.SessionSupervisor.start_session(:user_101)
IO.puts("Session 1 PID: #{inspect(session_pid_1)}")

# Start a session for user_102
{:ok, session_pid_2} = MyApp.SessionSupervisor.start_session(:user_102)
IO.puts("Session 2 PID: #{inspect(session_pid_2)}")

# Look up user_101's session via Registry
{:ok, [pid_from_registry]} = Registry.lookup(MyApp.SessionsRegistry, :user_101)
IO.puts("Found user_101 session PID via Registry: #{inspect(pid_from_registry)}")
IO.puts("User ID from session: #{MyApp.UserSession.get_user_id(pid_from_registry)}")

Dynamic & Registry Quiz

Consider an application that uses DynamicSupervisor to manage user sessions and Registry to look up sessions by user ID. What is the primary benefit of using Registry in this scenario?

Recap: Dynamic & Registry

You've mastered dynamic process management!

  • DynamicSupervisor allows you to start and stop child processes on demand, making your application highly flexible and adaptable.
  • The Registry module provides a powerful key-value store for associating processes with meaningful names or IDs, enabling reliable lookup of dynamically started processes.

By combining these two, you can build robust, scalable applications that manage their resources efficiently.

자주 묻는 질문

“동적 감독자와 레지스트리” 강의는 무료인가요?

네 — “동적 감독자와 레지스트리” 전체 내용을 이 웹사이트에서 무료로 읽을 수 있습니다. 인터랙티브하게 실습하려면(내장 코드 에디터와 24/7 AI 튜터), CoddyKit PRO로 업그레이드하면 Elixir & Phoenix: Scalable Backend Development 강의 전체를 잠금 해제할 수 있습니다. Elixir & Phoenix: Scalable Backend Development 강의에는 총 4개의 강의가 포함되어 있습니다.

“동적 감독자와 레지스트리”에서 뭘 배우나요?

`DynamicSupervisor`로 프로세스를 동적으로 시작하고 중지하며 `Registry`로 프로세스를 조회하는 방법을 배웁니다. 브라우저에서 직접 실행하는 실습 코드로 Elixir & Phoenix: Scalable Backend Development을(를) 배우며, 24/7 AI 튜터가 강의를 진행하면서 질문에 답변해줍니다.

Elixir & Phoenix: Scalable Backend Development을(를) 시작하는 데 경험이 필요한가요?

사전 경험은 필요하지 않습니다. CoddyKit의 Elixir & Phoenix: Scalable Backend Development은(는) 초급자부터 고급 학습자까지를 위해 구성되어 있으므로, 여기서 시작하거나 처음부터 시작할 수 있으며 자신의 속도대로 진행할 수 있습니다. 이것은 4개 중 3번째 강의입니다.

“동적 감독자와 레지스트리” 강의는 얼마나 걸리나요?

대부분의 CoddyKit 강의는 약 5~10분이 소요됩니다. 각 강의는 간결하고 인터랙티브하여 꾸준한 진행이 가능하며, 웹과 앱에서 중단한 부분부터 바로 시작할 수 있습니다.

이 Elixir & Phoenix: Scalable Backend Development 강의에서 코드를 작성하고 실행할 수 있나요?

네. 모든 Elixir & Phoenix: Scalable Backend Development 강의에는 내장 코드 에디터가 포함되어 있으므로, 브라우저에서 바로 실제 코드를 작성하고 실행한 후 즉시 AI 피드백을 받을 수 있습니다 — 로컬 설정이 필요 없습니다.

이 강의의 모든 강의

  1. 분산 Elixir와 클러스터링
  2. 고급 감독 전략
  3. 동적 감독자와 레지스트리
  4. GenStage와 백프레셔 파이프라인
← Elixir & Phoenix: Scalable Backend Development(으)로 돌아가기