“未找到订阅类”具有动作效果和铁路6 API

Question

我使用Ruby 3.0.2p107，Rails 6.1.6，并且我是Rails Backend（API）和React TypeScript前端。

后端代码

# app/channels/notification_channel.rb
class NotificationChannel < ApplicationCable::Channel
  def subscribed
    stream_from "notification_channel_#{current_user.user_id}"
  end

  def unsubscribed; end
end

# app/channels/application_cable/connection.rb
module ApplicationCable
  class Connection < ActionCable::Connection::Base
    identified_by :current_user

    def connect
      self.current_user = find_user
    end

    private 

    # search the current user
    def find_user
      current_user = Profile::Account.find_by(user_id: request.query_parameters[:user_id])
      current_user ? current_user : reject_unauthorized_connection
    end
  end
end

前端代码

    const createSubscription = (consumer: ActionCable.Cable) => {
        consumer.subscriptions.create({ channel: `notification_channel_${user.sub}` }, {
            connected: () => console.log(`connected to notifications.${user.sub}`),
            received: (notification) => handleReceivedNotification(notification),
        });
    };

    const handleReceivedNotification = (notification: any) => {
        console.log(JSON.stringify(notification));
    }

    useEffect((): void => {
        if (user) setComsumer(ActionCable.createConsumer(`ws://localhost:3100/cable?user_id=${user.sub}`));
    }, [user]);

    useEffect((): void => {
        if (consumer) createSubscription(consumer);
    }, [consumer]);

当我运行应用程序（后端和前端）时，我会得到连接，但找不到订阅类。

Registered connection (Z2lkOi8vYXBpL1Byb2ZpbGU6OkFjY291bnQvMQ)
Subscription class not found: "notification_channel_facebook|10157537128720479"

另外，如果我尝试从命令行进行广播，它将无法解决（返回0）。

$ ActionCable.server.broadcast "notification_channel_#{user.user_id}", { action: "new_notification" }
D, [2022-07-07T14:44:03.820530 #19220] DEBUG -- : [ActionCable] Broadcasting to notification_channel_facebook|10157537128720479: {:action=>"new_notification"}
=> 0

我还检查了redis通道，但找不到notification_channel。

Redis.new.pubsub("channels")
=> ["action_cable/Z2lkOi8vYXBpL1Byb2ZpbGU6OkFjY291bnQvMQ", "_action_cable_internal"]

这是我的config/cable.yml config file

default: &default
  adapter: redis
  url: redis://localhost:6379/1

development:
  <<: *default

test:
  <<: *default

production:
  adapter: redis
  url: <%= ENV['REDIS_URL'] %>
  channel_prefix: api_production

在这里config> config/application.rb

require "rails"
# Pick the frameworks you want:
require "active_model/railtie"
require "active_job/railtie"
require "active_record/railtie"
require "active_storage/engine"
require "action_controller/railtie"
require "action_mailer/railtie"
require "action_view/railtie"
require "action_cable/engine"
# require "sprockets/railtie"
require "rails/test_unit/railtie"
# activate the action mailer system
require "active_storage/engine"
require "action_mailbox/engine"

我相信我已经浏览了有关该主题的所有文档，但是我开始放松选择。任何帮助都将不胜感激。

谢谢

Answer 1

看起来我一直在找到答案，这

要 感谢本文 API和客户端要使用的操作电缆不在导轨上，转到config/application.rb，包括：

config.action_cable.disable_request_forgery_protection = true
config.action_cable.url = "/cable"

我也意识到，确定的用户只需要在连接阶段使用，而对于订阅，我需要使用模块名称。

consumer.subscriptions.create({ channel: `NotificationChannel` }, {
  received: (notification) => handleReceivedNotification(notification),
});

现在，如果我播放一条消息，它可以顺利进行

ActionCable.server.broadcast "notification_channel_#{user.user_id}", { action: "new_notification" }