SpringBootSample022之springbootdataredislettuce

编程

一、环境

  • Idea 2020.1
  • JDK 1.8
  • maven

二、目的

spring boot 通过lettuce整合redis

gitHub地址:

https://github.com/ouyushan/ouyushan-spring-boot-samples

三、步骤

3.1、点击File -> New Project -> Spring Initializer,点击next

3.2、在对应地方修改自己的项目信息

3.3、选择Web依赖,选中Spring Web、Spring Boot Redis。可以选择Spring Boot版本,本次默认为2.2.7,点击Next

3.4、项目结构

四、添加文件

pom.xml文件

<?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>2.2.7.RELEASE</version>

<relativePath/> <!-- lookup parent from repository -->

</parent>

<groupId>org.ouyushan</groupId>

<artifactId>spring-boot-data-redis-jedis</artifactId>

<version>0.0.1-SNAPSHOT</version>

<name>spring-boot-data-redis-jedis</name>

<description>Jedis project for Spring Boot</description>

<properties>

<java.version>1.8</java.version>

</properties>

<dependencies>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-data-redis</artifactId>

<exclusions>

<exclusion>

<groupId>io.lettuce</groupId>

<artifactId>lettuce-core</artifactId>

</exclusion>

</exclusions>

</dependency>

<dependency>

<groupId>redis.clients</groupId>

<artifactId>jedis</artifactId>

<version>3.3.0</version>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-web</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-test</artifactId>

<scope>test</scope>

<exclusions>

<exclusion>

<groupId>org.junit.vintage</groupId>

<artifactId>junit-vintage-engine</artifactId>

</exclusion>

</exclusions>

</dependency>

</dependencies>

<build>

<plugins>

<plugin>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-maven-plugin</artifactId>

</plugin>

</plugins>

</build>

</project>

application.properties文件

######## REDIS ########

# Redis数据库索引(默认为0)

spring.redis.database=0

# Redis服务器地址

spring.redis.host=127.0.0.1

# Redis服务器连接端口

spring.redis.port=6379

# Redis服务器连接密码(默认为空)

spring.redis.password=

# 连接超时时间(毫秒)

spring.redis.timeout=3000

# 连接池最大连接数(使用负值表示没有限制)

spring.redis.lettuce.pool.max-active=8

# 连接池最大阻塞等待时间(使用负值表示没有限制)

spring.redis.lettuce.pool.max-wait=-1

# 连接池中的最大空闲连接

spring.redis.lettuce.pool.max-idle=8

# 连接池中的最小空闲连接

spring.redis.lettuce.pool.min-idle=0

LettuceRedisConfig.java

package org.ouyushan.springboot.data.redis.lettuce.config;

import com.fasterxml.jackson.annotation.JsonAutoDetect;

import com.fasterxml.jackson.annotation.PropertyAccessor;

import com.fasterxml.jackson.databind.ObjectMapper;

import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;

import org.springframework.cache.CacheManager;

import org.springframework.cache.annotation.EnableCaching;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.data.redis.cache.RedisCacheManager;

import org.springframework.data.redis.connection.RedisConnectionFactory;

import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;

import org.springframework.data.redis.serializer.StringRedisSerializer;

import javax.annotation.Resource;

import java.util.Set;

/**

* @Description:

* @Author: ouyushan

* @Email: ouyushan@hotmail.com

* @Date: 2020/5/11 9:55

*/

@Configuration

@EnableCaching

public class LettuceRedisConfig {

@Resource

private LettuceConnectionFactory lettuceConnectionFactory;

// 缓存管理器

@Bean

public RedisCacheManager cacheManager(RedisConnectionFactory lettuceConnectionFactory) {

RedisCacheManager redisCacheManager = RedisCacheManager.builder(lettuceConnectionFactory).build();

return redisCacheManager;

}

@Bean

public RedisTemplate<Object, Object> redisTemplate(LettuceConnectionFactory lettuceConnectionFactory) {

RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();

redisTemplate.setConnectionFactory(lettuceConnectionFactory);

// key序列化

redisTemplate.setKeySerializer(new StringRedisSerializer());

// 使用Jackson ,将对象序列化为JSON

Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);

//json 转对象类,不设置默认的会将json转成hashmap 报错:java.util.LinkedHashMap cannot be cast to XX

ObjectMapper om = new ObjectMapper();

om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);

om.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL);

jackson2JsonRedisSerializer.setObjectMapper(om);

redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);

redisTemplate.afterPropertiesSet();

return redisTemplate;

}

}

package org.ouyushan.springboot.data.redis.jedis.entity;

import java.io.Serializable;

/**

* @Description:

* @Author: ouyushan

* @Email: ouyushan@hotmail.com

* @Date: 2020/5/9 14:03

*/

public class UserInfo implements Serializable {

private static final long serialVersionUID = -6264728881593912971L;

private Long id;

private String userName;

private String password;

private int age;

public Long getId() {

return id;

}

public void setId(Long id) {

this.id = id;

}

public String getUserName() {

return userName;

}

public void setUserName(String userName) {

this.userName = userName;

}

public String getPassword() {

return password;

}

public void setPassword(String password) {

this.password = password;

}

public int getAge() {

return age;

}

public void setAge(int age) {

this.age = age;

}

@Override

public String toString() {

return "UserInfo{" +

"id=" + id +

", userName="" + userName + """ +

", password="" + password + """ +

", age=" + age +

"}";

}

}

五、测试

运行以下测试用例验证String、Object、List以及Map在redis中的使用

SpringBootDataRedisJedisApplicationTests .java

package org.ouyushan.springboot.data.redis.lettuce;

import org.junit.jupiter.api.Test;

import org.ouyushan.springboot.data.redis.lettuce.entity.UserInfo;

import org.springframework.boot.test.context.SpringBootTest;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.data.redis.core.StringRedisTemplate;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import static org.assertj.core.api.Assertions.assertThat;

@SpringBootTest

class SpringBootDataRedisLettuceApplicationTests {

@Autowired

private StringRedisTemplate stringRedisTemplate;

@Autowired

private RedisTemplate redisTemplate;

@Test

public void testStringRedisTemplateForObject() {

stringRedisTemplate.opsForValue().set("keyString", "valueString");

String value = stringRedisTemplate.opsForValue().get("keyString");

System.out.println(value);

assertThat(value).isEqualTo("valueString");

}

@Test

public void testRedisTemplateForObject() {

UserInfo userInfo = new UserInfo();

userInfo.setAge(24);

userInfo.setId(1L);

userInfo.setUserName("username");

userInfo.setPassword("password");

redisTemplate.opsForValue().set("object", userInfo);

UserInfo userInfoFromRedis = (UserInfo) redisTemplate.opsForValue().get("object");

System.out.println(userInfoFromRedis);

}

@Test

public void testRedisTemplateForList() {

UserInfo userInfo1 = new UserInfo();

userInfo1.setAge(11);

userInfo1.setId(1L);

userInfo1.setUserName("username");

userInfo1.setPassword("password");

UserInfo userInfo2 = new UserInfo();

userInfo2.setAge(21);

userInfo2.setId(2L);

userInfo2.setUserName("username");

userInfo2.setPassword("password");

List<UserInfo> list = new ArrayList<>();

list.add(userInfo1);

list.add(userInfo2);

redisTemplate.opsForValue().set("list", list);

List<UserInfo> userInfoFromRedis = (List) redisTemplate.opsForValue().get("list");

System.out.println(userInfoFromRedis);

}

@Test

public void testRedisTemplateForMap() {

UserInfo userInfo1 = new UserInfo();

userInfo1.setAge(11);

userInfo1.setId(1L);

userInfo1.setUserName("username");

userInfo1.setPassword("password");

UserInfo userInfo2 = new UserInfo();

userInfo2.setAge(22);

userInfo2.setId(2L);

userInfo2.setUserName("username");

userInfo2.setPassword("password");

Map<String, UserInfo> map = new HashMap<>();

map.put("userInfo1", userInfo1);

map.put("userInfo2", userInfo2);

redisTemplate.opsForValue().set("map", map);

Map<String, UserInfo> userInfoFromRedis = (Map<String, UserInfo>) redisTemplate.opsForValue().get("map");

System.out.println(userInfoFromRedis);

}

}

以上是 SpringBootSample022之springbootdataredislettuce 的全部内容, 来源链接: utcz.com/z/517227.html

回到顶部