java - Paho MQTT 抛出异常

标签 java mqtt paho iot

为了演示 Paho MQTT,我下载了一个 Java 示例。

 public class Thermometer {

    public static final String BROKER_URL = "tcp://test.mosquitto.org:1883";

    public static final String TOPIC = "xyz.abc";

    private MqttClient client;


    public Thermometer() {
        try {
            MemoryPersistence per = new MemoryPersistence();
            String clientId = UUID.randomUUID().toString();
            client = new MqttClient(BROKER_URL, clientId, per);
        } catch (MqttException e) {
            e.printStackTrace();
            System.exit(1);
        }
    }

当我运行它时出现问题,它位于 client = new MqttClient(BROKER_URL, clientId, per);

Exception in thread "main" java.lang.IllegalArgumentException at org.eclipse.paho.client.mqttv3.MqttClient.(MqttClient.java:170) at mqtt_pub.Thermometer.(Thermometer.java:26) at mqtt_pub.Thermometer.main(Thermometer.java:65)

我发现如果 QoS 的值不是 0、1 或 2,但在 MemoryPersistence 类中他们没有提到,@throws IllegalArgumentException。请帮忙,提前谢谢你。

最佳答案

如果您查看 source code MttqClient 你可以看到 uuid 的长度最多只能是 23 个字符。看起来 uuid 更长:

if (clientId == null || clientId.length() == 0 || clientId.length() > 23)  
{
      throw new IllegalArgumentException();
}

UUID.randomUUID().toString()返回一个长度为36个字符的字符串;

关于java - Paho MQTT 抛出异常,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/28440131/

相关文章:

java - 如何将MQTT Paho导入Java 'playground'?

python - 谷歌云物联网 Python MQTT "out of memory"错误

java - spring:一个接收类列表的bean

c - 如何使用mosquitto_publish同步发布数据?

android - Android 上最具扩展性的推送通知系统是什么?

ios - 保持 iOS 应用程序处于事件状态以使用 MQTT 协议(protocol)

cmake - 如何使用 cmake 构建 eclipse paho

java - 提供文件时未正确获取文件扩展名

java - 预览窗口(如 Windows 7 任务栏显示打开的应用程序)

java - Spring:添加查询参数的惯用方式