如何使用 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 是什么？在文档中他们说它是，Object callbackContext但我不明白它是什么以及为什么我们使用它msg作为这个参数。

谢谢您的回答

Answer 1

将整数作为二进制消息发送非常简单：Message msg = new Message(ByteBuffer.allocate(4).putInt(1695609641).array());sendEventAsync 方法中的第三个参数是第二个参数中回调方法的上下文对象，方法签名如下void execute(IotHubStatusCode responseStatus, Object callbackContext);所以在第三个参数中传入消息可以让你在回调方法中访问消息