当前位置：首页 > news >正文

用jedis获取redis连接(集群和非集群状态下)

news 来源：原创 2024/5/7 17:44:56

第一：非集群状态下

非集群状态下用Jedis获取redis连接，得到Jedis对象即可，一共有两种：

1.利用Jedis构造器，仅限用于测试，在实际项目中肯定是用JedisPool。

Jedis(String host);

Jedis(String host , int port);

2.利用JedisPool

主要是利用Jedis jedis=jedisPool.getResource();

JedisPool有N多个构造器，常用的构造器参数有GenericObjectPoolConfig poolConfig，String host，int port，int timeout，String password，创建GenericObjectPoolConfig对象时我们一般用其子类JedisPoolConfig (redis.clients.jedis.JedisPoolConfig)，timeout是连接redis服务器的超时时间，以毫秒为单位，一般设置为0，如果不设为0，则不可设置太小，如果设成1、2，那么可能因为网络原因在1毫秒、2毫秒之内没有连上服务器而报错。见下例：

public static void main(String[] args) {
    JedisPoolConfig poolConfig = new JedisPoolConfig();
    // 最大连接数
    poolConfig.setMaxTotal(2);
    // 最大空闲数
    poolConfig.setMaxIdle(2);
    // 最大允许等待时间，如果超过这个时间还未获取到连接，则会报JedisException异常：
    // Could not get a resource from the pool
    poolConfig.setMaxWaitMillis(1000);
    JedisPool pool = new JedisPool(poolConfig, "192.168.83.128", 6379, 0, "123");
    Jedis jedis = null;
    try {
        for (int i = 0; i < 5; i++) {
            jedis = pool.getResource();
            jedis.set("foo" + i, "bar" + i);
            System.out.println("第" + (i + 1) + "个连接, 得到的值为" + jedis.get("foo" + i));
            // 用完一定要释放连接
            jedis.close();
        }
    } finally {
        pool.close();
    }
}

如上，创建出一个JedisPool对象，然后调用其getResource()方法获取redis连接即可，之后就可以调用Jedis API操作redis了。jedis连接用完要释放即close，如果不close，则产生的连接会越来越多，当达到了最大连接数，再想获得连接，就会等待，当超过了最大等待时间后就会报异常。

如果用了spring框架，则可以用spring管理redis连接池，在spring配置文件中配置如下：

<!-- 属性注入 -->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
    <property name="maxIdle" value="300" /> <!--最大能够保持idel状态的对象数 -->
    <property name="maxTotal" value="60000" /><!--最大分配的对象数 -->
    <property name="testOnBorrow" value="true" /><!--当调用borrow Oject方法时，是否进行有效性检查 -->
</bean>
<!-- 构造注入 -->
<bean id="jedisPool" class="redis.clients.jedis.JedisPool">
    <constructor-arg name="poolConfig" ref="jedisPoolConfig" />
    <constructor-arg name="host" value="192.168.220.128" />
    <constructor-arg name="port" value="6379" type="int" />
    <constructor-arg name="timeout" value="10000" type="int" />
    <constructor-arg name="password" value="123" />
</bean>