import java.util.ArrayList;import java.util.Set;import redis.clients.jedis.Jedis;public class Login { public String checkToken(Jedis conn,String token){  return conn.hget("login:", token); } public void updateToken(Jedis conn,String token,String user,String item){  long time=System.currentTimeMillis()/1000;  conn.hset("login:", token, user);//維持令牌與用戶之間的映射  conn.zadd("recent:", time, token);//保存令牌最后一次出現(xiàn)的時(shí)間  if(item!=null){   conn.zadd("viewd:"+token, time, item);//根據(jù)這個(gè)令牌來(lái)設(shè)置該用戶在這個(gè)時(shí)間戳訪問的商品名字   conn.zremrangeByRank("viewd:"+token, 0, -26);//移除就的用戶記錄，只保留用戶瀏覽過的25個(gè)商品。   conn.zincrby("viewd:", -1, item);  } } public class CleanSessionsThread extends Thread{  private Jedis conn;  private int limit;  private boolean quit;  public CleanSessionsThread(int limit) {   // TODO Auto-generated constructor stub   this.conn=new Jedis("localhost");   conn.select(15);   this.limit=limit;  }  public void quit(){   quit=true;  }  @Override  public void run() {   // TODO Auto-generated method stub   while(!quit){    long size=conn.zcard("recent:");//依據(jù)登錄時(shí)間確定在線人數(shù)    if(size<=limit){     try {      Thread.sleep(1000);     } catch (InterruptedException e) {      // TODO Auto-generated catch block      e.printStackTrace();     }    }else{     long endIndex=Math.min(size-limit,100);     Set<String> tokensSet=conn.zrange("recent:", 0, endIndex-1);     String[] tokens=tokensSet.toArray(new String[tokensSet.size()]);     ArrayList<String> sessionKeys=new ArrayList<>();     for(String token:tokens){      sessionKeys.add("viewd:"+token);     }     conn.del(sessionKeys.toArray(new String[sessionKeys.size()]));     conn.hdel("login:", tokens);     conn.zrem("recent:", tokens);    }   }  } }}