javascript – node.js socket.io redis rails – 实时应用程序

我需要在我的应用程序( Ruby On Rails)中添加实时,因此,我认为更好的方法是使用node.js socket.io redis.

我在后端有这个application.js文件(node.js)

var app = require('http').createServer();
var io = require('socket.io');
var redis = require('redis').createClient();
var _ = require('underscore')._;

io = io.listen(app);
io.configure(function() {
    io.set("transports",["xhr-polling"]);
    io.set("polling duration",10);
    io.set("close timeout",10);
    io.set("log level",1);
})

redis.subscribe('rt-change');

io.on('connection',function(socket) {
    redis.on('message',function(channel,message) {
        socket.emit('rt-change',message)
    });
});

var port = process.env.PORT || 5001;
app.listen(port);

和前端的messages.js

var socket = io.connect('http://localhost:5001/socket.io');
socket.on('rt-change',function (data) {
    console.log(data);
});

我正在使用node application.js命令启动application.js,它可以工作！

MacBook-Pro-Zhirayr:rt zhirayr$node application.js info –
socket.io started

但是当我尝试从Rails应用程序发送带有redis的消息($redis.publish’rt-change’,{hello：’world’})时,我的浏览器不会在控制台中记录任何内容.
我确定,从浏览器建立的连接,导致我停止节点时,它会抛出连接拒绝错误.我确信redis和node之间建立了连接,导致application.js中的console.log(message)记录它.
但是浏览器中的console.log不会记录任何内容.

有什么想法吗？

谢谢.

UPD for #Antoine

在application.js中添加了console.log
io.on(‘connection’,function(socket){
redis.on(‘message’,message){
console.log(‘来自redis的新消息’);
socket.emit(‘rt-change’,message);
});
});

当r.publish’rt-change’,{：hello =>’world’}被执行时,节点记录下：

new message from redis
new message from redis
new message from redis
new message from redis
new message from redis
new message from redis
new message from redis
new message from redis
new message from redis
new message from redis
new message from redis

奇怪的是,1个消息的节点记录11次.

解决方法

var socket = io.connect('http://localhost:5001/socket.io');
socket.on('rt-change',function (data) {
    console.log(data);
});

根据http://socket.io上的文档,这部分代码似乎不正确,
你应该做的事情如下：

<script src="http://localhost:5001/socket.io/socket.io.js"></script>
<script>
  var socket = io.connect('http://localhost:5001');
</script>