禁止Redis重复订阅实现幂等性（redis禁止重复订阅）

禁止Redis重复订阅——实现幂等性

在使用Redis进行消息订阅时，我们会遇到一个问题，那就是重复订阅。如果我们重复订阅同一个消息，那么就会出现多次处理消息的情况，导致数据异常。这时候我们需要实现幂等性来解决这个问题。

实现幂等性的方法有很多，下面给出一种基于Redis的实现方法，代码如下：

public boolean redisSetNx(String key,String val,long expireTime){
   //redis中不存在当前key，可以执行set操作，返回1

   //redis中已存在当前key，不能执行set操作，返回0

   //expireTime单位：秒

   return stringRedisTemplate.execute(connection -> {

         RedisSerializer redisSerializer = stringRedisTemplate.getStringSerializer();
         byte[] keyBytes = redisSerializer.serialize(key);

         byte[] valueBytes = redisSerializer.serialize(val);

         Boolean result = connection.setNX(keyBytes, valueBytes);

         if (result && expireTime > 0) {

            connection.expire(keyBytes, expireTime);

         }

         return result;

   });

}

public boolean redisDel(String key){

    return stringRedisTemplate.delete(key);

}

在进行订阅前，我们首先使用redisSetNx()函数来进行尝试锁定，用来判断是否可以进行订阅。如果锁定成功，我们就可以进行订阅。如果锁定不成功，说明已经有一个进程在订阅了，此时我们可以选择直接忽略订阅操作，或者等待一段时间后重新进行尝试。在订阅完成后，我们还需要调用redisDel()函数来释放锁定。

public void subMsg(String channel) {
    RedisMessageListenerContner redisMessageListenerContner = new RedisMessageListenerContner();

    redisMessageListenerContner.setConnectionFactory(redisConnectionFactory);

    redisMessageListenerContner.addMessageListener((message, bytes) -> {

        String msgBody = stringRedisTemplate.getStringSerializer().deserialize(message.getBody());

        //处理消息

    }, new ChannelTopic(channel));

    redisMessageListenerContner.afterPropertiesSet();

    redisMessageListenerContner.start();

    boolean lock = redisSetNx("sub_" + channel, channel, 60);

    if (!lock) {

        redisMessageListenerContner.stop();

        log.info("重复订阅，不进行处理");

        return;

    }

    Runtime.getRuntime().addShutdownHook(new Thread(() -> {

        redisMessageListenerContner.stop();

        redisDel("sub_" + channel);

    }));

}

通过以上代码的实现，我们就可以解决Redis重复订阅的问题，保证数据处理的幂等性，确保系统稳定、可靠地运行。