Redis 集群 Java Demo

桃扇骨 2022-05-22 05:27 163阅读 0赞

既然学习了Redis，最好的方式就是自己尝试写一个购物车，将redis与数据库联系在一起，通过项目巩固知识。

具体源代码见个人的Github：https://github.com/wzcwzcwzc/redis-java

这里列举了一些jedis配置集群端口以及核心的功能代码。

此处在本机配置了集群的端口，将这些端口放入java的集合内，这样便于操作。

public Set<HostAndPort> PoolInitial() {
    	    
    	    Set<HostAndPort> nodes = new LinkedHashSet<HostAndPort>();
    	    
    	    nodes.add(new HostAndPort("127.0.0.1", 7000));
    
    	    nodes.add(new HostAndPort("127.0.0.1", 7001));
    
    	    nodes.add(new HostAndPort("127.0.0.1", 7002));
    
    	    nodes.add(new HostAndPort("127.0.0.1", 7003));
    
    	    nodes.add(new HostAndPort("127.0.0.1", 7004));
    
    	    nodes.add(new HostAndPort("127.0.0.1", 7005));
    	    
    	    return nodes;
        }

接下来就是展示一下利用redis与数据库对用户的信息进行简单的认证。

package cn.auth;
    
    import java.io.IOException;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    
    import redis.clients.jedis.JedisCluster;
    import redis.clients.jedis.JedisPoolConfig;
    
    public class Login {
    
         DBConnect c = new DBConnect();
         Redis redis = new Redis();		
         ResultSet rs = null;
         JedisPoolConfig poolConfig = new JedisPoolConfig();
    
         /*模拟登陆缓存, 若在缓存内部发现数据则直接读取缓存，若没有则进入数据库进行查询操作，
          * 如果数据库内部依旧没有数据，则信息输入有误或者用户未进行注册
          */
         public synchronized void clusterLogin(String userid, String username, String pass) 
            throws SQLException {
               
             poolConfig.setMaxTotal(8);
     	   poolConfig.setMaxIdle(8);
     	   poolConfig.setMaxWaitMillis(1000);
    
     	   JedisCluster cluster = new JedisCluster(redis.PoolInitial(), poolConfig);
    
     	   String id = userid;
               String sql = "select * from \"user\" where id=\'"+ id +"'";
    
               if(cluster.hexists("user_"+id, "username_") && 
                       pass.equals(cluster.hget("user_"+id, "userpass_"))){
                        username = cluster.hget("user_"+id, "username_");
                      pass = cluster.hget("user_"+id, "userpass_");
                        System.out.println("RedisCluster! " + username + " login success");
               }else{
                        rs = c.conn.createStatement().executeQuery(sql);
                    if(rs.next() == false) {
                             System.out.println("Cluster information wrong!");
    //                         跳转至登陆界面
    //                         register();
                    }else{
                        if(username.equals(rs.getString("name")) && 
                                pass.equals(rs.getString("password"))){
                     	   
                               username = rs.getString("name");
                               pass = rs.getString("password");
    
                     	   System.out.println("postgresql! " + username + " login success");
    
                               cluster.hset("user_"+id, "username_", username);
                               cluster.hset("user_"+id, "userpass_", pass);
    
                               //30分钟未操作就过期
                               cluster.expire("user_"+id, 1800);      
                        }
                        else {
                     	   System.out.println("information in cluster wrong !!!");
                        }
                    }
           	}
    
           try{
        	   cluster.close();
           }catch(IOException e) {
        	   e.printStackTrace();
           }
    
         }
    }

至于数据库的驱动连接过程可以参考我之前写的连接数据库代码，在工程内直接调用即可。