SpringBoot整合Mysql和Redis的详细过程，
分享于 点击 20576 次 点评：52
SpringBoot整合Mysql和Redis的详细过程，
目录
- 一、项目创建
- 1.1 创建项目
- 1.2 目录结构
- 1.3 pom.xml配置文件
- 二、初始化数据库
- 三、初始化代码
- 3.1 实体类entity
- 3.2 Mapper接口类
- 3.3 Redis工具类
- 3.4 Service层
- 3.5 Controller层
- 四、单元测试
- 4.1 Respository和Service层单元测试
- 4.2 Controller层接口测试
一、项目创建
1.1 创建项目
在IDEA中，File--New--Project--Spring Initializer
名称为springboot-mysql-redis
1.2 目录结构
1.3 pom.xml配置文件
spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://localhost:3306/mybatis?serverTimezone=UTC
username: root
password: 1234
redis:
host: localhost
port: 6379
server:
port: 8080
mybatis:
mapper-locations: classpath:mapper/*xml
type-aliases-package: com.xsbc.entity
# 开启驼峰命名
configuration:
map-underscore-to-camel-case: true
二、初始化数据库
drop database if exists blog; create database blog; user blog; drop table if exists user; create table user( id int(11) not null, name varchar(255) DEFAULT "", age int(11) DEFAULT 0, PRIMARY KEY(id) )ENGINE=INNODB DEFAULT CHARSET=utf8; insert into user values(1,'小王',20); insert into user values(2,'老李',23);
三、初始化代码
3.1 实体类entity
@Data
@NoArgsConstructor
@AllArgsConstructor
public class User {
private int id;
private String name;
private int age;
}
3.2 Mapper接口类
@Mapper
public interface UserMapper {
List<User> getAllUsers();
int updateUser(Integer id);
}
xml映射文件
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.xsbc.mapper.UserMapper">
<select id="getAllUsers" resultType="com.xsbc.entity.User">
select * from user
</select>
<!-- User类的id参数是int类型，mysql默认是Integer -->
<update id="updateUserAgeById" parameterType="java.lang.Integer">
update user set age=age+2 where id=#{id}
</update>
</mapper>
3.3 Redis工具类
1）config包创建类
Redis常量类RedisConstant
public class RedisConstant {
public static String ALL_USER_KEY="allUser";
}
Redis配置类RedisConfig
@Configuration
public class RedisConfig {
@Resource
private RedisTemplate redisTemplate;
@Bean
public RedisTemplate redisTemplateInit(){
//序列化key的实例化对象
redisTemplate.setKeySerializer(new StringRedisSerializer());
//序列化value的实例化对象
redisTemplate.setValueSerializer(
new GenericJackson2JsonRedisSerializer());
return redisTemplate;
}
}
2）util包下创建类
@Component
public class RedisUtil {
@Resource
private RedisTemplate<String,Object> redisTemplate;
public void setRedisTemplate(RedisTemplate<String,Object> redisTemplate){
this.redisTemplate=redisTemplate;
}
// 指定缓存失效时间
public boolean expire(String key,long time) {
try {
if (time > 0) {
redisTemplate.expire(key, time, TimeUnit.SECONDS);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
// 根据key获取过期时间
public long getExpire(String key){
return redisTemplate.getExpire(key,TimeUnit.SECONDS);
// 判断key是否存在
public boolean hasKey(String key){
return redisTemplate.hasKey(key);
}catch(Exception e){
// 删除缓存
@SuppressWarnings("unchecked")
public void del(String... key){
if (key!=null&&key.length> 0){
if (key.length==1) {
redisTemplate.delete(key[0]);
}else{
redisTemplate.delete(
(Collection<String>)CollectionUtils.arrayToList(key));
// 普通缓存获取
public Object get(String key){
return key==null?null:redisTemplate.opsForValue().get(key);
// 普通缓存放入
public boolean set(String key,Object value){
redisTemplate.opsForValue().set(key,value);
// 普通缓存放入并设置时间
public boolean set(String key,Object value,long time){
try{
if(time>0){
redisTemplate.opsForValue()
.set(key,value,time,TimeUnit.SECONDS);
set(key,value);
// 递增
public long incr(String key,long delta){
if(delta<0){
throw new RuntimeException("递增因子必须大于0");
return redisTemplate.opsForValue().increment(key,delta);
// 递减
public long decr(String key, long delta){
throw new RuntimeException("递减因子必须大于0");
return redisTemplate.opsForValue().increment(key,-delta);
// HashGet
public Object hget(String key,String item){
return redisTemplate.opsForHash().get(key,item);
// 获取hashKey对应的所有键值
public Map<Object, Object> hmget(String key){
return redisTemplate.opsForHash().entries(key);
// HashSet
public boolean hmset(String key,Map<String, Object> map){
redisTemplate.opsForHash().putAll(key,map);
// HashSet 并设置时间
public boolean hmset(String key,Map<String, Object> map,long time){
redisTemplate.opsForHash().putAll(key, map);
if (time>0){
expire(key,time);
// 向一张hash表中放入数据,如果不存在将创建
public boolean hset(String key,String item,Object value){
redisTemplate.opsForHash().put(key,item,value);
public boolean hset(String key,String item,Object value,long time){
// 删除hash表中的值
public void hdel(String key,Object... item) {
redisTemplate.opsForHash().delete(key,item);
// 判断hash表中是否有该项的值
public boolean hHasKey(String key,String item) {
return redisTemplate.opsForHash().hasKey(key,item);
// hash递增 如果不存在,就会创建一个 并把新增后的值返回
public double hincr(String key,String item,double by) {
return redisTemplate.opsForHash().increment(key,item,by);
// hash递减
public double hdecr(String key,String item,double by) {
return redisTemplate.opsForHash().increment(key,item,-by);
// 根据key获取Set中的所有值
public Set<Object> sGet(String key) {
return redisTemplate.opsForSet().members(key);
return null;
// 根据value从一个set中查询,是否存在
public boolean sHasKey(String key,Object value) {
return redisTemplate.opsForSet().isMember(key,value);
// 将数据放入set缓存
public long sSet(String key,Object... values) {
return redisTemplate.opsForSet().add(key,values);
return 0;
// 将set数据放入缓存
public long sSetAndTime(String key,long time,Object... values){
Long count=redisTemplate.opsForSet().add(key,values);
if (time> 0)expire(key, time);
return count;
// 获取set缓存的长度
public long sGetSetSize(String key){
return redisTemplate.opsForSet().size(key);
// 移除值为value的
public long setRemove(String key,Object... values){
Long count=redisTemplate.opsForSet().remove(key,values);
// 获取list缓存的内容
public List<Object> lGet(String key,long start,long end){
return redisTemplate.opsForList().range(key,start,end);
// 获取list缓存的长度
public long lGetListSize(String key){
return redisTemplate.opsForList().size(key);
// 通过索引 获取list中的值
public Object lGetIndex(String key,long index){
return redisTemplate.opsForList().index(key,index);
// 将list放入缓存
public boolean lSet(String key, Object value){
redisTemplate.opsForList().rightPush(key,value);
public boolean lSet(String key,Object value,long time){
if (time > 0) expire(key, time);
public boolean lSet(String key, List<Object> value){
redisTemplate.opsForList().rightPushAll(key,value);
public boolean lSet(String key,List<Object> value,long time){
if(time>0) expire(key, time);
// 根据索引修改list中的某条数据
public boolean lUpdateIndex(String key,long index,Object value){
redisTemplate.opsForList().set(key,index,value);
// 移除N个值为value
public long lRemove(String key,long count,Object value){
Long remove=redisTemplate.opsForList().remove(key,count,value);
return remove;
}
3.4 Service层
1）UserService接口类
public interface UserService {
public List<User> getAllUsers();
public void updateUserAge();
}
2）接口实现类
@Service("userService")
public class UserServiceImpl implements UserService {
@Resource
private UserMapper userMapper;
@Autowired
private RedisUtil redisUtil;
@Override
public List<User> getAllUsers() {
List<User> users=(List<User>)redisUtil
.get(RedisConstant.ALL_USER_KEY);
if(CollectionUtils.isEmpty(users)){
users=userMapper.getAllUsers();
redisUtil.set(RedisConstant.ALL_USER_KEY,users);
}
return users;
}
@Transactional
public void updateUserAge() {
redisUtil.del(RedisConstant.ALL_USER_KEY);
userMapper.updateUserAgeById(1);
userMapper.updateUserAgeById(2);
}
3.5 Controller层
@Controller
public class UserController {
@Autowired
private UserService userService;
@RequestMapping("/getAll")
@ResponseBody
public List<User> getUsers(){
return userService.getAllUsers();
}
@RequestMapping("/update")
@ResponseBody
public int updateUser(){
userService.updateUserAge();
return 1;
}
}
四、单元测试
4.1 Respository和Service层单元测试
@SpringBootTest
class SpringbootMysqlRedisApplicationTests {
@Autowired
private UserMapper userMapper;
private UserService userService;
@Test
void testUserMapper(){
userMapper.updateUserAgeById(1);
List<User> users=userMapper.getAllUsers();
for(User user:users){
System.out.println(user);
}
}
void testUserService(){
userService.updateUserAge();
List<User> users=userService.getAllUsers();
}
4.2 Controller层接口测试
到此这篇关于SpringBoot整合Mysql、Redis的文章就介绍到这了,更多相关SpringBoot整合Mysql、Redis内容请搜索3672js教程以前的文章或继续浏览下面的相关文章希望大家以后多多支持3672js教程！
您可能感兴趣的文章:- SpringBoot整合Redis之编写RedisConfig
- 使用SpringBoot中整合Redis
- SpringBoot整合Redis将对象写入redis的实现
- Spring boot 整合 Redisson实现分布式锁并验证功能
- SpringBoot整合Shiro和Redis的示例代码
- spring boot整合redis主从sentinel方式
- SpringBoot整合Redis实现访问量统计的示例代码
- springboot整合redis实现发送邮箱并验证
- Spring Boot示例代码整合Redis详解
用户点评