SpringBoot整合Redis

2023-12-18 21:30:18

Redis 是一个高性能的 key-value 数据库,常用于缓存、消息队列、分布式锁等场景。Spring Boot 是一个快速开发框架,可以让开发者快速地开发 Spring 应用程序。本文将介绍如何在 Spring Boot 中使用 Redis。

1. 添加依赖

要使用 Redis,需要在 pom.xml 文件中添加如下依赖:

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

2. 配置 Redis

在 application.properties 文件中配置 Redis 的连接信息:

spring.redis.host=localhost
spring.redis.port=6379
spring.redis.password=password

3. 使用 Redis

要使用 Redis,可以使用 RedisTemplate 对象。 RedisTemplate 提供了一系列方法来操作 Redis 中的 key-value 数据。

例如,以下代码可以将一个字符串 “hello world” 存储到 Redis 中:

String key = "key";
String value = "hello world";

template.opsForValue().set(key, value);

以下代码可以从 Redis 中获取 key 对应的 value:

String key = "key";
String value = template.opsForValue().get(key);

4. 使用 Spring Data Redis

Spring Data Redis 提供了一系列的 Repository 接口,可以简化 Redis 的使用。

例如,以下代码可以使用 Spring Data Redis 来存储和获取一个字符串:

@Repository
public interface StringRepository extends CrudRepository<String, String> {
}

String key = "key";
String value = "hello world";

stringRepository.save(new StringEntity(key, value));

String entity = stringRepository.findById(key).get();

5. 使用 Redis 事务

Redis 支持事务,可以保证多个 Redis 命令的原子性。

要使用 Redis 事务,可以使用 RedisTemplatemulti()exec() 方法。

以下代码使用 Redis 事务来存储两个字符串:

template.multi();
template.opsForValue().set("key1", "value1");
template.opsForValue().set("key2", "value2");
template.exec();

6. 使用 Redis 发布订阅

Redis 支持发布订阅,可以让一个 Redis 客户端向其他 Redis 客户端发送消息。

要使用 Redis 发布订阅,可以使用 RedisTemplateconvertAndSend() 方法。

以下代码向所有订阅了 “channel” 频道的客户端发送 “message” 消息:

template.convertAndSend("channel", "message");

7. 使用 Redis 限流

Redis 可以用来实现限流,可以防止某个资源被过度访问。

要使用 Redis 限流,可以使用 RedisTemplateopsForHash() 方法。

以下代码可以限制某个用户每分钟只能访问 10 次:

String key = "user:<username>:count";
long count = template.opsForHash().increment(key, "count", 1);

if (count > 10) {
    throw new RuntimeException("Too many requests");
}

8. 使用 Redis 分布式锁

Redis 可以用来实现分布式锁,可以防止多个客户端同时访问某个资源。

要使用 Redis 分布式锁,可以使用 RedisTemplateopsForValue() 方法。

以下代码可以获取一个分布式锁:

String key = "lock";
String value = UUID.randomUUID().toString();

template.opsForValue().set(key, value, 10, TimeUnit.SECONDS);

如果获取分布式锁成功,则可以访问资源。如果获取分布式锁失败,则需要等待其他客户

文章来源:https://blog.csdn.net/qq_63519395/article/details/135071738
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。