如何用paho mqtt java实现请求-响应模式？

Question

我想使用 Paho MQTT Java 并实现一些 "请求-响应 "模式。我的意思是，在某些情况下，客户端必须与服务器对话，并期望对特定的请求做出特定的回答。感觉这个lib已经具备了匹配请求和响应所需的一切，但我不能完全把它放在一起。

我发现我可以通过以下方式检索令牌 deliveryComplete，我可以做一个 setActionCallback 在此基础上。但首先，我并不完全确定 "动作 "是什么意思，那么，如果它的意思是我认为的意思，如何从那里得到我的请求的实际响应？那么，如果它的意思是我认为的意思，如何从那里得到我的请求的实际响应？

sampleClient.setCallback(new MqttCallback() {
    @Override
    public void connectionLost(Throwable cause) {
    }

    @Override
    public void messageArrived(String topic, MqttMessage message) throws Exception {
        System.out.println(topic);
        System.out.println("setCallback: "+ message.toString());
    }

    @Override
    public void deliveryComplete(IMqttDeliveryToken token) {
        System.out.println(token.getMessageId());
        token.setActionCallback(new IMqttActionListener() {
            @Override
            public void onSuccess(IMqttToken asyncActionToken) {
                var response = asyncActionToken.getResponse();

                try {
                    System.out.println(new String(response.getPayload()));
                } catch (MqttException e) {
                    e.printStackTrace();
                }
            }
            @Override
            public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
            }
        });
    }
});

Answer 1

另一答案