我有一个PHP代码,它将数据发布到一个名为"MESSAGE_FROM_MARS"的通道。摘录如下:
function send_data_to_check_spam($feedback)
{
$d_id=$this->redis_connect(11);
//echo $feedback;
//die();
echo "<b style='color:red'>MESSAGE SENT TO SPAM SWATTER</b>"."<br>";
$d_id->PUBLISH("MESSAGE_FROM_MARS",$feedback);
}
有一个服务器端python侦听器,它接收发布的数据,代码片段如下:
r = redis.StrictRedis(host='localhost', port=6379, db=11)
def sum(a,b):
print a+b
def main():
sub = r.pubsub()
sub.subscribe('MESSAGE_FROM_MARS')
python代码进行处理并将结果发布回来。摘录如下:
r.publish('SPAM_STATUS',spam)
我正在尝试使用socket.io websocket获取结果,代码片段如下:
<script>
var socket = io.connect('127.0.0.1:6379');
console.log(socket);
socket.on('SPAM_STATUS', function (data) {
alert("here");
console.log(data);
//socket.emit('my other event', { my: 'data' });
});
</script>
除了socket.io由于某种原因没有从SPAM_STATUS通道获得消息之外,一切都像桃子一样工作。
我做错了什么?我对socket.io还比较陌生,所以请原谅我的天真
据我所知,您需要在服务器端安装一个socketIO服务器。
显然,"varsocket=io.connect('yourredisport')"不起作用。
Redis只用于pub/sub部分,用于您的服务器->服务器广播。
对于服务器端和客户端之间的实时交互,您需要一个socketIO服务器和socketIO客户端。
这是一个我自己觉得非常有用的例子:
https://github.com/jonashagstedt/redis-pubsub-chat/tree/master/redischat