0

我正在尝试跟踪用户在UserSocker使用时的存在，Phoenix.Presence而无需客户端出现在特定频道上。

稍后我想订阅用户在不同频道中的存在，以了解用户的存在。

我得到了这个工作，除了presence_diff在用户断开连接时收到一个。我正在做的是跟踪UserSocket每个用户的不同主题的存在：

defmodule MyAppWeb.UserSocket do

  # ...

  def connect(%{"user_id" => user_id, "password" => password}, socket) do
    case Accounts.authenticate(user_id, password) do
      {:ok, user} ->
        track_user_presence(socket.transport_pid, user)
        {:ok, assign(socket, :user, user)}
      _error -> :error
    end
  end

  defp user_presence_topic(user_id) do
    "user_presence:#{user_id}"
  end

  defp track_user_presence(pid, user) do
    MyApp.Presence.track(pid, user_presence_topic(user.id), user.id, %{
      online_at: inspect(System.system_time(:seconds))
    })
  end
end

在我的频道中，我订阅了用户不同的存在主题：

defmodule MyAppWeb.RoomChannel do
  # ...

  def join("room:" <> room_id, payload, socket) do
    send(self(), :after_join)
    {:ok, assign(socket, :room_id, room_id)}
  end

  def handle_info(:after_join, socket) do
    user_ids = ~w(1 2)
    presence_state = get_and_subscribe_to_user_presence(socket, user_ids)
    push(socket, "presence_state", presence_state)
    {:noreply, socket}
  end

  def get_and_subscribe_to_user_presence(socket, user_ids) do
    user_ids
    |> Enum.map(&user_presence_topic/1)
    |> Enum.map(fn topic ->
      Phoenix.PubSub.subscribe(
        socket.pubsub_server,
        topic,
        fastlane: {socket.transport_pid, socket.serializer, []}
      )
      Presence.list(topic)
    end)
    |> Enum.reduce(%{}, fn map, acc -> Map.merge(acc, map) end)
  end

  defp user_presence_topic(user_id) do
    "user_presence:#{user_id}"
  end
end

我得出的结论是，我需要以某种方式监视套接字transport_pid并在套接字终止时自己发送存在差异。

另一个想法是将客户端加入到UserSocket.connect/2功能之外的单独存在频道，但到目前为止我还没有找到如何存档它。

我将一个简单的凤凰应用程序与概述问题的测试一起破解：https ://github.com/kbredemeier/socket_presence

对此的任何建议将不胜感激。

4

1 回答 1

0

弄清楚了。PubSub.subscribe/3我最终没有使用 我MyApp.Endpoint.subscribe/1想要订阅的主题并handle_info/2在我的订阅频道上实施。handle_info/2然后将从订阅频道接收广播，在我的情况下是presence_diffs。

Chris McCord 在 slack 上向我指出，该fastlane选项Phoenix.PubSub.subscribe/3允许在广播时向与订阅者不同的进程发送消息。就我而言，这导致我的客户在presence_diff我期望的频道上收到了 not 。

于 2018-02-01T12:32:27.633 回答