Spring--集成jedis简单实例

今天药忘吃喽~ 2022-05-23 07:48 183阅读 0赞

jedis是redis的java客户端，spring将redis连接池作为一个bean配置。

redis连接池分为两种，一种是“redis.clients.jedis.ShardedJedisPool”，这是基于hash算法的一种分布式集群redis客户端连接池。

另一种是“redis.clients.jedis.JedisPool”，这是单机环境适用的redis连接池。

maven导入相关包：

<dependency>
          <groupId>redis.clients</groupId>
          <artifactId>jedis</artifactId>
          <version>2.9.0</version>
        </dependency>

ShardedJedisPool是redis集群客户端的对象池，可以通过他来操作ShardedJedis，下面是ShardedJedisPool的xml配置，spring-jedis.xml：

![复制代码][copycode.gif]

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:context="http://www.springframework.org/schema/context"
           xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans.xsd
           http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
    
        
        
        <context:property-placeholder location="classpath:properties/redis.properties" ignore-unresolvable="true" />
    
        
        <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
            
            <property name="maxTotal">
                <value>${redis.pool.maxActive}</value>
            </property>
            <property name="maxIdle">
                <value>${redis.pool.maxIdle}</value>
            </property>
            <property name="testOnBorrow" value="true"/>
            <property name="testOnReturn" value="true"/>
        </bean>
    
        <bean id="shardedJedisPool" class="redis.clients.jedis.ShardedJedisPool"  scope="singleton">
            <constructor-arg index="0" ref="jedisPoolConfig" />
            <constructor-arg index="1">
                <list>
                    <bean class="redis.clients.jedis.JedisShardInfo">
                        <constructor-arg name="host" value="${redis.uri}" />
                    </bean>
                </list>
            </constructor-arg>
        </bean>
    </beans>

![复制代码][copycode.gif]

下面是单机环境下redis连接池的配置：

![复制代码][copycode.gif]

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:context="http://www.springframework.org/schema/context"
           xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans.xsd
           http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
    
        
        
        <context:property-placeholder location="classpath:properties/redis.properties" ignore-unresolvable="true" />
    
        
        <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
            
            <property name="maxTotal">
                <value>${redis.pool.maxActive}</value>
            </property>
            <property name="maxIdle">
                <value>${redis.pool.maxIdle}</value>
            </property>
            <property name="testOnBorrow" value="true"/>
            <property name="testOnReturn" value="true"/>
        </bean>
    
        <bean id="jedisPool" class="redis.clients.jedis.JedisPool">
            <constructor-arg name="poolConfig" ref="jedisPoolConfig" />
            <constructor-arg name="host" value="${redis.host}" />
            <constructor-arg name="port" value="${redis.port}" type="int" />
            <constructor-arg name="timeout" value="${redis.timeout}" type="int" />
            <constructor-arg name="password" value="${redis.password}" />
            <constructor-arg name="database" value="${redis.database}" type="int" />
        </bean>
    </beans>

![复制代码][copycode.gif]

对应的classpath:properties/redis.properties.xml为：

![复制代码][copycode.gif]

#最大分配的对象数
    redis.pool.maxActive=200
    #最大能够保持idel状态的对象数
    redis.pool.maxIdle=50
    redis.pool.minIdle=10
    redis.pool.maxWaitMillis=20000
    #当池内没有返回对象时，最大等待时间
    redis.pool.maxWait=300
    
    #格式：redis://:[密码]@[服务器地址]:[端口]/[db index]
    redis.uri = redis://:12345@127.0.0.1:6379/0
    
    redis.host = 127.0.0.1
    redis.port = 6379
    redis.timeout=30000
    redis.password = 12345
    redis.database = 0

![复制代码][copycode.gif]

二者操作代码类似，都是先注入连接池，然后通过连接池获得jedis实例，通过实例对象操作redis。

ShardedJedis操作：

![复制代码][copycode.gif]

@Autowired
        private ShardedJedisPool shardedJedisPool;//注入ShardedJedisPool
    
        @RequestMapping(value = "/demo_set",method = RequestMethod.GET)
        @ResponseBody
        public String demo_set(){
            //获取ShardedJedis对象
            ShardedJedis shardJedis = shardedJedisPool.getResource();
            //存入键值对
            shardJedis.set("key1","hello jedis");
            //回收ShardedJedis实例
            shardJedis.close();
    
            return "set";
        }
    
        @RequestMapping(value = "/demo_get",method = RequestMethod.GET)
        @ResponseBody
        public String demo_get(){
            ShardedJedis shardedJedis = shardedJedisPool.getResource();
            //根据键值获得数据
            String result = shardedJedis.get("key1");
            shardedJedis.close();
    
            return result;
        }

![复制代码][copycode.gif]

Jedis操作：

![复制代码][copycode.gif]

@Autowired
        private JedisPool jedisPool;//注入JedisPool
    
        @RequestMapping(value = "/demo_set",method = RequestMethod.GET)
        @ResponseBody
        public String demo_set(){
            //获取ShardedJedis对象
            Jedis jedis = jedisPool.getResource();
            //存入键值对
            jedis.set("key2","hello jedis one");
            //回收ShardedJedis实例
            jedis.close();
    
            return "set";
        }
    
        @RequestMapping(value = "/demo_get",method = RequestMethod.GET)
        @ResponseBody
        public String demo_get(){
            Jedis jedis = jedisPool.getResource();
            //根据键值获得数据
            String result = jedis.get("key2");
            jedis.close();
    
            return result;
        }

[copycode.gif]: /images/20220523/540b611362cc4ce1b20f27c4ed3ddff7.png