千家信息网

关于Spring-data-redis集成redis的方法介绍

发表于:2025-02-02 作者:千家信息网编辑
千家信息网最后更新 2025年02月02日,今天小编给大家分享的是关于Spring-data-redis集成redis的方法介绍,很多人都不太了解,今天小编为了让大家更加了解Spring-data-redis集成redis的方法,所以给大家总结
千家信息网最后更新 2025年02月02日关于Spring-data-redis集成redis的方法介绍

今天小编给大家分享的是关于Spring-data-redis集成redis的方法介绍,很多人都不太了解,今天小编为了让大家更加了解Spring-data-redis集成redis的方法,所以给大家总结了以下内容,一起往下看吧。一定会有所收获的哦。

Spring-data-redis是spring大家族的一部分,提供了在srping应用中通过简单的配置访问redis服务,对reids底层开发包(Jedis, JRedis, and RJC)进行了高度封装。

一、安装redis服务

1、下载安装redis服务,安装完成后会自动启动redis服务

sudo apt-get install redis-server

2、下载完成后,我们可以通过命令检查redis服务进程

ps -aux|grep redis

结果如下图所示:

3、也可以检查Redis服务的状态

netstat -nlt|grep 6379#结果如下:# tcp 0 0 127.0.0.1:6379 0.0.0.0:* LISTEN

4、通过命令检查redis服务状态

sudo /etc/init.d/redis-server status# 结果如下:redis-server is running

二、配置redis

# 编辑redis配置文件sudo vim /etc/redis/redis.conf# 在vim中设置redis访问密码requirepass 123456# 在vim中注释bind,设置允许远程访问,redis默认只允许本机访问#bind 127.0.0.1# 重启redis服务sudo /etc/init.d/redis-server restart# 客户端访问redis服务sudo redis-cli# 客户端登录并访问redis服务sudo redis-cli -a youpassword# 远程客户端登录并访问redis服务sudo redis-cli -a youpassword -h 192.168.1.22

三、编写java代码

1、cache接口定义

public interface Cache {    /**     * 添加     * @param key     * @param value     */    void put(Object key, Object value);        /**     * 得到key的值     * @param key     * @return     */    Object get(Object key);    /**     * 移除key     * @param key     * @return     */    Object remove(Object key);}

2、cache接口实现

import org.springframework.dao.DataAccessException;import org.springframework.data.redis.connection.RedisConnection;import org.springframework.data.redis.connection.RedisListCommands;import org.springframework.data.redis.connection.RedisStringCommands;import org.springframework.data.redis.connection.RedisZSetCommands;import org.springframework.data.redis.connection.jedis.JedisConverters;import org.springframework.data.redis.core.Cursor;import org.springframework.data.redis.core.RedisCallback;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.core.ScanOptions;import org.springframework.data.redis.core.types.Expiration;import org.springframework.data.redis.serializer.RedisSerializer;import redis.clients.jedis.Jedis;public class DefaultRedisCache implements Cache {    private final static Logger logger = LoggerFactory.getLogger(DefaultRedisCache.class);    private RedisTemplate redisTemplate;    //秒    private final static Long DEFAULT_EXPIRE = 12 * 60 * 60L;    public DefaultRedisCache(RedisTemplate redisTemplate) {        this.redisTemplate = redisTemplate;    }    @Override    public void put(final Object key, final Object value) {        put(key, value, DEFAULT_EXPIRE);    }    @Override    public Object get(final Object key) {        return redisTemplate.execute(new RedisCallback() {            @Override            public Object doInRedis(RedisConnection connection) throws DataAccessException {                RedisSerializer serializer = getRedisSerializer();                byte[] keyByte = serializer.serialize(key);                if(keyByte == null){                    return null;                }                byte[] bytes = connection.get(keyByte);                if (bytes == null) {                    return null;                }                return serializer.deserialize(bytes);            }        });    }    @Override    public Object remove(final Object key) {        return redisTemplate.execute(new RedisCallback() {            @Override            public Object doInRedis(RedisConnection connection) throws DataAccessException {                RedisSerializer serializer = getRedisSerializer();                if (key == null) {                    return null;                }                byte[] bytes = serializer.serialize(key);                return connection.del(bytes);            }        });    }

3、配置applicationContext-cache-test.xml文件

                                                                                                                                                        

4、配置redis-config.properties文件

# jedis pool配置commons.cache.redis.maxTotal=1000commons.cache.redis.maxIdle=600commons.cache.redis.maxWait=1000commons.cache.redis.testOnBorrow=truecommons.cache.redis.testOnReturn=true# spring data redis 配置commons.cache.redis.host=192.168.1.230commons.cache.redis.port=6379commons.cache.redis.password=123456commons.cache.redis.timeout=1000

5、测试

@ContextConfiguration(locations = {        "classpath:applicationContext-cache-test.xml"})@RunWith(SpringJUnit4ClassRunner.class)public class CacheTest extends BaseTest{    @Autowired    private Cache cache;    @Test    public void redisTest() {        // 添加key为username的值到redis缓存里        cache.put("username","nathan");        // 获取值        Object username = cache.get("username");        System.out.println("cache.get = " + username);        // 删除值//        cache.remove("username");//        Object delResult = cache.get("username");//        System.out.println("cache.remove = " + delResult);    }}

以上就是关于Spring-data-redis集成redis的方法介绍的详细内容了,看完之后是否有所收获呢?如果想了解更多相关内容,欢迎来行业资讯!

0