Spring-data-redis가 redis를 통합하는 방법

Spring-data-redis는 spring 제품군의 일부이며 srping 애플리케이션의 간단한 구성을 통해 redis 서비스에 대한 액세스를 제공하고 개발 패키지(Jedis, JRedis 및 RJC) 기반의 reid를 고도로 캡슐화합니다.

1. 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

3. Java 코드 작성

1. 캐시 인터페이스 정의

# 编辑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

3. applicationContext-cache-test.xml 파일을 구성합니다.

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);

}

4.

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<Object> 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<Object> serializer = getRedisSerializer();

                if (key == null) {
                    return null;
                }

                byte[] bytes = serializer.serialize(key);

                return connection.del(bytes);
            }
        });
    }

5. Test

<?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:p="http://www.springframework.org/schema/p" 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:redis-config.properties" ignore-unresolvable="true"/>

    <!-- jedis pool配置 -->
    <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <property name="maxTotal" value="${commons.cache.redis.maxTotal}" />
        <property name="maxIdle" value="${commons.cache.redis.maxIdle}" />
        <property name="maxWaitMillis" value="${commons.cache.redis.maxWait}" />
        <property name="testOnBorrow" value="${commons.cache.redis.testOnBorrow}" />
        <property name="testOnReturn" value="${commons.cache.redis.testOnReturn}" />
    </bean>

    <!-- spring data redis -->
    <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
        <property name="usePool" value="true"></property>
        <property name="hostName" value="${commons.cache.redis.host}" />
        <property name="port" value="${commons.cache.redis.port}" />
        <property name="password" value="${commons.cache.redis.password}" />
        <property name="timeout" value="${commons.cache.redis.timeout}" />
        <!--<property name="database" value="${commons.cache.redis.default.db}"></property>-->
        <property name="poolConfig" ref="jedisPoolConfig" />
    </bean>

    <bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
        <property name="connectionFactory" ref="jedisConnectionFactory" />
    </bean>
    
    <!-- 自定义缓存工厂接口 -->
    <bean id="cacheFactory" class="com.xxx.cache.factory.CacheFactory"  p:redisTemplate-ref="redisTemplate"/>
</beans>

더 많은 Redis 지식을 알고 싶다면 Redis 입문 튜토리얼

컬럼을 주목해주세요.

위 내용은 Spring-data-redis가 redis를 통합하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!