正文
Spring in action - 会话管理
提示：扫一扫查出行【扫一扫了解最新限行尾号】
复制提示
传统的会话管理是用一个session表保存会话信息，每次请求时读取、写入该表。
public function read($sessID) {
$hander = is_array($this->hander)?$this->hander[1]:$this->hander;
$res = mysql_query("SELECT data AS data FROM ".$this->sessionTable." WHERE sid = '$sessID' AND expire >".time(),$hander);
if($res) {
$row = mysql_fetch_assoc($res);
return $row['data'];
}
return "";
}
public function write($sessID,$sessData) {
$hander = is_array($this->hander)?$this->hander[0]:$this->hander;
$expire = time() + $this->lifeTime;
mysql_query("REPLACE INTO ".$this->sessionTable." ( sid, expire, data) VALUES( '$sessID', '$expire', '$sessData')",$hander);
if(mysql_affected_rows($hander))
return true;
return false;
}
session表的expire是一个时间戳，每次请求时更新。使用此栏位可以清理会话。
public function gc($sessMaxLifeTime) {
$hander = is_array($this->hander)?$this->hander[0]:$this->hander;
mysql_query("DELETE FROM ".$this->sessionTable." WHERE expire < ".time(),$hander);
return mysql_affected_rows($hander);
}
Redis的处理方式
首先看一个JAVA方法：
public void updateToken(Jedis conn, String token, String user, String item) {
long timestamp = System.currentTimeMillis() / 1000;
conn.hset("login:", token, user);
conn.zadd("recent:", timestamp, token);
if (item != null) {
conn.zadd("viewed:" + token, timestamp, item);
}
}
login是一个哈希表，它的目的是记录所有在线用户，等同session表的记录。
recent是一个有序集合，目的是记录会话的最新访问时间，类似session表的expire字段。使用这个集合，可以对长时间没有请求的会话做清理。
viewed也是一个有序集合，存放访问历史，与session表的data字段作用相同。
如果viewed集合不清理，随着用户浏览的商品越多，集合会不断的增大，必须做清理处理。这里的处理方式是保持viewed集合只有25笔，其它的都删除，按照浏览时间排序，保存最新的25笔。看看修改后的updateToken()方法：
public void updateToken(Jedis conn, String token, String user, String item) {
long timestamp = System.currentTimeMillis() / 1000;
conn.hset("login:", token, user);
conn.zadd("recent:", timestamp, token);
if (item != null) {
conn.zadd("viewed:" + token, timestamp, item);
conn.zremrangeByRank("viewed:" + token, 0, -26); //只保留最后25笔
}
}
随着时间的推移，会话越来越多，为了限制会话数量，我们决定只保留最新的1000万个会话。rencent集合记录了每个会话的最后访问时间，可以以此为清理条件。
public class CleanSessionsThread
extends Thread
{
private Jedis conn;
private int limit;
private boolean quit; public CleanSessionsThread(int limit) {
this.conn = new Jedis("localhost");
this.conn.select(15);
this.limit = limit;
} public void quit() {
quit = true;
} public void run() {
while (!quit) {
long size = conn.zcard("recent:");
if (size <= limit){
try {
sleep(1000);
}catch(InterruptedException ie){
Thread.currentThread().interrupt();
}
continue;
} // 每次最多清理100个会话
long endIndex = Math.min(size - limit, 100); // recent是按照访问时间从小到大排列的
Set<String> tokenSet = conn.zrange("recent:", 0, endIndex - 1); String[] tokens = tokenSet.toArray(new String[tokenSet.size()]); ArrayList<String> sessionKeys = new ArrayList<String>();
for (String token : tokens) {
sessionKeys.add("viewed:" + token);
} conn.del(sessionKeys.toArray(new String[sessionKeys.size()]));
conn.hdel("login:", tokens);
conn.zrem("recent:", tokens);
}
}
}
有时候我们会统计访问最多的商品，每次访问商品时做一个计数。使用有序集合的特性，将所有商品加入到有序集合，访问一次该商品将就该商品的权值-1，访问越多，权值就越小。有序集合会按照权值从小到大排序，访问最多的商品就会排在最前面。
public void updateToken(Jedis conn, String token, String user, String item) {
long timestamp = System.currentTimeMillis() / 1000;
conn.hset("login:", token, user);
conn.zadd("recent:", timestamp, token);
if (item != null) {
conn.zadd("viewed:" + token, timestamp, item);
conn.zremrangeByRank("viewed:" + token, 0, -26); //只保留最后25笔
conn.zincrby("viewed:", -1, item); // 商品访问有序集合，访问越多，权值越小，在集合中月靠前
}
}
同理，viewed集合也需要定时的清理，不然该集合会不断的增大，最后将把所有的商品都包含在里面。我们单独开一个进程来清理viewed集合。
public class CleanViewedThread
extends Thread
{
private Jedis conn;
private int limit;
private boolean quit; public CleanViewedThread(int limit) {
this.conn = new Jedis("localhost");
this.conn.select(15);
this.limit = limit;
} public void quit() {
quit = true;
} public void run() {
while (!quit) {
long size = conn.zcard("viewed:");
if (size <= limit){
try {
sleep(1000);
}catch(InterruptedException ie){
Thread.currentThread().interrupt();
}
continue;
} // 每次最多清理100笔
long endIndex = Math.min(limit + 100, size); Set<String> viewedSet = conn.zrange("viewed:", limit, endIndex - 1);
conn.zrem("viewed:", viewedSet.toArray(new String[viewedSet.size()]));
}
}
}
