springboot整合redis,springboot连接redis集群

package com.txc.controller; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import org.springframework.data.redis.core.*; import org.springframework.stereotype.Controller; import org.springframework.util.StringUtils; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; import java.sql.Date; import java.util.*; import java.util.concurrent.TimeUnit; @Controller public class TestController { @Resource private RedisTemplate redisTemplate; //redsiTemplate操作，通用命令 @RequestMapping("/testGe") @ResponseBody public void testGe() { //获取指定的keyz值，如*，??list,keys* redisTemplate.keys(""); //删除指定的key redisTemplate.delete(""); //给key重命名 redisTemplate.rename("",""); //设置key的有效期 redisTemplate.expire("username",3000,TimeUnit.SECONDS); //获取key的有效期 redisTemplate.getExpire("username",TimeUnit.SECONDS); //清楚key的有效期 redisTemplate.persist("username"); //判断key的类型 redisTemplate.type(""); } //redsiTemplate操作set类型数据 @RequestMapping("/testZSET") @ResponseBody public void testZSET(){ ZSetOperations<String,Object> opsZSET= redisTemplate.opsForZSet(); //向集合zset中添加值java，且分数score设置为1 opsZSET.add("zset","java",1); //获取java的score Double score1=opsZSET.score("zset","java"); //获取zset中成员的数量 long count=opsZSET.zCard("zset"); //删除zset集合中的java String []arr={"java"}; opsZSET.remove("zset"); //按照范围删除，-1表示最后 opsZSET.removeRange("zset",0,-1); //删除集合zset中score在20-30的所有数据 opsZSET.removeRangeByScore("zset",20,30); //按照score从到小返回数据 Set<Object> sets=opsZSET.reverseRange("zset",0,-1); Iterator<Object> ites= sets.iterator(); while(ites.hasNext()){ System.out.println(ites.next()); } //返回集合zset中20-30的数据，且按照从低到高排序 opsZSET.rangeByScore("zset",20,30); //为集合zset中java的score值增加5 opsZSET.incrementScore("zset","java",5); //获取分数在20-30之间的成员 opsZSET.count("zset",20,30); //按照从小到大规则，返回java在集合zset中的排名 opsZSET.rank("zset","java"); //按照从大到小规则，返回java在集合zset中的排名 opsZSET.reverseRank("zset","java"); } //redsiTemplate操作set类型数据 @RequestMapping("/testSet") @ResponseBody public void testSet() throws Exception { SetOperations<String,Object> opsSet=redisTemplate.opsForSet(); //向test中添加三个参数 String []arr={"a","b","c"}; opsSet.add("test",arr); //移出rest中的a值 String []arr1={"a"}; opsSet.remove("test",arr1); //查询出test中的所有数据，并通过迭代器遍历数据 Set<Object> sets=opsSet.members("test"); Iterator<Object> ites= sets.iterator(); while(ites.hasNext()){ System.out.println(ites.next()); } //随机获取test中的两个值，但是不删除元数据 opsSet.randomMembers("test",2); //计算出test和test1的差运算值 opsSet.difference("test","test1"); //将test和test1的差值存入test2中 opsSet.differenceAndStore("test","test1","test2"); //计算test和test1的交集 opsSet.intersect("test","test1"); //将test和test1的交集存入test2中 opsSet.intersectAndStore("test","test1","test2"); //计算test和test1的并集 opsSet.union("test","test1"); //将test和test1的并集存入test2中 opsSet.unionAndStore("test","test1","test2"); //获取test中u安苏的个数 opsSet.size("test"); //从test中随机弹出一个数，且删除元数据 opsSet.pop("test",1); //将test中的a值移入到test1中 opsSet.move("test","a","test1"); //从集合中随机弹出两个数，不删除元数据 opsSet.randomMembers("test",2); } //redsiTemplate操作List类型数据 @RequestMapping("/testList") @ResponseBody public void testList() throws Exception { ListOperations<String,Object> opsList=redisTemplate.opsForList(); /*//向列表list左边添加值1 opsList.leftPush("list","1"); //向列表list左边添加多个值 String []a={"3","4","5"}; opsList.leftPushAll("list",a); //向列表list右边边添加值 opsList.rightPush("list","1"); //向列表list右边添加多个值 String []b={"7","8","9"}; opsList.rightPushAll("list",b);*/ //从集合的左边弹出三个数，并从结合中删除这三个元素，如：[5, 4, 3] List<Object> mvalue=opsList.leftPop("list",3); System.out.println(mvalue); //从集合的右边弹出三个数，并从结合中删除这三个元素 opsList.rightPop("list",3); //将集合list右边的值弹出，移动到list1的左边 opsList.rightPopAndLeftPush("list","list"); } //数据缓存值redis,String类型 @RequestMapping("/testString") @ResponseBody public void testString() throws Exception { System.out.println("======132========="); //创建操作字符串类型数据的对象 ValueOperations opsString=redisTemplate.opsForValue(); //使用1、添加一条key为username,值为shiyilang的String opsString.set("username", "shiyilang"); //使用2、查询key为username的值 opsString.get("username"); //使用3：multiSet同时添加多个key和value Map<String,Object> map=new HashMap<String,Object>(); map.put("a","123"); map.put("b","234"); opsString.multiSet(map); //使用4：添加key：username,value:晓春qie数据有效期为30秒 opsString.set("username","xiaochun",3000,TimeUnit.SECONDS); //使用6：getAndSet取值之后，重新赋值为大春 opsString.getAndSet("username","大春"); //使用7：为sex的值增加2 opsString.increment("sex",2); //使用8：为sex的值增加减2 opsString.decrement("sex",3); } //添加hash类型的参数及过期时间 @RequestMapping("/testHash") @ResponseBody public void testHash() { HashOperations opsHash=redisTemplate.opsForHash(); //用法1:put->添加一条hash参数，key为id,value为1001 opsHash.put("stu1","id","1001"); Map<String,Object> map=new HashMap<String,Object>(); map.put("id","123"); map.put("name","晓春"); map.put("sex","1"); //用法2：putAll->：同时向stu1中添加多条数据 opsHash.putAll("stu1",map); //用法3：get->获取stu1中key为name的值 opsHash.get("stu1","name"); //用法4：increment->为stu1中sex的值增加2 opsHash.increment("stu1","sex",2); //用法5：delete->删除stu1中的name opsHash.delete("stu1","name"); //用法6：获取stu1中所有的key和value Map<String,Object> allKeyAndValue=opsHash.entries("stu1"); //用法7：multiGet->获取stu1中，id和name的值