IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> SpringBoot整合redis -> 正文阅读

[大数据]SpringBoot整合redis

目录

1.pom文件

2.yml文件

3.创建实体类(要实现序列化接口,否则无法存入redis)

4.config配置文件,直接引入即可,根据情况可修改

5.创建启动类

6.具体操作

6.1 set操作

6.2 get操作

6.3 delete操作

?6.4 列表类型

??6.5?集合类型

?6.6?有序集合类型

6.7 hash类型?

?


1.pom文件

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

2.yml文件

spring:
  redis:
    host: 192.168.16.106
    database: 1
    port: 6379

3.创建实体类(要实现序列化接口,否则无法存入redis)

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

4.config配置文件,直接引入即可,根据情况可修改

存入redis的乱码问题配置文件中解决了(起初我用默认的redisTemplate,出现了乱码问题)

@EnableCaching
@Configuration
public class RedisConfig {
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String, Object> template =  new RedisTemplate<>();
        RedisSerializer<String> redisSerializer =  new StringRedisSerializer();
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer =  new
                Jackson2JsonRedisSerializer(Object.class);
        ObjectMapper om =  new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL , JsonAutoDetect.Visibility.ANY );
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL );
        jackson2JsonRedisSerializer.setObjectMapper(om);
        template.setConnectionFactory(factory);
        //key 序列化方式
        template.setKeySerializer(redisSerializer);
        //value 序列化
        template.setValueSerializer(jackson2JsonRedisSerializer);
        //value hashmap 序列化
        template.setHashValueSerializer(jackson2JsonRedisSerializer);
        return template;
    }
    @Bean
    public CacheManager cacheManager(RedisConnectionFactory factory) {
        RedisSerializer<String> redisSerializer =  new StringRedisSerializer();
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer =  new
                Jackson2JsonRedisSerializer(Object. class);
        //解决查询缓存转换异常的问题
        ObjectMapper om =  new ObjectMapper();
        om.setVisibility(PropertyAccessor. ALL , JsonAutoDetect.Visibility. ANY );
        om.enableDefaultTyping(ObjectMapper.DefaultTyping. NON_FINAL );
        jackson2JsonRedisSerializer.setObjectMapper(om);
        // 配置序列化(解决乱码的问题),过期时间 600 秒
        RedisCacheConfiguration config =
                RedisCacheConfiguration.defaultCacheConfig ()
                        .entryTtl(Duration.ofSeconds (600))
                        .serializeKeysWith(RedisSerializationContext.SerializationPair
                                .fromSerializer (redisSerializer))
                        .serializeValuesWith(RedisSerializationContext.SerializationPair
                                .fromSerializer (jackson2JsonRedisSerializer))
                        .disableCachingNullValues();
        RedisCacheManager cacheManager = RedisCacheManager.builder (factory)
                .cacheDefaults(config)
                .build();
        return cacheManager;
    }
}

5.创建启动类

@SpringBootApplication
public class RedisSpringbootApplication {

    public static void main(String[] args) {
        SpringApplication.run(RedisSpringbootApplication.class, args);
    }
}

6.具体操作

6.1 set操作

@RestController
public class UserController {

    @Autowired
    private RedisTemplate redisTemplate;

    @GetMapping("/set")
    public void set(){
        User user = new User("张三", 12);
        redisTemplate.opsForValue().set("user",user);
    }

}

6.2 get操作

 @GetMapping("/get/{key}")
 public String get(@PathVariable String key){
      Object value = redisTemplate.opsForValue().get(key);
      return value.toString();
 }

6.3 delete操作

@GetMapping("delete/{key}")
public void delete(@PathVariable String key){
     Boolean hasKey = redisTemplate.hasKey(key);
     if(hasKey){
        redisTemplate.delete(key);
     }
}

?6.4 列表类型

@GetMapping("list")
public String list(){
    ListOperations listOperations = redisTemplate.opsForList();
    //从左边添加
    listOperations.leftPush("list","left1");
    listOperations.leftPush("list","left2");
    //从右边添加
    listOperations.rightPush("list", "right1");
    listOperations.rightPush("list", "right2");

    //利用下标来取数据,这里取left和left1
    List<String> list = listOperations.range("list", 0, 3);
    return list.toString();
}

?

??6.5?集合类型

@GetMapping("/set")
public void setTest(){
    SetOperations<String, String> setOperations = redisTemplate.opsForSet();
    setOperations.add("k1", "v1");
    setOperations.add("k1", "v1");
    setOperations.add("k2", "v1");
    setOperations.add("k2", "v2");
    Set<String> k1 = setOperations.members("k1");
    Set<String> k2 = setOperations.members("k2");
    System.out.println(k1);
    System.out.println(k2);
}

?

?6.6?有序集合类型

@GetMapping("/zset")
public void zsetTest(){
    ZSetOperations<String, String> zSetOperations = redisTemplate.opsForZSet();
    zSetOperations.add("k2", "v1", 3);
    zSetOperations.add("k2", "v2", 2);
    zSetOperations.add("k2", "v3", 1);

    Set<String> zset = zSetOperations.range("k2", 0, 2);
    System.out.println(zset);
}

?

6.7 hash类型?

@GetMapping("/hash")
public void hashTest(){
    HashOperations<String, String, String> hashOperations = redisTemplate.opsForHash();
    hashOperations.put("k3","hashKey1","v1");
    hashOperations.put("k3","hashKey2","v2");
    String s1 = hashOperations.get("k3", "hashKey1");
    String s2 = hashOperations.get("k3", "hashKey2");
    System.out.println(s1);
    System.out.println(s2);
}

????????

?

?

?

?

  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2022-06-08 19:06:49  更:2022-06-08 19:09:24 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年5日历 -2024/5/19 23:29:10-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码