【发布时间】:2017-02-17 16:57:53
【问题描述】:
我正在使用 ActionCable 在我的游戏室(游戏)内实现聊天。 到目前为止,这是我的代码:
app/channels/game_channel.rb:
class GameChannel < ApplicationCable::Channel
def subscribed
stream_from "game_channel_#{params[:game]}"
end
def unsubscribed
# Any cleanup needed when channel is unsubscribed
end
def speak (data)
ActionCable.server.broadcast("game_channel_#{params[:game]}", data)
end
end
app/assets/javascripts/channels/game.js.erb:
<% Game.all.each do |game| %>
App['game' + <%=game.id%>] = App.cable.subscriptions.create({channel: 'GameChannel', game: <%= game.id %>}, {
received: function(data) {
alert(message)
},
setGameId: function(gameId) {
this.gameId = gameId
},
speak: function(data) {
this.perform('speak'), message => data['message']
}
});
<% end %>
当我发送命令时:
App.game1.speak (message: "Test1", player: 1, game:1)
--> Alerts Msg:"Test1" @ Game 1.
App.game2.speak (message: "Hello", player: 2, game:2)
--> Alerts Msg "Hello" @ Game 2, AND @ Game 1 它再次提醒 msg: "Test1"。
如何解决这个问题,只显示@更新游戏的消息,而不在其他游戏房间更新?
服务器正在显示:
17:03:01 web.1 | GameChannel is transmitting the subscription confirmation
17:03:01 web.1 | GameChannel is streaming from game_channel_2
17:03:01 web.1 | GameChannel is transmitting the subscription confirmation
17:03:01 web.1 | GameChannel is streaming from game_channel_1
17:03:06 web.1 | GameChannel#speak
17:03:06 web.1 | [ActionCable] Broadcasting to game_channel_1: {"action"=>"speak"}
17:03:06 web.1 | GameChannel transmitting {"action"=>"speak"} (via streamed from game_channel_1)
17:03:06 web.1 | GameChannel transmitting {"action"=>"speak"} (via streamed from game_channel_1)
17:03:11 web.1 | GameChannel#speak
17:03:11 web.1 | [ActionCable] Broadcasting to game_channel_2: {"action"=>"speak"}
17:03:11 web.1 | GameChannel transmitting {"action"=>"speak"} (via streamed from game_channel_2)
17:03:11 web.1 | GameChannel transmitting {"action"=>"speak"} (via streamed from game_channel_2)
【问题讨论】:
标签: ruby-on-rails ruby websocket actioncable