Redis pub/sub-chat-server in node.js
Ich versuche, die Arbeit der Redis Cookbook Beispiel:
var http = require('http'),
io = require('socket.io')
fs = require('fs'),
redis = require('redis'),
rc = redis.createClient(9189, "pike.redistogo.com");
rc.auth("passwd", function() {
console.log("Connected! to redistogo!");});
rc.on("connect", function() {
rc.subscribe("chat");
console.log("rc connect event");
});
Ich bin erfolgreich durch hier, aber nie bekommen "Nachricht".
rc.on("message", function (channel, message) {
console.log("Sending: " + message);
socketio.sockets.emit('message', message);
});
webpage = http.createServer(function(req, res){
console.log('webpage request starting...');
fs.readFile('./index.htm', function(error, content) {
if (error) {
res.writeHead(500);
res.end();
}
else {
res.writeHead(200, { 'Content-Type': 'text/html' });
res.end(content, 'utf-8');
}
});
});
webpage.listen(7777);
meine client-Seite index.htm ist dies
<!docttype html>
<html lang="en">
<head>
<script src ="https://ajax.googleapis.com/ajax/libs/jquery/1.6.1/jquery.min.js"> </script>
<script src="http://www.heaphash.com:7777/socket.io/socket.io.js"></script>
<script>
var socket = io.connect('www.heaphash.com', { port: 7777});
socket.on('message', function(data){
var li = new Element('li').insert(data);
$('messages').insert({top: li});
}
</script>
<meta charset="utf-8">
<title>Chat with Redis</title>
</head>
<body>
<ul id="messages">
<!-- chat messages go here -->
</ul>
<form id="chatform" action="">
<input id="chattext" type="text" value="" />
<input type="submit" value="Send" />
</form>
<script>
$('#chatform').submit(function(){
socket.emit('message', $('chattext').val());
$('chattext').val(""); //cleanup the field
return false;
});
</script>
</body>
</html>
wie einen client veröffentlichen, zu einem bestimmten Redis "chat" - Kanal.
Du musst angemeldet sein, um einen Kommentar abzugeben.
Wenn Sie mit redis pub/sub-Funktionalität in Ihre node.js Programm sollten Sie widmen einen redis-client-Verbindung für das hören auf irgendeinem Kanal und zweiten redis-client-Verbindung für das senden von normalen Befehle und/oder Veröffentlichung von Mitteilungen auf Ihrem channel(s). Von node_redis docs:
Dein problem ist auch in Bezug auf diese Fragen:
Ich glaube, dass das Beispiel aus diesem Buch etwas fehlt, habe ich auch gelesen und mich gewundert. Sie sind abonniert auf die Redis-Kanal und warten auf Nachrichten auf der server-Seite, aber man kann es nie veröffentlichen zu diesem Kanal. Was fehlt, ist ein Ereignis-listener, so dass, wenn es eine websocket-Nachricht, die Sie veröffentlichen, dass die Nachricht an die redis-Kanal.