Java操作redis常见类型数据存储

点击全文阅读

目录

一、Java连接Redis

1.1 导入pom依赖

1.2 建立连接

二、Java使用Redis

2.1 字符串 String

2.2 哈希 Hash

2.3 列表 List

2.4 集合 Set

2.5 有序集合 Sorted Set 

三、Redis的实际应用场景

---

一、Java连接Redis

        redis与mysq都是数据库，java操作redis其实跟操作mysql的过程是差不多的，首先都是导入依赖、建立连接，只是方式不同，redis是非关系数据库而mysql是关系数据库。

什么是关系数据库与非关系数据库？

        关系数据库 是一种基于关系模型的数据库系统，其中数据以表格形式组织，并使用 SQL（Structured Query Language）进行查询和管理。在关系数据库中，数据由多个表格组成，每个表格包含多个行和列，每行代表一个记录，每列代表一个属性。关系数据库中的表格之间可以建立关系，通过这些关系可以实现数据的联合查询和更新。关系数据库最常见的例子是MySQL、Oracle和SQL Server等。

        非关系数据库（NoSQL）是相对于传统的关系数据库而言的，它采用了非关系数据模型来存储和处理数据。非关系数据库通常不使用表格，而是使用其他形式的数据结构，例如键值对、文档、图形等，以便更好地处理大量非结构化数据。NoSQL数据库通常具有较高的可扩展性、灵活性和性能，并且能够处理复杂的数据处理任务。非关系数据库最常见的例子是MongoDB、Cassandra和Redis等。

1.1 导入pom依赖

在maven项目中导入redis依赖

    <!--redis-->    <dependency>      <groupId>redis.clients</groupId>      <artifactId>jedis</artifactId>      <version>2.9.0</version>    </dependency>

1.2 建立连接

首先的启动redis，Linux版与windos版启动redis方式详情文章 http://t.csdnimg.cn/UBt3Z

本次为了方便就使用了本机进行测试使用redis

package text;import redis.clients.jedis.Jedis;/** * @author 云村小威 * @create 2023-11-04 22:20 */public class demo1 {    public static void main(String[] args) {        Jedis jedis = new Jedis("localhost", 6379);        jedis.auth("123456");        System.out.println(jedis.ping());    }}

二、Java使用Redis

        Redis支持五种基本的数据类型：字符串（string），哈希（hash），列表（list），集合（set）和有序集合（sorted set，也被称为zset）。这些数据类型在数据库中都以key-value的形式保存，所有的key都是字符串类型的。

        具体来说，Redis的字符串是二进制安全的，这意味着他们可以包含任何数据，比如图片或者JSON。哈希是一个键值对的集合，适合用于存储对象。列表是简单的字符串列表，按插入顺序排序，适用于队列和栈等场景。集合是一个无序的字符串集合，用于存储不重复的数据。有序集合和集合类似，但每个元素都关联了一个分数，根据这个分数进行排序，适用于排行榜等场景。

此外，从Redis 5.0.5版本开始，还增加了两种数据类型：位图和地理位置。位图是一种压缩的字符串表示形式，可以节省空间；地理位置则用于存储地理坐标信息。

2.1 字符串 String

package text;import redis.clients.jedis.Jedis;/** * @author 云村小威 * @create 2023-11-04 22:20 */public class demo1 {    public static void main(String[] args) {        Jedis jedis = new Jedis("localhost", 6379);        jedis.auth("123456");        System.out.println(jedis.ping());        //string：set get del sexex ttl        jedis.select(3);//指定数据库        //添加数据        jedis.set("string_name", "云村小威");        //get key 获取        System.out.println(jedis.get("string_name"));        //type key 查看类型        System.out.println(jedis.type("string_name"));        //keys * 或 keys key 查看所有或者指定的key        System.out.println(jedis.keys("*"));        //SETEX KEY_NAME TIMEOUT VALUE    给键值对设置过期时间        jedis.setex("string_test", 100, "ready");        //ttl key 获取键值对剩余的存活时间        System.out.println(jedis.ttl("string_test"));    }}

2.2 哈希 Hash

        //Hash        jedis.select(4);//指定数据库        //hset key field1 value1 [field2 value2]  同时将多个field-value设置到哈希表key中        jedis.hset("hash_user", "name", "云村小威");        jedis.hset("hash_user", "sex", "男");        jedis.hset("hash_user", "age", "18");        //hget key field   获取指定的字段值        System.out.println(jedis.hget("hash_user", "sex"));        //hdel key field   删除指定的字段值        jedis.hdel("hash_user", "sex");        //hgetall key   查询指定key的所有字段        Map<String, String> hash_user_map = jedis.hgetAll("hash_user");        System.out.println(hash_user_map);        //hexists key field   查询指定key中的字段是否存在        Boolean hash_user = jedis.hexists("hash_user", "sex");        System.out.println(hash_user);        //hlen key   获取指定key中的长度        Long hash_user_len = jedis.hlen("hash_user");        System.out.println(hash_user_len);

优化后：

 public void setHashMap(Jedis jedis, String key, Map<String, String> map) {        if (map != null && map.size() > 0) {            Set<String> keys = map.keySet();            for (String k : keys) {                jedis.hset(key, k, map.get(k));            }        }    }

      Map map = new HashMap<>();        map.put("name", "云村小威");        map.put("sex", "男");        map.put("age", "18");        setHashMap(jedis, "user", map);

2.3 列表 List

        jedis.select(4);//指定数据库        //lpush key value1 value2 value3   将一个或多个值插入到列表头部        jedis.lpush("List_hobby", "sing", "jump", "rap", "basketball");        //llen key    获取列表的长度        System.out.println(jedis.llen("List_hobby"));        //lindex key index   根据索引获取列表中的元素        System.out.println(jedis.lindex("List_hobby", 2));        //lrange key start sop   查看指定范围内的元素        System.out.println(jedis.lrange("List_hobby", 0, 3));

2.4 集合 Set

        //sadd key value1 [value2]  向集合添加一个或多个元素        jedis.sadd("set_user", "老六", "老五", "老七", "老八");        //scard key   获取集合中的元素数量        System.out.println(jedis.scard("set_user"));        //exists key  是否存在        System.out.println(jedis.exists("set_user"));

2.5 有序集合 Sorted Set 

        // -1 表示最后一个成员， -2 表示倒数第二个成员，以此类推。        jedis.zadd("mysort", 1.0, "飞鸟集");        jedis.zadd("mysort", 2.0, "牧羊少年的奇幻之旅");        jedis.zadd("mysort", 3.0, "皮囊");        jedis.zadd("mysort", 4.0, "我与地坛");        Map<String, Double> map = new HashMap<>();        map.put("mutouliu", 5.0);        jedis.zadd("mysort", map);        //正序排列        Set<String> mysort = jedis.zrange("mysort", 0, -1);        System.out.println(mysort);        //倒序排列        Set<String> mysort1 = jedis.zrange("mysort", -1, 0);        System.out.println(mysort1);        //命令用于计算集合中元素的数量        System.out.println(jedis.zcard("mysort"));        //命令用于计算有序集合中指定分数区间的成员数量        System.out.println(jedis.zcount("mysort", 0, 4));        //命令在计算有序集合中指定字典区间内成员数量。        System.out.println(jedis.zlexcount("mysort", "-", "+"));

 

三、Redis的实际应用场景

redis一般用于存储基本不会变换的数据，然后这些数据又被多个地方使用且关联。

例如：我需要查询所有的会议状态，如果不使用redis的话我还需要通过查询到的state（0,1,2...）连表查询到所翻译的字符串（0 取消会议，1 待审核）

用到redis话，就可以将这些数据进行存储起来，如图示例：当status为0时就能查到是新增操作...

会议状态亦是如此，接下就是Redis的实际应用场景示例：

ssm项目中：利用spring自定义注解与AOP结合Redis的使用：首先在会议实体的state（会议状态）属性中使用了自定义注解，当我在controller层中调用了查询所有会议信息的方法时，通过切面结合state属性使用的自定义注解完成查询到会议信息的state字段的值时，则返回一个字符串形式的状态信息； 

1、定义会议实体

首先，我们定义一个会议实体类Meeting

public class Meeting {    private String name;    @State(value = 1)    private int state;        ...        // 构造方法、getter和setter方法省略}

2、定义自定义注解

接下来，我们定义一个自定义注解@State，用于标识会议状态字段。

import java.lang.annotation.ElementType;import java.lang.annotation.Retention;import java.lang.annotation.RetentionPolicy;import java.lang.annotation.Target;@Target(ElementType.FIELD)@Retention(RetentionPolicy.RUNTIME)public @interface State {    int value();}

3、创建切面类

然后，我们创建一个切面类MeetingAspect ，用于在查询会议信息时，根据状态字段的值进行特殊处理。

import org.aspectj.lang.JoinPoint;import org.aspectj.lang.annotation.AfterReturning;import org.aspectj.lang.annotation.Aspect;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Component;import redis.clients.jedis.Jedis;import java.util.List;@Aspect@Componentpublic class MeetingAspect {    @Autowired    private Jedis jedis;    @AfterReturning(pointcut = "execution(* com.example.controller.MeetingController.queryAllMeetings(..))", returning = "meetings")    public void handleQueryAllMeetings(JoinPoint joinPoint, List<Meeting> meetings) {        for (Meeting meeting : meetings) {            if (meeting.getState() == 1) {                jedis.set("待开会议", meeting.getName());            }        }    }}

        在上面的切面类中，我们使用@AfterReturning切点拦截MeetingController的getAllMeetings()方法的返回结果。然后，我们遍历会议列表，如果会议状态字段的值为1，将会议状态名称设置为"待开会议"，并将会议名称和状态名称存储到Redis中。

请确保你已经在Spring中配置了Redis相关的配置。

4、创建控制器类

现在，我们创建一个控制器类MeetingController，用于获取所有会议信息。

import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;import java.util.ArrayList;import java.util.List;@RestControllerpublic class MeetingController {    @Autowired    private MeetingService meetingService;    @GetMapping("/queryAllMeetings")    public List<Meeting> queryAllMeetings() {        return meetingService.findAll();    }}

        最后，确保在Spring配置文件中进行以下配置：这样，当调用MeetingController的getAllMeetings()方法时，切面会拦截返回结果，并根据会议状态字段的值进行特殊处理。如果会议状态字段的值为1，则将会议状态名称设置为"待开会议"，并将会议名称和状态名称存储到Redis中。

请注意，以上示例仅供参考，你需要根据实际情况进行适当的修改和完善。特别是Redis相关的配置，需要根据你的实际环境和需求进行调整。

点击全文阅读