railsからnodeサーバにemitする方法

Question

railsのAPI用途でJSONを返す処理があり、
JSONを返す前に、DBに保存された内容をnodeサーバにemitしたいのですが、
なにかいい方法はないでしょうか。

Rails

  def create
   @item = Item.new(item_params)
   #  nodeサーバにconnectして、@item.to_jsonをemitしたい

  end

Nodeサーバ

var io = require('socket.io').listen(3000);

io.sockets.on('connection', function(socket){
  socket.on('chat', function(data){
    console.log(data);
    socket.emit('chat', data); // echo
  });
});

Answer 1

よく行われる手段として、

1. Redisサーバを立ち上げる
2. Node.jsのSocket.ioサーバにsocket.io-redisを入れて、Redis経由でemitできるようにする
3. Ruby側にsocket.io-ruby-emitterを入れる

という手法があります。

Comments

[ricy]

ご回答ありがとうございます。
いただいた方針で一度実装してみましたが、emitされず、
申し訳ないですが、調べ方等アドバイスいただければ幸いです。

rails
emitter = SocketIO::Emitter.new(redis: Redis.new(:host => '127.0.0.1', :port => 6379))
response = emitter.emit("chat", item.to_json)

node

var cfg = require("config");
var company = process.env.COMPANY || "arrange"

var express = require('express');
var app = express();
var server = require('http').createServer(app);
var io = require('socket.io').listen(server);
var redis = require("socket.io-redis");
io.adapter(redis({host: '127.0.0.1', port: 6379}))
server.listen(5001);

io.sockets.on('connection', function(socket) {
console.log("connect")
socket.on("chat", function(messages){
console.log("emit")
console.log(messages)
io.sockets.emit("chat", messages)
});
socket.on('disconnect', function () {
console.log("user disconnected");
});
});

この対応で、
console.log("connect")
console.log("emit")
この2つがnodeのコンソールログ上にでてきません。

[maisumakun]

ちょっと読み違いとか勘違いがありましたが、この方法を使うと、RailsからSocket.ioの「クライアントに」直接emitできるようになります。サーバ側を制御したいときは、別な手段が必要となります。