flutter_bluetooth_serial高速蓝牙串口接收数据粘包问题求助

针对高速通信下的粘包问题，核心思路是通过中间缓冲区累积字节，凑够固定的40字节后再处理，完全不需要依赖换行符等分隔标识。下面提供两种实用实现方式：

方式一：直接维护全局缓冲区（简单直观） #

在业务类或页面中定义缓冲区和目标长度，修改数据接收逻辑：

// 全局缓冲区，用于累积未处理的字节
Uint8List _buffer = Uint8List(0);
// 固定读取长度
const int _targetChunkLength = 40;

void initBluetoothListener() {
  _dataSubscription = connection.input!.listen(_onDataReceived);
}

void _onDataReceived(Uint8List incomingData) {
  // 合并新接收的字节到缓冲区
  _buffer = Uint8List.fromList([..._buffer, ...incomingData]);

  // 循环处理所有完整的40字节块
  while (_buffer.length >= _targetChunkLength) {
    // 取出前40字节作为完整数据块
    Uint8List fixedChunk = _buffer.sublist(0, _targetChunkLength);
    // 更新缓冲区，保留剩余未处理字节
    _buffer = _buffer.sublist(_targetChunkLength);

    // 处理固定长度数据块
    _processFixedLengthData(fixedChunk);
  }
}

void _processFixedLengthData(Uint8List chunk) {
  print('收到40字节完整数据块: ${ascii.decode(chunk)}');

  // 保留原有退格字符处理逻辑
  var backspacesCounter = 0;
  for (var byte in chunk) {
    if (byte == 8 || byte == 127) backspacesCounter++;
  }

  var processedBuffer = Uint8List(chunk.length - backspacesCounter);
  var bufferIndex = processedBuffer.length;

  backspacesCounter = 0;
  for (int i = chunk.length - 1; i >= 0; i--) {
    if (chunk[i] == 8 || chunk[i] == 127) {
      backspacesCounter++;
    } else {
      if (backspacesCounter > 0) {
        backspacesCounter--;
      } else {
        processedBuffer[--bufferIndex] = chunk[i];
      }
    }
  }

  // 此处添加业务逻辑，比如解析处理后的buffer
}

方式二：封装StreamTransformer（复用性强） #

如果项目中有多处需要固定长度读取的场景，可将缓冲区逻辑封装为StreamTransformer，直接转换原始流：

// 创建固定长度流转换器
StreamTransformer<Uint8List, Uint8List> createFixedLengthTransformer(int targetLength) {
  Uint8List buffer = Uint8List(0);
  return StreamTransformer.fromHandlers(
    handleData: (data, sink) {
      // 合并新数据到缓冲区
      buffer = Uint8List.fromList([...buffer, ...data]);
      // 输出所有完整的目标长度块
      while (buffer.length >= targetLength) {
        sink.add(buffer.sublist(0, targetLength));
        buffer = buffer.sublist(targetLength);
      }
    },
    handleError: (error, stackTrace, sink) {
      sink.addError(error, stackTrace);
    },
    handleDone: (sink) {
      // 通信结束时，处理剩余不完整字节（按需选择逻辑）
      if (buffer.isNotEmpty) {
        print('通信结束，剩余不完整数据：${buffer.length}字节');
        // 也可抛出错误：sink.addError('剩余未处理不完整数据');
      }
      sink.close();
    },
  );
}

// 使用转换器初始化监听
void initBluetoothListener() {
  _dataSubscription = connection.input!
      .transform(createFixedLengthTransformer(40))
      .listen(_onFixedLengthDataReceived);
}

// 直接处理固定40字节的数据块
void _onFixedLengthDataReceived(Uint8List chunk) {
  print('收到40字节完整数据块: ${ascii.decode(chunk)}');

  // 保留原有退格字符处理逻辑
  var backspacesCounter = 0;
  for (var byte in chunk) {
    if (byte == 8 || byte == 127) backspacesCounter++;
  }

  var processedBuffer = Uint8List(chunk.length - backspacesCounter);
  var bufferIndex = processedBuffer.length;

  backspacesCounter = 0;
  for (int i = chunk.length - 1; i >= 0; i--) {
    if (chunk[i] == 8 || chunk[i] == 127) {
      backspacesCounter++;
    } else {
      if (backspacesCounter > 0) {
        backspacesCounter--;
      } else {
        processedBuffer[--bufferIndex] = chunk[i];
      }
    }
  }

  // 此处添加业务逻辑
}

关键说明 #

1. 两种方式均能确保每次处理完整的40字节数据，彻底解决粘包问题，不受传输速率影响。
2. 通信结束时的剩余不完整字节，可根据业务需求选择忽略、抛出错误或补全（若协议支持）。
3. 保留了原有退格字符处理逻辑，确保数据格式符合预期。

内容的提问来源于stack exchange，提问作者Victor Garcia