ActionCable.server.broadcast无法广播问题求助

问题描述 #

我正尝试将Rails应用从使用Pusher迁移到ActionCable，服务器端的PagesChannel代码如下：

class PagesChannel < ApplicationCable::Channel
     def subscribed
        stream_from 'pages'
     end
     def speak(data)
        ActionCable.server.broadcast('pages',data)
     end
 end

客户端订阅代码为：

const app=ActionCable.createConsumer("wss://localhost.branch.co:3000/cable");
const channel =app.subscriptions.create("PagesChannel",{
    connected:()=>{
        console.log("connected")
    },
    received:()=>{
        console.log("got mail")
    }
})

根据Rails官方文档，ActionCable.server.broadcast可在应用任意位置调用向指定房间广播，但我在Rails控制台执行ActionCable.server.broadcast("pages",{})时，客户端未收到消息也无报错；不过客户端调用channel.perform("speak")可正常广播。已确认客户端已连接且无跨域问题，想咨询：

• ActionCable.server.broadcast是否只能在Channel类内调用？
• 若只能在类内调用，如何从服务器端调用Channel类的方法？

解决方案 #

1. ActionCable.server.broadcast的调用范围 #

ActionCable.server.broadcast并非只能在Channel类内调用，它可以在Rails应用的任何地方使用（控制器、模型、后台任务、控制台等）。控制台调用无效的常见原因是：

• 控制台进程与ActionCable服务器进程分离，开发环境下两者默认不属于同一进程，导致广播消息无法传递到Cable服务器。
• 默认的async适配器仅在当前进程内有效，控制台进程的广播无法被Cable服务器进程接收。

2. 解决控制台广播无效的方法 #

要让控制台的广播能被客户端接收，需将ActionCable适配器改为跨进程类型，比如Redis：

• 在config/cable.yml中配置Redis适配器：

development:
  adapter: redis
  url: redis://localhost:6379/1

• 确保Redis服务已启动，重启Rails服务器和控制台，此时在控制台执行ActionCable.server.broadcast("pages", {message: "test"})，客户端就能收到消息。

3. 从服务器端调用Channel类方法的方式 #

如果确实需要调用Channel类内的方法，有两种常见方式：

• 通过连接标识符定位连接：若知道用户的连接标识符（比如current_user的id），可找到对应连接并触发方法：

# 假设通过current_user的id定位连接
user_id = 1
connections = ActionCable.server.connections.select do |conn|
  conn.current_user.id == user_id
end
connections.each do |conn|
  # 获取该用户订阅的PagesChannel实例
  channel = conn.subscriptions.find { |sub| sub.channel == PagesChannel }
  channel&.speak({message: "Hello from server"}) if channel
end

• 封装广播逻辑到独立服务类：更推荐的做法是将广播逻辑抽离到单独的服务类，方便在Channel内或其他地方调用：

# app/services/page_broadcaster.rb
class PageBroadcaster
  def self.broadcast(data)
    ActionCable.server.broadcast('pages', data)
  end
end

之后在Channel类和其他场景都能直接调用：

# 在Channel内
def speak(data)
  PageBroadcaster.broadcast(data)
end

# 在控制台或其他地方
PageBroadcaster.broadcast({message: "Test broadcast"})

内容的提问来源于stack exchange，提问作者Akshat Jaiswal