Springboot 通过Template 整合 redis
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了Springboot 通过Template 整合 redis，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含6439字，纯文字阅读大概需要10分钟。
内容图文
前言
在springboot框架中，通过RedisTemplate中封装好的方法去操作redis中的各种数据类型，完成增删改查操作。
本项目将数据序列化为json格式，分别以set、zset、hash的结构存入数据库中，完成查询所有数据、通过id查询单个数据，新增数据的操作。
实体类
public class User {
private int id;
private String name;
private String password;
}
yml配置文件
用于配置redis的ip、端口、数据库、连接池等
spring:
redis:
port: 6379
host: 127.0.0.1
database: 1
password: 123456
jedis:
pool:
max-active: 8
max-idle: 8
max-wait: 1ms
timeout: 5000ms
config配置
将实体类数据序列化为json格式
import java.text.SimpleDateFormat;
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.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import com.fasterxml.jackson.databind.ObjectMapper;
@Configuration
public class RedisConfig {
@Bean
public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory){
RedisTemplate<Object, Object> template = new RedisTemplate<>();
//ObjectMapper 指定在转成json的时候的一些转换规则
ObjectMapper objectMapper = new ObjectMapper();
objectMapper.setDateFormat(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"));
template.setConnectionFactory(redisConnectionFactory);
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
// 把自定义的objectMapper设置到jackson2JsonRedisSerializer
jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
// RedisTemplate默认的序列化方式使用的是jdk的序列化
// 设置了key的序列化方式
template.setKeySerializer(new StringRedisSerializer());
template.setHashKeySerializer(jackson2JsonRedisSerializer); // 配置hash格式
// 设置了value序列化方式
template.setValueSerializer(jackson2JsonRedisSerializer);
template.setHashValueSerializer(jackson2JsonRedisSerializer); // 配置hash格式
return template;
}
}
在启动类中需要使用@ComponentScan(）注解扫描配置文件
hash
@RestController
@RequestMapping("/user")
public class UserController {
@Autowired
private UserService userService;
@Autowired
private RedisTemplate redisTemplate;
/**
* 获取所有数据
*
* @return
*/
@RequestMapping("/getuser")
public AjaxMessage getUserList() {
// 设置过期时间
redisTemplate.expire("userHash", 5, TimeUnit.SECONDS);
if (redisTemplate.opsForHash().size("userHash") <= 0) {
// 如果redis缓存没有，则去数据库中寻找
List<User> userList = userService.queryAllUsers();
if (userList == null) {
return new AjaxMessage(false, "没有数据", null);
} else {
for (User user : userList) {
redisTemplate.opsForHash().put("userHash", user.getId(), user);
}
return new AjaxMessage(true, "从sqlserver获取的数据", userList);
}
} else {
// 直接从redis中获取数据
return new AjaxMessage(true, "从Redis获取userHash数据", redisTemplate.opsForHash().values("userHash"));
}
}
/**
* 根据id获取单条数据
* @param id
* @return
*/
@RequestMapping("/getuserid/{id}")
public AjaxMessage getUser(@PathVariable("id") int id) {
// User user = userService.querUserById(id);
// if (user != null) {
// return new AjaxMessage(true, "", user);
// }else {
// return new AjaxMessage(false, "没有数据", null);
// }
return new AjaxMessage(true, "从Redis获取userHash数据", redisTemplate.opsForHash().get("userHash", id));
}
/**
* 添加数据
* @param user
* @return
*/
@RequestMapping("/add")
public String addUser(@RequestBody User user) {
int res = userService.addUser(user);
if (res > 0) {
// 添加成功后，将数据写入redis数据库
redisTemplate.opsForHash().put("userHash", user.getId(), user);
return "添加成功";
} else {
return "添加失败";
}
}
}
zset
@RestController
@RequestMapping("/user")
public class UserController {
@Autowired
private UserService userService;
@Autowired
private RedisTemplate redisTemplate;
/**
* 获取所有数据
* @return
*/
@RequestMapping("/getuser")
public AjaxMessage getUserList() {
if (redisTemplate.opsForZSet().zCard("userZset")<=0) {
// 如果redis缓存没有，则去数据库中寻找
List<User> userList = userService.queryAllUsers();
if (userList == null) {
return new AjaxMessage(false, "没有数据", null);
} else {
for (User user : userList) {
redisTemplate.opsForZSet().add("userZset", user,user.getId());
}
return new AjaxMessage(true, "从sqlserver获取的数据", userList);
}
}else {
// 直接从redis中获取数据
return new AjaxMessage(true,"从Redis获取的userZset数据",redisTemplate.opsForZSet().range("userZset", 0, -1));
}
}
/**
* 根据id获取单条数据
* @param password
* @return
*/
@RequestMapping("/getuserid/{id}")
public AjaxMessage getUser(@PathVariable("id") int id) {
// User user = userService.querUserById(id);
// if (user != null) {
// return new AjaxMessage(true, "", user);
// }else {
// return new AjaxMessage(false, "没有数据", null);
// }
return new AjaxMessage(true,"从Redis中获取userZset数据",redisTemplate.opsForZSet().range("userZset", id-1, id-1));
}
/**
* 添加数据
* @param user
* @return
*/
@RequestMapping("/add")
public String addUser(@RequestBody User user) {
int res = userService.addUser(user);
if(res>0) {
// 添加成功后，将数据写入redis数据库
redisTemplate.opsForZSet().add("userZset", user, user.getId());
return "添加成功";
}else {
return "添加失败";
}
}
}
set
使用set格式，无法根据id获取指定数据
@RestController
@RequestMapping("/user")
public class UserController {
@Autowired
private UserService userService;
@Autowired
private RedisTemplate redisTemplate;
/**
* 查询所有数据
* @return
*/
@RequestMapping("/getuser")
public AjaxMessage getUserList() {
if (redisTemplate.opsForSet().size("userSet")<=0) {
// 如果redis缓存没有，则去数据库中寻找
List<User> userList = userService.queryAllUsers();
if (userList == null) {
return new AjaxMessage(false, "没有数据", null);
} else {
for (User user : userList) {
redisTemplate.opsForSet().add("userSet", user);
}
return new AjaxMessage(true, "从sqlserver获取的数据", userList);
}
}
else {
// 直接从redis中获取数据
return new AjaxMessage(true,"从Redis中获取userSet数据",redisTemplate.opsForSet().members("userSet"));
}
}
/**
* 添加数据
* @param user
* @return
*/
@RequestMapping("/add")
public String addUser(@RequestBody User user) {
int res = userService.addUser(user);
if (res > 0) {
// 添加成功后，将数据写入redis数据库
redisTemplate.opsForSet().add("userSet", user);
return "添加成功";
} else {
return "添加失败";
}
}
}
注意
执行添加操作时要注意，当sqlserver数据库添加成功而redis添加失败的情况。
在hash、set、zset中，zset既要排序又要查重，对内存的消耗是最大的，所以一般不使用。
内容总结
以上是互联网集市为您收集整理的Springboot 通过Template 整合 redis全部内容，希望文章能够帮你解决Springboot 通过Template 整合 redis所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。
来源：【匿名】