Elixir完全ガイド｜特徴・メリット・Erlang/OTP採用事例と学習ロードマップ【2025年版】

defmodule Counter do
  # プロセスを開始する関数
  def start(initial_value \\ 0) do
    spawn(fn -> loop(initial_value) end)
  end

  # メッセージを受信し続けるループ
  defp loop(current_value) do
    receive do
      {:increment, caller} ->
        new_value = current_value + 1
        send(caller, {:ok, new_value})
        loop(new_value)
      
      {:get_value, caller} ->
        send(caller, {:ok, current_value})
        loop(current_value)
      
      :stop ->
        :ok
    end
  end

  # カウンターの値を増加させる
  def increment(pid) do
    send(pid, {:increment, self()})
    receive do
      {:ok, value} -> value
    end
  end

  # 現在の値を取得する
  def get_value(pid) do
    send(pid, {:get_value, self()})
    receive do
      {:ok, value} -> value
    end
  end
end

# 使用例
counter_pid = Counter.start(0)
Counter.increment(counter_pid)  # => 1
Counter.increment(counter_pid)  # => 2
Counter.get_value(counter_pid)  # => 2

defmodule UserProcessor do
  def process_user({:ok, %{name: name, age: age}}) when age >= 18 do
    "成人ユーザー: #{name}さん（#{age}歳）"
  end

  def process_user({:ok, %{name: name, age: age}}) when age < 18 do
    "未成年ユーザー: #{name}さん（#{age}歳）"
  end

  def process_user({:error, reason}) do
    "エラー: #{reason}"
  end
end

# 使用例
UserProcessor.process_user({:ok, %{name: "田中", age: 25}})
# => "成人ユーザー: 田中さん（25歳）"

UserProcessor.process_user({:error, "ユーザーが見つかりません"})
# => "エラー: ユーザーが見つかりません"

defmodule ChatRoom.Supervisor do
  use Supervisor

  def start_link(opts) do
    Supervisor.start_link(__MODULE__, :ok, opts)
  end

  def init(:ok) do
    children = [
      # チャットルームのワーカープロセス
      {ChatRoom.Worker, []},
      # メッセージ配信プロセス
      {MessageDispatcher, []},
      # ユーザー管理プロセス
      {UserManager, []}
    ]

    # :one_for_one → 一つのプロセスが停止しても他は継続
    Supervisor.init(children, strategy: :one_for_one)
  end
end

defmodule ChatWeb.RoomLive do
  use ChatWeb, :live_view

  def mount(_params, _session, socket) do
    # チャットルームに参加
    Phoenix.PubSub.subscribe(Chat.PubSub, "room:general")
    
    {:ok, assign(socket, messages: [], current_user: "ユーザー")}
  end

  def handle_event("send_message", %{"message" => message}, socket) do
    # メッセージを全参加者に配信
    Phoenix.PubSub.broadcast(Chat.PubSub, "room:general", {:new_message, message})
    
    {:noreply, socket}
  end

  def handle_info({:new_message, message}, socket) do
    # 新しいメッセージを受信したら画面を更新
    {:noreply, update(socket, :messages, &[message | &1])}
  end
end

# 1. 基本的なデータ型
age = 25
name = "田中"
is_student = true
scores = [80, 90, 75]
user = %{name: "田中", age: 25}

# 2. パターンマッチング
{:ok, result} = {:ok, "成功"}
[head | tail] = [1, 2, 3, 4, 5]

# 3. 関数の定義
defmodule Calculator do
  def add(a, b), do: a + b
  
  def divide(a, 0), do: {:error, "ゼロ除算エラー"}
  def divide(a, b), do: {:ok, a / b}
end

# シンプルなチャットルームの実装
defmodule ChatRoom do
  use GenServer

  # クライアントAPI
  def start_link(room_name) do
    GenServer.start_link(__MODULE__, [], name: via_tuple(room_name))
  end

  def join(room_name, user_name) do
    GenServer.call(via_tuple(room_name), {:join, user_name})
  end

  def send_message(room_name, user_name, message) do
    GenServer.cast(via_tuple(room_name), {:message, user_name, message})
  end

  # サーバーコールバック
  def init(_) do
    {:ok, %{users: []}}
  end

  def handle_call({:join, user_name}, _from, state) do
    new_state = %{state | users: [user_name | state.users]}
    {:reply, :ok, new_state}
  end

  def handle_cast({:message, user_name, message}, state) do
    # 全ユーザーにメッセージを配信
    Enum.each(state.users, fn user ->
      IO.puts("#{user}に配信: [#{user_name}] #{message}")
    end)
    {:noreply, state}
  end

  defp via_tuple(room_name) do
    {:via, Registry, {ChatRegistry, room_name}}
  end
end

# LiveViewでのTODO管理
defmodule TodoWeb.TodoLive do
  use TodoWeb, :live_view

  def mount(_params, _session, socket) do
    {:ok, assign(socket, todos: [], new_todo: "")}
  end

  def handle_event("add_todo", %{"todo" => todo_text}, socket) do
    new_todo = %{id: :rand.uniform(1000), text: todo_text, done: false}
    updated_todos = [new_todo | socket.assigns.todos]
    
    {:noreply, assign(socket, todos: updated_todos, new_todo: "")}
  end

  def handle_event("toggle_todo", %{"id" => id}, socket) do
    id = String.to_integer(id)
    updated_todos = 
      Enum.map(socket.assigns.todos, fn todo ->
        if todo.id == id do
          %{todo | done: !todo.done}
        else
          todo
        end
      end)
    
    {:noreply, assign(socket, todos: updated_todos)}
  end
end