Spring Boot整合Redis实现订单超时处理

1.首先，我们需要在pom.xml文件中添加以下依赖：

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

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

# Redis配置
spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.password=
spring.redis.database=0

3.创建一个RedisUtil工具类，用于操作Redis：

@Component
public class RedisUtil {@Autowiredprivate RedisTemplate<String, Object> redisTemplate;// 设置key-value到Redis中，并设置过期时间（单位：秒）public boolean set(String key, Object value, long expireTime) {try {ValueOperations<String, Object> operations = redisTemplate.opsForValue();operations.set(key, value);redisTemplate.expire(key, expireTime, TimeUnit.SECONDS);return true;} catch (Exception e) {e.printStackTrace();return false;}}// 从Redis中获取key对应的valuepublic Object get(String key) {ValueOperations<String, Object> operations = redisTemplate.opsForValue();return operations.get(key);}// 删除Redis中的keypublic boolean delete(String key) {return redisTemplate.delete(key);}}

4.创建一个订单处理类，用于处理超时订单：

@Service
public class OrderService {@Autowiredprivate RedisUtil redisUtil;// 将订单放入Redis中，设置过期时间public void createOrder(String orderId) {redisUtil.set(orderId, "订单信息", 60 * 30);}// 判断订单是否超时public boolean isOrderTimeout(String orderId) {Object value = redisUtil.get(orderId);if (value != null) {return false;}return true;}// 处理超时订单public void handleTimeoutOrder(String orderId) {// 处理超时订单redisUtil.delete(orderId);}}

5.在需要创建订单的地方调用createOrder方法：

@Autowired
private OrderService orderService;public void createNewOrder(String orderId) {orderService.createOrder(orderId);
}

6.在需要处理订单的地方定时检查订单是否超时，并调用handleTimeoutOrder方法处理超时订单：

@Autowired
private OrderService orderService;@Scheduled(fixedDelay = 1000)
public void checkTimeoutOrder() {List<String> orderIds = getOrderList();for (String orderId : orderIds) {if (orderService.isOrderTimeout(orderId)) {orderService.handleTimeoutOrder(orderId);}}
}