Spring Boot整合Redis并提供多种实际场景的应用

今天药忘吃喽~ 2023-09-30 20:58 9阅读 0赞

#### Spring Boot整合Redis并提供多种实际场景的应用 ####

*  1. 整合Redis
 *  2. 场景应用
 *   *  2.1 缓存
     *  2.2 分布式锁
     *  2.3 计数器
     *  2.4 发布/订阅
 *  3. 总结

Spring Boot是一个快速构建基于Spring框架的应用程序的工具，它提供了大量的自动化配置选项，可以轻松地集成各种不同的技术。Redis是一个高性能的键值存储数据库，广泛用于缓存、队列、发布/订阅等场景。本文将介绍如何使用Spring Boot整合Redis，并提供多种实际场景的应用。

![在这里插入图片描述][63d3820e2de742beac5180561ce52580.png]

## 1. 整合Redis ##

在Spring Boot中，可以通过添加相关的依赖来整合Redis。以下是常用的Redis客户端库及其对应的依赖：

Jedis: spring-boot-starter-data-redis  
Lettuce: spring-boot-starter-data-redis-reactive

这里以Jedis为例进行演示。首先在pom.xml中添加依赖：

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

然后在application.properties文件中配置Redis连接信息：

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

或

spring:
      redis:
        host: localhost
        password: ''
        port: 6379

这里配置了Redis的地址和端口号，如果Redis需要密码验证，也可以在这里配置密码。接下来可以通过注入RedisTemplate来使用Redis：

@Autowired
    private RedisTemplate<String, Object> redisTemplate;
    
    public void setValue(String key, Object value) {
        
        redisTemplate.opsForValue().set(key, value);
    }
    
    public Object getValue(String key) {
        
        return redisTemplate.opsForValue().get(key);
    }

以上代码中的setValue方法将一个值存储到Redis中，getValue方法从Redis中获取一个值。Spring Boot会自动配置RedisTemplate，所以我们可以直接注入并使用它。

## 2. 场景应用 ##

### 2.1 缓存 ###

Redis最常见的应用场景就是缓存。在Spring Boot中，可以使用@Cacheable注解来开启缓存。下面的例子演示了如何使用@Cacheable注解实现缓存：

@Service
    public class UserServiceImpl implements UserService {
        
    
        @Autowired
        private UserRepository userRepository;
    
        @Cacheable(value = "userCache", key = "#id")
        public User getUserById(Integer id) {
        
            return userRepository.findById(id);
        }
    }

以上代码中，getUserById方法使用@Cacheable注解进行了缓存。value属性指定了缓存名称，key属性指定了缓存的键值，这里以用户ID作为缓存的键。如果缓存中存在指定键值的数据，那么将直接从缓存中获取数据，而不会执行方法体中的代码。

### 2.2 分布式锁 ###

在分布式环境中，为了保证数据的一致性，可能需要使用分布式锁。Redis提供了实现分布式锁的方法，可以使用setnx命令来实现。下面的例子演示了如何使用Redis实现分布式锁：

@Service
    public class UserServiceImpl implements UserService {
        
    
        @Autowired
    	private RedisTemplate<String, Object> redisTemplate;
    	
    	/**
    	* 获取锁
    	*/
    	public boolean acquireLock(String key, String value, long expireTime) {
        
    	    Boolean result = redisTemplate.opsForValue().setIfAbsent(key, value, expireTime, TimeUnit.MILLISECONDS);
    	    return result != null && result;
    	}
    	
    	/**
    	* 释放锁
    	*/
    	public void releaseLock(String key, String value) {
        
    	    Object currentValue = redisTemplate.opsForValue().get(key);
    	    if (currentValue != null && value.equals(currentValue.toString())) {
        
    	        redisTemplate.delete(key);
    	    }
    	}
    }

以上代码中，acquireLock方法尝试获取锁，如果获取成功，则返回true，否则返回false。releaseLock方法释放锁，只有持有相同value值的锁才能被释放。expireTime参数指定了锁的过期时间，避免锁被一直占用。

### 2.3 计数器 ###

Redis提供了incr和decr命令来实现原子递增和递减操作。这些命令可以用于实现计数器。下面的例子演示了如何使用Redis实现计数器：

@Service
    public class CounterServiceImpl implements CounterService {
        
    
        private static final String COUNTER_KEY = "counter";
    
        @Autowired
        private RedisTemplate<String, Object> redisTemplate;
    	/**
    	* 自增1
    	*/
        public long increase() {
        
            return redisTemplate.opsForValue().increment(COUNTER_KEY);
        }
    
    	/**
    	* 自减1
    	*/
        public long decrease() {
        
            return redisTemplate.opsForValue().decrement(COUNTER_KEY);
        }
    
    	/**
    	* 获取计数
    	*/
        public long getCount() {
        
            Object value = redisTemplate.opsForValue().get(COUNTER_KEY);
            if (value != null) {
        
                return Long.parseLong(value.toString());
            } else {
        
                return 0;
            }
        }
    }

以上代码中，increase和decrease方法分别实现了原子递增和递减操作，getCount方法获取当前计数器的值。

### 2.4 发布/订阅 ###

Redis提供了发布/订阅功能，可以用于实现消息队列等功能。下面的例子演示了如何使用Redis实现发布/订阅：

@Service
    public class MessageServiceImpl implements MessageService {
        
    
        private static final String CHANNEL_NAME = "message";
    
        @Autowired
        private RedisTemplate<String, Object> redisTemplate;
    
        @Override
        public void sendMessage(String message) {
        
            redisTemplate.convertAndSend(CHANNEL_NAME, message);
        }
    
        @Override
        public void subscribeMessage(MessageListener listener) {
        
            MessageListenerAdapter adapter = new MessageListenerAdapter(listener);
            redisTemplate.getConnectionFactory().getConnection().subscribe(adapter, CHANNEL_NAME.getBytes());
        }
    }

以上代码中，sendMessage方法发布一条消息到指定的频道，subscribeMessage方法订阅指定频道的消息，并将消息交给MessageListener处理。

## 3. 总结 ##

本文介绍了如何使用Spring Boot整合Redis，并提供了多种实际场景的应用。在实际开发中，Redis的应用场景非常广泛，可以根据需求选择合适的Redis客户端库及相关的操作命令来实现功能。

[63d3820e2de742beac5180561ce52580.png]: https://img-blog.csdnimg.cn/63d3820e2de742beac5180561ce52580.png