pb 蓝牙电子秤接口

蓝牙电子秤 API 接口用于 PB 数据传输
对于蓝牙电子秤的数据传输，采用 Protocol Buffers (PB) 可以显著提高效率并减少数据量。由于 PB 是一种高效的序列化机制，它非常适合于资源受限环境下的应用开发。
设计 Proto 文件结构
定义一个适用于蓝牙电子秤的 .proto 文件来描述消息格式：
syntax = "proto3";

package scale;

message WeightData {
float weight_kg = 1;
string unit = 2; // kg, g, lb etc.
int64 timestamp_ms = 3;
}

此 WeightData 消息包含了重量数值、单位以及时间戳三个字段[^1]。
实现 Android 客户端接收处理逻辑
当在 Android 平台上使用时，可以通过 Bluetooth API 建立连接，并利用 PB 解析接收到的数据流：
// 假设已经建立了蓝牙Socket对象socket
InputStream inputStream = socket.getInputStream();
CodedInputStream codedInput = CodedInputStream.newInstance(inputStream);

try {
Scale.WeightData data = Scale.WeightData.parseFrom(codedInput);
Log.d("Scale", String.format("Received weight %.2f %s at %d",
data.getWeightKg(), data.getUnit(), data.getTimestampMs()));
} catch (IOException e) {
Log.e("Scale", "Failed to parse message from device");
}

这段代码展示了如何通过已建立好的蓝牙套接字获取输入流，并将其转换为适合 PB 的编码方式；之后调用静态方法 parseFrom() 来反序列化得到具体的 WeightData 对象实例[^2]。
Python Socket 编程实现 Protobuf 传输
如果服务器端是基于 Python 构建，则可以按照如下方式进行设置：
import socket
from google.protobuf.internal.decoder import _DecodeVarint32
from my_proto_pb2 import WeightData as WD

server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind(('localhost', 8080))
server_socket.listen(5)

conn, addr = server_socket.accept()
buf = b''

while True:
chunk = conn.recv(4096)
if not chunk:
break

buf += chunk
msg_len, new_pos = _DecodeVarint32(buf, 0)

if new_pos != 0:
proto_msg = WD.FromString(buf[new_pos:new_pos+msg_len])

print(f"Got {proto_msg.weight_kg:.2f}{proto_msg.unit}")
buf = buf[new_pos + msg_len:]

这里实现了简单的 TCP Server，在接收到客户端发送过来的消息后会尝试解码其中包含的 PB 数据包[^3]。