坂東です。

以前に、Redisのpub/sub機能を使ってRailsとsocket.ioと連携させるという、記事を書きました。

Railsとnode.jsを連携させる

スケールアウトしようとしようとNode.jsにCluster入れてマルチスレッドにしたら問題発生。
Redisからpub/subしたときに、各workerが個別に反応する。
１つのアクションにつき４つ通知が発生するという困った状態になりました。

worker間で通知の状況を共有するとか、手を抜いてmasterだけ通知を出すようにするか。
考えてたところ、「socket.io-emmiter」というのがそこらへんうまくやってくれるとの情報を得ました。

Railsの生pub/subしてるコードを、

json = ActiveSupport::JSON.encode({
  ‘channel’ => ‘チャンネルA’,
  ‘event’ => ‘イベント1’,
  ‘message’ => ‘メッセージ’,
})
Redis.current.publish(‘REDIS_SUB’, json)

socket.io-emitterに書き換えます。

Gemfile
gem 'socket.io-emitter'

emmiter = SocketIO::Emitter.new(Redis.new)
emmiter.to( 'チャンネルA' ).emit('イベント1', 'メッセージ')

通知が多重に発生するようなことはなくなりました。
worker間で通知の状況を共有するとか、手を抜いてmasterだけ通知を出すようにするとか、うまくやってくれてるんでしょう。

おわり。