Redis 订阅消息限速消费：两种常见方法

在 Redis 中，如果想要限速消费订阅的消息，可以使用以下方法：

使用 RateLimiter：RateLimiter 是 Guava 库中的一个工具，可以限制每秒处理的消息数量。在 onMessage 方法中，使用 RateLimiter 来控制消息的处理速度。

private RateLimiter rateLimiter = RateLimiter.create(10); // 每秒处理 10 条消息

@Override
public void onMessage(Message message, byte[] pattern) {
    if (rateLimiter.tryAcquire()) {
        // 处理消息的逻辑
    } else {
        // 超过限速，不处理消息
    }
}

使用 Redis 的 Lua 脚本：Redis 支持使用 Lua 脚本执行一些复杂的操作。可以编写一个 Lua 脚本，通过 Redis 的 lua 脚本执行功能来实现限速消费。

private Jedis jedis;

@Override
public void onMessage(Message message, byte[] pattern) {
    String script = 'local rate = tonumber(redis.call('get', KEYS[1])) or 0
' + 
                    'if rate >= tonumber(ARGV[1]) then
' + 
                    '    return 0
' + 
                    'else
' + 
                    '    redis.call('incr', KEYS[1])
' + 
                    '    return 1
' + 
                    'end';
    String key = 'message_rate_limit';
    List<String> keys = Collections.singletonList(key);
    List<String> args = Collections.singletonList('10'); // 每秒处理 10 条消息
    Long result = (Long) jedis.eval(script, keys, args);
    if (result == 1) {
        // 处理消息的逻辑
    } else {
        // 超过限速，不处理消息
    }
}

以上是两种常用的限速消费订阅消息的方法，根据具体情况选择适合自己的方式。