springboot如何判断Redis Stream消费组是否存在

柔情只为你懂 2024-03-26 21:24 46阅读 0赞

public class StreamMqTest {
        @Autowired
        private RedisConnectionFactory redisConnectionFactory;
        @Autowired
        private StreamRedisQueue streamRedisQueue;
        @Autowired
        private RedisTemplate<String, Object> redisTemplate;
        @Test
        public void createGroup(){
            streamRedisQueue.createGroup("stream_key", "suiye");
            streamRedisQueue.createGroup("stream_key", "lasse");
        }
    
        @Test
        public void doIsStreamGroupExist() {
            boolean consumerGroupExists = isStreamGroupExists("stream_key", "lasse");
            System.out.println("完成任务");
        }
    
        public boolean isStreamGroupExists(String streamKey, String groupName) {
            RedisStreamCommands commands = redisConnectionFactory.getConnection().streamCommands();
    
            //首先检查Stream Key是否存在，否则下面代码可能会因为尝试检查不存在的Stream Key而导致异常
            if (!redisTemplate.hasKey(streamKey)){
                return false;
            }
    
            //获取streamKey下的所有groups
            StreamInfo.XInfoGroups xInfoGroups = commands.xInfoGroups(streamKey.getBytes());
            AtomicBoolean exists= new AtomicBoolean(false);
            xInfoGroups.forEach(xInfoGroup -> {
                if (xInfoGroup.groupName().equals(groupName)){
                    exists.set(true);
                }
            });
    
            return exists.get();
        }
    
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，46人围观）

还没有评论，来说两句吧...

相关阅读

相关 springboot如何判断Redis Stream消费组是否存在

public class StreamMqTest { @Autowired private RedisConnectionFactor

柔情只为你懂/ 2024年03月26日 21:24/ 0 赞/ 47 阅读

相关如何使用Python判断文本文件是否存在

在Python编程中，经常需要检查文件是否存在。这在处理文件输入/输出和数据处理任务时非常常见。幸运的是，Python提供了一种简单的方法来判断文件是否存在。本文将介绍如何使用

「爱情、让人受尽委屈。」/ 2024年03月02日 10:37/ 0 赞/ 59 阅读

相关 Java中如何判断文件是否存在

在Java编程中，判断文件是否存在是一个常见的任务。通过判断文件是否存在，我们可以在程序中采取相应的操作，如读取文件内容、写入文件或者执行其他文件操作。下面将详细介绍如何在Ja

短命女/ 2024年03月02日 09:41/ 0 赞/ 79 阅读

相关如何判断Perl中是否存在文件

Perl has a set of useful file test operators that can be used to see whether a file exis

绝地灬酷狼/ 2022年12月06日 15:37/ 0 赞/ 373 阅读

相关 html怎么判断是否存在,javascript – 如何判断属性是否存在且为false

我很难确定传入 jquery模板的数据是否存在,并且在没有出错的情况下为false.这是我用来测试的 jQuery Templates \{ \{if\}\} logic

╰+攻爆jí腚メ/ 2022年10月07日 12:56/ 0 赞/ 235 阅读

相关如何判断Javascript对象是否存在

Javascript 语言的设计不够严谨，很多地方一不小心就会出错。举例来说，请考虑以下情况。现在，我们要判断一个全局对象myObj是否存在，如果不存在，就对它进行声明

￡神魔★判官ぃ/ 2022年10月01日 01:57/ 0 赞/ 261 阅读

相关判断文件是否存在

import java.io.File; import java.io.IOException; import java.net.HttpURLConn

朴灿烈づ我的快乐病毒、/ 2022年07月18日 05:55/ 0 赞/ 372 阅读

相关 linux下判断路径是否存在(文件夹是否存在)

\include<iostream> \include<sys/types.h> \include<dirent.h> \include<sys/stat.h>

Myth丶恋晨/ 2022年06月12日 09:21/ 0 赞/ 505 阅读

相关判断文件是否存在

File f = new File("D:\\All"); //new一个f对象，输入要查找的文件 if (f.exists()) { //判断文件是否存在

我就是我/ 2022年04月10日 06:17/ 0 赞/ 439 阅读

相关判断对象是否存在

判断对象是否存在录入日期:2006-11-15 21:49:52 -------------------- <SCRIPT language=JavaScri

怼烎@/ 2021年09月10日 04:28/ 0 赞/ 566 阅读