0

RabbitMQ およびメッセージ パッシング API の新機能。数ミリ秒ごとに float 値のトリプレットを送信したいと考えています。接続/チャネルを初期化するには、次のものが必要です。

connection = factory.newConnection();
channel = connection.createChannel();
channel.queueDeclare(QUEUE_NAME, false, false, false, null);

次に、メッセージを送信したい場合、次のように文字列を実行します。

private void sendMessage(String message) throws IOException {
    channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
}

sendMessagesendに変更するにはどうすればよいfloat x1, float x2, float x3ですか?

サーバー側では、このメッセージを 3 つのフロートにどのように受信/解析するのでしょうか?

4

1 に答える 1