Method loadMQ

ZezeJava/ZezeJava/src/main/java/Zeze/MQ/MQManager.java:102–124

()

    }

    private void loadMQ() throws IOException {
        var topics = new File(home).listFiles();
        if (null == topics)
            return ;

        for (var topic : topics) {
            if (topic.isDirectory()) {
                var partitions = topic.listFiles();
                if (null == partitions)
                    continue;
                var partitionIndexes = new HashSet<Integer>();
                for (var partition : partitions) {
                    if (partition.isFile()) {
                        // 相同分区的文件可能有多个，这里使用HashSet会去重。
                        var pa = partition.getName().split("\\.");
                        if (pa.length == 2)
                            partitionIndexes.add(Integer.parseInt(pa[0]));
                    }
                }
                createPartition(topic.getName(), partitionIndexes);
            }
        }
    }

    private void createPartition(String topic, HashSet<Integer> partitionIndexes) {
        var cp = queues.computeIfAbsent(topic, (key) -> new MQPartition(this));