【发布时间】:2019-03-26 08:27:40
【问题描述】:
我正在尝试通过 MQTT 协议连续发送 6 个浮点数的数组。我使用 sprintf 函数将它们作为 ASCII 字符发送。我决定将它们作为原始字节发送。我将这些浮点数放入一个联合中以将它们表示为无符号字符。问题是当这些浮点数中的任何一个是整数值时,它们的字节表示在整数位置之后变为空。
union {
float array[6];
unsigned char bytes[6 * sizeof(float)];
} floatAsBytes;
如果所有 floatAsBytes.array 都包含浮点值,则完全没有问题。
如果我说floatAsBytes.array[0] = 0,floatAsBytes.bytes 将变为 null。
如果我说floatAsBytes.array[3] = 4,我可以看到前 8 个字节,但是这次最后 16 个字节变为空。
我的客户端 C 代码的最小示例
#define QOS 0
#define TIMEOUT 1000L
#include <stdlib.h>
#include <unistd.h>
#include <stdio.h>
#include <stdint.h>
#include <string.h>
#include <limits.h>
#include "MQTTClient.h"
union bitFloat{
float f[6];
unsigned char s[6*sizeof(float)];
};
void publish(MQTTClient client, char* topic, char* payload) {
MQTTClient_message pubmsg = MQTTClient_message_initializer;
pubmsg.payload = payload;
pubmsg.payloadlen = strlen(pubmsg.payload);
pubmsg.qos = QOS;
pubmsg.retained = 0;
MQTTClient_deliveryToken token;
MQTTClient_publishMessage(client, topic, &pubmsg, &token);
MQTTClient_waitForCompletion(client, token, TIMEOUT);
}
int main(){
MQTTClient client;
MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
MQTTClient_message pubmsg = MQTTClient_message_initializer;
MQTTClient_deliveryToken token;
int rc;
MQTTClient_create(&client, "MQTTADDRESS:MQTTPORT", "TestClient",
MQTTCLIENT_PERSISTENCE_NONE, NULL);
conn_opts.keepAliveInterval = 20;
conn_opts.cleansession = 1;
if ((rc = MQTTClient_connect(client, &conn_opts)) != MQTTCLIENT_SUCCESS)
{
printf("Failed to connect, return code %d\n", rc);
exit(-1);
}
int i;
while(1){
union bitFloat payload;
payload.f[0] = 4.53; payload.f[1] = 2.39; payload.f[2] = 28.96; payload.f[3] = -1.83; payload.f[4] = -27.0; payload.f[5] = 9.32;
publish(client, "MyTestTopic", payload.s);
sleep(1);
}
return 0;
}
接收消息并显示消息的 Python 脚本
# !/usr/bin/env python
import struct
import numpy as np
import paho.mqtt.client as mqtt
def on_message(client, userdata, message):
test1 = struct.unpack('<f', message.payload[0:4])[0]
test2 = struct.unpack('<f', message.payload[4:8])[0]
test3 = struct.unpack('<f', message.payload[8:12])[0]
test4 = struct.unpack('<f', message.payload[12:16])[0]
test5 = struct.unpack('<f', message.payload[16:20])[0]
test6 = struct.unpack('<f', message.payload[20:24])[0]
print(test1, test2, test3, test4, test5, test6)
client = mqtt.Client()
client.on_message = on_message
client.connect("MQTTADDRESS", MQTTPORT)
client.subscribe("MyTestTopic")
client.loop_forever()
【问题讨论】:
-
这可能与字节序或网络字节顺序有关。检查你得到了哪些字节,你发送了哪些字节,以及两端使用了哪种字节序。
-
字节顺序为小端。同样在发送它们之前,我正在使用 printf("Byte representation: %s\n", floatAsBytes.bytes) 检查它。它在客户端和服务器端都是空的。 @RudyVelthuis
-
好的,那不是问题。
-
您能否提供一个发生意外行为的测试样本?
标签: c floating-point byte bit