在Elixir中如何结合使用OTP和WebSockets构建实时应用

在Elixir中，可以使用OTP（Open Telecom Platform）和WebSockets来构建实时应用。下面是一个简单的示例，演示如何结合使用OTP和WebSockets：

1. 首先，在mix.exs文件中添加依赖项cowboy和plug：

defp deps do
  [
    {:cowboy, "~> 2.9"},
    {:plug, "~> 1.12"}
  ]
end

1. 创建一个GenServer来处理WebSockets连接：

defmodule MyApp.WebSocketHandler do
  use GenServer

  def start_link do
    GenServer.start_link(__MODULE__, %{})
  end

  def init(state) do
    {:ok, state}
  end

  def handle_info({:cowboy_websocket, _pid, {:text, msg}}, state) do
    # 处理收到的消息
    IO.inspect(msg)
    {:noreply, state}
  end
end

1. 创建一个Plug中间件来处理WebSocket连接：

defmodule MyApp.WebSocketPlug do
  import Plug.Conn

  def init(opts), do: opts

  def call(conn, _opts) do
    case upgrade_websocket(conn) do
      {:ok, conn} ->
        {:ok, conn}
      {:error, _reason} ->
        send_resp(conn, 400, "")
    end
  end

  defp upgrade_websocket(conn) do
    case Plug.Conn.get_req_header(conn, "upgrade") do
      "websocket" ->
        MyApp.WebSocketHandler.start_link()
        {:ok, %{conn | upgrade: :websocket, adapter: :cowboy_websocket}}
      _ ->
        {:error, :not_upgrade}
    end
  end
end

1. 创建一个Cowboy路由来处理WebSocket连接：

defmodule MyApp.Router do
  use Plug.Router

  plug MyApp.WebSocketPlug

  forward "/websocket", to: MyApp.WebSocketHandler
end

1. 启动应用并运行Cowboy服务器：

defmodule MyApp.Application do
  use Application

  def start(_type, _args) do
    children = [
      MyApp.Router
    ]

    opts = [strategy: :one_for_one, name: MyApp.Supervisor]
    Supervisor.start_link(children, opts)
  end
end

现在，您已经搭建好了一个简单的使用OTP和WebSockets的实时应用。您可以进一步扩展和优化这个示例，以满足您实际应用的需求。