在porn中配置好 以后,打开application.properties,进行配置
配置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) {//key希望是String,value希望是Object RedisTemplate<String, Object> template = new RedisTemplate<>();//实例化RedisTemplate 这个bean template.setConnectionFactory(factory); // 设置key的序列化方式 template.setKeySerializer(RedisSerializer.string()); // 设置value的序列化方式 template.setValueSerializer(RedisSerializer.json());//因为json()数据是结构化的,恢复过来也很好读取 // 设置hash的key的序列化方式 template.setHashKeySerializer(RedisSerializer.string()); // 设置hash的value的序列化方式 template.setHashValueSerializer(RedisSerializer.json()); template.afterPropertiesSet();//触发以生效 return template; } }
接下来便可以 通过 redisTemplate 访问redis
下面写一个测试类 RedisTests 演示redis
redis 第11个库里面 什么都没有
@Test public void testStrings() { String redisKey = "test:count";//设置key为redisKey redisTemplate.opsForValue().set(redisKey, 1); System.out.println(redisTemplate.opsForValue().get(redisKey));//获取redisKey下的value System.out.println(redisTemplate.opsForValue().increment(redisKey));//将redisKey 下的value加1,因此输出为2 System.out.println(redisTemplate.opsForValue().decrement(redisKey));//将redisKey 下的value减1,因此输出为1 }
此时:
@Test public void testHashes() { String redisKey = "test:user";//声明一个key redisTemplate.opsForHash().put(redisKey, "id", 1);//hk表示哈希key,hv表示哈希value redisTemplate.opsForHash().put(redisKey, "username", "zhangsan"); System.out.println(redisTemplate.opsForHash().get(redisKey, "id")); System.out.println(redisTemplate.opsForHash().get(redisKey, "username")); }
@Test public void testLists() { String redisKey = "test:ids"; redisTemplate.opsForList().leftPush(redisKey, 101);//从左边压入leftPush 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));//获取第0个位置的数据 System.out.println(redisTemplate.opsForList().range(redisKey, 0, 2));//取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, "刘备", "关羽", "张飞", "赵云", "诸葛亮"); 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, "八戒", 50); 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, "八戒"));统计八戒的排名(默认正序由小到大,但此处reverseRank 是按倒序 由大到小) System.out.println(redisTemplate.opsForZSet().reverseRange(redisKey, 0, 2));//取排名在某一范围内的数据(默认正序由小到大,但此处reverseRank 是按倒序) }
@Test public void testKeys() {//访问key的公共命令 redisTemplate.delete("test:user");//删除key System.out.println(redisTemplate.hasKey("test:user"));//判断key是否存在 redisTemplate.expire("test:students", 10, TimeUnit.SECONDS);//针对某一个key设置过期时间,默认ms }
10s以后 students没了
// 多次访问同一个key @Test public void testBoundOperations() {//绑定操作。将一个key绑定到一个对象上,所产生的对象都是绑定对象。 String redisKey = "test:count";//声明key //若想反复访问redisKey,则: BoundValueOperations operations = redisTemplate.boundValueOps(redisKey);//若想访问其他类型的key,则可以变BoundValueOperations 为BoundHashOperations或BoundSetOperations。相应的boundValueOps可以为boundHashOps、boundSetOps //利用对象 operations 访问redis operations.increment();//之前累加是要传入redisKey的,现在不需要了 operations.increment(); operations.increment(); operations.increment(); operations.increment(); System.out.println(operations.get());//结果为6,之前是1,加了5次 }
// 编程式事务 //redis是一个数据库,因此其也是支持事务的。但是他所支持事务的机制 不完全满足acid四个特性,因为只有关系型数据库才会严格满足四个特点 //redis事务管理是比较简单的,事务之内的命令仅在提交前 统一批量执行 //通常采用编程式 事务 @Test public void testTransactional() { Object obj = redisTemplate.execute(new SessionCallback() { @Override public Object execute(RedisOperations operations) throws DataAccessException { String redisKey = "test:tx";//提前定义key operations.multi();//启用事务 operations.opsForSet().add(redisKey, "zhangsan"); operations.opsForSet().add(redisKey, "lisi"); operations.opsForSet().add(redisKey, "wangwu"); System.out.println(operations.opsForSet().members(redisKey));//在方法内部做出查询 return operations.exec(); } }); System.out.println(obj); }
第一次输出就是 在方法内部做出查询
因此在redis事务中 查询是无效的