当前位置: 首页 > biancheng >正文

在java中操作Redis

文章目录

  • 介绍
  • Jedis
    • maven坐标
    • 使用Jedis操作Redis
      • 新建maven工程
  • Spring Data Redis
    • maven坐标
    • 使用Spring Data Redis操作Redis
      • 新建springboot项目
      • 测试运行(发现问题)
      • 更改序列化方式
        • 编辑配置类
        • 取消序列化失败
        • 在让序列化key在java代码中返回
      • 操作String类型数据
      • 操作list类型数据
      • 操作Hash类型数据
      • 操作set类型数据
      • 操作ZSet类型数据
      • 操作通用类型数据
  • 注意(对于取消序列化失败处理)

介绍

在这里插入图片描述
在这里插入图片描述

Jedis

maven坐标

<dependency>
	<groupId>redis.clients</groupId>
	<artifactId>jedis</artifactId>
	<version>2.8.0</version>
</dependency>

使用Jedis操作Redis

新建maven工程

新建默认maven工程,并导入jedis坐标以及测试坐标
在这里插入图片描述

编写JedisTest类

import org.junit.Test;
import redis.clients.jedis.Jedis;

/**
 * create by 刘鸿涛
 * 2022/10/4 11:07
 */
@SuppressWarnings({"all"})
public class JedisTest {
    @Test
    public void testRedis(){
        //1.获取连接
        Jedis jedis = new Jedis("127.0.0.1",6379);

        //2.执行具体操作
        jedis.set("username","xiaoming");

        //关闭连接
        jedis.close();
    }
}

启动redis服务
在这里插入图片描述

运行代码并测试
在这里插入图片描述

测试其他方法
在这里插入图片描述

Spring Data Redis

在这里插入图片描述
在这里插入图片描述

maven坐标

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

使用Spring Data Redis操作Redis

新建springboot项目

在这里插入图片描述

改为2.4.5版本,并刷新maven依赖在这里插入图片描述

导入依赖

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

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <scope>test</scope>
        </dependency>

配置yml

spring:
    application:
        name: springdataredis_demo
    #Redis相关配置
    redis:
        host: 127.0.0.1
        port: 6379
        #password: 123456
        database: 0 #操作的是0号数据库,默认配置文件中分配了16个数据库
        jedis:
            #Redis连接池配置
            pool:
                max-active: 8 #最大连接数
                max-wait: 1ms #连接池最大阻塞等待时间
                max-idle: 4 #连接池中最大空闲连接
                min-idle: 0 #连接池中的最小空闲连接




测试运行(发现问题)

被序列化查不到
在这里插入图片描述

更改序列化方式

使get city能查到

编辑配置类

在这里插入图片描述

import org.springframework.cache.annotation.CachingConfigurationSelector;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;

/**
 * create by 刘鸿涛
 * 2022/10/4 11:56
 */
@SuppressWarnings({"all"})
@Configuration
public class RedisConfig extends CachingConfigurerSupport {

    @Bean
    public RedisTemplate<Object,Object> redisTemplate (RedisConnectionFactory connectionFactory){
        RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();

        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());

        redisTemplate.setConnectionFactory(connectionFactory);

        return redisTemplate;

    }
}

取消序列化失败

原因未知
在这里插入图片描述

在让序列化key在java代码中返回

返回正常
在这里插入图片描述

操作String类型数据

    /**
     * 操作String类型数据
     */
    @Test
    public void testString(){
//        ValueOperations valueOperations = redisTemplate.opsForValue();
        redisTemplate.opsForValue().set("name" , "taotao");

        String name = (String)redisTemplate.opsForValue().get("name");
        System.out.println(name);
    }

操作list类型数据

 /**
     * 操作List类型的数据
     */
    @Test
    public void testList(){
        ListOperations listOperations = redisTemplate.opsForList();

        //存值
        listOperations.leftPush("mylist","a");
        listOperations.leftPushAll("mylist","b","c","d");

        //取值
        List mylist = listOperations.range("mylist", 0, -1);
        for (Object value : mylist){
            System.out.println(value);
        }

        //获取列表长度 llen
        Long size = listOperations.size("mylist");
        int lSize = size.intValue();
        for (int i = 0; i < lSize; i++) {
            //出队列
            String element = (String)listOperations.rightPop("mylist");
            System.out.println(element);
        }
    }

操作Hash类型数据

    /**
     * 操作Hash类型数据
     */
    @Test
    public void testHash(){
        HashOperations hashOperations = redisTemplate.opsForHash();

        hashOperations.put("002","name","xiaoming");
        hashOperations.put("002","age","20");
        hashOperations.put("002","address","bj");

        String age = (String)hashOperations.get("002", "age");
        System.out.println(age);

        //获得hash结构中的所有字段
        Set keys = hashOperations.keys("002");
        for (Object key:keys
             ) {
            System.out.println(keys);
        }
    }

操作set类型数据

    /**
     * 操作set类型的数据
     */
    @Test
    public void testSet(){
        SetOperations setOperations = redisTemplate.opsForSet();

        //存值
        setOperations.add("myset","a","b","c","d");

        //取值
        Set<String> myset = setOperations.members("myset");
        for (String o : myset){
            System.out.println(o);
        }

        //删除成员
        setOperations.remove("myset","a","b");

        //取值
        myset = setOperations.members("myset");
        for (String o : myset){
            System.out.println(o);
        }
    }

操作ZSet类型数据

    /**
     * 操作ZSet类型的数据
     */
    @Test
    public void testZset(){
        ZSetOperations zSetOperations = redisTemplate.opsForZSet();

        //存值
        zSetOperations.add("myZset","a",10.0);
        zSetOperations.add("myZset","b",11.0);
        zSetOperations.add("myZset","c",12.0);
        zSetOperations.add("myZset","a",13.0);

        //取值
        Set<String> myZset = zSetOperations.range("myZset", 0, -1);
        for (String s : myZset){
            System.out.println(s);
        }

        //修改分数
        zSetOperations.incrementScore("myZset","b",20.0);

        //删除成员
        zSetOperations.remove("myZset","a","b");

        //取值
         myZset = zSetOperations.range("myZset",0,-1);
         for (String s : myZset){
             System.out.println(s);
         }
    }

操作通用类型数据

   /**
     * 通用操作,针对不同的数据类型都可以操作
     */
    @Test
    public void testCommon(){
        //获取Redis种所有的key
        Set<String> keys = redisTemplate.keys("*");
        for (String key : keys){
            System.out.println(key);
        }

        //判断某个key是否存在
        Boolean taotao = redisTemplate.hasKey("taotao");
        System.out.println(taotao);

        //删除指定key
        redisTemplate.delete("myZset");

        //获取指定key对应的value的数据类型
        DataType myset = redisTemplate.type("myset");
    }

注意(对于取消序列化失败处理)

我们暂时使用StringRedisTeamplate类来处理,这样就不用为RedisTemplate配置config类了
目前用着没问题,3种Redis数据类型都支持类型

在这里插入图片描述

相关文章:

  • switch循环语句
  • 牛客练习赛#84 F 莫比乌斯反演+杜教筛+技巧+斐波那契数列和gcd的结论+矩阵快速幂
  • ZZNUOJ_用C语言编写程序实现1342:支配值数目(附完整源码)
  • java毕业设计后勤管理系统餐饮评价监督系统(附源码、数据库)
  • 前端基础学习笔记
  • 【TS】联合类型--类型断言--类型推断
  • 谈笑风声的秘密
  • QT影城网上售票系统
  • NetCDF数据在ArcMap中的使用
  • 打怪升级(考验思路)