sql >> Database teknologi >  >> NoSQL >> Redis

Hvordan genbruger man redis-forbindelse i socket.io?

Faktisk opretter du kun en ny redis-klient for hver forbindelse, hvis du instansierer klienten på "forbindelse"-hændelsen. Det, jeg foretrækker at gøre, når jeg opretter et chatsystem, er at oprette tre redis-klienter. Én til udgivelse, abonnement og én til lagring af værdier i redis.

for eksempel:

var socketio = require("socket.io")
var redis = require("redis")

// redis clients
var store = redis.createClient()
var pub = redis.createClient()
var sub = redis.createClient()

// ... application paths go here

var socket = socketio.listen(app)

sub.subscribe("chat")

socket.on("connection", function(client){
  client.send("welcome!")

  client.on("message", function(text){
    store.incr("messageNextId", function(e, id){
      store.hmset("messages:" + id, { uid: client.sessionId, text: text }, function(e, r){
        pub.publish("chat", "messages:" + id)
      })
    })
  })

  client.on("disconnect", function(){
    client.broadcast(client.sessionId + " disconnected")
  })

  sub.on("message", function(pattern, key){
    store.hgetall(key, function(e, obj){
      client.send(obj.uid + ": " + obj.text)
    })
  })

})


  1. Sådan laver du GROUP BY i Redis

  2. Pipelining vs Batching i Stackexchange.Redis

  3. Hvordan ændrer man strukturen af ​​MongoDBs kort-reducer resultater?

  4. E-Commerce API lavet med Node-Js, Typescript, PostgreSQL, Redis og Kafka