当前位置： 首页 > article >正文

HarmonyOS开发实战（ Beta5.0）蓝牙实现服务端和客户端通讯详解

article 2024/11/15 9:47:41

鸿蒙HarmonyOS开发往期必看：

HarmonyOS NEXT应用开发性能实践总结

最新版！“非常详细的” 鸿蒙HarmonyOS Next应用开发学习路线！（从零基础入门到精通）

介绍

本示例分为服务端和客户端两个功能模块。
服务端创建蓝牙服务实例，添加心率跳动服务。以心率跳动值作为特征值，通过notifyCharacteristicChanged接口将心率跳动特征值广播发送给连接到本服务端并订阅了该特征值变动通知的蓝牙客户端设备。
客户端以特定服务UUID作为过滤条件扫描服务端，连接到扫描的设备后通过setCharacteristicChangeNotification接口向服务端发送‘通知心率跳动特征值变动’的请求，以便收到服务端该特征值变动的通知消息。

主要有以下几点功能：

  1. 发现具有特定服务的设备。
  2. 连接到设备。
  3. 发现服务。
  4. 发现服务的特征、读取给定特征的值、为特征设置通知等。

相关概念：

  1. BLE扫描：通过BLE扫描接口startBLEScan实现对BLE设备的搜索。
  2. BLE连接：通过BLE的GattClientDevice实现对BLE设备的连接、断连等操作。
  3. 接收数据：通过BLECharacteristicChange接收特征值的改变。

效果图预览

使用说明

  1. 该功能需要两台设备，进入BLE通讯场景页面，选择当前设备是作为BLE服务端还是BLE客户端。
  2. 点击“BLE服务端”，进入服务端页面。点击“开启BLE心率广播”，打开蓝牙服务，向订阅了心率跳动值通知的客户端广播发送实时心率值。
  3. 点击“BLE客户端”，进入客户端页面。点击“搜索设备”，搜索开启了心率跳动服务的BLE服务端，连接搜索到的蓝牙设备。连接成功后，点击设备右边的“已连接”，进入心率波动图页面查看实时心率。

实现思路

服务端

  1. 开启或关闭蓝牙广播服务。源码参考BluetoothAdvertiser.ets及startAdvertiser。

    toggleAdvertiser(): void {
 if (this.startAdvertiserState) {
   //  TODO: 知识点 关闭蓝牙广播服务
   advertiserBluetoothViewModel.stopAdvertiser();
   this.toggleHeartRate(false);
   this.startAdvertiserState = false;
 } else {
   //  TODO: 知识点 开启蓝牙广播服务
   let ret = advertiserBluetoothViewModel.startAdvertiser();
   if (ret) {
     this.localName = advertiserBluetoothViewModel.getLocalName();
     // 模拟心率跳动
     this.toggleHeartRate(true);
     this.startAdvertiserState = true;
   } else {
     Log.showError(TAG, `toggleAdvertiser: ret = ${ret}`);
   }
 }
}

     // TODO: 知识点 创建蓝牙服务实例
 this.mGattServer = ble.createGattServer();

 let descriptors: Array<ble.BLEDescriptor> = [];
 const arrayBuffer = ArrayBufferUtils.byteArray2ArrayBuffer([11]);
 const descriptor: ble.BLEDescriptor = {
   serviceUuid: BleConstants.UUID_SERVICE_HEART_RATE, //  特定服务（service）的 UUID
   characteristicUuid: BleConstants.UUID_CHARACTERISTIC_HEART_RATE_MEASUREMENT, // 特定特征（characteristic）的 UUID
   descriptorUuid: BleConstants.UUID_DESCRIPTOR_HEART_RATE, // 描述符（descriptor）的 UUID
   descriptorValue: arrayBuffer  // 描述符对应的二进制值
 };
 descriptors[0] = descriptor;

 let characteristics: Array<ble.BLECharacteristic> = [];
 const arrayBufferC = ArrayBufferUtils.byteArray2ArrayBuffer([1]);
 const characteristic: ble.BLECharacteristic = {
   serviceUuid: BleConstants.UUID_SERVICE_HEART_RATE, // 特定服务（service）的 UUID
   characteristicUuid: BleConstants.UUID_CHARACTERISTIC_HEART_RATE_MEASUREMENT, // 特定特征（characteristic）的 UUID
   characteristicValue: arrayBufferC, // 特征对应的二进制值
   descriptors: descriptors  // 特定特征的描述符列表
 };
 characteristics[0] = characteristic;
 // 定义心率跳动服务
 const service: ble.GattService = {
   serviceUuid: BleConstants.UUID_SERVICE_HEART_RATE,
   isPrimary: true, // 主服务
   characteristics: characteristics,
   includeServices: []
 };

 try {
   // 添加服务
   this.mGattServer.addService(service);
   Log.showInfo(TAG, `startAdvertiser: addService suc`);
 } catch (err) {
   Log.showError(TAG, `startAdvertiser: addService err = ${err}`);
 }

 try {
   // 订阅连接服务状态
   this.onConnectStateChange();

   // 设置广播发送的参数
   let setting: ble.AdvertiseSetting = {
     interval: DurationConstants.ADVERTISE_INTERVAL, // 广播间隔，最小值设置160个slot表示100ms
     txPower: 1, // 发送功率，最小值设置-127，最大值设置1，默认值设置-7
     connectable: true  // 是否是可连接广播
   };
   // BLE广播包内容
   let advData: ble.AdvertiseData = {
     serviceUuids: [BleConstants.UUID_SERVICE_HEART_RATE], // 要广播的服务 UUID 列表
     manufactureData: [], // 广播的制造商信息列表
     serviceData: [], // 广播的服务数据列表
   };
   // BLE回复扫描请求回复响应
   let advResponse: ble.AdvertiseData = {
     serviceUuids: [BleConstants.UUID_SERVICE_HEART_RATE],
     manufactureData: [],
     serviceData: [],
   };
   // TODO: 知识点 开始广播
   ble.startAdvertising(setting, advData, advResponse);
   Log.showInfo(TAG, `startAdvertiser: startAdvertising success`);
   return true;
 } catch (err) {
   Log.showError(TAG, `startAdvertiser: startAdvertising err = ${err}`);
 }

  2. 服务开启状态下，广播通知特征值变动。源码参考BluetoothAdvertiser.ets及notifyCharacteristicChanged。

       this.mIntervalId = setInterval(() => {
     this.heartRate = MathUtils.getRandomInt(MIN_HEART_RATE, MAX_HEART_RATE);
     if (this.deviceId) {
       // TODO: 知识点 通知客户端心率特征值变动
       advertiserBluetoothViewModel.notifyCharacteristicChanged(this.deviceId, this.heartRate);
     } else {
       Log.showWarn(TAG, `toggleHeartRate: deviceId is null， heartRate = ${this.heartRate}`);
     }
   }, DurationConstants.NOTIFY_DELAY_TIME)

         // 构造BLECharacteristic
     let arrayBufferC = ArrayBufferUtils.byteArray2ArrayBuffer([0x00, heartRate]);
     let characteristic: CharacteristicModel = {
       serviceUuid: BleConstants.UUID_SERVICE_HEART_RATE,
       characteristicUuid: BleConstants.UUID_CHARACTERISTIC_HEART_RATE_MEASUREMENT,
       characteristicValue: arrayBufferC,
       descriptors: descriptors
     };
     // 通知的特征值消息
     let notifyCharacteristic: NotifyCharacteristicModel = {
       serviceUuid: BleConstants.UUID_SERVICE_HEART_RATE,
       characteristicUuid: BleConstants.UUID_CHARACTERISTIC_HEART_RATE_MEASUREMENT,
       characteristicValue: characteristic.characteristicValue,
       confirm: false  // 对端不需要确认
     };
     // TODO: 知识点 server端特征值发生变化时，主动通知已连接的client设备。
     this.mGattServer.notifyCharacteristicChanged(deviceId, notifyCharacteristic, (err: BusinessError) => {
       if (err) {
         Log.showError(TAG, 'notifyCharacteristicChanged callback failed， err.code = ' + err.code + ", err.message =" + err.message);
       } else {
         Log.showInfo(TAG, 'notifyCharacteristicChanged callback success');
       }
     });
客户端

  1. 启动时请求蓝牙权限。源码参考BluetoothClient.ets。

    // 所需蓝牙权限
const PERMISSION_LIST: Array<Permissions> = [
  'ohos.permission.APPROXIMATELY_LOCATION',
  'ohos.permission.LOCATION'
];

// TODO 知识点： 获取蓝牙相关权限
function reqPermissionsFromUser(permissions: Array<Permissions>, context: common.UIAbilityContext): void {
  const atManager: abilityAccessCtrl.AtManager = abilityAccessCtrl.createAtManager();
  atManager.requestPermissionsFromUser(context, permissions).then((data) => {
    const granStatus: Array<number> = data.authResults;
    const length: number = granStatus.length;
    for (let i = 0; i < length; i++) {
      if (granStatus[i] === 0) {

      } else {
        return;
      }
    }
  })
}

  2. 扫描设备。源码参考BluetoothClientModel.ets

    startBLEScan(): boolean {   
  if (!this.isBluetoothEnabled()) {
    Log.showInfo(TAG, `startBLEScan: bluetooth is disable.`);
    // 启动蓝牙服务
    this.enableBluetooth();
    promptAction.showToast({
      message: $r('app.string.ble_toast_enable_bluetooth'),
        duration: DurationConstants.DURATION_TIME
      });
    return false;
  }
  // 订阅搜索蓝牙服务
  this.onBLEDeviceFind(); 
  // 扫描蓝牙设备
  const ret = this.startBLEScanInner();
  return ret;
}

  3. 连接设备。源码参考BluetoothClientModel.ets及connectInner。

    .onClick(() => {
  if (this.bluetoothDevice.connectionState === ConnectionState.STATE_DISCONNECTED) {
    // 连接蓝牙设备
    bluetoothViewModel.connect(this.bluetoothDevice);
  } else if (this.bluetoothDevice.connectionState === ConnectionState.STATE_CONNECTED) { 
    // 断开与蓝牙设备的连接
    bluetoothViewModel.disconnect();
  }
})

    private connectInner(gattClientDevice: ble.GattClientDevice): boolean {
  try {
    if (!gattClientDevice) {
      Log.showWarn(TAG, `connectInner: mGattClientDevice is null`);
      return false;
    }
    // 订阅连接状态改变消息
    this.onBLEConnectionStateChange();
    // 订阅特征值改变消息
    this.onBLECharacteristicChange();
    // 开始连接
    gattClientDevice.connect();
    this.mConnectBluetoothDevice.connectionState = ConnectionState.STATE_CONNECTING;
    AppStorage.setOrCreate('connectBluetoothDevice', this.mConnectBluetoothDevice);
    return true;
  } catch (err) {
    Log.showError(TAG, `connectInner: err = ${err}`);
  }
  return false;
}

  4. 向服务端发送‘通知心率跳动’特征值请求,侦听特征值变化数据。源码参考BLECharacteristicChange。

    // connect success, Starts discovering services.
let services: Array<ble.GattService> = await this.mGattClientDevice!.getServices();
Log.showInfo(TAG, `onBLEConnectionStateChange: services = ${JSON.stringify(services)}`);

// Characteristic enable/disable indicate/notify
let service: ble.GattService | undefined =
services.find(item => item.serviceUuid === BleConstants.UUID_SERVICE_HEART_RATE);
let characteristics: Array<ble.BLECharacteristic> = service!.characteristics;
let characteristic: ble.BLECharacteristic | undefined =
characteristics.find(item => item.characteristicUuid ===
BleConstants.UUID_CHARACTERISTIC_HEART_RATE_MEASUREMENT);
Log.showInfo(TAG, `onBLEConnectionStateChange: characteristic = ${JSON.stringify(characteristic)}`);
// TODO 知识点： 向服务端发送设置通知此特征值请求
this.mGattClientDevice!.setCharacteristicChangeNotification(characteristic, true);
let descriptors: Array<ble.BLEDescriptor> = characteristic!.descriptors;
let descriptor: ble.BLEDescriptor | undefined =
descriptors.find(item => item.descriptorUuid === BleConstants.UUID_DESCRIPTOR_HEART_RATE);
Log.showInfo(TAG, `onBLEConnectionStateChange: descriptor = ${JSON.stringify(descriptor)}`);
descriptor!.descriptorValue = ArrayBufferUtils.byteArray2ArrayBuffer([0x01, 0x00]);
this.mGattClientDevice!.writeDescriptorValue(descriptor);

    // TODO 知识点： 订阅特征值变化事件
this.mGattClientDevice.on('BLECharacteristicChange', (data: ble.BLECharacteristic) => {
Log.showInfo(TAG, `onBLECharacteristicChange: data = ${JSON.stringify(data)}`);
let characteristicValue: ArrayBuffer = data.characteristicValue;
Log.showInfo(TAG,
`onBLECharacteristicChange: characteristicValue.length = ${characteristicValue.byteLength}, characteristicValue = ${JSON.stringify(new Uint8Array(characteristicValue))}`);
let byteArr = ArrayBufferUtils.arrayBuffer2ByteArray(characteristicValue);
Log.showInfo(TAG, `byteArr = ${byteArr}`);
let heartRate = byteArr[1];
AppStorage.setOrCreate('heartRate', heartRate);
})

高性能知识点

不涉及

工程结构&模块类型

bluetooth                                  // har类型
src/main/ets/
|---constants
|   |---BleConstants.ts                    // BLE常量
|   |---StyleConstants.ts                  // Style样式常量
|   |---DurationConstants.ts.ts            // 定时、延迟类常量
|---model
|   |---BluetoothDevice.ets                // 蓝牙设备model
|---pages
|   |---BluetoothView.ets                  // 场景首页，可选择进入客户端、服务端
|   |---BluetoothAdvertiser.ets            // 广播者角色（作为服务端）
|   |---BluetoothClient.ets                // 客户端连接页面
|   |---HeartRate.ets                      // 连接成功后，侦听到服务端的心率数据   
|---uicomponents
|   |---HeartRateGraph.ets                 // 实时心率图表
|   |---NavigationBar.ets                  // 顶部导航栏
|---uitls
|   |---ArrayBufferUtils.ts                // ArrayBuffer工具
|   |---DateUtils.ts                       // 日期工具
|   |---Log.ts                             // 日志工具
|   |---MathUtils.ts                       // Math工具，用于生成随机数
|---viewmodel
|   |---BluetoothClientModel.ets           // 开启蓝牙、扫描BLE、连接、断连等BLE接口
|   |---AdvertiserBluetoothViewModel.ets   // 开启蓝牙、开启蓝牙心率广播等

最后

小编在之前的鸿蒙系统扫盲中，有很多朋友给我留言，不同的角度的问了一些问题，我明显感觉到一点，那就是许多人参与鸿蒙开发，但是又不知道从哪里下手，因为体系杂乱无章，教授的人也多，无从选择。有很多小伙伴不知道学习哪些鸿蒙开发技术？不知道需要重点掌握哪些鸿蒙应用开发知识点？而且学习时频繁踩坑，最终浪费大量时间。所以有一份实用的鸿蒙（HarmonyOS NEXT）路线、视频、文档用来跟着学习是非常有必要的。

如果你是一名有经验的资深Android移动开发、Java开发、前端开发、对鸿蒙感兴趣以及转行人员

鸿蒙 NEXT 全栈开发学习笔记 希望这一份鸿蒙学习文档能够给大家带来帮助~

 鸿蒙（HarmonyOS NEXT）最新学习路线

​

该路线图包含基础技能、就业必备技能、多媒体技术、六大电商APP、进阶高级技能、实战就业级设备开发，不仅补充了华为官网未涉及的解决方案

路线图适合人群：

IT开发人员：想要拓展职业边界
零基础小白：鸿蒙爱好者，希望从0到1学习，增加一项技能。
技术提升/进阶跳槽：发展瓶颈期，提升职场竞争力，快速掌握鸿蒙技术

2.视频教程+学习PDF文档

（鸿蒙语法ArkTS、TypeScript、ArkUI教程……）

 纯血版鸿蒙全套学习文档（面试、文档、全套视频等）

                   

总结

参与鸿蒙开发，你要先认清适合你的方向，如果是想从事鸿蒙应用开发方向的话，可以参考本文的学习路径，简单来说就是：为了确保高效学习，建议规划清晰的学习路线


http://www.kler.cn/a/310869.html

相关文章：

  • 软件测试面试大全（含答案+文档）
  • Linux网络——网络初识
  • 大数据新视界 -- 大数据大厂之 Impala 存储格式转换：从原理到实践，开启大数据性能优化星际之旅（下）（20/30）
  • 三、损失函数
  • 量化交易系统开发-实时行情自动化交易-3.4.2.2.Okex交易数据
  • 马斯克万卡集群AI数据中心引发的科技涟漪：智算数据中心挑战与机遇的全景洞察
  • 面向对象设计的五大原则（SOLID 原则）
  • Jsp学习笔记(详解)
  • 【2025】儿童疫苗接种预约小程序（源码+文档+解答）
  • python 实现collatz sequence考拉兹序列算法
  • 如何使用下拉字段创建WordPress表单（简单方法）
  • 1.熟悉接口测试（Postman工具）
  • JavaWeb笔记整理——Redis
  • 程序员装新机
  • 【架构设计】多级缓存：应用案例与问题解决策略
  • Linux入门学习：Linux权限理解
  • PyQGIS开发 1 环境配置
  • web渗透—RCE
  • 单片机中为什么要使用5v转3.3v，不直接使用3.3V电压
  • 【Bug解决】Nacos启动成功，但却无法访问（提示：无法访问此网站，192.168.10.88的响应时间过长）
  • 【算法题】46. 全排列-力扣(LeetCode)
  • Flink 实现无界流
  • 十七，Spring Boot 整合 MyBatis 的详细步骤(两种方式)
  • 四、JVM原理-4.2、内存管理
  • 计算机视觉（CV）技术是指计算机系统通过模拟人类视觉系统来识别、理解和解释图像和视频的能力。它可以在各种领域中发挥巨大作用，但也面临一些挑战。
  • tasklist命令的应用实例