如果资源路径包含namesapce，那么把namespace去掉

public static String wrapNamespace(String namespace, String resourceWithOutNamespace) {

当然也有反向的，除了去掉resource中的namespace外，还有给resource包上namespace

if (isRetryTopic(resourceWithOutNamespace)) {
    stringBuilder.append(MixAll.RETRY_GROUP_TOPIC_PREFIX);
}

if (isDLQTopic(resourceWithOutNamespace)) {
    stringBuilder.append(MixAll.DLQ_GROUP_TOPIC_PREFIX);
}

return stringBuilder.append(namespace).append(NAMESPACE_SEPARATOR).append(resourceWithoutRetryAndDLQ).toString();

基本是一样的，这里也可以看出来，Topic分RetryTopic，DLQTopic两大类

且namespace是以 % 做分割的

public static final String RETRY_GROUP_TOPIC_PREFIX = "%RETRY%";
public static final String DLQ_GROUP_TOPIC_PREFIX = "%DLQ%";

从MixAll工具类里，这一点也得到应征。

还有RetryTopic DLQTopic的判断方式：

public static boolean isRetryTopic(String resource) {
    return StringUtils.isNotBlank(resource) && resource.startsWith(MixAll.RETRY_GROUP_TOPIC_PREFIX);
}

public static boolean isDLQTopic(String resource) {
    return StringUtils.isNotBlank(resource) && resource.startsWith(MixAll.DLQ_GROUP_TOPIC_PREFIX);
}

也就是该resource资源路径是

以RetryTopic 或者DLQTopic

开头的。

总结下namesapceutil

org.apache.rocketmq.common.protocol.NamespaceUtil

这个工具类，

它围绕namespace

提供了很多拼接，以及拆分的方法

比如把 资源路径中的 namespace 去掉

或者给 资源路径 包上namespace

回到ClientConfig类

public Set<String> withNamespace(Set<String> resourceSet) {
    Set<String> resourceWithNamespace = new HashSet<String>();
    for (String resource : resourceSet) {
        resourceWithNamespace.add(withNamespace(resource));
    }
    return resourceWithNamespace;
}

public String withoutNamespace(String resource) {
    return NamespaceUtil.withoutNamespace(resource, this.getNamespace());
}

public Set<String> withoutNamespace(Set<String> resourceSet) {
    Set<String> resourceWithoutNamespace = new HashSet<String>();
    for (String resource : resourceSet) {
        resourceWithoutNamespace.add(withoutNamespace(resource));
    }
    return resourceWithoutNamespace;
}