我是这些tecnologies的新手。nodejs&redis&socket.io的实时访问者&php
我想为我的网站获得每种产品的实时访问者。 我的意思是像“X用户看这个产品”这样的通知。
无论何时用户连接到产品,本产品的计数器都会增加,并且当断开连接计数器的数量将减少到只有该产品。
我试图搜索大量的文件,但我很困惑。
我正在使用Predis Library for PHP。
我所做的事情可能总是错的。 我不确定在哪里放createClient,何时订阅&何时退订。
我还没有完成:
在商品详细页:
$key = "product_views_".$product_id;
$counter = $redis->incr($key);
$redis->publish("productCounter", json_encode(array("product_id"=> "1000", "counter"=> $counter)));
在app.js
var app = require('express')()
, server = require('http').createServer(app)
, socket = require('socket.io').listen(server,{ log: false })
, url = require('url')
, http= require('http')
, qs = require('querystring')
,redis = require("redis");
var connected_socket = 0;
server.listen(8080);
var productCounter = redis.createClient();
productCounter.subscribe("productCounter");
productCounter.on("message", function(channel, message){
console.log("%s, the message : %s", channel, message);
io.sockets.emit(channel,message);
}
productCounter.on("unsubscribe", function(){
//I think to decrease counter here, Shold I? and How?
}
io.sockets.on('connection', function (socket) {
connected_socket++;
socket_id = socket.id;
console.log("["+socket_id+"] connected");
socket.on('disconnect', function (socket) {
connected_socket--;
console.log("Client disconnected");
productCounter.unsubscribe("productCounter");
});
})
非常感谢您的回答!