26

我使用 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函数从未被调用。难道我做错了什么?

注意:我使用actioncablenpm 包从 BackboneJS 应用程序连接。

4

1 回答 1

67

将电缆适配器从更改为async固定redisconfig/cable.yml我固定。

更新

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

于 2016-04-01T22:36:17.390 回答