目录
一、创建项目引入依赖
二、controller层编写
(1)String类型相关操作测试:
(2)List类型相关操作测试:
(3)Set类型相关操作测试:
(4)Hash类型相关操作测试:
(5)ZSet类型相关操作测试:
三、注意事项
一、创建项目引入依赖
二、controller层编写
以下基本都是通过注入的RedisTemplate对象调用相应的方法来对应redis的原始命令来操作redis服务器。
(1)String类型相关操作测试:
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ZSetOperations;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import java.util.Set;
@RestController
public class MyController {
@Autowired
private RedisTemplate redisTemplate;
@RequestMapping("/testString")
@ResponseBody
public String testString() {
redisTemplate.opsForValue().set("key", "111");
redisTemplate.opsForValue().set("key2", "222");
redisTemplate.opsForValue().set("key3", "333");
String value = (String) redisTemplate.opsForValue().get("key");
System.out.println(value);
return "ok";
}
(2)List类型相关操作测试:
@RequestMapping("/testList")
@ResponseBody
public String testList() {
//清楚之前的数据
redisTemplate.execute((RedisConnection redisConnection)->{
//excute 要求回调方法中必须写 return语句,返回个东西
//这个回调返回的对象,就会作为excute本身的返回值。
redisConnection.flushAll();
return null;
});
redisTemplate.opsForList().leftPush("key", "111");
redisTemplate.opsForList().leftPush("key", "222");
redisTemplate.opsForList().leftPush("key", "333");
String value = (String) redisTemplate.opsForList().leftPop("key");
System.out.println(value);
value = (String) redisTemplate.opsForList().leftPop("key");
System.out.println(value);
return "ok";
}
(3)Set类型相关操作测试:
@RequestMapping("/testSet")
@ResponseBody
public String testSet(){
redisTemplate.execute((RedisConnection connection)->{
connection.flushAll();
return null;
});
redisTemplate.opsForSet().add("key","111","222","333");
Set<String> result = redisTemplate.opsForSet().members("key");
System.out.println("result:"+result);
Boolean exists = redisTemplate.opsForSet().isMember("key","111");
System.out.println("exists:"+exists);
long count = redisTemplate.opsForSet().size("key");
System.out.println("count:"+count);
redisTemplate.opsForSet().remove("key","111","222");
result = redisTemplate.opsForSet().members("key");
System.out.println(result);
return "ok";
}
(4)Hash类型相关操作测试:
@RequestMapping("/testHash")
@ResponseBody
public String testHash(){
redisTemplate.execute((RedisConnection connection)->{
connection.flushAll();
return null;
});
redisTemplate.opsForHash().put("key","f1","111");
redisTemplate.opsForHash().put("key","f2","222");
redisTemplate.opsForHash().put("key","f3","333");
String value = (String) redisTemplate.opsForHash().get("key","f2");
System.out.println("value:"+value);
Boolean exists = redisTemplate.opsForHash().hasKey("key","f1");
System.out.println("exists:"+exists);
redisTemplate.opsForHash().delete("key","f3","f2");
Long size = redisTemplate.opsForHash().size("key");
System.out.println("size:"+size);
return "OK";
}
(5)ZSet类型相关操作测试:
@RequestMapping("/testZSet")
@ResponseBody
public String testZSet(){
redisTemplate.execute((RedisConnection connection)->{
connection.flushAll();
return null;
});
redisTemplate.opsForZSet().add("key","kzf",88);
redisTemplate.opsForZSet().add("key","whx",77);
redisTemplate.opsForZSet().add("key","lyz",85);
Set<String>members = redisTemplate.opsForZSet().range("key", 0, -1);
System.out.println("members:"+members);
Set<ZSetOperations.TypedTuple<String>>membersWithScore = redisTemplate.opsForZSet().rangeWithScores("key",0,-1);
System.out.println("membersWithScore:"+membersWithScore);
Double score = redisTemplate.opsForZSet().score("key","lyz");
System.out.println("score:"+score);
redisTemplate.opsForZSet().remove("key","kzf");
Long size = redisTemplate.opsForZSet().size("key");
System.out.println("size:"+size);
Long rank = redisTemplate.opsForZSet().rank("key", "whx");
System.out.println("rank:"+rank);
return "OK";
}
三、注意事项
运行此springboot项目时,需要保持xshell之类的终端与云服务器的redis保持好连接,这样才能进行端口映射,从而转发操作命名。
未进行正确连接结果如下: