1 创建springboot项目
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>2.2.2.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.example</groupId><artifactId>demo</artifactId><version>0.0.1-SNAPSHOT</version><name>demo</name><description>Demo project for Spring Boot</description><properties><java.version>8</java.version></properties><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.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-configuration-processor</artifactId><optional>true</optional></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><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>
3 创建application.yml
#redis的配置
spring:redis:host: 192.168.222.131password: 123456port: 6379jedis:pool:max-active: 20max-idle: 8min-idle: 0max-wait: 20004 测试StringRedisTemplate
package com.example.demo;import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.core.*;import java.util.Collection;
import java.util.List;@SpringBootTest
class ApplicationTests {@Autowiredprivate StringRedisTemplate redisTemplate;@Testvoid contextLoads() {System.out.println(redisTemplate);}@Testvoid flushdb(){redisTemplate.execute(new RedisCallback<String>() {@Overridepublic String doInRedis(RedisConnection connection) throws DataAccessException {connection.flushAll();connection.flushDb();return "ok";}});}@Testvoid testNormal(){redisTemplate.keys("*");redisTemplate.multi();redisTemplate.exec();redisTemplate.watch("");redisTemplate.unwatch();redisTemplate.delete("k1");Collection<String> keys=null;redisTemplate.delete(keys);redisTemplate.randomKey();redisTemplate.rename("oldKey","newKey");redisTemplate.discard();//redisTemplate.getStringSerializer(); //指redis key序列化方式redisTemplate.getValueSerializer(); //指值的序列化方式redisTemplate.getHashKeySerializer();//指hash Vlaue的 key序列化方式 hset(key,key,value)redisTemplate.getHashValueSerializer();//指hash Vlaue的 value序列化方式}@Testvoid testString(){ValueOperations<String, String> opsForValue = redisTemplate.opsForValue();//System.out.println(redisTemplate.getKeySerializer());//System.out.println(redisTemplate.getValueSerializer());//其它方法集RedisOperations<String, String> operations = opsForValue.getOperations();
// opsForValue.get("");
// opsForValue.set("","");
// opsForValue.setIfPresent("","");
// opsForValue.increment("");
// opsForValue.decrement("");
// opsForValue.set("name","xiaoming");System.out.println(opsForValue.get("name"));System.out.println("--------------------------");System.out.println("操作完成");}@Testvoid testList(){ListOperations<String, String> opsForList = this.redisTemplate.opsForList();RedisOperations<String, String> operations = opsForList.getOperations();opsForList.leftPush("","");opsForList.leftPushAll("","","","");opsForList.rightPush("","");opsForList.rightPushAll("","");opsForList.leftPop("");opsForList.rightPop("");List<String> key = opsForList.range("key", 0, -1);}@Testvoid testHash(){HashOperations<String, Object, Object> opsForHash = this.redisTemplate.opsForHash();opsForHash.put("","hashKey","value");opsForHash.get("","hashKey");}@Testvoid testSet(){SetOperations<String, String> opsForSet = this.redisTemplate.opsForSet();opsForSet.add("","");opsForSet.members("");}@Testvoid testZset(){ZSetOperations<String, String> opsForZSet = this.redisTemplate.opsForZSet();opsForZSet.add("key","value",1);}/*** 集群操作*/@Testvoid test(){ClusterOperations<String, String> clusterOperations = this.redisTemplate.opsForCluster();}}
5 创建User
package com.example.demo;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;import java.io.Serializable;
import java.util.Date;@Data
@AllArgsConstructor
@NoArgsConstructor
public class User implements Serializable {private Integer id;private String name;private String address;private Date brith;
}
6 测试RedisTemplate<Object,Object>
序列化接口
若不设置序列化规则，它将使用JDK自动的序列化将对象转换为字节，存到Redis 里面
它可以存在对象到redis里面
如果对象没有序列化，那么默认使用的JDK的序列化方式
package com.example.demo;import org.junit.jupiter.api.Test;
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.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;import java.util.Date;@SpringBootTest
class ApplicationRedisTemplateTests {@Autowiredprivate RedisTemplate redisTemplate;@Testvoid contextLoads() {System.out.println(redisTemplate);System.out.println(redisTemplate.getKeySerializer());System.out.println(redisTemplate.getValueSerializer());}@Testvoid testString(){//这是设置key的序列化方式 因为RedisTemplate<Object,Object> 如果传String key会被当做object进么序列化this.redisTemplate.setKeySerializer(new StringRedisSerializer());ValueOperations opsForValue = redisTemplate.opsForValue();opsForValue.set("user:1".toString(),new User(1,"xiaoming","wh",new Date()));User user = (User) opsForValue.get("user:1");System.out.println(user);System.out.println("操作成功");}@Testvoid testString2(){//这是设置key的序列化方式 因为RedisTemplate<Object,Object> 如果传String key会被当做object进么序列化this.redisTemplate.setKeySerializer(new StringRedisSerializer());this.redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());ValueOperations opsForValue = redisTemplate.opsForValue();//opsForValue.set("user:2".toString(),new User(1,"xiaoming","wh",new Date()));User user = (User) opsForValue.get("user:2");System.out.println(user);System.out.println("操作成功");}
}
