Idea + Springboot 下 java 對Redis的基本操作。
阿新 • • 發佈:2019-02-14
一、引入redis pom依賴,程式碼如下:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
<version>2.0.0.RELEASE</version>
</dependency>
二、建立config包,在包下建立RedisConfig類,程式碼如下:
@Configuration @EnableCaching public class RedisConfig { @Bean public RedisTemplate<Serializable,Object> redisTemplate(RedisConnectionFactory redisConnectionFactory){ RedisTemplate<Serializable,Object> template = new RedisTemplate<>(); template.setConnectionFactory(redisConnectionFactory); template.afterPropertiesSet(); template.setKeySerializer(new StringRedisSerializer()); template.setValueSerializer(new ObjectRadisSerializer()); return template; } }
注意:
1、@Configuration和@EnableCaching註解,宣告是springboot配置類,和springboot啟動快取的,@Bean是宣告此方法是一個依賴。
2、而RedisTemplate<Serializable,Object> 是用來操作redis 的一個類,RedisConnectionFactory是用來連線redis的一個類,Serializable是可序列化物件,因為redis儲存是以二進位制形式儲存的。
3、template.afterPropertiesSet()是表面在application.properties(在下面會給出)配置檔案載入完成後再執行下面的程式。
三、application.properties配置檔案程式碼如下:
spring.redis.database=0
spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.password=
spring.redis.timeout=2000ms
注意這是redis資料庫的一些配置,在執行上面方法之前先執行此配置連線到redis資料庫。
四、在util包下建立一個序列化POJO物件的類ObjectRedisSerializer,程式碼如下:
public class ObjectRadisSerializer implements RedisSerializer<Object> {
/**
* ObjectRadisSerializer序列化VO物件的類,要實現RedisSerializer介面
* */
/**
* 新建序列化和反序列化物件
* */
private Converter<Object,byte[]> serializer = new SerializingConverter();
private Converter<byte[],Object> deSerializer = new DeserializingConverter();
/***
* 定義一個位元組空陣列
*/
private static final byte[] EMPTY_ARRAY = new byte[0];
/**
* 下面為序列化方法
* @param obj
* @return
* @throws SerializationException
*/
@Override
public byte[] serialize(Object obj) throws SerializationException {
byte[] byteArray = null;
if (obj == null){
byteArray = EMPTY_ARRAY;
}else {
try {
byteArray = serializer.convert(obj);
} catch (Exception e){
System.out.print("==============>redis序列化失敗=======");
byteArray = EMPTY_ARRAY;
}
}
return byteArray;
}
/**
* 這是反序列化的方法
* @param datas
* @return
* @throws SerializationException
*/
@Override
public Object deserialize(byte[] datas) throws SerializationException {
Object object = null;
if (datas == null || datas.length ==0){
System.out.print("=================>redis待反序列化物件為空");
}else {
object = deSerializer.convert(datas);
}
return object;
}
}
注意:要實現RedisSerializer介面,這是redis序列化的一個類。
四、建立POJO物件,此處用User,程式碼如下:
public class User implements Serializable {
private String id;
private String name;
private String password;
private String nickname;
private String gender;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public String getNickname() {
return nickname;
}
public void setNickname(String nickname) {
this.nickname = nickname;
}
public String getGender() {
return gender;
}
public void setGender(String gender) {
this.gender = gender;
}
}
五、測試,程式碼如下:
/**
* 定義操作redis的物件redisTemplate,序列化設定值時要用set,取值要有get
*/
@Autowired
private RedisTemplate<Serializable,Object> redisTemplate;
@RequestMapping("/setPOJO")
public String setPOJO(){
User user = new User();
user.setName("cjx");
user.setPassword("123");
user.setNickname("lhy");
user.setGender("16");
user.setId("001");
redisTemplate.opsForValue().set("love",user);
return "設定成功";
}
@RequestMapping("/getPOJO")
public Object getPOJO(){
if (!redisTemplate.hasKey("love")){
return null;
}else {
return redisTemplate.opsForValue().get("love");
}
}