java - Java获取Redis当前订阅列表的方法

Question

我正在编写一个应用程序，其中一个进程应将数据发送到多个订阅 channel 。该过程事先不知道 channel (因为客户端订阅了不同的主题)，所以我需要查询所有 Activity 订阅以了解要获取和发送的数据。我找到了 Redis 命令:

127.0.0.1:6379> pubsub channels

但是:1.它总是返回一个空列表2. 我在 Jedis 或 Spring 实现中找不到等效的 Java。

Answer 1

根据我从您的端口​​中了解到的情况和方法文档 getSubscription()(返回此连接的当前订阅，如果未订阅该连接则返回 null。)，我认为这会有所帮助你。

redisTemplate.execute(new RedisCallback<Object>(){
        @Override
        public Object doInRedis(RedisConnection connection) throws DataAccessException {
            Subscription susb = connection.getSubscription();
            Collection<byte[]> channels = susb.getChannels();
            return null;
        }

    });

订阅 具有此连接订阅的 channel 。