如何在 Rails 控制器中调用通道方法？

我有一个订阅用户的 ActionCable 方法。如果启动新的 convo，我也希望用户订阅新频道。我无法找出在控制器中调用通道方法的正确语法。

更新：问题是消息在发送时附加到聊天框，但是当发送第一条消息时，Websocket 连接尚未建立，因此用户看起来好像消息未发送（因为它是不予追加）。

频道/msgs_channel.rb

class MsgsChannel < ApplicationCable::Channel  
  #This function subscribes the user to all existing convos
  def subscribed
    @convos = Convo.where("sender_id = ? OR recipient_id = ?", current_user, current_user)
    @convos.each do |convo|
        stream_from "msg_channel_#{convo.id}"
    end
  end

  #This is a new function I wrote to subscribe the user to a new convo that is started during their session.
  def subscribe(convo_id)
      stream_from "msg_channel_#{convo_id}"
  end
end

在我的 convos 控制器的 create 方法中，我尝试了几件事：

convos_controller.rb

def create
  @convo = Convo.create!({sender_id: @sender_id, recipient_id: @recipient_id})
  ActionCable.server.subscribe(@convo.id)
end

ActionCable.subscribe(@convo.id)

error: NoMethodError (undefined method订阅 ActionCable:Module)`

ActionCable.msgs.subscribe(@convo.id)

error: NoMethodError (undefined methodActionCable 的消息：模块）：`

  App.msgs.subscribe(@convo.id)

error:NameError (uninitialized constant ConvosController::App):

MsgsChannel.subscribe(@convo.id)

error:NoMethodError (undefined method订阅 MsgsChannel:Class`

ActionCable.server.subscribe(@convo.id)

error:NoMethodError (undefined method订阅#):`

从控制器检索特定通道实例

Channel实例与用户的相关联Connection。以下将获取哈希值Channels for a Connection:

conn = ActionCable.server.connections.first { |c| c.current_user == user_id }

# subs is a hash where the keys are json identifiers and the values are Channels
subs = conn.subscriptions.instance_variable_get("@subscriptions")

(If Connection#current_user不存在，则按照第 3.1.1 节顶部的说明进行操作导轨 ActionCable 概述 http://guides.rubyonrails.org/action_cable_overview.html#connect-consumer添加它。）

然后你可以获得一个Channel基于您想要的任何标准。例如，您可以按类型搜索，在您的情况下是MsgsChannel。 json 中的键subs也可以使用，但可能更复杂。

一旦你有了这个实例，你就可以调用你想要的任何方法（在你的情况下MsgsChannel#subscribe).

对这种方法的担忧

A Channel仅封装服务器端工作，这些工作将响应来自应用程序客户端的消息而启动。让服务器调用Channel方法实际上相当于让服务器假装消费者发送了一条它没有发送的消息。

我建议不要这样做，将您想要使用的任何逻辑都放在Controller and a Channel进入共享位置的方法。这Controller and Channel然后可以根据需要直接调用该方法。

话虽这么说，但有一个痛苦的警告，那就是你需要Channel打电话stream_from。不幸的是，管理流是特定于Channel即使从根本上来说它只是更新 pubsub 信息Server.

我认为流管理实际上应该只需要适当的连接和Server及其发布订阅。如果是这样的话，你就不用担心打电话了Channel来自应用程序服务器端的方法。

你应该能够有效地运行stream_for如果你得到一个更直接的Channel, any Channel（你可以使用subs也从这个答案的顶部开始）并打电话stream_for on it

conn = ActionCable.server.connections.first { |c| c.current_user == user_id }
MsgsChannel.new(conn, "made up id").stream_from "your_stream_name"

我自己还没有尝试过，但看起来应该可行。