`
357029540
  • 浏览: 735860 次
  • 性别: Icon_minigender_1
  • 来自: 重庆
社区版块
存档分类
最新评论

RedisTemplate常用集合使用说明(一)

RedisTemplateSpringBootexecpipeline 
阅读更多

   在这里我使用的是spring-boot框架组合的redisTemplate的jar包spring-boot-starter-data-redis，采用POM的方式引入，引入代码如下:

 

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.6.RELEASE</version>
</parent>

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-configuration-processor</artifactId>
        <optional>true</optional>
    </dependency>
</dependencies>

  RedisTemplate主要支持String，List,Hash,Set,ZSet这几种方式的参数，其对应的方法分别是opsForValue()、opsForList()、opsForHash()、opsForSet()、opsForZSet()。下面分别介绍这几个方法的使用。

 

  在介绍之前，首先说下RedisTemplate的序列化方法，在RedisTemplate类下有一个继承了该类的StringRedisTemplate类，该类主要用于opsForValue()方法的String类型的实现，而且这2个类的内部实现不一样，如果是使用RedisTemplate类作为连接Redis的工具类，如果不使用opsForValue方法的话，我们可以这样初始化序列化方法:

 

ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
template.setKeySerializer(template.getStringSerializer());
template.setValueSerializer(jackson2JsonRedisSerializer);
template.setHashValueSerializer(jackson2JsonRedisSerializer);

 如果需要使用opsForValue()方法的话，我们就必须使用如下的序列化方法:

 

 

ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om); 
//在使用String的数据结构的时候使用这个来更改序列化方式
RedisSerializer<String> stringSerializer = new StringRedisSerializer();
template.setKeySerializer(stringSerializer );
template.setValueSerializer(stringSerializer );
template.setHashKeySerializer(stringSerializer );
template.setHashValueSerializer(stringSerializer );

   当然如果想使用RedisTemplate方法作为bean来使用，必须按照如下的方式实现代码(这里介绍的都是通过使用spring-boot方式进行使用)：

1.  我们可以在application.properties文件定义如下的redis连接:

 

	#配置缓存redis
spring.redis.database=8
# Redis服务器地址
spring.redis.host=127.0.0.1
# Redis服务器连接端口
spring.redis.port=6379
# Redis服务器连接密码（默认为空）
spring.redis.password=
# 连接池最大连接数（使用负值表示没有限制）
spring.redis.pool.max-active=8
# 连接池最大阻塞等待时间（使用负值表示没有限制）
spring.redis.pool.max-wait=-1
# 连接池中的最大空闲连接
spring.redis.pool.max-idle=8
# 连接池中的最小空闲连接
spring.redis.pool.min-idle=0
# 连接超时时间（毫秒）
spring.redis.keytimeout=1000
spring.redis.timeout=0

2. 使用RedisTemplate类来设置bean文件：

 

 

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import redis.clients.jedis.JedisPoolConfig;

/**
 * @author liaoyubo
 * @version 1.0 2017/8/1
 * @description
 */
@Configuration
public class RedisConfig {

    @Value("${spring.redis.host}")
    private String hostName;
    @Value("${spring.redis.port}")
    private int port;
    @Value("${spring.redis.password}")
    private String passWord;
    @Value("${spring.redis.pool.max-idle}")
    private int maxIdl;
    @Value("${spring.redis.pool.min-idle}")
    private int minIdl;
    @Value("${spring.redis.database}")
    private int database;
    @Value("${spring.redis.keytimeout}")
    private long keytimeout;
    @Value("${spring.redis.timeout}")
    private int timeout;

    /*@Bean
    public JedisConnectionFactory redisConnectionFactory() {
        JedisConnectionFactory factory = new JedisConnectionFactory();
        factory.setHostName(hostName);
        factory.setPort(port);
        factory.setTimeout(timeout); //设置连接超时时间
        return factory;
    }

    @Bean
    public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {
        StringRedisTemplate template = new StringRedisTemplate(factory);
        setSerializer(template); //设置序列化工具，这样ReportBean不需要实现Serializable接口
        template.afterPropertiesSet();
        return template;
    }
    private void setSerializer(StringRedisTemplate template) {
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        template.setValueSerializer(jackson2JsonRedisSerializer);
    }*/

    @Bean
    public RedisConnectionFactory redisConnectionFactory(){
        JedisPoolConfig poolConfig=new JedisPoolConfig();
        poolConfig.setMaxIdle(maxIdl);
        poolConfig.setMinIdle(minIdl);
        poolConfig.setTestOnBorrow(true);
        poolConfig.setTestOnReturn(true);
        poolConfig.setTestWhileIdle(true);
        poolConfig.setNumTestsPerEvictionRun(10);
        poolConfig.setTimeBetweenEvictionRunsMillis(60000);
        JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(poolConfig);
        jedisConnectionFactory.setHostName(hostName);
        if(!passWord.isEmpty()){
            jedisConnectionFactory.setPassword(passWord);
        }
        jedisConnectionFactory.setPort(port);
        jedisConnectionFactory.setDatabase(database);
        return jedisConnectionFactory;
    }
    @Bean
    public RedisTemplate<String, Object> redisTemplateObject() throws Exception {
        RedisTemplate<String, Object> redisTemplateObject = new RedisTemplate<String, Object>();
        redisTemplateObject.setConnectionFactory(redisConnectionFactory());
        setSerializer(redisTemplateObject);
        redisTemplateObject.afterPropertiesSet();
        return redisTemplateObject;
    }



    private void setSerializer(RedisTemplate<String, Object> template) {
        Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>(
                Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        /*template.setKeySerializer(template.getStringSerializer());
        template.setValueSerializer(jackson2JsonRedisSerializer);
        template.setHashValueSerializer(jackson2JsonRedisSerializer);*/
        //在使用String的数据结构的时候使用这个来更改序列化方式
        RedisSerializer<String> stringSerializer = new StringRedisSerializer();
        template.setKeySerializer(stringSerializer );
        template.setValueSerializer(stringSerializer );
        template.setHashKeySerializer(stringSerializer );
        template.setHashValueSerializer(stringSerializer );

    }

}

 3.  创建启动类App类

 

 

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * @author liaoyubo
 * @version 1.0 2017/7/31
 * @description
 */
@SpringBootApplication
public class App {

    public static void main(String [] args){
        SpringApplication.run(App.class);
    }

}

  通过以上步骤我们就可以以bean的注入方式正常使用RedisTemplate模板类了,如果没有安装Redis，请到https://redis.io/download官网下载需要的Redis。下面依次主要介绍RedisTemplate集合以及pipeline、multi的使用，官网地址是http://docs.spring.io/spring-data/redis/docs/current/api/org/springframework/data/redis/core/RedisTemplate.html。注入RedisTemplate方法如下:

 

 

 

@Autowired
private RedisTemplate<String,Object> redisTemplate;

 一、pipeline介绍

 

      Pipeline是redis提供的一种通道功能，通常使用pipeline的地方是不需要等待结果立即返回的时候，使用pipeline的好处是处理数据的速度更快因为它专门开辟了一个管道来处理数据(具体的对比可以参考网上的文章)，它是单向的，从客户端向服务端发送数据，当管道关闭链接时将会从服务端返回数据，再次期间是无法获取到服务端的数据的。

   因为这个例子的需要，我们把RedisConfig.java类的序列化的方式修改为：

 

template.setKeySerializer(template.getStringSerializer());
template.setValueSerializer(jackson2JsonRedisSerializer);
template.setHashValueSerializer(jackson2JsonRedisSerializer);

 下面是一个基本的使用示例：

import com.springRedis.App;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.test.context.junit4.SpringRunner;


/**
 * @author liaoyubo
 * @version 1.0 2017/7/31
 * @description
 */

@RunWith(SpringRunner.class)
@SpringBootTest(classes = App.class)
public class PipelineTest {

    @Autowired
    private RedisTemplate<String,Object> redisTemplate;

    @Test
    public void testPipeLine(){
        redisTemplate.opsForValue().set("a",1);
        redisTemplate.opsForValue().set("b",2);
        redisTemplate.executePipelined(new RedisCallback<Object>() {
            @Override
            public Object doInRedis(RedisConnection redisConnection) throws DataAccessException {
                redisConnection.openPipeline();
                for (int i = 0;i < 10;i++){
                    redisConnection.incr("a".getBytes());
                }
                System.out.println("a:"+redisTemplate.opsForValue().get("a"));
                redisTemplate.opsForValue().set("c",3);
                for(int j = 0;j < 20;j++){
                    redisConnection.incr("b".getBytes());
                }
                System.out.println("b:"+redisTemplate.opsForValue().get("b"));
                System.out.println("c:"+redisTemplate.opsForValue().get("c"));
                redisConnection.closePipeline();
                return null;
            }
        });
        System.out.println("b:"+redisTemplate.opsForValue().get("b"));
        System.out.println("a:"+redisTemplate.opsForValue().get("a"));
    }

}

 二、multi与exec

 

   这2个方法是RedisTemplate.java类提供的事务方法。在使用这个方法之前必须开启事务才能正常使用。例子如下：

 

import com.springRedis.App;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.List;

/**
 * @author liaoyubo
 * @version 1.0 2017/8/4
 * @description
 */
@RunWith(SpringRunner.class)
@SpringBootTest(classes = App.class)
public class MultiTest {

    @Autowired
    private RedisTemplate<String,Object> redisTemplate;

    @Test
    public void testMulti(){
        ValueOperations<String,Object> valueOperations = redisTemplate.opsForValue();
        redisTemplate.setEnableTransactionSupport(true);
        //在未提交之前是获取不到值得，同时再次循环报错
        while (true){
            redisTemplate.watch("multiTest");
            redisTemplate.multi();
            valueOperations.set("multiTest",1);
            valueOperations.increment("multiTest",2);
            Object o = valueOperations.get("multiTest");
            List list = redisTemplate.exec();
            System.out.println(list);
            System.out.println(o);
        }

    }

}

           在使用exec()方法的时候，没有带入参数，使用的是默认的序列化方法，同时提供了一个exec(RedisSerializer<?> valueSerializer)方法，这个方法可以自己定义序列化方法，如Jackson2JsonRedisSerializer。

       后面将一次介绍RedisTemplate集合的使用。

 

 

 

 

 

 

 

2
顶
0
踩
分享到：
| 在kafka单服务器的情况下消费者端如何确定 ...
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    RedisTemplate常用集合使用说明-opsForZSet(六)

    这篇博客"RedisTemplate常用集合使用说明-opsForZSet(六)"可能详细介绍了如何使用RedisTemplate操作有序集合。 首先，有序集合的操作主要包括添加元素、删除元素、获取范围、更新分数等。RedisTemplate的opsForZSet...

    RedisTemplate 的基本使用手把手教源码

    RedisTemplate 的基本使用手把手教源码

    redistemplate

    标题中的"redistemplate"可能指的是一个基于Redis的模板或者框架，它简化了在应用程序中使用Redis客户端的操作。Redis是一个高性能的键值数据库，常用于数据缓存、消息队列和分布式计算等领域。这个模板可能提供了...

    redisTemplate封装成redisUtils和分布式锁实现

    RedisTemplate是Spring Data Redis模块中的一个核心组件，用于在Java应用中操作Redis数据库。它提供了一种面向对象的方式来执行各种Redis命令，简化了与Redis的数据交互。本篇将深入探讨如何将RedisTemplate封装成...

    RedisTemplate-JDBCTemplate.zip

    在Java开发中，Spring框架是不可或缺的一部分，它提供了一种高效且灵活的方式来管理应用程序的组件。...在学习和使用过程中，深入理解它们的内部原理和使用方法，对于提升作为一名Java开发者的技能水平至关重要。

    通过RedisTemplate连接多个Redis过程解析

    在这里，我们使用了一个本地的Redis数据库和一个远程的Redis数据库，假设了IP地址不同，其他的配置都相同。 接下来，我们需要添加RedisTemplate的Bean，使用import语句导入相关的类，例如...

    Redis之RedisTemplate使用（RedisTemplate工具类）

    Redis之RedisTemplate使用（RedisTemplate工具类） String类型相关操作 List类型相关操作 Set类型相关操作 Map类型相关操作 ZSet类型相关操作

    RedisTemplate具体操作

    RedisTemplate是Spring Data Redis模块中的一个核心组件，用于在Java应用程序中方便地操作Redis数据库。它提供了一套完整的API，可以进行键值对的增删改查等操作，同时还支持事务、序列化、模板方法等多种高级特性。...

    spring整合redis以及使用RedisTemplate的方法

    `RedisTemplate`是一个通用的模板类，封装了多种Redis操作，如键值操作、列表、集合、有序集合等。在Spring配置文件中定义`RedisTemplate`，并注入`JedisConnectionFactory`： ```xml &lt;bean id="redisTemplate" ...

    pom.xml+redisTemplate配置

    包含SSM+redisTemplate+shiro

    RedisTemplate redisTemplate(RedisConnectionFactory factory)

    RedisTemplate, Object&gt; redisTemplate(RedisConnectionFactory factory)自定义RedisTemplate配置类，是个固定模板，可以拿来直接使用，可以直接传入Key:String和Value:Object这种类型，注意Object类需要实现序列化...

    Redis+RedisTemplate分布式锁

    Redis+RedisTemplate分布式锁

    分布式缓存RedisTemplate取不到数据的问题（csdn）————程序.pdf

    在使用 RedisTemplate 进行操作时，有时可能会遇到无法获取数据的问题，这通常涉及到多个方面。以下是对这些可能出现问题的详细分析： 1. **服务数据源配置一致性**： 确保你的应用与 Redis 服务器之间的连接配置...

    RedisTemplate 用法

    详细介绍RedisTemplate5种数据结构，并且有每种不同数据结构的用法的例子

    在Java中使用redisTemplate操作缓存的方法示例

    使用redisTemplate可以简化对Redis的操作，redisTemplate是Spring提供的一个强大的模板，方便在开发的时候操作Redis缓存。下面将针对List和Hash分别介绍。 List在Redis中的List为简单的字符串列表，常见的有以下几...

    spring使用RedisTemplate的操作类访问Redis

    Spring 使用 RedisTemplate 操作类访问 Redis 本篇文章主要介绍了 Spring 使用 RedisTemplate 的操作类访问 Redis，具有一定的参考价值。下面将详细说明标题和描述中的知识点。 首先，RedisTemplate 是 Spring ...

    Spring学习笔记之RedisTemplate的配置与使用教程

    【Spring中的RedisTemplate配置与使用】 在Spring框架中，RedisTemplate是用于操作Redis数据库的一个强大工具，它提供了丰富的API来简化Redis的操作。本教程将详细讲解如何配置和使用RedisTemplate。 **I. 基本...

    RedisTemplate-redis-优雅玩法

    在提供的"demo-redis"文件中，应该包含了一个完整的Spring Boot项目，演示了如何配置RedisTemplate以及如何在实际应用中使用它。通过阅读和运行这个示例，你可以更直观地了解上述概念。 总的来说，通过合理配置和...

    redisTemplate示例代码

    RedisTemplate是Spring与Redis集成的重要工具，它提供了丰富的操作接口，方便开发者进行键值对、哈希、列表、集合和有序集合等多种数据结构的操作，同时支持事务和过期时间设置等功能，极大地简化了Redis在Java应用...

Magicbox
Global site tag (gtag.js) - Google Analytics