首页 \ 教程 \ redis

redis教程

redis集群与主从配置

redis 基础教程

redis 数据类型

Redis 高级教程

知识点

Redis

redis整合spring示例二—java操作redis（存对象及List）

使用java操作redis入门示例

Httpclient整合Spring教程

RabbitMQ 与Spring整合

Spring boot整合mybatis plus

DWR与struts spring 整合问题

关于spring和hibernate的一个整合问题

MyBatis-Spring整合Spring Batch

spring boot 整合 ueditor 教程一

jBPM与Spring整合无法使用Hibernate的currentSession。

spring 3.0 和jpa 整合用jboss

spring整合activemq时候出现的一个问题，望好心人解答

MyBatis-Spring 示例代码

Spring Boot CLI 基于Thymeleaf的示例

Spring Boot上传文件示例

redis整合spring示例一

2019-03-12 22:05|来源: 网路

这里使用java操作redis的示例，也是领悟书生网站项目中使用的代码.当然本示例也是参考网上的相关文章做了相应的改动。

首先看看redis所依懒的maven包

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

spring的配置文件

<context:component-scan base-package="com._656463.redis" />
<context:property-placeholder location="classpath:redis.properties" ignore-unresolvable="true"/>
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
    <property name="maxTotal" value="50" />
     <property name="maxIdle" value="8" />
     <property name="maxWaitMillis" value="1000" />
     <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.host}" />
                <constructor-arg name="port" value="${redis.port}" />
                 <property name="password" value="${redis.pass}"/>
            </bean>
        </list>
    </constructor-arg>
</bean>

属性文件：

redis.host=121.40.80.59
redis.port=6379
redis.pass=dddddd
  
redis.pool.maxIdle=300
redis.pool.maxActive=600
redis.pool.maxWait=1000
redis.pool.testOnBorrow=true

数据源接口

package com._656463.redis;
  
import redis.clients.jedis.ShardedJedis;
  
public interface RedisDataSource {
  
    /**
     * 获取redis的客户端
     * 
     * @return
     */
    public abstract ShardedJedis getRedisClient();
  
    /**
     * 将资源返还给pool
     * 
     * @param shardedJedis
     */
    public void returnResource(ShardedJedis shardedJedis);
  
    /**
     * 出现异常后，将资源返还给pool （其实不需要第二个方法）
     * 
     * @param shardedJedis
     * @param broken
     */
    public void returnResource(ShardedJedis shardedJedis, boolean broken);
}

实现类

package com._656463.redis;
  
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
  
import redis.clients.jedis.ShardedJedis;
import redis.clients.jedis.ShardedJedisPool;
  
@Repository("redisDataSource")
public class RedisDataSourceImpl implements RedisDataSource {
  
    @Autowired
    private ShardedJedisPool shardedJedisPool;
  
    public ShardedJedis getRedisClient() {
        try {
            ShardedJedis shardJedis = shardedJedisPool.getResource();
            return shardJedis;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }
  
    public void returnResource(ShardedJedis shardedJedis) {
        shardedJedisPool.returnResource(shardedJedis);
    }
  
    public void returnResource(ShardedJedis shardedJedis, boolean broken) {
        if (broken) {
            shardedJedisPool.returnBrokenResource(shardedJedis);
        } else {
            shardedJedisPool.returnResource(shardedJedis);
        }
    }
}

redis连接模板类RedisClientTemplate

package com._656463.redis;
  
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
  
import redis.clients.jedis.ShardedJedis;
  
@Repository("redisClientTemplate")
public class RedisClientTemplate {
  
    @Autowired
    private RedisDataSource redisDataSource;
  
    public void disconnect() {
        ShardedJedis shardedJedis = redisDataSource.getRedisClient();
        shardedJedis.disconnect();
    }
      
    public void delKey(String key){
        ShardedJedis shardedJedis = redisDataSource.getRedisClient();
        boolean broken = false;
        try {
            if (shardedJedis != null) {
                shardedJedis.del(key);
            }
        } catch (Exception e) {
            e.printStackTrace();
            broken = true;
        } finally {
            redisDataSource.returnResource(shardedJedis, broken);
        }
    }
      
    public void delKey(byte[] key){
        ShardedJedis shardedJedis = redisDataSource.getRedisClient();
        boolean broken = false;
        try {
            if (shardedJedis != null) {
                shardedJedis.del(key);
            }
        } catch (Exception e) {
            e.printStackTrace();
            broken = true;
        } finally {
            redisDataSource.returnResource(shardedJedis, broken);
        }
    }
      
    public void setExpire(String key,int seconds){
        ShardedJedis shardedJedis = redisDataSource.getRedisClient();
        boolean broken = false;
        try {
            if (shardedJedis != null) {
                shardedJedis.expire(key, seconds);
            }
        } catch (Exception e) {
            e.printStackTrace();
            broken = true;
        } finally {
            redisDataSource.returnResource(shardedJedis, broken);
        }
    }
      
    public void setExpire(byte[] key,int seconds){
        ShardedJedis shardedJedis = redisDataSource.getRedisClient();
        boolean broken = false;
        try {
            if (shardedJedis != null) {
                shardedJedis.expire(key, seconds);
            }
        } catch (Exception e) {
            e.printStackTrace();
            broken = true;
        } finally {
            redisDataSource.returnResource(shardedJedis, broken);
        }
    }
  
    /**
     * 设置单个值
     * 
     * @param key
     * @param value
     * @return
     */
    public String set(String key, String value) {
        String result = null;
  
        ShardedJedis shardedJedis = redisDataSource.getRedisClient();
        if (shardedJedis == null) {
            return result;
        }
        boolean broken = false;
        try {
            result = shardedJedis.set(key, value);
        } catch (Exception e) {
            e.printStackTrace();
            broken = true;
        } finally {
            redisDataSource.returnResource(shardedJedis, broken);
        }
        return result;
    }
  
    /**
     * 获取单个值
     * 
     * @param key
     * @return
     */
    public String get(String key) {
        String result = null;
        ShardedJedis shardedJedis = redisDataSource.getRedisClient();
        if (shardedJedis == null) {
            return result;
        }
  
        boolean broken = false;
        try {
            result = shardedJedis.get(key);
  
        } catch (Exception e) {
            e.printStackTrace();
            broken = true;
        } finally {
            redisDataSource.returnResource(shardedJedis, broken);
        }
        return result;
    }
  
    /**
     * 存储byte对象
     * 
     * @param key
     * @param value
     */
    public void set(byte[] key, byte[] value) {
  
        ShardedJedis shardedJedis = redisDataSource.getRedisClient();
        if (shardedJedis == null) {
            return;
        }
        boolean broken = false;
        try {
            shardedJedis.set(key, value);
        } catch (Exception e) {
            e.printStackTrace();
            broken = true;
        } finally {
            redisDataSource.returnResource(shardedJedis, broken);
        }
    }
  
    /**
     * 获取byte[]对象
     * 
     * @param key
     * @return
     */
    public byte[] get(byte[] key) {
        ShardedJedis shardedJedis = redisDataSource.getRedisClient();
        if (shardedJedis == null) {
            return null;
        }
  
        boolean broken = false;
        try {
            return shardedJedis.get(key);
        } catch (Exception e) {
            e.printStackTrace();
            broken = true;
        } finally {
            redisDataSource.returnResource(shardedJedis, broken);
        }
        return null;
    }
}

先到这，下篇继续