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());
}
sendMessage
sendに変更するにはどうすればよいfloat x1, float x2, float x3
ですか?
サーバー側では、このメッセージを 3 つのフロートにどのように受信/解析するのでしょうか?