Redis-Jedis连接池\RedisTemplate\StringRedisTemplate

news/2024/7/24 10:17:47 标签: redis, 数据库, 缓存

Redis-Jedis连接池\RedisTemplate\StringRedisTemplate

  • 1. Jedis连接池
    • 1.1 通过工具类
    • 1.1.1 连接池：JedisConnectionFactory：
    • 1.1.2 test：（代码其实只有连接池那里改变了）
  • 2. SpringDataRedis（lettuce）
    • 2.1 新建一个springboot项目：
    • 2.2 pom：
    • 2.3 application.yaml：
    • 2.4 Test
  • 3 为什么要使用StringRedisTemplate？
    • 3.1 进行序列化配置：
      • 3.1.1 创建配置类RedisConfig ：
      • 3.1.2 修改Test：
      • 3.1.3 存储对象
  • 4 StringRedisTemplate
    • 4.1 问题
    • 4.2 重新测试，使用StringRedisTemplate：
    • 4.3 RedisTemplate 操作Hash

1. Jedis连接池

1.1 通过工具类

1.1.1 连接池：JedisConnectionFactory：

package com.fst.jedis.util;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class JedisConnectionFactory {
    private static final JedisPool jedispool;
    static {
        //配置连接池
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        poolConfig.setMaxTotal(8);//连接数，最多只允许创建8个
        poolConfig.setMaxIdle(8);//最大空闲连接数
        poolConfig.setMinIdle(0);//释放到0为止
        poolConfig.setMaxWaitMillis(1000);//当连接池里，没有连接可以用的时候，我们等多少时间，默认值为-1（一直等等到有连接），这里设置1000毫秒
        //创建连接池对象
        jedispool=new JedisPool(poolConfig,"192.168.88.128",6379,1000,"123456");
    }
    public static Jedis getJedisPool(){

        return jedispool.getResource();
    }
}

1.1.2 test：（代码其实只有连接池那里改变了）

package com.fst.test;
import com.fst.jedis.util.JedisConnectionFactory;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import redis.clients.jedis.Jedis;
import java.util.Map;
public class JedisTest {
    private Jedis jedis; //创建一个jedis对象
    @BeforeEach //初始化方法
    void setUp() {
        //jedis=new Jedis("192.168.88.128",6379);//地址和端口号，没有连接池的时候才需要使用这个
        jedis= JedisConnectionFactory.getJedisPool();
        jedis.auth("123456");//密码
        jedis.select(0);//哪个库
    }

    @Test
    void testString() {
        String result = jedis.set("name", "涛哥");//String类型，创建
        System.out.println("result="+result);
        String name = jedis.get("name");//得到值
        System.out.println("name="+name);
    }
    @Test
    void testHash(){
        //插入hash
        jedis.hset("user:1","name","涛哥");//Hash类型，创建
        jedis.hset("user:1","age","21");//Hash类型，创建
        Map<String, String> map = jedis.hgetAll("user:1"); //讲得到的Hash用Map封装起来

        System.out.println("map="+map);//打印map
    }
    @AfterEach
    void tearDown() {
        if (jedis != null){
            jedis.close();//底层源码里：没有连接池释放缓存，有连接池则是归还
        }
    }

}

2. SpringDataRedis（lettuce）

2.1 新建一个springboot项目：

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

2.2 pom：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>3.3.1</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.fst</groupId>
    <artifactId>redis-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>redis-demo</name>
    <description>redis-demo</description>
    <url/>
    <licenses>
        <license/>
    </licenses>
    <developers>
        <developer/>
    </developers>
    <scm>
        <connection/>
        <developerConnection/>
        <tag/>
        <url/>
    </scm>
    <properties>
        <java.version>21</java.version>
    </properties>
    <dependencies>
<!--  redis依赖      -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
<!--  common-pool 连接池-->
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
        </dependency>
<!--  Jackson依赖，用来支持我们配置文件里面的序列化转为json-->
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombok</groupId>
                            <artifactId>lombok</artifactId>
                        </exclude>
                    </excludes>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

2.3 application.yaml：

spring:
  data:
    redis:
      host: 192.168.88.128
      port: 6379
      password: 123456
      lettuce:
        pool:
          max-active: 8
          max-idle: 8
          min-idle: 0
          max-wait: 1000ms

2.4 Test

package com.fst;

import com.fst.redis.pojo.User;
import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;

@SpringBootTest
class RedisDemoApplicationTests {
    @Resource
    private RedisTemplate redisTemplate;//注入RedisTemplate依赖

    @Test
    void testString() {
        //写入一条String数据
        redisTemplate.opsForValue().set("name","涛哥");
        //获取String数据
        Object name = redisTemplate.opsForValue().get("name");
        System.out.println("name="+name);
    }
    }

3 为什么要使用StringRedisTemplate？

因为我们使用RedisTemplate的时候他写入redis中的是
在这里插入图片描述
因为序列化到redis的时候，是以二进制的形式存储的，所以需要将对象序列化，才能存储到redis中，和redis的值保持一致。

3.1 进行序列化配置：

3.1.1 创建配置类RedisConfig ：

package com.fst.redis.config;

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.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;
//因为序列化到redis的时候，是以二进制的形式存储的，所以需要将对象序列化，才能存储到redis中，和redis的值保持一致
@Configuration
public class RedisConfig {
    @Bean
    public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory connectionFactory){//连接工厂由springboot创建
        //创建RedisTemplate 对象
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        //设置连接工厂
        template.setConnectionFactory(connectionFactory);
        //创建JSON序列化工具
        GenericJackson2JsonRedisSerializer jsonRedisSerializer = new GenericJackson2JsonRedisSerializer();
        //设置key的序列化
        template.setKeySerializer(RedisSerializer.string());
        template.setHashKeySerializer(RedisSerializer.string());
        //设置Value的序列化
        template.setValueSerializer(jsonRedisSerializer);
        template.setHashValueSerializer(jsonRedisSerializer);
        //返回
        return template;
    }
}

3.1.2 修改Test：

package com.fst;

import com.fst.redis.pojo.User;
import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;

@SpringBootTest
class RedisDemoApplicationTests {
    @Resource
    private RedisTemplate<String,Object> redisTemplate;//注入redisTemplate的依赖
    //并且，还需要指定<String,Object>。

    @Test
    void testString() {
        //写入一条String数据
        redisTemplate.opsForValue().set("name","涛哥");
        //获取String数据
        Object name = redisTemplate.opsForValue().get("name");
        System.out.println("name="+name);
    }
    }

3.1.3 存储对象

新建User类：

package com.fst.redis.pojo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@NoArgsConstructor
@AllArgsConstructor
public class User {
    private String name;
    private int age;
}

test：

package com.fst;

import com.fst.redis.pojo.User;
import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;

@SpringBootTest
class RedisDemoApplicationTests {
    @Resource
    private RedisTemplate<String,Object> redisTemplate;//注入redisTemplate的依赖

    @Test
    void testString() {
        //写入一条String数据
        redisTemplate.opsForValue().set("name","涛哥");
        //获取String数据
        Object name = redisTemplate.opsForValue().get("name");
        System.out.println("name="+name);
    }
    @Test
    void testSaveUser(){
        //写入数据
        redisTemplate.opsForValue().set("user:100",new User("涛哥",18));
        //获取数据
        User o = (User) redisTemplate.opsForValue().get("user:100");
        System.out.println("o="+o);
    }

}

在这里插入图片描述

4 StringRedisTemplate

4.1 问题

在这里插入图片描述

4.2 重新测试，使用StringRedisTemplate：

（别忘了在pom中引入我们的json依赖)，mapper工具类，可以学习

package com.fst;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fst.redis.pojo.User;
import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import java.lang.runtime.ObjectMethods;
import java.util.Map;

@SpringBootTest
class RedisStringTests {
    @Resource
    private StringRedisTemplate stringRedisTemplate;

    @Test
    void testString() {
        //写入一条String数据
        stringRedisTemplate.opsForValue().set("name","涛哥");
        //获取String数据
        Object name = stringRedisTemplate.opsForValue().get("name");
        System.out.println("name="+name);
    }
    private static  final ObjectMapper mapper =new ObjectMapper();

    @Test
    void testSaveUser() throws JsonProcessingException {
        //创建对象
        User user = new User("涛哥",18);
        //手动序列化
        String json = mapper.writeValueAsString(user);
        //写入数据
        stringRedisTemplate.opsForValue().set("user:200",json);
        //获取数据
       String jsonUser =  stringRedisTemplate.opsForValue().get("user:200");
       //手动反序列化
           User user1 = mapper.readValue(jsonUser, User.class);
        System.out.println("user1="+user1);
    }
    @Test
    void testHash(){
        stringRedisTemplate.opsForHash().put("user:400","name","涛哥");
        stringRedisTemplate.opsForHash().put("user:400","age","20");

        Map<Object, Object> entries = stringRedisTemplate.opsForHash().entries("user:400");
        System.out.println("entries="+entries);

    }
}

在这里插入图片描述

4.3 RedisTemplate 操作Hash

package com.fst;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fst.redis.pojo.User;
import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;

import java.lang.runtime.ObjectMethods;
import java.util.Map;

@SpringBootTest
class RedisStringTests {
    @Resource
    private StringRedisTemplate stringRedisTemplate;

    @Test
    void testString() {
        //写入一条String数据
        stringRedisTemplate.opsForValue().set("name","涛哥");
        //获取String数据
        Object name = stringRedisTemplate.opsForValue().get("name");
        System.out.println("name="+name);
    }
    private static  final ObjectMapper mapper =new ObjectMapper();

    @Test
    void testSaveUser() throws JsonProcessingException {
        //创建对象
        User user = new User("涛哥",18);
        //手动序列化
        String json = mapper.writeValueAsString(user);
        //写入数据
        stringRedisTemplate.opsForValue().set("user:200",json);
        //获取数据
       String jsonUser =  stringRedisTemplate.opsForValue().get("user:200");
       //手动反序列化
           User user1 = mapper.readValue(jsonUser, User.class);
        System.out.println("user1="+user1);
    }
    @Test
    void testHash(){
        stringRedisTemplate.opsForHash().put("user:400","name","涛哥");
        stringRedisTemplate.opsForHash().put("user:400","age","20");

        Map<Object, Object> entries = stringRedisTemplate.opsForHash().entries("user:400");
        System.out.println("entries="+entries);

    }
}

在这里插入图片描述


http://www.niftyadmin.cn/n/5547008.html

相关文章

快速上手LangChain：构建强大的语言模型应用

快速上手LangChain：构建强大的语言模型应用

引言 在人工智能和自然语言处理&#xff08;NLP&#xff09;领域&#xff0c;构建高效且强大的语言模型应用变得越来越重要。LangChain 是一个专为开发者设计的框架&#xff0c;它简化了语言模型应用的构建流程。本文将详细介绍LangChain的功能和使用方法&#xff0c;帮助读者…
阅读更多...
C++ 算法——二分查找

C++ 算法——二分查找

如果要你在一个升序序列中查找一个值的位置&#xff0c;你是否还会傻乎乎的用下面这个 O ( n ) \mathcal O(n) O(n) 的代码暴力查找&#xff0c;如果是&#xff0c;我告诉你&#xff0c;其实根本不用这么做。 int find(int a[],int n,int k) {for(int i0;i<n;i) if(a[i]k)…
阅读更多...
Echarts桑基图

Echarts桑基图

关于Echarts的使用方法参考&#xff1a;vue2中echarts的使用_vue2中使用echarts-CSDN博客 实现效果&#xff1a; 代码&#xff1a; var sysT {"用采": #2D9BFF,"营销系统": #39BFFF,"ERP": #76C2FF,"财务管控": #5F57FC,"PMS&…
阅读更多...
正则表达式-使用笔记

正则表达式-使用笔记

正则使用不当&#xff0c;会导致CPU飙升&#xff1b;场景区分&#xff0c;是判断存在还是提取内容&#xff1b;匹配范围&#xff0c;是匹配部分内容还是整行&#xff1b; 一、初识正则 正则表达式 – 语法 | 菜鸟教程 sparksql 正则匹配总结 https://www.cnblogs.com/he1m4n…
阅读更多...
离线运行Llama3：本地部署终极指南_liama2 本地部署

离线运行Llama3：本地部署终极指南_liama2 本地部署

4月18日&#xff0c;Meta在官方博客官宣了Llama3&#xff0c;标志着人工智能领域迈向了一个重要的飞跃。经过笔者的个人体验&#xff0c;Llama3 8B效果已经超越GPT-3.5&#xff0c;最为重要的是&#xff0c;Llama3是开源的&#xff0c;我们可以自己部署&#xff01; 本文和大家…
阅读更多...
【7.29-1800】

【7.29-1800】

B. Missing Subsequence Sum 题意&#xff1a;构造一个长度不超过 25 的序列&#xff0c;保证任意子集的和的集合为 { x ∣ 1 ≤ x < k a n d k < x ≤ n } \{x|1\leq x<k ~and ~ k<x\leq n\} {x∣1≤x<k and k<x≤n} 【不会解决空缺的问题&#xff0c;看…
阅读更多...
gitee及git的简单使用、下载教（保姆级教程）

gitee及git的简单使用、下载教（保姆级教程）

前言&#xff1a; GitHub&#xff0c;一个由外国研发的代码开源网站&#xff0c;我们可以通过它获得别人优秀的项目源码&#xff0c;也可以在上面上传自己的劳动成果。但是&#xff0c;我们很难访问外网。于是&#xff0c;我们将目光转向国内一个类似的网站---码云&#xff08…
阅读更多...
探索多模态预训练：MAnTiS、ActionCLIP、CPT与CoOp的Prompt技巧

探索多模态预训练：MAnTiS、ActionCLIP、CPT与CoOp的Prompt技巧

上一篇博文整理了 预训练新范式&#xff08;Prompt-tuning&#xff0c;Prefix-tuning&#xff0c;P-tuning&#xff09; &#xff0c;主要是围绕NLP上的成果&#xff0c;具体的概念本文也不做过多赘述。本篇文章将主要整理几篇有代表性的Prompt方法在多模态领域中的应用。 Mult…
阅读更多...
最新文章

Copyright @ 2022~2023