You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-07 13:22:56 +03:00
Authentication is now remembered by the client and will be automatically sent to the server on every connection, including any reconnections.
42 lines
1.3 KiB
JavaScript
42 lines
1.3 KiB
JavaScript
var redis = require("redis"),
|
|
client1 = redis.createClient(), msg_count = 0,
|
|
client2 = redis.createClient();
|
|
|
|
redis.debug_mode = false;
|
|
|
|
// Most clients probably don't do much on "subscribe". This example uses it to coordinate things within one program.
|
|
client1.on("subscribe", function (channel, count) {
|
|
console.log("client1 subscribed to " + channel + ", " + count + " total subscriptions");
|
|
if (count === 2) {
|
|
client2.publish("a nice channel", "I am sending a message.");
|
|
client2.publish("another one", "I am sending a second message.");
|
|
client2.publish("a nice channel", "I am sending my last message.");
|
|
}
|
|
});
|
|
|
|
client1.on("unsubscribe", function (channel, count) {
|
|
console.log("client1 unsubscribed from " + channel + ", " + count + " total subscriptions");
|
|
if (count === 0) {
|
|
client2.end();
|
|
client1.end();
|
|
}
|
|
});
|
|
|
|
client1.on("message", function (channel, message) {
|
|
console.log("client1 channel " + channel + ": " + message);
|
|
msg_count += 1;
|
|
if (msg_count === 3) {
|
|
client1.unsubscribe();
|
|
}
|
|
});
|
|
|
|
client1.on("ready", function () {
|
|
// if you need auth, do it here
|
|
client1.incr("did a thing");
|
|
client1.subscribe("a nice channel", "another one");
|
|
});
|
|
|
|
client2.on("ready", function () {
|
|
// if you need auth, do it here
|
|
});
|