springcloud分布式程序加redis监听一个key过期事件会被重复消费吗

在Spring Cloud分布式程序中，如果多个实例都监听同一个Redis key过期事件，可能会导致重复消费的问题。因为Redis的keyspace notifications功能是发布-订阅模式，每个订阅者都会收到相同的事件通知。

为了避免这个问题，可以使用分布式锁来控制只有一个实例能够处理该事件。常用的分布式锁包括Redisson、ZooKeeper、Curator等。

以下是使用Redisson实现分布式锁的示例代码：

1. 添加Redisson和Spring Data Redis依赖：

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

2. 创建一个RedissonClient Bean：

   @Bean
   public RedissonClient redissonClient() {
       Config config = new Config();
       config.useSingleServer().setAddress("redis://localhost:6379");
       return Redisson.create(config);
   }

3. 创建一个RedisKeyExpirationListener类，并在其中加入分布式锁逻辑：

   public class RedisKeyExpirationListener {
       private static final String LOCK_NAME = "key-expiration-lock";

       @Autowired
       private RedissonClient redissonClient;

       public void onMessage(Message message, byte[] pattern) {
           String expiredKey = message.toString();
           RLock lock = redissonClient.getLock(LOCK_NAME);
           try {
               if (lock.tryLock()) {
                   // 这里可以写你要执行的代码
                   System.out.println("Key expired: " + expiredKey);
               }
           } finally {
               lock.unlock();
           }
       }
   }

4. 将RedisKeyExpirationListener注册到RedisMessageListenerContainer中：

   @Autowired
   private RedisMessageListenerContainer redisMessageListenerContainer;

   @Autowired
   private MessageListenerAdapter messageListenerAdapter;

   @PostConstruct
   public void init() {
       // 要监听的key的pattern
       String pattern = "__keyevent@0__:expired";
       redisMessageListenerContainer.addMessageListener(messageListenerAdapter, new PatternTopic(pattern));
   }

通过加入分布式锁逻辑，可以确保只有一个实例能够处理该事件，避免了重复消费的问题。需要注意的是，锁的粒度应该尽量小，避免对性能产生影响。