java 用redisTemplate 的 Operations存取list集合操作

java redisTemplate 的 Operations存取list集合

一 、存取為list類型

@RestController
@RequestMapping("/test")
@Slf4j
public class TestController {
 
    @Autowired
    private RedisTemplate redisTemplate;
 
    @ApiOperation("redis-savelist")
    @PostMapping("/redis/save/list")
    public void redisSaveList() {
        List<Person> list = getPersonList();
        //清空
        while (redisTemplate.opsForList().size("oowwoo") > 0){
            redisTemplate.opsForList().leftPop("oowwoo");
        }
        //存儲
        redisTemplate.opsForList().rightPushAll("oowwoo", list);
 
        //取出
        List<Person> oowwoo = redisTemplate.opsForList().range("oowwoo", 0, -1);
        log.info(">>>>>>>>>>>>>>>list = {}", oowwoo.toString());
        Iterator<Person> it = oowwoo.iterator();
        while(it.hasNext()){
            Person p = it.next();
            log.info("person = {}", p.toString());
        }
    }
 
    private List<Person> getPersonList() {
        Person p1 = new Person();
        p1.setId(1L);
        p1.setName("張一");
        p1.setAge(11);
 
        Person p2 = new Person();
        p2.setId(2L);
        p2.setName("張二");
        p2.setAge(22);
 
        Person p3 = new Person();
        p3.setId(3L);
        p3.setName("張三");
        p3.setAge(33);
 
        List<Person> list = new ArrayList<>();
        list.add(p1);
        list.add(p2);
        list.add(p3);
        return list;
    }
}

二 、將list轉為json對象存取

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject; 
  @Autowired
    private StringRedisTemplate stringRedisTemplate;
 
//存
List<Long> businessIdList = eeFreecarriageShopService.selectBusinessIdInPromotion();
 stringRedisTemplate.opsForValue().set(RedisConstants.FREECARRIAGE_BUSINESSIDLIST, JSON.toJSON(businessIdList).toString());
 
//取
String businessJsonArray = stringRedisTemplate.opsForValue().get(RedisConstants.FREECARRIAGE_BUSINESSIDLIST);
List<Long> businessIdList = JSONObject.parseArray(businessJsonArray, Long.class);

redis在java中的使用,基本存取操作(RedisTemplate)

redis

REmote DIctionary Server(Redis) 是一個由 Salvatore Sanfilippo 寫的 key-value 存儲系統,是跨平臺的非關系型數據庫。

Redis 是一個開源的使用 ANSI C 語言編寫、遵守 BSD 協議、支持網絡、可基於內存、分佈式、可選持久性的鍵值對(Key-Value)存儲數據庫,並提供多種語言的 API。

Redis 通常被稱為數據結構服務器,因為值(value)可以是字符串(String)、哈希(Hash)、列表(list)、集合(sets)和有序集合(sorted sets)等類型。

RedisTemplate

spring 封裝瞭 RedisTemplate 對象來進行對redis的各種操作,它支持所有的 redis 原生的 api。

StringRedisTemplate與RedisTemplate

兩者的關系是StringRedisTemplate繼承RedisTemplate。

兩者的數據是不共通的;也就是說StringRedisTemplate隻能管理StringRedisTemplate裡面的數據,RedisTemplate隻能管理RedisTemplate中的數據。

SDR默認采用的序列化策略有兩種,一種是String的序列化策略,一種是JDK的序列化策略。

StringRedisTemplate默認采用的是String的序列化策略,保存的key和value都是采用此策略序列化保存的。

RedisTemplate默認采用的是JDK的序列化策略,保存的key和value都是采用此策略序列化保存的。

set void set(K key, V value);

使用:redisTemplate.opsForValue().set(“name”,”tom”);

結果:redisTemplate.opsForValue().get(“name”) 輸出結果為tom

set void set(K key, V value, long timeout, TimeUnit unit);

使用:redisTemplate.opsForValue().set(“name”,”tom”,10, TimeUnit.SECONDS);

結果:redisTemplate.opsForValue().get(“name”)由於設置的是10秒失效,十秒之內查詢有結果,十秒之後返回為null

這裡隻討論對string數據的使用,附上一個小demo

首先需要導入相關的依賴

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

序列化,序列化是為瞭方便數據傳輸

這裡提供兩種序列化封裝操作:

第一種

@Service
public class TokenServiceTask {
    public static final String ONLINE_OPERRATOR = "";
    /**
     * redis序列化存儲
     *
     * @param redisTemplate
     */
    @SuppressWarnings({"rawtypes", "unchecked"})
    @Autowired(required = false)
    public void setRedisTemplate(RedisTemplate redisTemplate) {
        RedisSerializer stringSerializer = new StringRedisSerializer();
        redisTemplate.setKeySerializer(stringSerializer);
        redisTemplate.setValueSerializer(stringSerializer);
        redisTemplate.setHashKeySerializer(stringSerializer);
        redisTemplate.setHashValueSerializer(stringSerializer);
        this.redisTemplate = redisTemplate;
    }
    @Resource
    private RedisTemplate<String, String> redisTemplate;
    public void setToken(String key, String token) {
        ValueOperations<String, String> value = redisTemplate.opsForValue();
        value.set(ONLINE_OPERRATOR + key, token);
    }
    public void setTokenWithTime(String key, String token, long number, TimeUnit timeUnit) {
        ValueOperations<String, String> value = redisTemplate.opsForValue();
        value.set(ONLINE_OPERRATOR + key, token, number, timeUnit);
    }
    public void freshTime(String key) {
        redisTemplate.expire(key, 1800, TimeUnit.SECONDS);
    }
    public String getToken(String key) {
        return redisTemplate.boundValueOps(key).get();
    }
}

第二種

@Configuration
@EnableCaching //啟用緩存,這個註解很重要;
public class RedisCacheConfig extends CachingConfigurerSupport {
    /**
     * 緩存管理器.
     * @param redisTemplate
     * @return
     */
    @Bean
    public CacheManager cacheManager(RedisTemplate<?,?> redisTemplate) {
        CacheManager cacheManager = new RedisCacheManager(redisTemplate);
        return cacheManager;
    }
    /**
     * redis模板操作類,類似於jdbcTemplate的一個類;
     *
     * 雖然CacheManager也能獲取到Cache對象,但是操作起來沒有那麼靈活;
     *
     * 這裡在擴展下:RedisTemplate這個類不見得很好操作,我們可以在進行擴展一個我們
     *
     * 自己的緩存類,比如:RedisStorage類;
     *
     * @param factory : 通過Spring進行註入,參數在application.properties進行配置;
     * @return
     */
    @Bean
    public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String,String> redisTemplate = new RedisTemplate<String, String>();
        redisTemplate.setConnectionFactory(factory);
        //key序列化方式;(不然會出現亂碼;),但是如果方法上有Long等非String類型的話,會報類型轉換錯誤;
        //所以在沒有自己定義key生成策略的時候,以下這個代碼建議不要這麼寫,可以不配置或者自己實現ObjectRedisSerializer
        //或者JdkSerializationRedisSerializer序列化方式;
        RedisSerializer<String> redisSerializer = new StringRedisSerializer();//Long類型不可以會出現異常信息;
        redisTemplate.setKeySerializer(redisSerializer);
        redisTemplate.setHashKeySerializer(redisSerializer);
        return redisTemplate;
    }
}

接下來上操作

    public void test01() {
        redisTemplate.opsForValue().set("chenlianghongtest","chenlianghong",30, TimeUnit.SECONDS);
        String test = redisTemplate.opsForValue().get("chenlianghongtest");
        System.out.println(test);
        logger.info("牛啊牛啊");
    }

以上為個人經驗,希望能給大傢一個參考,也希望大傢多多支持WalkonNet。

推薦閱讀: