Redis緩存Mysql模擬用戶登錄Java實現實例

這段時間在研究Redis，作為緩存界的新寵，現在使用它的公司越來越多。本文使用的是最新穩定版Redis3.0.實現的具體邏輯是：

    1. 用戶登錄首先判斷是否在redis緩存中，如果在redis緩存中，直接登錄成功；

    2. 若用戶未在redis緩存，則訪問Mysql，判斷用戶是否存在，如果不存在，則提示用戶注冊；如果存在，則登錄成功；

    3. 在mysql存在並登錄成功的同時，將改條數據用Redis Hash類型進行緩存，並設置過期時間為30分鍾；

    4. 設置redis最大內存，若超出內存范圍，則使用FIFO方式進行清除。

本文實現方式為最簡單的模擬方式，有的代碼有進一步封裝得必要。

 

一、首先創建兩個類，一個類連接Mysql，一個類連接Redis，並復寫相關方法

1.mysql

public class Mysql {

         public Connection conn;

         {

                 try {

                          Class.forName("com.mysql.jdbc.Driver");

                          conn=DriverManager.getConnection("jdbc:mysql://localhost/spring","root","root");

                 } catch (ClassNotFoundException e) {

                          e.printStackTrace();

                 } catch (SQLException e) {

                          e.printStackTrace();

                 }

         }

 

}

 

2.redis

public class Redis extends Jedis {

 

         public Jedis redis;

         {

                 redis = new Jedis("192.168.217.128", 6379);

                 redis.auth("root");

         }

 

         // public static void main(String[] args) {

         // System.out.println(redis.get("name"));

         // System.out.println(redis.keys("*"));

         // // redis.sinter(keys);

         // }

 

         public String get(String key) {

                 return redis.get("name");

         }

 

         public String set(String key, String value) {

                 return redis.set(key, value);

         }

 

         public Long del(String... keys) {

                 return redis.del(keys);

         }

 

         // 鍵值增加字符

         public Long append(String key, String str) {

                 return redis.append(key, str);

         }

 

         public Boolean exists(String key) {

                 return redis.exists(key);

         }

 

         // Need research

         public Long setnx(String key, String value) {

                 return redis.setnx(key, value);

         }

 

         public String setex(String key, String value, int seconds) {

                 return redis.setex(key, seconds, value);

         }

 

         public Long setrange(String key, String str, int offset) {

                 return redis.setrange(key, offset, str);

         }

 

         public List<String> mget(String... keys) {

                 return redis.mget(keys);

         }

 

         public String mset(String... keys) {

                 return redis.mset(keys);

         }

 

         public Long msetnx(String... keysvalues) {

                 return redis.msetnx(keysvalues);

         }

 

         public String getset(String key, String value) {

                 return redis.getSet(key, value);

         }

 

         public String hmset(String key, Map<String, String> hash) {

                 return redis.hmset(key, hash);

         }

 

         public Map<String, String> hgetall(String key) {

                 return redis.hgetAll(key);

         }

 

         public String hget(final String key, final String field) {

                 return redis.hget(key, field);

         }

 

         public Long hset(final String key, final String field, final String value) {

                 return redis.hset(key, field, value);

         }

 

         public Long expire(final String key, final int seconds) {

                 return redis.expire(key, seconds);

         }

 

         public Boolean hexists(final String key, final String field) {

                 return redis.hexists(key, field);

         }

 

}

 

3.二、邏輯具體實現：

public class Main {

         Mysql mysql=new Mysql();

         Redis redis=new Redis();

         ResultSet rs=null;

        

         //模擬登陸緩存

         @Test

         public void redisLogin() throws SQLException{

                 //正常業務的ID是通過UI的request.getParamenter()獲取

                 String id="9028935b527d22cc01527d235aea0142";

                 String sql="select * from user where id_='"+id+"'";

                 String username;

                 if(redis.hexists("user_"+id, "username_")){

                          username=redis.hget("user_"+id, "username_");

                          System.out.println("Welcome Redis! User "+username+" login success");

                 }else{

                          rs=mysql.conn.createStatement().executeQuery(sql);

                          if(rs.next()==false){

                                   System.out.println("Mysql no register, Please register first");

                          }else{

                                   username=rs.getString("username_");

                                   System.out.println("Welcome Mysql ! User "+username+" login success");

                                   redis.hset("user_"+id, "username_", username);

                                   //30分鍾未操作就過期

                                   redis.expire("user_"+id, 1800);

                          }

                 }

                

         }

}