java - 使用 Redis 发布/订阅 : how to make a subscription expire

Question

我们在 java 框架 (vertx) 中使用 redis pub/sub 来跟踪一些 rest 调用。

为了不让 Redis 过载，我在 30 秒后取消订阅一个 channel ，如下所示:

private void subscribe(Message<String> message) {

    String msgId = message.body();
    redisClient.subscribe(msgId, result -> {
        if (!result.succeeded()) {
            log.warn("subscribe failed msgId={}", msgId, result.cause());
            message.fail(500, String.format("retrieve conversation %s failure", msgId));
            return;
        }

        log.info("subscribed for message id :{}", msgId);
        message.reply("OK");

        //unsubscribe after 30 seconds.
        vertx.setTimer(30000, r -> {
            redisClient.unsubscribe(Collections.singletonList(msgId), r2 -> {
                if(!r2.succeeded()){
                    log.warn("unsubscribe failed msgId={}", msgId, r2.cause());
                }
            });

        });
    });
}

我想知道 redis 中是否有一种方法可以在延迟或类似的情况下回滚订阅。

欢迎提出任何改进意见。

Answer 1

不，没有。

根据文档:https://redis.io/commands/subscribe

您只能指定要收听的 channel 。您要么断开连接，要么发出 UNSUBSCRIBE 命令。