1. 在config中加入RedisConfig配置類
package com.nowcoder.community.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.RedisSerializer;
@Configuration
public class RedisConfig {
@Bean
public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory factory){
RedisTemplate<String, Object> template = new RedisTemplate<>();
template.setConnectionFactory(factory);
// 設(shè)置Key的序列化方式
template.setKeySerializer(RedisSerializer.string());
// 設(shè)置value的序列化方式
template.setValueSerializer(RedisSerializer.json());
// 設(shè)置hash的key的序列化方式
template.setHashKeySerializer(RedisSerializer.json());
// 設(shè)置hash的value的序列化方式
template.setHashValueSerializer(RedisSerializer.json());
template.afterPropertiesSet();
return template;
}
}
2. 寫個測試類測試一下
package com.nowcoder.community;
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.dao.DataAccessException;
import org.springframework.data.redis.core.*;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringRunner;
import java.util.concurrent.TimeUnit;
@RunWith(SpringRunner.class)
@SpringBootTest
@ContextConfiguration(classes = CommunityApplication.class)
public class RedisTests {
@Autowired
private RedisTemplate redisTemplate;
@Test
public void testStrings(){
String redisKey = "test:count";
redisTemplate.opsForValue().set(redisKey, 1);
System.out.println(redisTemplate.opsForValue().get(redisKey));
System.out.println(redisTemplate.opsForValue().increment(redisKey));
System.out.println(redisTemplate.opsForValue().decrement(redisKey));
}
@Test
public void testHash(){
String redisKey = "test:user";
redisTemplate.opsForHash().put(redisKey,"id",1);
redisTemplate.opsForHash().put(redisKey,"name","katniss");
redisTemplate.opsForHash().put(redisKey,"age",24);
System.out.println(redisTemplate.opsForHash().get(redisKey,"id"));
System.out.println(redisTemplate.opsForHash().get(redisKey,"name"));
System.out.println(redisTemplate.opsForHash().get(redisKey,"age"));
}
@Test
public void testLists(){
String redisKey = "test:ids";
redisTemplate.opsForList().leftPush(redisKey,101);
redisTemplate.opsForList().leftPush(redisKey,102);
redisTemplate.opsForList().leftPush(redisKey,103);
System.out.println(redisTemplate.opsForList().size(redisKey));
System.out.println(redisTemplate.opsForList().index(redisKey,0));
System.out.println(redisTemplate.opsForList().range(redisKey,0,2));
System.out.println(redisTemplate.opsForList().leftPop(redisKey));
System.out.println(redisTemplate.opsForList().leftPop(redisKey));
System.out.println(redisTemplate.opsForList().leftPop(redisKey));
}
@Test
public void testSets(){
String redisKey = "test:teachers";
redisTemplate.opsForSet().add(redisKey,"111","222","333","444","555");
System.out.println(redisTemplate.opsForSet().size(redisKey));
System.out.println(redisTemplate.opsForSet().pop(redisKey));
System.out.println(redisTemplate.opsForSet().members(redisKey));
}
@Test
public void testSortedSets(){
String redisKey = "test:students";
redisTemplate.opsForZSet().add(redisKey, "唐僧", 80);
redisTemplate.opsForZSet().add(redisKey, "悟空", 90);
redisTemplate.opsForZSet().add(redisKey, "八戒", 70);
redisTemplate.opsForZSet().add(redisKey, "沙僧", 60);
System.out.println(redisTemplate.opsForZSet().zCard(redisKey));
System.out.println(redisTemplate.opsForZSet().score(redisKey,"悟空"));
System.out.println(redisTemplate.opsForZSet().reverseRank(redisKey,"八戒"));
System.out.println(redisTemplate.opsForZSet().reverseRange(redisKey,0,2));
}
@Test
public void testKeys(){
System.out.println(redisTemplate.hasKey("test:user"));
redisTemplate.delete("test:user");
System.out.println(redisTemplate.hasKey("test:user"));
redisTemplate.expire("test:students",10, TimeUnit.SECONDS);
}
// 多次訪問同一個Key
@Test
public void testBoundOperations(){
String redisKey = "test:count";
BoundValueOperations operations = redisTemplate.boundValueOps(redisKey);
operations.increment();
operations.increment();
operations.increment();
operations.increment();
operations.increment();
operations.increment();
System.out.println(operations.get());
}
// 編程式事務(wù)
@Test
public void testTransaction(){
Object obj = redisTemplate.execute(new SessionCallback() {
@Override
public Object execute(RedisOperations operations) throws DataAccessException {
String redisKey = "test:tx";
operations.multi();
operations.opsForSet().add(redisKey,"zhangsan");
operations.opsForSet().add(redisKey,"lisi");
operations.opsForSet().add(redisKey,"wangwu");
System.println.out(operations.opsForSet().members(redisKey));
return operations.exec();
}
});
System.out.println(obj);
}
}
3. 注意事項
- Redis不滿足事務(wù)的原子性,原子性是指事務(wù)要么被全部執(zhí)行,要么都不執(zhí)行。但是Redis不支持回滾,就可能會出現(xiàn)有些語句執(zhí)行成功,有些執(zhí)行失敗,因此具備原子性;
- Redis事務(wù)的三個階段:
- 開始事務(wù)
- 命令入隊
- 順序執(zhí)行
- 用Redis管理事務(wù)的時候中間不要做查詢,查詢會被執(zhí)行但無效。例如在
testTransaction
方法中,operations.opsForSet().members(redisKey)
將返回空。
文章來源地址http://www.zghlxwxcb.cn/news/detail-697480.html
文章來源:http://www.zghlxwxcb.cn/news/detail-697480.html
到了這里,關(guān)于【Java Web】利用Spring整合Redis,配置RedisTemplate的文章就介紹完了。如果您還想了解更多內(nèi)容,請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!