Elixir Phoenix再帰関数はページ読み込みを停止します

Question

私は、Webアプリケーションがインデックスページを読み込む必要があり、メッセージを受け取るためにバックグラウンドで待機する必要があるPhoenixエリクシールを使用してWebアプリケーションを構築しています。これは私が問題

defmodule ApplicationB.PageController do 
    use ApplicationB.Web, :controller 
    use AMQP 

    def index(conn, _params) do 
    {:ok, connection} = AMQP.Connection.open 
    {:ok, channel} = AMQP.Channel.open(connection) 
    AMQP.Queue.declare(channel, "hello") 
    AMQP.Basic.consume(channel, "hello", nil, no_ack: true) 
    IO.puts " [*] Waiting for messages. To exit press CTRL+C, CTRL+C" 

    wait_for_messages 

    render conn, "index.html" 
    end 

    def wait_for_messages do 
    receive do 
     {:basic_deliver, payload, _meta} -> 
     IO.puts " [x] Received #{payload}" 
     ApplicationB.Endpoint.broadcast! "message", "hello", %{body: "poruka"} 
     wait_for_messages 
    end 
    end 

end 

私は、インデックス内のwait_for_messagesを呼び出すとき、それは再帰関数であり、それはrender conn, "index.html"ラインに到達することはありませんので、私の問題は、私のwait_for_messages関数内であることを知っているを持っている私のコードです。それは、ページinde.htmlがロードされ、wait_for_messagesがバックグラウンドで実行されるように、動作させる方法はありますか？

Answer 1

あなたはTaskモジュールを探しているようです。あなたの行動を阻止するからwait_for_messages/0を防ぐため

、あなたはこのようにTask.start_link/1を使用することがあります。

def index(conn, _params) do 
    {:ok, connection} = AMQP.Connection.open 
    {:ok, channel} = AMQP.Channel.open(connection) 
    AMQP.Queue.declare(channel, "hello") 
    AMQP.Basic.consume(channel, "hello", nil, no_ack: true) 
    IO.puts " [*] Waiting for messages. To exit press CTRL+C, CTRL+C" 

    Task.start_link(fn -> wait_for_messages end) 

    render conn, "index.html" 
end 

Answer 2

おそらくフェニックスチャンネルは、このためのより良いフィット感だろう。クライアントにindex.htmlを送信し、そのクライアント側のアプリケーションからAMQPバスからメッセージを送信するチャネルに参加させる（接続されたすべてのクライアントにブロードキャストする）。これは、あなたのアプリケーションに、実際に無料でより多くの分散方法でその機能を与えるでしょう。ドキュメントはここにあります：http://www.phoenixframework.org/docs/channels

私はコンソール出力をする目的ではっきりしていません...これを行うには、エリクサー - yの方法は、 AMQPメッセージングと別のプロセスでは、そこからメッセージを消費するiexコンソールから開始/対話することができ、AMQPプロセッサを停止（たとえば強制終了）するためのAPIを提供します。

..しかし、そのコンソール出力に依存すると、一度に1つのそのようなやりとりに制限されます...そして、Webサービスは本質的にそのようなものではありません。