如何限制 Redis 消息消费者每秒只消费 10 条数据

可以使用计数器的方式来限制每秒只消费 10 条数据。可以定义一个全局变量或者使用 Redis 的计数器来记录已消费的消息数量。在每次接收到消息时，先判断已消费的消息数量是否已经达到 10 条。如果达到了，则不继续处理该消息，直接返回。否则，对消息进行处理，并将已消费的消息数量加 1。

以下是示例代码：

// 定义全局变量记录已消费的消息数量
private AtomicInteger consumedCount = new AtomicInteger(0);

@Override
public void onMessage(Message message, byte[] pattern) {
    String channel = new String(pattern);
    log.info('onMessage --> 消息通道是：', channel);

    RedisSerializer<?> valueSerializer = redisTemplate.getValueSerializer();
    Object deserialize = valueSerializer.deserialize(message.getBody());
    log.info('反序列化的结果:', deserialize);
    if (deserialize == null) return;
    String md5DigestAsHex = DigestUtils.md5DigestAsHex(deserialize.toString().getBytes(StandardCharsets.UTF_8));
    log.info('计算得到的key: ', md5DigestAsHex);
    
    // 判断已消费的消息数量是否达到 10 条
    if (consumedCount.get() >= 10) {
        log.info('每秒只能消费 10 条数据，当前已达到上限');
        return;
    }
    
    Boolean result = redisTemplate.opsForValue().setIfAbsent(md5DigestAsHex, '1', 20, TimeUnit.SECONDS);
    if (Boolean.TRUE.equals(result)) {
        // redis消息进行处理
        log.info('接收的结果：', deserialize.toString());
        
        // 已消费的消息数量加 1
        consumedCount.incrementAndGet();
    } else {
        log.info('其他服务处理中');
    }
}

在代码中，通过 AtomicInteger 类型的 consumedCount 变量来记录已消费的消息数量。每次处理消息时，先判断 consumedCount 是否已达到 10 条。如果达到了，则直接返回，不继续处理该消息。如果未达到，则对消息进行处理，并将 consumedCount 加 1。这样就实现了每秒只消费 10 条数据的限制。

注意：

此代码仅供参考，具体实现需要根据实际情况进行调整。
可以考虑使用 Redis 的计数器来实现更可靠的计数功能。
为了避免计数器在不同消费者的实例之间出现冲突，需要确保每个消费者实例都有自己的计数器。
可以使用线程池来处理消息，并根据需要调整线程池的大小。
可以使用定时任务来重置计数器，例如每秒重置一次。
可以根据需要调整每秒消费数据的数量。