首页 文章

在ActionCable中找不到订阅类'MyChannel'

提问于
浏览
5

我在使用Action Cable时遇到问题,每当我运行我的程序时,我收到一条错误,上面写着 Subscription 未找到类 ConversationChannel

当我尝试发送消息时,我得到了这个日志

已成功升级到WebSocket(REQUEST_METHOD:GET,HTTP_CONNECTION:升级,HTTP_UPGRADE:websocket)未找到订阅类:“ConversationChannel”无法从{“command”=>“message”执行命令,“identifier”=>“{\” channel \“:\”ConversationChannel \“}”,“data”=>“{\”message \“:[{\”name \“:\”conversation_id \“,\”value \“:\”2 \“ },{\ “名称\”:\ “amitian_id \”,\ “值\”:\ “1 \”},{\ “名称\”:\ “身体\”,\ “值\”:\“NMM \“}],\”action \“:\”speak \“}”}} [RuntimeError - 无法找到带标识符的订阅:{“channel”:“ConversationChannel”}]:C:/RailsInstaller/Ruby2.3.0/ lib / ruby / gems / 2.3.0 / gems / actioncable-5.0.1 / lib / action_cable / connection / subscriptions.rb:74:in find'| C:/RailsInstaller/Ruby2.3.0/lib/ruby/gems/2.3.0/gems/actioncable-5.0.1/lib/action_cable/connection/subscriptions.rb:53:in perform_action'| C:/RailsInstaller/Ruby2.3.0/lib/ruby/gems/2.3.0/gems/actioncable-5.0.1/lib/action_cable/connection/subscriptions.rb:17:incute_command'| C:/RailsInstaller/Ruby2.3.0/lib/ruby/gems/2.3.0/gems/actioncable-5.0.1/lib/action_cable/connection/base.rb:88:indispatch_websocket_message'| C:/RailsInstaller/Ruby2.3.0/lib/ruby/gems/2.3.0/gems/actioncable-5.0.1/lib/action_cable/server/worker.rb:58:在`block in invoke'中

ConversationChannel.rb

class ConversationChannel < ApplicationCable::Channel
  def subscribed
    # stream_from "some_channel"
    stream_from "conversations-#{current_amitian.id}"
  end

  def unsubscribed
    # Any cleanup needed when channel is unsubscribed
    stop_all_streams
  end

  def speak(data)

    message_params = data['message'].each_with_object({}) do |el, hash|
      hash[el.values.first] = el.values.last
    end

    ActionCable.server.broadcast(
      "conversations-#{current_amitian.id}",
      message: message_params
    )
  end 
 end

conversation.js

App.conversation = App.cable.subscriptions.create("ConversationChannel", {
  connected: function() {

  },
  disconnected: function() {

  },
  received: function(data) {
  console.log(data['message']);
  },
  speak: function(message) {
    return this.perform('speak' , {
    message: message
    });
  }
});

$(document).on('submit', '.new_message', function(e) {
  e.preventDefault();
  var values = $(this).serializeArray();
  App.conversation.speak(values);
  $(this).trigger('reset');
});

connection.rb

module ApplicationCable
  class Connection < ActionCable::Connection::Base
    identified_by :current_amitian

    def connect
        self.current_amitian = find_verified_amitian
    end

    protected

    def find_verified_amitian
        if(current_amitian = env['warden'].amitian)
            current_amitian
        else
            reject_unauthorized_connection
        end
    end
  end
end

使用上面给出的日志文件,任何人都可以告诉我为什么它找不到我的 conversation_channel.rb 文件?

3 回答

  • 13

    我通过将通道文件移动到一个目录来解决它 .

    app/channels/application_cable/conversation_channel.rbapp/channels/conversation_channel.rb

  • 1

    您的文件需要命名为 conversation_channel.rb ,因为snake_case是通道文件名的rails约定 .

  • 1

    您必须在客户端(JS)代码中提供完整的Module :: Class名称 . 对于例如如果你的 ConversationChannel 类在 ApplicationCable 模块内,那么在你的客户端而不是 ConversationChannel 你需要做 ApplicationCable::ConversationChannel

相关问题