准备

本人写的spring data是通过maven子父工程管理
parent项目的 : pom.xml

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 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <parent> <artifactId>spring-boot-data</artifactId> <groupId>com.ronnie</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion> <artifactId>spring-data-redis</artifactId> <dependencies> <dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-redis</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!-- fix start java.lang.ClassNotFoundException: io.lettuce.core.AbstractRedisClient --> <dependency> <groupId>io.lettuce</groupId> <artifactId>lettuce-core</artifactId> <version>5.0.3.RELEASE</version> <optional>true</optional> </dependency> <!-- fix end java.lang.ClassNotFoundException: io.lettuce.core.AbstractRedisClient --> </dependencies> </project> 

使用的是lettuce redis连接客户端

配置

package com.ronnie.data.config; import com.ronnie.data.entity.User; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.data.redis.connection.RedisPassword; import org.springframework.data.redis.connection.RedisStandaloneConfiguration; import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer; import org.springframework.data.redis.serializer.StringRedisSerializer; import java.io.Serializable; /** * @Description: * @Author: rongyu * @CreateDate: 2018/9/8$ 16:08$ * @Remark: */ @Configuration public class ApplicationConfig { // TODO remove config of redis to application.yml @Bean public RedisConnectionFactory redisConnectionFactory() { RedisStandaloneConfiguration configuration = new RedisStandaloneConfiguration("192.168.1.12", 6379); RedisPassword redisPassword = RedisPassword.of("lcex123"); configuration.setDatabase(5); configuration.setPassword(redisPassword); return new LettuceConnectionFactory(configuration); } @Bean public RedisTemplate<String, Serializable> redisCacheTemplate(RedisConnectionFactory redisConnectionFactory) { RedisTemplate<String, Serializable> template = new RedisTemplate<>(); template.setKeySerializer(new StringRedisSerializer()); template.setValueSerializer(new GenericJackson2JsonRedisSerializer()); template.setConnectionFactory(redisConnectionFactory); return template; } @Bean public RedisTemplate<String, User> redisUserTemplate(RedisConnectionFactory redisConnectionFactory) { RedisTemplate<String, User> stringUserRedisTemplate = new RedisTemplate<>(); stringUserRedisTemplate.setKeySerializer(new StringRedisSerializer()); stringUserRedisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer()); stringUserRedisTemplate.setConnectionFactory(redisConnectionFactory); return stringUserRedisTemplate; } } 

测试

package com.ronnie.data; import com.ronnie.data.entity.User; import lombok.extern.slf4j.Slf4j; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.ValueOperations; import org.springframework.test.context.junit4.SpringRunner; import java.io.Serializable; @Slf4j @RunWith(SpringRunner.class) @SpringBootTest public class DemoApplicationTests { @Autowired private RedisTemplate<String, Serializable> redisTemplate; @Autowired private RedisTemplate<String, User> userRedisTemplate; @Test public void saveString() { // 保存字符串 redisTemplate.opsForValue().set("a:b:c", "111"); Serializable serializable = redisTemplate.opsForValue().get("a:b:c"); log.info("s={}", serializable); } @Test public void saveUser() { // 保存字符串 User user = new User(); user.setUsername("root"); user.setPassword("root"); ValueOperations<String, User> opsForValue = userRedisTemplate.opsForValue(); opsForValue.set("1", user); User user1 = opsForValue.get("1"); log.info("user={}", user1); } }