Node.js + Redis Pub/Sub Örneği

var io = require("socket.io").listen(3000)
  , redis = require("redis")
  , pub = redis.createClient()
  , sub = redis.createClient();

console.log("Listening on *:3000");

io.sockets.on("connection", function (socket) {
  // listen event'i ile client bir kanala abone oluyor.
  socket.on("listen", function (data) {
    // kanala abone ol.
    sub.subscribe("user:" + data.user_id);
  });

  // bir kanala mesaj gonderir.
  socket.on("message", function (data) {
    // kanala mesaj gönder.
    pub.publish("user:" + data.user_id, data.action);
  });

  // abone olunan kanallara mesaj geldiginde
  sub.on("message", function (channel, message) {
    // bu kanala gelen mesaji ilgili event"e gonderir.
    // redis channel => socket event
    socket.emit(channel, message);
  });

  // baglantiyi kapattiginda
  socket.on("close", function () {
    sub.quit();
  });
});

<input type="text" id="msg">
<br>
<div id="thread-status"></div>

<!-- aşağıdaki socket.io dosyası, yukarıdaki node.js server tarafından sunuculacaktır. -->
<script src="http://localhost:3000/socket.io/socket.io.js"></script>
<script>
var socket = io.connect("http://localhost:3000");
var thread_status = "";

// bu örnekte 27 nolu kullanıcı ile 3 nolu kullanıcı mesajlaşıyor.
// üyelerin yazı yazma etkinlikleri karşı tarafın kanalına bildiriliyor.
var my_user_id = 3;
var her_user_id = 27;
var her_name = "Karşı taraf";

// üye kendi kanalına abone oluyor.
// böylece 3 nolu kullanıcı kanalına gelen mesajları alabilir.
socket.emit("listen", {user_id: my_user_id});

// kendi kanalına mesaj geldiğinde çalışacak callback methodu.
socket.on("user:" + my_user_id, function (action) {
  var status = $("#thread-status");

  if (action == "write:start") {
    status.html(her_name + " yazıyor..");
  } else if (action == "write:stop") {
    status.html("");
  }
});

$(document).ready(function () {
  // mesaj yazma alanında değişiklik olduğunda
  $("#msg").keyup(function () {
    var msg = $(this).val();
    var action = "";

    // action'ı belirle.
    if (msg) {
      action = "write:start";
    } else {
      action = "write:stop";
    }

    // her harfe basıldığında event göndermeye gerek yok.
    // o nedenle bir öncekiyle aynı ise bir şey yapma.
    if (thread_status == action) return;

    // yeni durumu socket ile diğer üyenin kanalına gönder.
    window.socket.emit("message", { user_id: her_user_id, action: action });

    // mevcut durumu güncelle.
    thread_status = action;
  });
});
</script>

window.socket.emit('message', {
  user_id : 27,
  action : "message:start",
  token : "76d34d94c2e7fdd50c36585a4e9a7b77"
});

socket.on('listen', function (data)
{
  // kullanicidan token iste.
  // yetkili olduğu kişiler listesinde var mi diye kontrol et.
  // eger listesindeyse dinlemesine izin ver.

  client.sismember('user:' + data.token + ':friends', data.user_id, function (err, response) {
    if (response) {
      // istenilen kanala abone ol
      sub.subscribe("user:" + data.user_id);
    }
  });
});