使用Java连接Redis进行操作

朴灿烈づ我的快乐病毒、 2023-01-11 09:25 186阅读 0赞

# 使用Java连接Redis进行操作 #

## 一、pom依赖 ##

<dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
        <version>2.9.0</version>
    </dependency>
    
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-pool2</artifactId>
        <version>2.8.0</version>
    </dependency

## 二、使用池化技术连接Redis（高并发情况下） ##

package com.redis;
    
    import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    
    public class JedisPoolExercise { 
    
        public static void main(String[] args) { 
    
            //JedisPool: 保存jedis连接的连接池
    
            //连接池通用的一些设置
            GenericObjectPoolConfig poolconf = new GenericObjectPoolConfig();
            //设置连接池的属性
            //设置连接池最多创建200个jedis连接
            poolconf.setMaxTotal(200);
            //设置池中最多保留30个空闲的jedis连接
            poolconf.setMinIdle(30);
            //当池中没有多余的连接时，客户端最多等多久
            poolconf.setMaxWaitMillis(30000);
            //当连接用完时，是否阻塞客户端直到超时。false代表连接耗尽，直接给客户端抛异常
            poolconf.setBlockWhenExhausted(true);
            //从池中借一个连接时，先测试一下连接是否正常
            poolconf.setTestOnBorrow(true);
    
            //创建一个连接池
            JedisPool jedispool = new JedisPool(poolconf, "hadoop102", 6379, 60000);
    
            //从池中获取一个连接
            Jedis jedis = jedispool.getResource();
    
            //使用
            System.out.println(jedis.ping());
    
            //将连接放回连接池
            jedis.close();
    
        }
    }

## 三、连接有哨兵模式的Redis集群 ##

package com.redis;
    
    import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPoolConfig;
    import redis.clients.jedis.JedisSentinelPool;
    
    import java.util.HashSet;
    import java.util.Set;
    
    public class JedisSentinePoll { 
    
        public static void main(String[] args) { 
    
            //连接池通用的一些设置
            GenericObjectPoolConfig poolconf = new JedisPoolConfig();
            //设置连接池的属性
            //设置连接池最多创建200个jedis连接
            poolconf.setMaxTotal(200);
            //设置池中最多保留30个空闲的jedis连接
            poolconf.setMinIdle(30);
            //当池中没有多余的连接时，客户端最多等多久
            poolconf.setMaxWaitMillis(30000);
            //当连接用完时，是否阻塞客户端直到超时。false代表连接耗尽，直接给客户端抛异常
            poolconf.setBlockWhenExhausted(true);
            //从池中借一个连接时，先测试一下连接是否正常
            poolconf.setTestOnBorrow(true);
    
    
    
            //保存哨兵信息
            Set<String> sentinels = new HashSet<String>();
            //添加哨兵的信息
            sentinels.add("hadoop102:26379");
    
            JedisSentinelPool mymast = new JedisSentinelPool("mymast", sentinels, poolconf);
    
            Jedis jedis = mymast.getResource();
    
            jedis.set("session","jedis");
    
            System.out.println(jedis.get("session"));
    
            jedis.close();
        }
    }

## 四、连接Redis集群 ##

package com.redis;
    
    import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
    import redis.clients.jedis.HostAndPort;
    import redis.clients.jedis.JedisCluster;
    import redis.clients.jedis.JedisPoolConfig;
    
    import java.io.IOException;
    import java.util.HashSet;
    import java.util.Set;
    
    public class JedisClusterExercise { 
    
        public static void main(String[] args) throws IOException { 
    
            //连接池通用的一些设置
            GenericObjectPoolConfig poolconf = new JedisPoolConfig();
            //设置连接池的属性
            //设置连接池最多创建200个jedis连接
            poolconf.setMaxTotal(200);
            //设置池中最多保留30个空闲的jedis连接
            poolconf.setMinIdle(30);
            //当池中没有多余的连接时，客户端最多等多久
            poolconf.setMaxWaitMillis(30000);
            //当连接用完时，是否阻塞客户端直到超时。false代表连接耗尽，直接给客户端抛异常
            poolconf.setBlockWhenExhausted(true);
            //从池中借一个连接时，先测试一下连接是否正常
            poolconf.setTestOnBorrow(true);
    
    
            Set<HostAndPort> nodes = new HashSet<HostAndPort>();
            nodes.add(new HostAndPort("hadoop102",6379));
            nodes.add(new HostAndPort("hadoop102",6380));
            nodes.add(new HostAndPort("hadoop102",6381));
    
            //JedisCluster 代表从集群中获取一个连接，可以直接使用jedisCluster调用API
            JedisCluster jedisCluster = new JedisCluster(nodes, 60000, poolconf);
    
            jedisCluster.mset("{a}a1","a1","{a}a2","a2","{a}a3","a3");
    
            System.out.println(jedisCluster.mget("{a}a1", "{a}a2", "{a}a3"));
    
            jedisCluster.close();
        }
    }