关于mqtt client不能支持通配符的问题

PublishProcessor类的processPublishMessage方法存在问题
以下是我的本地解决方案
    private void processPublishMessage(MqttPublishMessage mqttPublishMessage, MqttClient mqttClient) {
        MqttPublishVariableHeader header = mqttPublishMessage.getVariableHeader();
        Subscribe subscribe = mqttClient.getSubscribes().get(header.getTopicName());
        if (subscribe == null) {
            Set<String> subKeys = mqttClient.getSubscribes().keySet();
            for (String subKey : subKeys) {
                if (subKey.endsWith("/#")) {
                    if (header.getTopicName().startsWith(subKey.substring(0, subKey.indexOf("/#")))) {
                        subscribe = mqttClient.getSubscribes().get(subKey);
                    }
                }
            }
        }
        // If unsubscribed, maybe null.
        if (subscribe != null && !subscribe.getUnsubscribed()) {
            subscribe.getConsumer().accept(mqttClient, mqttPublishMessage);
        }
    }![本地截图](https://foruda.gitee.com/images/1667554715236518083/1cafd470_1402815.png "1.png")

smartboot/smart-mqtt

内容风险标识

评论 (0)

smartboot/smart-mqtt .gitee-modal { width: 500px !important; }

内容风险标识