分布式系统中Redis的Key过期监听事件如何防止重复处理

一枚假程序猿 发布于 2017/10/17 16:17
阅读 845
收藏 0

分布式系统中Redis的Key过期监听事件如何防止重复处理

我在Java的分布式系统中,使用了Redis的Key过期时间

Redis中设置如下:

notify-keyspace-events Ex

在Java中代码使用了JedisPubSub进行订阅:

        /*
         * 添加Redisd的key过期事件监听(因为会阻塞线程,所以放到最后执行)
         */
        try {
            logger.info("正在添加Redisd的key过期事件监听...");

            Jedis jedis = Redis.use("data").getJedis();
            JedisPubSub jedisPubSub = new RedisKeyExpiredListener();
            String channel = "__keyevent@0__:expired";// key过期事件
            if (jedis != null) {
                new Thread(() -> {
                    jedis.subscribe(jedisPubSub, channel);// 这里启动了订阅监听,线程将在这里被阻塞
                }).start();
                logger.info("添加Redisd的key过期事件监听完成!");
            } else {
                logger.warn("添加Redisd的key过期事件监听失败,未获取到 jedis 对象!");
            }
        } catch (Exception ex) {
            logger.error("添加Redisd的key过期事件监听异常!", ex);
        }

监听事件如下:

     /**
     * 监听到订阅频道接受到消息时的回调
     */
    @Override
    public void onMessage(String channel, String message) {
        logger.info("【onMessage】");
        logger.info("channel = " + channel);
        logger.info("message = " + message);

    }

现在出现的问题是每当Redis中有Key过期时,都会调用各个程序中的onMessage事件,而且是同时调用,请问如果防止处理重复?处理完成后存缓存或者库来保证同步吗?

加载中
0
一枚假程序猿
一枚假程序猿

谁来回答下?

0
p
pandajava

引用来自“一枚假程序猿”的评论

谁来回答下?

解决方案是啥呢?

一枚假程序猿
一枚假程序猿
没有解决呢
0
不染纤尘醉一笑
不染纤尘醉一笑

请教:预防多次订阅问题解决了吗

一枚假程序猿
一枚假程序猿
没有解决
返回顶部
顶部