如何使用 Azure Java SDK 发送和接收消息

Question

我正在使用 Azure Java SDK 来学习开发 Java IoT Edge 模块。我正在学习本教程 https://docs.microsoft.com/en-us/azure/iot-edge/tutorial-java-module.

因此他们解释了如何使用回调发送消息和接收消息，如下所示：

// Send message:
client.sendEventAsync(msg, eventCallback, msg, App.OUTPUT_NAME);

// Receive message:
private static MessageCallbackMqtt msgCallback = new MessageCallbackMqtt();

client.setMessageCallback(App.INPUT_NAME, msgCallback, client);

protected static class MessageCallbackMqtt implements MessageCallback {
    private int counter = 0;

    @Override
    public IotHubMessageResult execute(Message msg, Object context) {
            System.out.println(String.format("Received message %d: %s", this.counter, new String(msg.getBytes(), Message.DEFAULT_IOTHUB_MESSAGE_CHARSET))); 
    }
}

所以如您所见，发送和接收的消息类型为Message。

例如，我如何发送整数？我看到我可以用

将它转换成字符串

String msgString = new String(msg.getBytes(), Message.DEFAULT_IOTHUB_MESSAGE_CHARSET);

但是整数呢？

另外，sendEventAsync 方法中的第三个参数 msg 是什么？在 documentation 他们说它是 Object callbackContext 但我不明白它是什么以及为什么我们使用 msg 作为这个参数。

感谢您的回答

Answer 1

将整数作为二进制消息发送非常简单：

Message msg = new Message(ByteBuffer.allocate(4).putInt(1695609641).array());

sendEventAsync 方法中的第三个参数是第二个参数中回调方法的上下文对象，方法签名如下

void execute(IotHubStatusCode responseStatus, Object callbackContext);

所以在第三个参数中传入消息就可以在回调方法中访问消息

如何使用 Azure Java SDK 发送和接收消息

How to send & receive message with Azure Java SDK

java

azure

azure-sdk

azure-iot-edge