本文由 简悦 SimpRead 转码， 原文地址 blog.csdn.net
提供一个完整的示例，演示如何在 Spring Boot 项目中使用 Redisson 实现延迟执行。
1. 添加 Redisson 依赖：
在你的 pom.xml 文件中添加 Redisson 的依赖：
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson-spring-boot-starter</artifactId>
<version>3.16.4</version>
</dependency>
2. 配置 Redisson：
在 application.properties 或 application.yml 文件中配置 Redisson。以下是一个示例：
application.properties
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RedissonConfig {
@Value("${redisson.address}")
private String address;
@Bean
public RedissonClient redissonClient() {
Config config = new Config();
config.useSingleServer().setAddress(address);
return Redisson.create(config);
}
}
或者
application.yml
import org.redisson.api.RDelayedQueue;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
@Service
public class DelayedExecutionService {
@Autowired
private RedissonClient redissonClient;
private final ExecutorService executorService = Executors.newFixedThreadPool(10);
public void addTaskToQueue(String taskId, long delay, TimeUnit timeUnit) {
RDelayedQueue<String> delayedQueue = redissonClient.getDelayedQueue("myDelayedQueue");
delayedQueue.offer(taskId, delay, timeUnit);
}
public void processTaskFromQueue() {
RDelayedQueue<String> delayedQueue = redissonClient.getDelayedQueue("myDelayedQueue");
String taskId = delayedQueue.poll();
if (taskId != null) {
executorService.submit(() -> {
System.out.println("Task executed: " + taskId);
// 在这里执行你的任务逻辑
});
}
}
}
3. 创建 Redisson 客户端：
在 Spring Boot 项目中，你可以通过自动配置的方式创建 Redisson 客户端。首先，创建一个配置类，如下所示：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class DelayedExecutionController {
@Autowired
private DelayedExecutionService delayedExecutionService;
@GetMapping("/addTask")
public String addTask() {
delayedExecutionService.addTaskToQueue("task1", 5, TimeUnit.SECONDS);
return "Task added to the queue";
}
@GetMapping("/processTask")
public String processTask() {
delayedExecutionService.processTaskFromQueue();
return "Task processing started";
}
}
在这个配置类中，我们使用 @Value 注解获取 Redis 服务器的地址，并创建一个 RedissonClient 实例。
4. 实现延迟执行服务：
创建一个服务类，实现延迟执行的功能。以下是一个示例：
import org.redisson.api.RDelayedQueue;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
@Service
public class DelayedExecutionService {
@Autowired
private RedissonClient redissonClient;
private final ExecutorService executorService = Executors.newFixedThreadPool(10);
public void addTaskToQueue(String taskId, long delay, TimeUnit timeUnit) {
RDelayedQueue<String> delayedQueue = redissonClient.getDelayedQueue("myDelayedQueue");
delayedQueue.offer(taskId, delay, timeUnit);
}
public void processTaskFromQueue() {
RDelayedQueue<String> delayedQueue = redissonClient.getDelayedQueue("myDelayedQueue");
String taskId = delayedQueue.poll();
if (taskId != null) {
executorService.submit(() -> {
System.out.println("Task executed: " + taskId);
// 在这里执行你的任务逻辑
});
}
}
}
在这个服务类中，我们首先通过 @Autowired 注解注入 RedissonClient 实例。然后，我们创建了两个方法：addTaskToQueue 用于向延迟队列中添加任务，processTaskFromQueue 用于处理延迟队列中的任务。在 processTaskFromQueue 方法中，我们使用了一个线程池 executorService 来异步执行任务。
5. 使用延迟执行服务：
在你的应用程序中，你可以通过调用 DelayedExecutionService 中的方法来使用延迟执行。例如，你可以在一个控制器中添加如下代码：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class DelayedExecutionController {
@Autowired
private DelayedExecutionService delayedExecutionService;
@GetMapping("/addTask")
public String addTask() {
delayedExecutionService.addTaskToQueue("task1", 5, TimeUnit.SECONDS);
return "Task added to the queue";
}
@GetMapping("/processTask")
public String processTask() {
delayedExecutionService.processTaskFromQueue();
return "Task processing started";
}
}
在这个控制器中，我们创建了两个端点：/addTask 用于向延迟队列中添加任务，/processTask 用于处理延迟队列中的任务。