【问题标题】:how to configure the key expired event listener in redisson reactive api (spring boot project)如何在redisson响应式api中配置密钥过期事件监听器(spring boot项目)
【发布时间】:2021-09-23 00:57:33
【问题描述】:

我正在使用带有 redisson 的 Spring Boot Web Flux。我想在我的应用程序中启用所有密钥过期事件。我试过这样。但它不起作用。

this.client.getTopic("__keyevent@*__:expired", StringCodec.INSTANCE)
        .addListener(String.class, new MessageListener<String>() {
            @Override
            public void onMessage(CharSequence channel, String msg) {
                //
            }
        });

我希望帮助解决这个问题。

【问题讨论】:

  • 第一个问题是,你还没有订阅监听器
  • 是的。接下来呢?

标签: redis spring-webflux reddison


【解决方案1】:

第一个问题是,您还没有订阅监听器。第二个是,如果您在 redisson 中使用模式,则不能将 getTopic 用于 pub-sub 事件。你应该像这样使用getPatternTopic 方法。并确保最终订阅该过程。并且监听器应该从PatternMessageListener接口实现。


        this.client
                .getPatternTopic("__keyevent@*__:expired", StringCodec.INSTANCE)
                .addListener(String.class, new PatternMessageListener<String>() {
                    @Override
                    public void onMessage(CharSequence pattern, CharSequence channel, String msg) {
                        System.out.println("pattern = " + pattern + ", channel = " + channel + ", msg = " + msg);
                    }
                })
                .subscribe();

【讨论】:

    猜你喜欢
    • 2017-12-23
    • 2019-04-06
    • 1970-01-01
    • 2011-10-10
    • 1970-01-01
    • 2017-03-02
    • 2019-03-10
    • 2015-06-02
    • 2019-01-16
    相关资源
    最近更新 更多