差别

这里会显示出您选择的修订版和当前版本之间的差别。

--- it:server:redis [2022-08-17 10:53] – goldentianya
+++ it:server:redis [2022-08-17 14:31] (当前版本) – [Node.js 使用] goldentianya
@@ 行 33: / 行 33: @@
 serverfin:6379> AUTH "138629"
 serverfin:6379> subscribe maichannel // 认证后才允许订阅频道
+</code>
+===== 订阅与发布 =====
+<code download>
+// 订阅
+redis 127.0.0.1:6379> SUBSCRIBE <channelname>
+// 发布
+redis 127.0.0.1:6379> PUBLISH <channelname> "messa...."
+</code>
+===== Node.js 使用 =====
+[[https://docs.redis.com/latest/rs/references/client_references/client_nodejs/|Redis with Node.js]]
+<code >
+var redis = require('redis');
+var client = redis.createClient("6379", "127.0.0.1", {auth_pass: "yoursecret"});
+client.on('connect', function () {
+    //client.hset("hash key", "field 1", "v1", redis.print);
+    //client.hget("hash key", "field 1", redis.print);
+    //client.quit();
+});
+var client1 = redis.createClient("6379", "127.0.0.1", {auth_pass: "yoursecret"});
+client1.on('connect', function () {
+    client1.subscribe("channel");
+});
+client1.on("message", function (channel, message) {
+    console.log("普通订阅接收到来自" + channel + "的信息:" + message);
+    if (message == "demo") {
+        client.publish("demo","demo msg");
+    }
+    if (message == "quit1") {
+        client1.unsubscribe("channel");
+        console.log("普通订阅操作已经取消");
+        //client2.quite();
+    }
+});
+var client2 = redis.createClient("6379", "127.0.0.1", {auth_pass: "yoursecret"});
+client2.on('connect', function () {
+    client2.psubscribe("channel*");
+});
+client2.on("pmessage", function (p, channel, message) {
+    console.log("批量订阅接收到来自" + channel + "的信息:" + message);
+    if (message == "quit2") {
+        client2.punsubscribe("channel*");
+        console.log("批量订阅操作已经取消");
+        //client2.quite();
+    }
+});
 </code>

it/server/redis.1660733633.txt.gz · 最后更改: 2022-08-17 10:53 由 goldentianya

回到顶部