springboot 线程池实现redis订阅异步处理消息

Spring Boot 中可以利用 Spring 的 `ThreadPoolTaskExecutor` 或者第三方库如 `Spring Cloud Task` 实现 Redis 订阅异步处理消息。以下是基本步骤：

1. 配置 ThreadPoolTaskExecutor 或创建一个自定义线程池：

   @Bean
   public ThreadPoolTaskExecutor redisThreadPoolExecutor() {
       ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
       executor.setCorePoolSize(5); // 核心线程数
       executor.setMaxPoolSize(10); // 最大线程数
       executor.setQueueCapacity(100); // 队列容量
       executor.setThreadNamePrefix("redis-async-task-");
       executor.initialize();
       return executor;
   }

2. 创建一个 Runnable 接口实现类，用于处理 Redis 的消息：

   public class RedisMessageHandler implements Runnable {
       private final String channel;
       private final RedisTemplate<String, Object> redisTemplate;

       public RedisMessageHandler(String channel, RedisTemplate<String, Object> redisTemplate) {
           this.channel = channel;
           this.redisTemplate = redisTemplate;
       }

       @Override
       public void run() {
           List<String> messages = redisTemplate.opsForSubscription().subscribe(channel);
           for (String message : messages) {
               handleMessage(message);
           }
       }

       // 处理接收到的消息逻辑
       private void handleMessage(String message) {
           // ... your handling logic here
       }
   }

3. 异步监听 Redis 更新并发送到线程池执行：

   @EventListener
   public void onRedisMessage(RedisMessageEvent event) {
       String channel = event.getChannel(); // 获取频道名
       redisThreadPoolExecutor().execute(new RedisMessageHandler(channel, context.getBean(RedisTemplate.class)));
   }

4.