使用nodejs作为服务器使用Python发送socket.io消息

Question

我需要一些帮助。

我正在做测试，以了解如何构建一个实时网站，所以我使用node.js与socket.io。所有的作品都很有趣，但是如果我尝试在通道中发布一些消息，而这些消息是使用不是节点或JavaScript的不同源的侦听节点，则会崩溃。

服务器端：（节点，当外部发布的sended失败）

var app = require('express')(); 
var http = require('http').Server(app); 

var pub = require('redis').createClient(6379, 'localhost', {detect_buffers: true, return_buffers: false}); 
var sub = require('redis').createClient(6379, 'localhost', {return_buffers: true}); 

var io = require('socket.io')(http); 

var redis = require('socket.io-redis'); 
io.adapter(redis({pubClient: pub, subClient: sub, host: '127.0.0.1', port: 6379})); 


io.on('connection', function(socket){ 
    socket.on('chat message', function(msg){ 
    io.emit('chat message', msg); 
    console.log("something happens: " + msg); 
    }); 
}); 


http.listen(3000, function(){ 
    console.log('listening on *:3000'); 
}); 

你并不需要尝试的客户端代码，只是把这个代码，并与节点运行它。当它运行时，尝试直接在Redis上发布频道，看看会发生什么。

Error: 5 trailing bytes 
    at Object.decode (.../node/node_modules/msgpack-js-v5/msgpack.js:266:47) 
    at Redis.onmessage (.../node/node_modules/socket.io-redis/index.js:93:24) 
    at emitTwo (events.js:87:13) 
    at RedisClient.emit (events.js:172:7) 
    at RedisClient.return_reply (.../node/node_modules/redis/index.js:654:22) 
    at .../node/node_modules/redis/index.js:307:18 
    at nextTickCallbackWith0Args (node.js:419:9) 
    at process._tickCallback (node.js:348:13) 
    enter code here 

有人知道为什么会发生这种情况？我该如何解决它？

谢谢！

最新评论： 感谢robertklep我知道它需要使用相同的协议，因此我使用它编写了一个简单的Python脚本，但它失败并出现相同的错误。

import redis 
import msgpack 
text_packed = msgpack.packb('refresh', use_bin_type=True) 
r = redis.StrictRedis(host='localhost', port=6379, db=0) 
r.publish('socket.io#/#', text_packed) 

我也尝试过这种方法，我觉得我通过一些PARAM错误：

from emitter import Emitter 
io = Emitter(dict(host='localhost', port=6379)) 
io.Emit('chat message', "message from python!") 
# or specificating the room 
io.To("socket.io#/#").Emit('chat message', "message from python!") 

在这种情况下，没有到达Redis的。

Answer 1

socket.io-redis在Redis之上使用msgpack发布/发送消息，因此您不能只是将常规字符串推送到发布/订阅消息，并期望它能够正常工作。您使用的客户端需要使用相同的协议。