Table des matières
SpringBoot intégré Redis
1. Ajouter une dépendance redis
2. Dans l'application. Ajoutez des informations de configuration Redis aux propriétés
3. Ajoutez une configuration d'annotation à la classe de démarrage SpringBoot
4. Créez une classe d'entité Entity
5. Créer une couche Dao - couche d'opération de données
6. Créer une couche de service - couche de service
7. Créer une couche de contrôleur - couche de contrôle
. 8.classe de configuration redis
La structure dans Redis est
redis outils d'encapsulation
Maison base de données Redis Comment SpringBoot intègre Redis pour utiliser RedisRepositories

Comment SpringBoot intègre Redis pour utiliser RedisRepositories

May 26, 2023 pm 12:50 PM
redis springboot

    SpringBoot intégré Redis

    1. Ajouter une dépendance redis

    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
    <dependency>
      <groupId>org.apache.commons</groupId>
      <artifactId>commons-pool2</artifactId>
    </dependency>
    Copier après la connexion

    2. Dans l'application. Ajoutez des informations de configuration Redis aux propriétés

    spring.redis.host=127.0.0.1
    # Redis服务器连接端口
    spring.redis.port=6379
    # Redis服务器连接密码(默认为空)
    spring.redis.password=
    # 连接池最大连接数(使用负值表示没有限制)
    spring.redis.lettuce.pool.max-active=8
    # 连接池最大阻塞等待时间(使用负值表示没有限制)
    spring.redis.lettuce.pool.max-wait=-1
    # 连接池中的最大空闲连接
    spring.redis.lettuce.pool.max-idle=8
    # 连接池中的最小空闲连接
    spring.redis.lettuce.pool.min-idle=0
    # 连接超时时间(毫秒)
    spring.redis.timeout=30000
    Copier après la connexion

    3. Ajoutez une configuration d'annotation à la classe de démarrage SpringBoot

    @EnableCaching
    @EnableRedisRepositories
    //注解开启使用RedisRepositories
    //CRUD操作将会操作redis中的数据
    @SpringBootApplication
    public class RedisApplication {
     
        public static void main(String[] args) {
            SpringApplication.run(RedisApplication.class, args);
        } 
    }
    Copier après la connexion

    4. Créez une classe d'entité Entity

    @Data
    @RedisHash("user")
    //RedisHash非常重要
    //user表示在redis中新建user集合
    //之后所有的UserEntity的保存操作全部会保存在user这个集合中
    //保存时Key的格式为——user:id
    public class UserEntity{
        @Id
        private Long id; 
        private String name; 
        private Integer age; 
        private Date createTime = new Date();
    }
    Copier après la connexion

    5. Créer une couche Dao - couche d'opération de données

    @Repository
    public interface UserDao extends CrudRepository<UserEntity,Long> {
    }
    Copier après la connexion

    6. Créer une couche de service - couche de service

    @Service
    public class UserService {
     
        @Autowired
        private UserDao userDao;
     
    //因为使用了RedisRepositories,所以简单的crud将不用使用RedisTemplate
    //    @Autowired
    //    private RedisTemplate redisTemplate; 
     
        /**
         * 按user:id的方式存入redis
         * @param user
         */
        public void save(UserEntity user){
            //redisTemplate.opsForValue().set(new Random().nextDouble() + "",user); 
            userDao.save(user); 
        }
     
        /**
         * 根据key从redis中查找对应value
         * @param id
         * @return
         */
        public UserEntity findOne(Long id){ 
            //UserEntity user = (UserEntity) redisTemplate.opsForValue().get(key); 
            UserEntity user = userDao.findById(id).get(); 
            return user;
        }
    }
    Copier après la connexion

    7. Créer une couche de contrôleur - couche de contrôle

    @RestController
    @RequestMapping("user")
    public class UserController {
     
        @Autowired
        private UserService userService;
     
        /**
         * 保存到redis中
         * @return
         */
        @GetMapping("save")
        public String save(){
     
            UserEntity user = new UserEntity(); 
            user.setName(String.valueOf(new Random().nextInt(100000))); 
            user.setAge(new Random().nextInt(100000)); 
            userService.save(user); 
            System.out.println(user.toString()); 
            return "success";
        }
     
        /**
         * 根据key从redis中查找value
         * @param id
         * @return
         */
        @GetMapping("find/{id}")
        public String find(@PathVariable Long id){
           UserEntity user = userService.findOne(id);
     
            System.out.println(user);
            return "success";
        }
    }
    Copier après la connexion

    . 8.classe de configuration redis

    @Configuration
    public class RedisConfig {
     
        @Bean
        public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
            RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
            template.setConnectionFactory(factory);
            Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
            ObjectMapper om = new ObjectMapper();
            om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
            om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
            jackson2JsonRedisSerializer.setObjectMapper(om);
            StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
            // key采用String的序列化方式
            template.setKeySerializer(stringRedisSerializer);
            // hash的key也采用String的序列化方式
            template.setHashKeySerializer(stringRedisSerializer);
            // value序列化方式采用jackson
            template.setValueSerializer(jackson2JsonRedisSerializer);
            // hash的value序列化方式采用jackson
            template.setHashValueSerializer(jackson2JsonRedisSerializer);
            template.afterPropertiesSet();
            return template;
        }
    }
    Copier après la connexion

    La structure dans Redis est

    Comment SpringBoot intègre Redis pour utiliser RedisRepositories

    redis outils d'encapsulation

    @Component
    public class RedisUtils {
     
    	@Autowired
    	private RedisTemplate<String, Object> redisTemplate;
     
    	// =============================common============================
     
    	/**
    	 * 指定缓存失效时间
    	 *
    	 * @param key  键
    	 * @param time 时间(秒)
    	 * @return
    	 */
    	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 获取过期时间
    	 *
    	 * @param key 键 不能为null
    	 * @return 时间(秒) 返回0代表为永久有效
    	 */
    	public long getExpire(String key) {
    		return redisTemplate.getExpire(key, TimeUnit.SECONDS);
    	}
     
    	/**
    	 * 判断key是否存在
    	 *
    	 * @param key 键
    	 * @return true 存在 false不存在
    	 */
    	public boolean hasKey(String key) {
    		try {
    			return redisTemplate.hasKey(key);
    		} catch (Exception e) {
    			e.printStackTrace();
    			return false;
    		}
    	}
     
    	/**
    	 * 删除缓存
    	 *
    	 * @param key 可以传一个值 或多个
    	 */
    	@SuppressWarnings("unchecked")
    	public void del(String... key) {
    		if (key != null && key.length > 0) {
    			if (key.length == 1) {
    				redisTemplate.delete(key[0]);
    			} else {
    				redisTemplate.delete(CollectionUtils.arrayToList(key));
    			}
    		}
    	}
    	// ============================String=============================
     
    	/**
    	 * 普通缓存获取
    	 *
    	 * @param key 键
    	 * @return 值
    	 */
    	public  Object get(String key) {
    		return key == null ? null : redisTemplate.opsForValue().get(key);
    	}
     
    	/**
    	 * 普通缓存放入
    	 *
    	 * @param key   键
    	 * @param value 值
    	 * @return true成功 false失败
    	 */
    	public boolean set(String key, Object value) {
    		try {
    			redisTemplate.opsForValue().set(key, value);
    			return true;
    		} catch (Exception e) {
    			e.printStackTrace();
    			return false;
    		}
    	}
     
    	/**
    	 * 普通缓存放入并设置时间
    	 *
    	 * @param key   键
    	 * @param value 值
    	 * @param time  时间(秒) time要大于0 如果time小于等于0 将设置无限期
    	 * @return true成功 false 失败
    	 */
    	public boolean set(String key, Object value, long time) {
    		try {
    			if (time > 0) {
    				redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
    			} else {
    				set(key, value);
    			}
    			return true;
    		} catch (Exception e) {
    			e.printStackTrace();
    			return false;
    		}
    	}
     
    	/**
    	 * 递增
    	 *
    	 * @param key   键
    	 * @param delta 要增加几(大于0)
    	 * @return
    	 */
    	public long incr(String key, long delta) {
    		if (delta < 0) {
    			throw new RuntimeException("递增因子必须大于0");
    		}
    		return redisTemplate.opsForValue().increment(key, delta);
    	}
     
    	/**
    	 * 递减
    	 *
    	 * @param key   键
    	 * @param delta 要减少几(小于0)
    	 * @return
    	 */
    	public long decr(String key, long delta) {
    		if (delta < 0) {
    			throw new RuntimeException("递减因子必须大于0");
    		}
    		return redisTemplate.opsForValue().increment(key, -delta);
    	}
    	// ================================Map=================================
     
    	/**
    	 * HashGet
    	 *
    	 * @param key  键 不能为null
    	 * @param item 项 不能为null
    	 * @return 值
    	 */
    	public Object hget(String key, String item) {
    		return redisTemplate.opsForHash().get(key, item);
    	}
     
    	/**
    	 * 获取hashKey对应的所有键值
    	 *
    	 * @param key 键
    	 * @return 对应的多个键值
    	 */
    	public Map<Object, Object> hmget(String key) {
    		return redisTemplate.opsForHash().entries(key);
    	}
     
    	/**
    	 * HashSet
    	 *
    	 * @param key 键
    	 * @param map 对应多个键值
    	 * @return true 成功 false 失败
    	 */
    	public boolean hmset(String key, Map<String, Object> map) {
    		try {
    			redisTemplate.opsForHash().putAll(key, map);
    			return true;
    		} catch (Exception e) {
    			e.printStackTrace();
    			return false;
    		}
    	}
     
    	/**
    	 * HashSet 并设置时间
    	 *
    	 * @param key  键
    	 * @param map  对应多个键值
    	 * @param time 时间(秒)
    	 * @return true成功 false失败
    	 */
    	public boolean hmset(String key, Map<String, Object> map, long time) {
    		try {
    			redisTemplate.opsForHash().putAll(key, map);
    			if (time > 0) {
    				expire(key, time);
    			}
    			return true;
    		} catch (Exception e) {
    			e.printStackTrace();
    			return false;
    		}
    	}
     
    	/**
    	 * 向一张hash表中放入数据,如果不存在将创建
    	 *
    	 * @param key   键
    	 * @param item  项
    	 * @param value 值
    	 * @return true 成功 false失败
    	 */
    	public boolean hset(String key, String item, Object value) {
    		try {
    			redisTemplate.opsForHash().put(key, item, value);
    			return true;
    		} catch (Exception e) {
    			e.printStackTrace();
    			return false;
    		}
    	}
     
    	/**
    	 * 向一张hash表中放入数据,如果不存在将创建
    	 *
    	 * @param key   键
    	 * @param item  项
    	 * @param value 值
    	 * @param time  时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间
    	 * @return true 成功 false失败
    	 */
    	public boolean hset(String key, String item, Object value, long time) {
    		try {
    			redisTemplate.opsForHash().put(key, item, value);
    			if (time > 0) {
    				expire(key, time);
    			}
    			return true;
    		} catch (Exception e) {
    			e.printStackTrace();
    			return false;
    		}
    	}
     
    	/**
    	 * 删除hash表中的值
    	 *
    	 * @param key  键 不能为null
    	 * @param item 项 可以使多个 不能为null
    	 */
    	public void hdel(String key, Object... item) {
    		redisTemplate.opsForHash().delete(key, item);
    	}
     
    	/**
    	 * 判断hash表中是否有该项的值
    	 *
    	 * @param key  键 不能为null
    	 * @param item 项 不能为null
    	 * @return true 存在 false不存在
    	 */
    	public boolean hHasKey(String key, String item) {
    		return redisTemplate.opsForHash().hasKey(key, item);
    	}
     
    	/**
    	 * hash递增 如果不存在,就会创建一个 并把新增后的值返回
    	 *
    	 * @param key  键
    	 * @param item 项
    	 * @param by   要增加几(大于0)
    	 * @return
    	 */
    	public double hincr(String key, String item, double by) {
    		return redisTemplate.opsForHash().increment(key, item, by);
    	}
     
    	/**
    	 * hash递减
    	 *
    	 * @param key  键
    	 * @param item 项
    	 * @param by   要减少记(小于0)
    	 * @return
    	 */
    	public double hdecr(String key, String item, double by) {
    		return redisTemplate.opsForHash().increment(key, item, -by);
    	}
    	// ============================set=============================
     
    	/**
    	 * 根据key获取Set中的所有值
    	 *
    	 * @param key 键
    	 * @return
    	 */
    	public Set<Object> sGet(String key) {
    		try {
    			return redisTemplate.opsForSet().members(key);
    		} catch (Exception e) {
    			e.printStackTrace();
    			return null;
    		}
    	}
     
    	/**
    	 * 根据value从一个set中查询,是否存在
    	 *
    	 * @param key   键
    	 * @param value 值
    	 * @return true 存在 false不存在
    	 */
    	public boolean sHasKey(String key, Object value) {
    		try {
    			return redisTemplate.opsForSet().isMember(key, value);
    		} catch (Exception e) {
    			e.printStackTrace();
    			return false;
    		}
    	}
     
    	/**
    	 * 将数据放入set缓存
    	 *
    	 * @param key    键
    	 * @param values 值 可以是多个
    	 * @return 成功个数
    	 */
    	public long sSet(String key, Object... values) {
    		try {
    			return redisTemplate.opsForSet().add(key, values);
    		} catch (Exception e) {
    			e.printStackTrace();
    			return 0;
    		}
    	}
     
    	/**
    	 * 将set数据放入缓存
    	 *
    	 * @param key    键
    	 * @param time   时间(秒)
    	 * @param values 值 可以是多个
    	 * @return 成功个数
    	 */
    	public long sSetAndTime(String key, long time, Object... values) {
    		try {
    			Long count = redisTemplate.opsForSet().add(key, values);
    			if (time > 0)
    				expire(key, time);
    			return count;
    		} catch (Exception e) {
    			e.printStackTrace();
    			return 0;
    		}
    	}
     
    	/**
    	 * 获取set缓存的长度
    	 *
    	 * @param key 键
    	 * @return
    	 */
    	public long sGetSetSize(String key) {
    		try {
    			return redisTemplate.opsForSet().size(key);
    		} catch (Exception e) {
    			e.printStackTrace();
    			return 0;
    		}
    	}
     
    	/**
    	 * 移除值为value的
    	 *
    	 * @param key    键
    	 * @param values 值 可以是多个
    	 * @return 移除的个数
    	 */
    	public long setRemove(String key, Object... values) {
    		try {
    			Long count = redisTemplate.opsForSet().remove(key, values);
    			return count;
    		} catch (Exception e) {
    			e.printStackTrace();
    			return 0;
    		}
    	}
    	// ===============================list=================================
     
    	/**
    	 * 获取list缓存的内容
    	 *
    	 * @param key   键
    	 * @param start 开始
    	 * @param end   结束 0 到 -1代表所有值
    	 * @return
    	 */
    	public List<Object> lGet(String key, long start, long end) {
    		try {
    			return redisTemplate.opsForList().range(key, start, end);
    		} catch (Exception e) {
    			e.printStackTrace();
    			return null;
    		}
    	}
     
    	/**
    	 * 获取list缓存的长度
    	 *
    	 * @param key 键
    	 * @return
    	 */
    	public long lGetListSize(String key) {
    		try {
    			return redisTemplate.opsForList().size(key);
    		} catch (Exception e) {
    			e.printStackTrace();
    			return 0;
    		}
    	}
     
    	/**
    	 * 通过索引 获取list中的值
    	 *
    	 * @param key   键
    	 * @param index 索引 index>=0时, 0 表头,1 第二个元素,依次类推;index<0时,-1,表尾,-2倒数第二个元素,依次类推
    	 * @return
    	 */
    	public Object lGetIndex(String key, long index) {
    		try {
    			return redisTemplate.opsForList().index(key, index);
    		} catch (Exception e) {
    			e.printStackTrace();
    			return null;
    		}
    	}
     
    	/**
    	 * 将list放入缓存
    	 *
    	 * @param key   键
    	 * @param value 值
    	 * @return
    	 */
    	public boolean lSet(String key, Object value) {
    		try {
    			redisTemplate.opsForList().rightPush(key, value);
    			return true;
    		} catch (Exception e) {
    			e.printStackTrace();
    			return false;
    		}
    	}
     
    	/**
    	 * 将list放入缓存
    	 *
    	 * @param key   键
    	 * @param value 值
    	 * @param time  时间(秒)
    	 * @return
    	 */
    	public boolean lSet(String key, Object value, long time) {
    		try {
    			redisTemplate.opsForList().rightPush(key, value);
    			if (time > 0)
    				expire(key, time);
    			return true;
    		} catch (Exception e) {
    			e.printStackTrace();
    			return false;
    		}
    	}
     
    	/**
    	 * 将list放入缓存
    	 *
    	 * @param key   键
    	 * @param value 值
    	 * @return
    	 */
    	public boolean lSet(String key, List<Object> value) {
    		try {
    			redisTemplate.opsForList().rightPushAll(key, value);
    			return true;
    		} catch (Exception e) {
    			e.printStackTrace();
    			return false;
    		}
    	}
     
    	/**
    	 * 将list放入缓存
    	 *
    	 * @param key   键
    	 * @param value 值
    	 * @param time  时间(秒)
    	 * @return
    	 */
    	public boolean lSet(String key, List<Object> value, long time) {
    		try {
    			redisTemplate.opsForList().rightPushAll(key, value);
    			if (time > 0)
    				expire(key, time);
    			return true;
    		} catch (Exception e) {
    			e.printStackTrace();
    			return false;
    		}
    	}
     
    	/**
    	 * 根据索引修改list中的某条数据
    	 *
    	 * @param key   键
    	 * @param index 索引
    	 * @param value 值
    	 * @return
    	 */
    	public boolean lUpdateIndex(String key, long index, Object value) {
    		try {
    			redisTemplate.opsForList().set(key, index, value);
    			return true;
    		} catch (Exception e) {
    			e.printStackTrace();
    			return false;
    		}
    	}
     
    	/**
    	 * 移除N个值为value
    	 *
    	 * @param key   键
    	 * @param count 移除多少个
    	 * @param value 值
    	 * @return 移除的个数
    	 */
    	public long lRemove(String key, long count, Object value) {
    		try {
    			Long remove = redisTemplate.opsForList().remove(key, count, value);
    			return remove;
    		} catch (Exception e) {
    			e.printStackTrace();
    			return 0;
    		}
    	}
    }
    Copier après la connexion

    Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

    Déclaration de ce site Web
    Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn

    Article chaud

    Repo: Comment relancer ses coéquipiers
    3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
    Combien de temps faut-il pour battre Split Fiction?
    3 Il y a quelques semaines By DDD
    R.E.P.O. Crystals d'énergie expliqués et ce qu'ils font (cristal jaune)
    1 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
    Hello Kitty Island Adventure: Comment obtenir des graines géantes
    3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌

    Article chaud

    Repo: Comment relancer ses coéquipiers
    3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
    Combien de temps faut-il pour battre Split Fiction?
    3 Il y a quelques semaines By DDD
    R.E.P.O. Crystals d'énergie expliqués et ce qu'ils font (cristal jaune)
    1 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
    Hello Kitty Island Adventure: Comment obtenir des graines géantes
    3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌

    Tags d'article chaud

    Bloc-notes++7.3.1

    Bloc-notes++7.3.1

    Éditeur de code facile à utiliser et gratuit

    SublimeText3 version chinoise

    SublimeText3 version chinoise

    Version chinoise, très simple à utiliser

    Envoyer Studio 13.0.1

    Envoyer Studio 13.0.1

    Puissant environnement de développement intégré PHP

    Dreamweaver CS6

    Dreamweaver CS6

    Outils de développement Web visuel

    SublimeText3 version Mac

    SublimeText3 version Mac

    Logiciel d'édition de code au niveau de Dieu (SublimeText3)

    Solution à l'erreur 0x80242008 lors de l'installation de Windows 11 10.0.22000.100 Solution à l'erreur 0x80242008 lors de l'installation de Windows 11 10.0.22000.100 May 08, 2024 pm 03:50 PM

    Solution à l'erreur 0x80242008 lors de l'installation de Windows 11 10.0.22000.100

    Comment changer le mot de passe dans Redis Comment changer le mot de passe dans Redis Apr 20, 2024 am 03:00 AM

    Comment changer le mot de passe dans Redis

    Analyser les goulots d'étranglement des fonctions PHP et améliorer l'efficacité de l'exécution Analyser les goulots d'étranglement des fonctions PHP et améliorer l'efficacité de l'exécution Apr 23, 2024 pm 03:42 PM

    Analyser les goulots d'étranglement des fonctions PHP et améliorer l'efficacité de l'exécution

    Redis est-il un cache mémoire ? Redis est-il un cache mémoire ? Apr 20, 2024 am 05:26 AM

    Redis est-il un cache mémoire ?

    Stratégie de mise en cache et optimisation de l'API Golang Stratégie de mise en cache et optimisation de l'API Golang May 07, 2024 pm 02:12 PM

    Stratégie de mise en cache et optimisation de l'API Golang

    Redis est-il une base de données non relationnelle ? Redis est-il une base de données non relationnelle ? Apr 20, 2024 am 05:36 AM

    Redis est-il une base de données non relationnelle ?

    Mécanisme de mise en cache et pratique d'application dans le développement PHP Mécanisme de mise en cache et pratique d'application dans le développement PHP May 09, 2024 pm 01:30 PM

    Mécanisme de mise en cache et pratique d'application dans le développement PHP

    Lequel a les meilleures performances, erlang ou golang ? Lequel a les meilleures performances, erlang ou golang ? Apr 21, 2024 am 03:24 AM

    Lequel a les meilleures performances, erlang ou golang ?

    See all articles