EMQX - 发布具有唯一标识符的 MQTT 主题比静态 MQTT 主题花费更多时间

Question

我试图在 emqx 代理上发布不同主题的消息。场景在使用一个客户端发布动态主题时需要很多时间，如果我们将主题名称设置为静态，则需要的时间要少得多。

我在这里发布了相同的结果和代码。

我正在使用带有 Eclipse paho 客户端版本 3 和 Qos 级别 1 的 EMQX 代理。

使用 100 条简单发布消息的不同主题的时间（在此处将 id 视为动态）：

总时间模式 1：/config/{id}/outward::36 sec -----------------> 这里的主题是动态的。 {id} 是一个变量，其值在循环中改变，如下代码所示

总时间模式 2：/config/test::1.2 sec -----------------------> HERE TOPIC 是 STATIC

我应该如何发布具有不同 id 的消息，以便创建主题不会花费太多时间？

public class MwttPublish {
    static IMqttClient instance= null;
public static IMqttClient getInstance() {
        try {
            if (instance == null) {         
                instance = new MqttClient(mqttHostUrl, "SimpleTestMQTT");
            }
            if (!instance.isConnected()) {
                MqttConnectOptions options = new MqttConnectOptions();
                options.setUserName("test");
                options.setPassword("test".toCharArray());
                options.setAutomaticReconnect(true);
                options.setCleanSession(false);
                options.setConnectionTimeout(10);

                instance.connect(options);
            }
        } catch (final Exception e) {
            System.out.println("Exception in mqtt: {}" + e.getMessage());
        }
        return instance;
    }
    public static void publishMessage() throws MqttException {
        IMqttClient iMqttClient = getInstance();
        MqttMessage mqttMessage = new MqttMessage("Hello".getBytes());
        mqttMessage.setQos(1);
        mqttMessage.setRetained(true);

        System.out.println("Publish Start for pattern 1");
        int i =0;
        final BigDecimal mqttmsgPublishstartTime = new BigDecimal(System.currentTimeMillis());
        do {
            iMqttClient.publish("/config/" +i +"/outward", mqttMessage);
            i++;
        }while(i<100);
        System.out.println("Total time  pattern 1 /config/i/outward::" + (new BigDecimal(System.currentTimeMillis())).subtract(mqttmsgPublishstartTime));


        System.out.println("Publish Start for pattern 2");

        final BigDecimal mqttmsgPublishstartTime1 = new BigDecimal(System.currentTimeMillis());
        i =0;
        do {
            iMqttClient.publish("/config/test", mqttMessage);
            i++;
        }while(i<100);
        System.out.println("Total time pattern 2 /config/test::" + (new BigDecimal(System.currentTimeMillis())).subtract(mqttmsgPublishstartTime1));

        
    }
}

Answer 1

这不是一个有效的测试，您已经陷入了许多经典的微型基准测试陷阱，例如

• 样本量太小了
• 不考虑 JVM JIT 预热或 GC 开销
• 不比较喜欢与喜欢，例如连接主题字符串所花费的时间

请查看以下内容：https://stackoverflow.com/a/2844291/504554

此外，从 MQTT 的角度来看，主题是短暂的，它们仅在消息发布的那一刻才真正“存在”，同时代理检查具有匹配模式的订阅客户端。