ActionCable无法接收数据

Question

我使用ActionCable创建了下面的内容，但无法接收正在广播的任何数据。 评论频道:

class CommentsChannel < ApplicationCable::Channel
  def subscribed
    comment = Comment.find(params[:id])
    stream_for comment
  end
end

JavaScript：

var cable = Cable.createConsumer('ws://localhost:3000/cable');

var subscription = cable.subscriptions.create({
  channel: "CommentsChannel",
  id: 1
},{
  received: function(data) {
    console.log("Received data")
  }
});

它连接良好，我可以在日志中看到以下内容：

CommentsChannel is streaming from comments:Z2lkOi8vdHJhZGUtc2hvdy9FdmVudC8x

我随后向该流进行广播：

ActionCable.server.broadcast "comments:Z2lkOi8vdHJhZGUtc2hvdy9FdmVudC8x", { test: '123' }

问题在于“received”函数从未被调用。我做错了什么吗？ 注意：我正在使用“actioncable”npm包从BackboneJS应用程序连接。

- Artem Kalinchuk

---

在 config/cable.yml 中将电缆适配器从 async 更改为 redis 解决了这个问题。 - Artem Kalinchuk

Answer 1

将config/cable.yml中的电缆适配器从async更改为redis，这对我有所帮助。

更新

正如Erem在下面指出的那样，服务器和控制台是隔离的进程，因此您需要使用集中式队列管理器。

- Artem Kalinchuk

---

太棒了，我也遇到了同样的问题。很高兴你发布了解决方案！对我有用。 - DiegoSalazar

@Artem，这对我没用。即使使用redis，广播也无法正常工作。服务器控制台显示：“[ActionCable] Broadcasting to room_channel: {:message=>"llllllllllll"}”，但接收函数没有被调用。我尝试使用异步适配器和redis适配器。 - sufinsha

@sufinsha 是打错了吗？在我的js中，我连接的方式是 App.cable.subscriptions.create("NotificationsChannel", { ... }，而在我的ruby中，我得到了 class NotificationsChannel < ApplicationCable::Channel，这应该是正确的，对吧？ - Maxim Zubarev

你是在Rails控制台中进行广播吗？服务器和控制台使用独立的进程。你需要一个集中式的队列管理器，并且需要使用Redis。 - Erem

我也解决了。真奇怪。谢谢@ArtemKalinchuk。 - JohnSalzarulo