java paho 库中的行为 setTimeToWait() 方法

Question

我使用库 paho 与 mqtt 代理连接，发送消息，几乎一切正常，但我对 setTimeToWait() 方法有疑问。它不会影响我在方法 setTimeToWait(2000) 或 setTimeToWait(10) 中投入了多少毫秒。我总是收到来自 publiusher 的消息。

为什么我可以在几个小时内收到消息？如果我将等待时间设置为 2000 毫秒。 我认为在 2 秒后没有来自发布者的消息，我的订阅者无法从发布者接收消息并且控制将被返回。

我做错了什么？

出版商代码：

public class MqttPublishSample {

    public static void main(String[] args) throws MqttException {

        String messageString = "{\"device_status\": \"ready\"}";

        if (
                args.length == 2 ) {
            messageString = args[1];
        }


        System.out.println("== START PUBLISHER ==");
        MqttClient client = new MqttClient("tcp://localhost:1883" , MqttClient.generateClientId());
        client.connect();
        MqttMessage message = new MqttMessage();
        message.setPayload(messageString.getBytes());
        message.setQos(1);
        client.publish("/catalog", message);

        System.out.println("\tMessage '"+ messageString +"' to 'iot_data'");
        client.disconnect();

        System.out.println("== END PUBLISHER ==");

    }
}

订阅者代码：

public class MqttSuscribeSample {

    public static void main(String[] args) {

        System.out.println("== START SUBSCRIBER ==");

        try{
            MqttClient client=new MqttClient("tcp://localhost:1883", MqttClient.generateClientId());
            client.setTimeToWait(2000);
            client.setCallback( new SimpleMqttCallback() );
            client.connect();
            client.subscribe( "/catalog");
        }catch (Exception ex){
            ex.printStackTrace();
        }
    }

}

SimpleMqttCallback 代码

public class SimpleMqttCallback implements MqttCallback {

    public void connectionLost(Throwable throwable) {
        System.out.println("Connection to MQTT broker lost!");
    }

    public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
        System.out.println("Message received:\t"+ new String(mqttMessage.getPayload()) );

    }

    public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
    }
}

Answer 1

setTimeToWait()方法是客户端在执行特定操作时等待代理响应的时间，例如

发布消息
进行订阅
连接或断开与代理的连接

这不是客户端应等待多长时间或为现有订阅传递消息。

如果您想要这种行为，您需要运行您自己的计时器，并在超时时取消订阅该主题或断开与代理的连接。

java paho 库中的行为 setTimeToWait() 方法

Behaviour setTimeToWait() method in java paho library

java

mqtt

paho