Redis学习笔记——SpringDataRedis的使用

女爷i 2023-10-01 07:52 3阅读 0赞

### 与Spring集成 ###

> 我需要哪些jar包？

<dependency>
    	<groupId>org.springframework.data</groupId>
        <artifactId>spring-data-redis</artifactId>
    </dependency>
    <dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
    </dependency>

> 如何配置spring配置文件？

<?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"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
        
        <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory" p:hostName="127.0.0.1" p:port="6379" p:usePool="true"/>
        
        <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate" p:connectionFactory-ref="jedisConnectionFactory"/>
        
        <bean id="stringRedisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate" p:connectionFactory-ref="jedisConnectionFactory"/>
    </beans>

一般情况，只需要配置RedisTemplate或StringRedisTemplate其中一个就行，常用的为StringRedisTemplate。

> RedisTemplate与StringRedisTemplate的区别？

StringRedisTemplate：

public class StringRedisTemplate extends RedisTemplate<String, String> {
        
        public StringRedisTemplate() {
        
            StringRedisSerializer stringSerializer = new StringRedisSerializer();
            this.setKeySerializer(stringSerializer);
            this.setValueSerializer(stringSerializer);
            this.setHashKeySerializer(stringSerializer);
            this.setHashValueSerializer(stringSerializer);
        }
    
        public StringRedisTemplate(RedisConnectionFactory connectionFactory) {
        
            this();
            this.setConnectionFactory(connectionFactory);
            this.afterPropertiesSet();
        }
    
        protected RedisConnection preProcessConnection(RedisConnection connection, boolean existingConnection) {
        
            return new DefaultStringRedisConnection(connection);
        }
    }

从上面的代码可以看出，StringRedisTemplate继承了键值类型都为String的RedisTemplate，且使用StringRedisSerializer作为序列化工具。所以StringRedisTemplate能使用的方法，RedisTemplate都能使用，下面的例子只会展示StringRedisTemplate的方法。

StringRedisSerializer：

public class StringRedisSerializer implements RedisSerializer<String> {
        
        private final Charset charset;
    
        public StringRedisSerializer() {
        
            this(Charset.forName("UTF8"));
        }
    
        public StringRedisSerializer(Charset charset) {
        
            Assert.notNull(charset);
            this.charset = charset;
        }
    
        public String deserialize(byte[] bytes) {
        
            return bytes == null?null:new String(bytes, this.charset);
        }
    
        public byte[] serialize(String string) {
        
            return string == null?null:string.getBytes(this.charset);
        }
    }

可以看出，StringRedisSerializer使用UTF8字符集处理字符串。

### 使用API操作基本redis基本数据类型 ###

--------------------

> spring提供哪些接口操作redis基本数据？

**第一组**

ValueOperations：字符串类型操作
    ListOperations：列表类型操作
    SetOperations：集合类型操作
    ZSetOperations：有序集合类型操作
    HashOperations：散列操作

**第二组**

BoundValueOperations：字符串类型操作
    BoundListOperations：列表类型操作
    BoundSetOperations：集合类型操作
    BoundZSetOperations：有序集合类型操作
    BoundHashOperations：散列操作

> 如何获得接口的实现？

**第一组**

ValueOperations<String, String> valueOperations = stringRedisTemplate.opsForValue();
    ListOperations<String, String> listOperations = stringRedisTemplate.opsForList();
    SetOperations<String, String> setOperations = stringRedisTemplate.opsForSet();
    ZSetOperations<String, String> zSetOperations = stringRedisTemplate.opsForZSet();
    HashOperations<String, Object, Object> hashOperations = stringRedisTemplate.opsForHash();

**第二组**

BoundValueOperations<String, String> valueOperations = stringRedisTemplate.boundValueOps("key");
    BoundListOperations<String, String> listOperations = stringRedisTemplate.boundListOps("key");
    BoundSetOperations<String, String> setOperations = stringRedisTemplate.boundSetOps("key");
    BoundZSetOperations<String, String> zSetOperations = stringRedisTemplate.boundZSetOps("key");
    BoundHashOperations<String, Object, Object> hashOperations = stringRedisTemplate.boundHashOps("key");

从上面两组实现可以发现，第二组API只是在第一组API的上面将key值的绑定放在获得接口时了，此举方便了每次操作基本数据类型的时候不用反复的去填写key值，只需要操作具体的value就行了。

具体有哪些数据操作方式，如ValueOperations的get与set，ListOperations的push与pop等可以参照：[Redis学习笔记（2）-Redis数据类型][Redis_2_-Redis]。他们的方法签名与客户端redis-cli操作redis时的签名是一样的。

### 使用API操作消息队列 ###

--------------------

> 使用API前需要了解

[Redis学习笔记（3）-Redis事务，过期时间，队列][Redis_3_-Redis]

> 如何发送消息队列？

RedisTemplate template = template.convertAndSend("channel", "message");

第一个参数为发送的消息的频道，第二个参数为消息本身。

> 如何接受队列中的消息？

public interface MessageDelegate {
        
      void handleMessage(String message);
      void handleMessage(Map message); void handleMessage(byte[] message);
      void handleMessage(Serializable message);
      void handleMessage(Serializable message, String channel);
    }

首先，需要一个符合MessageDelegate 接口方法签名的类，这个类是自定义的，可以使用MessageDelegate 中的一个或多个签名方式，如：

public class UserMessageDelegate {
        
        public void handleMessage(String message) {
        
            System.out.println(message);
        }
    }

得到此类后，将此类注册到消息监听容器中：

<?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:redis="http://www.springframework.org/schema/redis"
           xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans.xsd
           http://www.springframework.org/schema/redis
           http://www.springframework.org/schema/redis/spring-redis.xsd">
           
        <redis:listener-container>
            <redis:listener ref="listener" method="handleMessage" topic="chatroom"/>
        </redis:listener-container>
        
        <bean id="listener" class="com.hzw.redis.listener.UserMessageDelegate"/>
        
    </beans>

其中，topic就是你要监听的频道。

[Redis_2_-Redis]: http://blog.csdn.net/qq_29994609/article/details/51708104
[Redis_3_-Redis]: http://blog.csdn.net/qq_29994609/article/details/51708666