• 【云原生进阶之PaaS中间件】第一章Redis-1.6.1Java项目使用Redis

    1 Java 使用 Redis

    1.1 方案简述

            redis的java客户端很多，官方推荐的有三种：

    1. Jedis
    2. Lettuce
    3. Redisson
    4. Spring 对Redis 客户端进行了整合，提供了Spring Date Redis ，在Spring Boot项目中还提供了对应的Starter，即spring-boot-starter-data-redis。

    1.2 使用Jedis连接到 redis 服务

            使用Jedis操作Redis的步骤：

    1.获取链接；

    2.执行操作；

    3.关闭连接；

    1.2.1 实例

    1. import redis.clients.jedis.Jedis;
    2.  
    3. public class RedisJava {
    4.     public static void main(String[] args) {
    5.         //连接本地的 Redis 服务
    6.         Jedis jedis = new Jedis("localhost");
    7.  
    8.         // 如果 Redis 服务设置了密码，需要下面这行，没有就不需要
    9.         // jedis.auth("123456"); 
    10.         System.out.println("连接成功");
    11.  
    12.         //查看服务是否运行
    13.         System.out.println("服务正在运行: "+jedis.ping());
    14.     }
    15. }

            编译以上 Java 程序，确保驱动包的路径是正确的。

    1. 连接成功
    2.  
    3. 服务正在运行: PONG

    1.2.2 Redis Java String(字符串) 实例

    1. import redis.clients.jedis.Jedis;
    2.  
    3. public class RedisStringJava {
    4.     public static void main(String[] args) {
    5.         //连接本地的 Redis 服务
    6.         Jedis jedis = new Jedis("localhost");
    7.         System.out.println("连接成功");
    8.  
    9.         //设置 redis 字符串数据
    10.         jedis.set("runoobkey", "www.runoob.com");
    11.  
    12.         // 获取存储的数据并输出
    13.         System.out.println("redis 存储的字符串为: "+ jedis.get("runoobkey"));
    14.     }
    15. }

            编译以上程序。

    1. 连接成功 redis
    2.  
    3. 存储的字符串为: www.runoob.com

    1.2.3 Redis Java List(列表) 实例

    1. import java.util.List;
    2. import redis.clients.jedis.Jedis;
    3.  
    4. public class RedisListJava {
    5.     public static void main(String[] args) {
    6.         //连接本地的 Redis 服务
    7.         Jedis jedis = new Jedis("localhost");
    8.         System.out.println("连接成功");
    9.  
    10.         //存储数据到列表中
    11.         jedis.lpush("site-list", "Runoob");
    12.         jedis.lpush("site-list", "Google");
    13.         jedis.lpush("site-list", "Taobao");
    14.  
    15.         // 获取存储的数据并输出
    16.         List list = jedis.lrange("site-list", 0 ,2);
    17.         for(int i=0; i
    18.             System.out.println("列表项为: "+list.get(i));
    19.         }
    20.     }
    21. }

            编译以上程序。

    1. 连接成功
    2. 列表项为: Taobao
    3. 列表项为: Google
    4. 列表项为: Runoob

    1.2.4 Redis Java Keys 实例

    1. import java.util.Iterator;
    2. import java.util.Set;
    3. import redis.clients.jedis.Jedis;
    4.  
    5. public class RedisKeyJava {
    6.     public static void main(String[] args) {
    7.         //连接本地的 Redis 服务
    8.         Jedis jedis = new Jedis("localhost");
    9.         System.out.println("连接成功");
    10.  
    11.         // 获取数据并输出
    12.         Set keys = jedis.keys("*"); 
    13.         Iterator it=keys.iterator() ;   
    14.         while(it.hasNext()){   
    15.             String key = it.next();   
    16.             System.out.println(key);   
    17.         }
    18.     }
    19. }

            编译以上程序。

    1. 连接成功
    2.  
    3. runoobkey site-list

    1.3 Lettuce

            另一个流行的Java Redis客户端库Lettuce，它具有异步和响应式API，支持集群模式、Sentinel模式以及Redis 6中的新特性。以下是使用Lettuce连接Redis并执行一些基本操作的代码示例：

            在上面的代码中，我们使用了Lettuce客户端库来连接Redis服务器并执行一些基本操作。首先，我们创建了一个RedisClient实例，并将Redis服务器的地址和端口作为参数传递给create方法。然后，我们通过调用connect方法来创建一个StatefulRedisConnection实例，该实例提供了同步和异步的API来操作Redis。接下来，我们使用sync方法来获取一个同步的RedisCommands实例，然后使用set方法来设置一个键值对，get方法获取一个键的值，del方法删除一个键。最后，我们关闭了连接哦。

    1.4 Redisson

            Redisson是一个基于Netty框架的Java Redis客户端库，它提供了分布式锁、分布式集合、分布式对象等功能，支持Redis集群和Sentinel模式。以下是使用Redisson连接Redis并执行一些基本操作的代码示例：

            在上面的代码中，我们使用了Redisson客户端库来连接Redis服务器并执行一些基本操作。首先，我们创建了一个Config实例，并使用useSingleServer方法来指定Redis服务器的地址和端口。然后，我们通过调用create方法来创建一个RedissonClient实例。接下来，我们使用getBucket方法来获取一个RBucket实例，该实例可以用来操作一个特定的键。我们使用set方法来设置一个键值对，get方法获取一个键的值，delete方法删除一个键。最后，我们关闭了连接。

    1.5 Spring Data Redis

            Spring Data Redis 中提供了一个高度封装的类，针对jedis客户端中大量api进行了归类封装，将同一类型操作封装为operation接口，具体分类如下：

    • ValueOperations：简单K-V操作
    • SetOperations ：set 类型数据操作
    • ZSetOperations：zset 类型数据操作
    • HashOperations：针对map类型的数据操作
    • ListOperations：针对list类型的数据操作

            默认操作的是0号数据库，也可以切换其他数据库：

            设置一下序列化，这样设置key的时候不会变成乱码：

    1. package com.example.demotest;
    2.  
    3. import org.springframework.cache.annotation.CachingConfigurerSupport;
    4. import org.springframework.context.annotation.Bean;
    5. import org.springframework.context.annotation.Configuration;
    6. import org.springframework.data.redis.connection.RedisConnectionFactory;
    7. import org.springframework.data.redis.core.RedisTemplate;
    8. import org.springframework.data.redis.serializer.StringRedisSerializer;
    9.  
    10. @Configuration
    11. public class RedisConfig extends CachingConfigurerSupport {
    12.  
    13.     @Bean
    14.     public RedisTemplate redisTemplate(RedisConnectionFactory connectionFactory){
    15.  
    16.         RedisTemplate redisTemplate = new RedisTemplate<>();
    17.  
    18.         redisTemplate.setKeySerializer(new StringRedisSerializer());
    19.  
    20.         redisTemplate.setHashKeySerializer(new StringRedisSerializer());
    21.  
    22.         redisTemplate.setConnectionFactory(connectionFactory);
    23.         return  redisTemplate;
    24.     }
    25. }
    1. package com.example.demotest;
    2.  
    3. import org.junit.Test;
    4. import org.junit.runner.RunWith;
    5. import org.springframework.beans.factory.annotation.Autowired;
    6. import org.springframework.boot.test.context.SpringBootTest;
    7. import org.springframework.data.redis.connection.DataType;
    8. import org.springframework.data.redis.core.*;
    9. import org.springframework.test.context.junit4.SpringRunner;
    10.  
    11. import java.util.List;
    12. import java.util.Set;
    13. import java.util.concurrent.TimeUnit;
    14.  
    15. @SpringBootTest
    16. @RunWith(SpringRunner.class)
    17. public class SpringDataRedisTest {
    18.  
    19.     @Autowired
    20.     private RedisTemplate redisTemplate;
    21.  
    22.     @Test
    23.     public void testString(){
    24.         redisTemplate.opsForValue().set("city2","sz");
    25.         String city2 = (String) redisTemplate.opsForValue().get("city2");
    26.         System.out.println("打印一下" + city2);
    27.         //指定过期时间 10 秒
    28.         redisTemplate.opsForValue().set("key1","value1",10l, TimeUnit.SECONDS);
    29.         //如果不存在key则设置
    30.         Boolean aBoolean = redisTemplate.opsForValue().setIfAbsent("city", "sz");
    31.         System.out.println(aBoolean);
    32.  
    33.     }
    34.  
    35.     @Test
    36.     public void testHash(){
    37.         HashOperations hashOperations = redisTemplate.opsForHash();
    38.         //存值
    39.         hashOperations.put("002","name","hh");
    40.         hashOperations.put("002","age","20");
    41.         hashOperations.put("002","address","sz");
    42.         //取值
    43.         String age = (String) hashOperations.get("002", "age");
    44.         System.out.println(age);
    45.  
    46.         //获得hash结构中的所有字段
    47.         Set keys = hashOperations.keys("002");
    48.         for (Object key : keys) {
    49.             System.out.println(key);
    50.         }
    51.         //获得hash结构中的所有值
    52.         List values = hashOperations.values("002");
    53.         for (Object value : values) {
    54.             System.out.println(value);
    55.         }
    56.  
    57.     }
    58.  
    59.     /**
    60.      * 操作list类型的数据
    61.      */
    62.     @Test
    63.     public void testList(){
    64.         ListOperations listOperations = redisTemplate.opsForList();
    65.  
    66.         //存储
    67.         listOperations.leftPush("mylist","a");
    68.         listOperations.leftPushAll("mylist","b","c","d");
    69.  
    70.         //取值
    71.         List mylist = listOperations.range("mylist", 0, -1);
    72.         for (String value : mylist) {
    73.             System.out.println(value);
    74.         }
    75.  
    76.         //获得列表长度
    77.         Long size = listOperations.size("mylist");
    78.         int lSize = size.intValue();
    79.         for (int i = 0; i < lSize; i++) {
    80.             //出队列
    81.             String elment = (String) listOperations.rightPop("mylist");
    82.             System.out.println(elment);
    83.         }
    84.     }
    85.  
    86.     /**
    87.      * 操作set类型的数据
    88.      */
    89.     @Test
    90.     public void testSet(){
    91.         SetOperations setOperations = redisTemplate.opsForSet();
    92.  
    93.         //存值
    94.         setOperations.add("myset","a","b","c","a");
    95.  
    96.         //取值
    97.         Set myset = setOperations.members("myset");
    98.         for (String s : myset) {
    99.             System.out.println(s);
    100.         }
    101.         //删除成员
    102.         setOperations.remove("myset","a","b");
    103.  
    104.         //取值
    105.         myset = setOperations.members("myset");
    106.         for (String s : myset) {
    107.             System.out.println(s);
    108.         }
    109.     }
    110.  
    111.     /**
    112.      * 操作zset类型的数据
    113.      */
    114.     @Test
    115.     public void testZset(){
    116.         ZSetOperations zSetOperations = redisTemplate.opsForZSet();
    117.  
    118.         //存值
    119.         zSetOperations.add("myZset","a",10.0);
    120.         zSetOperations.add("myZset","b",11.0);
    121.         zSetOperations.add("myZset","d",12.0);
    122.         zSetOperations.add("myZset","a",13.0);
    123.  
    124.         //取值
    125.         Set myZset = zSetOperations.range("myZset", 0, -1);
    126.         for (String s : myZset) {
    127.             System.out.println(s);
    128.         }
    129.         //修改分数
    130.         zSetOperations.incrementScore("myZset","b",20.0);
    131.  
    132.         //取值
    133.         myZset = zSetOperations.range("myZset", 0, -1);
    134.         for (String s : myZset) {
    135.             System.out.println(s);
    136.         }
    137.         //删除成员
    138.         zSetOperations.remove("myZset","a","b");
    139.     }
    140.  
    141.     @Test
    142.     public void testCommon(){
    143.         //获取Redis 中所有的key
    144.         Set keys = redisTemplate.keys("*");
    145.         for (String key : keys) {
    146.             System.out.println(key);
    147.         }
    148.  
    149.         //判断某个key是否存在
    150.         Boolean hh = redisTemplate.hasKey("hh");
    151.         System.out.println(hh);
    152.  
    153.         //删除指定key
    154.         redisTemplate.delete("myzset");
    155.  
    156.         //获取指定key对应的value的数据类型
    157.         DataType dataType = redisTemplate.type("myset");
    158.         System.out.println(dataType.name());
    159.     }
    160. }

     参考链接

    Java 使用 Redis | 菜鸟教程

    java在项目中如何使用redis_Redis_方法_操作

    在Java中操作Redis_java redis_周盛欢的博客-CSDN博客

    使用java操作redis_java连接redis_白未的博客-CSDN博客

    Redis在java项目中的使用

  • 相关阅读:
    AIGC+思维导图：提升你的学习与工作效率的「神器」
    基于Python+Tkinter实现一个贪食蛇小游戏
    t-SNE可视化-Python实现
    C#里如何简单的校验时间格式
    “空间代谢组学“用于食管鳞状细胞癌早期筛查的研究
    【JavaEE】Servlet API 详解（HttpServletResponse类方法演示、实现自动刷新、实现自动重定向）
    头歌-信息安全技术-用Python实现自己的区块链、支持以太坊的云笔记服务器端开发、编写并测试用于保存云笔记的智能合约、支持以太坊的云笔记小程序开发基础
    Anacoda的用途
    Visual C++ 2010开发的程序在其它电脑上运行提示“找不到MSVCR100D.dll”原因及解决
    win11安装双系统Ubuntu的坎坷记录
  • 原文地址：https://blog.csdn.net/junbaozi/article/details/132721873