Phoenix频道-每个插座有多个频道

我正在编写一个使用Elixir Channels处理实时事件的应用程序。我知道每个客户端会打开一个套接字，可以通过它多路复用多个频道。所以我的应用程序是一个聊天应用程序，用户是多个群聊的一部分。我有一个名为MessageChannel的Phoenix Channel，其中的join方法将处理动态主题。

def join("groups:" <> group_id, payload, socket) do
....

假设John加入了组/主题A和B，而Bob只加入了组或主题B。当John向组或主题A发送消息时，broadcast!/3也会向Bob发送该消息，对吗？因为handle_in没有消息发送到哪个主题/组的上下文。

我该如何处理，这样Bob就不会收到发送到A组的事件。我的设计正确吗？

因为handle_in没有消息发送到哪个主题/组的上下文。

当调用Phoenix.Channel.broadcast/3时，显然它确实具有与消息相关联的主题(从签名中看这并不明显(。你可以看到代码从这一行的信道开始。ex：

def broadcast(socket, event, message) do
    %{pubsub_server: pubsub_server, topic: topic} = assert_joined!(socket)
    Server.broadcast pubsub_server, topic, event, message
end

因此，当使用套接字调用broadcast/3时，它会模式匹配当前主题，然后调用底层Server.broadcast/4。

(如果你像我一样好奇，这反过来会调用底层的PubSub.broadcast/3，它会做一些分发魔法，将调用路由到你配置的pubsub实现服务器，很可能使用pg2，但我跑题了…(

因此，我在阅读Phoenix.Channel文档时发现这种行为并不明显，但他们确实在Incoming Events:中的phoenixframework channels页面中明确说明了这一点

broadcast!/3将通知该套接字主题上的所有已加入的客户端，并调用它们的handle_out/3回调。

所以它只在"这个插座的话题"上播出。他们在同一页面上定义主题为：

topic-字符串topic或topic:子主题对命名空间，例如"messages"、"messages:123">

因此，在您的示例中，"主题"实际上是主题：子主题对命名空间字符串："groups:A"和"groups:B"。John必须在客户端上分别订阅这两个主题，因此您实际上会引用两个不同的频道，即使它们使用相同的套接字。因此，假设您使用的是javascript客户端，通道创建看起来像这样：

let channelA = this.socket.channel("groups:A", {});
let channelB = this.socket.channel("groups:B", {});

然后，当你从客户端在通道上发送消息时，你只使用了一个主题在服务器上匹配的通道，正如我们上面看到的那样。

channelA.push(msgName, msgBody);

实际上，套接字路由是基于如何使用channel API在项目套接字模块中定义主题来完成的。对于我的Slack克隆，我使用三个频道。我有一个系统级频道来处理状态更新，一个用户频道和一个房间频道。

任何给定的用户都订阅了0或1个频道。然而，用户可以订阅多个频道。

对于发送到特定房间的消息，我会通过房间频道进行广播。

当我检测到特定房间的未读消息、通知或徽章时，我会使用用户通道。每个用户频道都存储用户已经预订的房间列表(它们列在客户端的侧栏上(。

这一切的诀窍是使用一对通道API，主要是intercept、handle_out、My.Endpoint.subscribe和handle_info(%Broadcast{},socket)。

我使用intercept来捕获广播的消息，我想在发送这些消息之前忽略或处理这些消息
在用户频道中，我订阅房间频道广播的事件
订阅时，会得到一个带有%Broadcast{}结构的handle_info调用，其中包括广播消息的主题、事件和有效负载

以下是我的几段代码：

defmodule UcxChat.UserSocket do
  use Phoenix.Socket
  alias UcxChat.{User, Repo, MessageService, SideNavService}
  require UcxChat.ChatConstants, as: CC
  ## Channels
  channel CC.chan_room <> "*", UcxChat.RoomChannel    # "ucxchat:"
  channel CC.chan_user <> "*", UcxChat.UserChannel  # "user:"
  channel CC.chan_system <> "*", UcxChat.SystemChannel  # "system:"
  # ...
end
# user_channel.ex
 # ...
 intercept ["room:join", "room:leave", "room:mention", "user:state", "direct:new"]
 #...
 def handle_out("room:join", msg, socket) do
    %{room: room} = msg
    UserSocket.push_message_box(socket, socket.assigns.channel_id, socket.assigns.user_id)
    update_rooms_list(socket)
    clear_unreads(room, socket)
    {:noreply, subscribe([room], socket)}
  end
  def handle_out("room:leave" = ev, msg, socket) do
    %{room: room} = msg
    debug ev, msg, "assigns: #{inspect socket.assigns}"
    socket.endpoint.unsubscribe(CC.chan_room <> room)
    update_rooms_list(socket)
    {:noreply, assign(socket, :subscribed, List.delete(socket.assigns[:subscribed], room))}
  end
  # ...
  defp subscribe(channels, socket) do
    # debug inspect(channels), ""
    Enum.reduce channels, socket, fn channel, acc ->
      subscribed = acc.assigns[:subscribed]
      if channel in subscribed do
        acc
      else
        socket.endpoint.subscribe(CC.chan_room <> channel)
        assign(acc, :subscribed, [channel | subscribed])
      end
    end
  end
  # ...
end

我还将user_channel用于与特定用户相关的所有事件，如客户端状态、错误消息等。

免责声明：我没有看过通道的内部工作，这些信息完全来自我在应用程序中使用通道的第一次体验。

当有人加入不同的组(基于join/3中的模式匹配(时，会通过单独的通道(套接字(进行连接。因此，对A的广播不会向B的成员发送消息，只有A。

在我看来，Channel模块类似于GenServer，join有点像start_link，其中会启动一个新的服务器(进程((但是，仅当它还不存在时(。

你真的可以忽略模块的内部工作，只需理解，如果你加入一个与现有名称不同的频道，你就是在加入一个独特的频道。你也可以相信，如果你向某个频道广播，只有该频道的成员才会收到消息。

例如，在我的应用程序中，我有一个用户通道，我只想连接一个用户。加入看起来像def join("agent:" <> _agent, payload, socket)，其中代理只是一个电子邮件地址。当我向该频道广播消息时，只有单个代理接收到该消息。我还有一个所有代理都可以加入的办公室频道，当我希望所有代理都能收到消息时，我会向它广播。

希望这能有所帮助。

相关内容

最新更新

热门标签：