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

鸿蒙NEXT开发中使用星闪服务

article 2025/1/6 17:29:06

大家好，我是 V 哥，学习鸿蒙开发的星闪服务，整理了这个学习笔记分享给大家。NearLink Kit（星闪服务）是鸿蒙操作系统提供的一种低功耗、高速率的短距离通信服务，它允许设备之间进行连接和数据交互。以下是一些具体的使用案例和步骤，以帮助理解如何在实际业务中使用星闪服务。

以下这些场景使用星闪

智能座舱
- 车内降噪：使用星闪服务在车辆内部进行音频信号的传输，以实现主动降噪功能。
- 互动投屏：通过星闪服务将手机或其他移动设备上的屏幕内容无线传输到车载显示屏幕上。
- 车载娱乐：利用星闪服务连接车载信息系统和乘客的个人设备，提供个性化娱乐体验。
- 智能车钥匙：通过星闪服务实现车辆的无钥匙进入和启动功能，提升车辆的智能化水平。
智能家居
- 设备控制：使用星闪服务连接家中的各种智能设备，如智能灯泡、智能插座等，实现远程控制和自动化操作。
智能终端
- 鼠标和手写笔：中心设备（如电脑或平板）通过星闪服务与外围设备（鼠标、手写笔）配对连接，使用鼠标和手写笔作为输入控制中心设备。
智能制造
- 生产线自动化：在生产线上使用星闪服务连接各种传感器和控制器，实现生产过程的实时监控和优化。

开发步骤

以下是使用NearLink Kit实现星闪广播的基本步骤：

准备软硬件环境
- 确保开发环境为DevEco Studio 5.0.1 Beta3及以上版本，SDK为API 13 beta及以上。
- 确认终端设备支持星闪功能，如Mate 60 Pro、Pura70系列等。
申请权限
- 动态申请星闪权限ohos.permission.ACCESS_NEARLINK。
广播接口说明
- 使用startAdvertising接口启动星闪广播。
- 使用stopAdvertising接口停止星闪广播。
- 通过on和off接口订阅和取消订阅星闪广播状态变化事件。
广播实现
- 创建一个类（如NearLinkAdvUtils），封装星闪广播的相关功能。
- 订阅星闪广播状态变化事件，以便在状态变化时接收通知。
- 设置广播参数和数据，包括广播UUID、广播内容等。
- 开启星闪广播，并获取返回的advertisingId。
- 停止星闪广播时使用对应的advertisingId。

来看一个案例代码

我们以实现车内降噪功能为例，使用星闪服务（NearLink Kit）进行音频信号的传输，涉及到音频信号的采集、处理和播放。通过一个简化的代码示例，来用一下星闪服务在车辆内部进行音频信号的传输，实际应用中需要根据具体的硬件和软件环境进行调整哈。

步骤1：导入必要的模块

import featureAbility from '@ohos.ability.featureAbility';
import want from '@ohos.want';
import { CommonEvent, CommonEventPublishInfo, CommonEventSubscribeInfo, CommonEventListener, CommonEventSubscribeInfoMatcher, CommonEventPublishInfoMatcher } from '@ohos.commonevent';
import { AudioRecord, AudioPlayer } from '@ohos.media.audio';

步骤2：定义星闪服务的广播和接收

// 星闪广播
function startNearLinkBroadcast() {
  const publishInfo = new CommonEventPublishInfo();
  publishInfo.event = 'com.vin.harmony.nearlink.audio';
  publishInfo.data = 'start_audio_capture';

  CommonEvent.publish(publishInfo, (err, data) => {
    if (err) {
      console.error('Failed to publish nearlink event:', err);
    } else {
      console.log('Nearlink event published successfully');
    }
  });
}

// 星闪接收
function onNearLinkEvent(event) {
  if (event.matchType === CommonEventSubscribeInfoMatcher.ABILITY && event.eventId === 'com.example.harmony.nearlink.audio') {
    const audioData = event.data;
    if (audioData === 'start_audio_capture') {
      startAudioCapture();
    }
  }
}

// 订阅星闪事件
function subscribeNearLinkEvent() {
  const subscribeInfo = new CommonEventSubscribeInfo();
  subscribeInfo.events = ['com.vin.harmony.nearlink.audio'];
  subscribeInfo.matchType = CommonEventSubscribeInfoMatcher.ABILITY;

  CommonEvent.subscribe(subscribeInfo, (err, data) => {
    if (err) {
      console.error('Failed to subscribe nearlink event:', err);
    } else {
      console.log('Subscribed to nearlink event successfully');
    }
  });
}

步骤3：音频信号的采集和播放

// 开始音频采集
function startAudioCapture() {
  const audioRecord = new AudioRecord({
    sampleRate: 44100,
    channels: 2,
    encoding: AudioRecord.AudioEncoding.PCM_16_BIT,
    callback: (buffer) => {
      // 处理音频数据，例如进行降噪处理
      processAudioData(buffer);
    }
  });

  audioRecord.start();
}

// 处理音频数据
function processAudioData(buffer) {
  // 这里可以添加降噪算法，例如使用FFT进行频域分析和滤波
  // 假设降噪后的数据存储在bufferProcessed中
  const bufferProcessed =降噪算法(buffer);

  // 播放处理后的音频
  playProcessedAudio(bufferProcessed);
}

// 播放处理后的音频
function playProcessedAudio(buffer) {
  const audioPlayer = new AudioPlayer();
  audioPlayer.play(buffer, (err) => {
    if (err) {
      console.error('Failed to play audio:', err);
    }
  });
}

步骤4：初始化和启动

// 在Ability的onStart中初始化和启动
export default featureAbility({
  data: {
  },
  onStart: function () {
    subscribeNearLinkEvent();
  },
  onStop: function () {
    // 取消订阅星闪事件
    CommonEvent.unsubscribe(subscribeInfo);
  },
  // 其他Ability生命周期方法...
});