【HarmonyOS】鸿蒙应用蓝牙功能实现（三） - ToB企服应用市场:ToB评测及商务社交产业平台

import { access } from '@kit.ConnectivityKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { BlueToothMgr } from '../manager/BlueToothMgr';
import { abilityAccessCtrl, common } from '@kit.AbilityKit';
import { connection } from '@kit.ConnectivityKit';
import { map } from '@kit.ConnectivityKit';
import { pbap } from '@kit.ConnectivityKit';
import { HashMap } from '@kit.ArkTS';
import { DeviceInfo } from '../info/DeviceInfo';
import { promptAction } from '@kit.ArkUI';
@Entry
@Component
struct Index {
private TAG: string = "BlueToothTest";
// 扫描状态定时器
private mNumInterval: number = -1;
// 当前设备蓝牙名
@State mCurrentDeviceName: string = "";
// 蓝牙状态
@State @Watch('onChangeBlueTooth') isStartBlueTooth: boolean = false;
// 蓝牙扫描状态
@State @Watch('onChangeBlueTooth') isStartScan: boolean = false;
// 当前蓝牙权限
@State userGrant: boolean = false;
// 扫描到设备名
@State mMapDevice: HashMap<string, DeviceInfo> = new HashMap();
// ui展现的设备列表
@State mListDeviceInfo: Array<DeviceInfo> = new Array();
async aboutToAppear() {
await this.requestBlueToothPermission();
let state = access.getState();
console.log(this.TAG, "getState state: " + state);
if(state == 2){
this.isStartBlueTooth = true;
console.log(this.TAG, "getState isStartBlueTooth: " + this.isStartBlueTooth);
}else{
this.isStartBlueTooth = false;
console.log(this.TAG, "getState isStartBlueTooth: " + this.isStartBlueTooth);
}
}
private onChangeBlueTooth(){
if(!this.isStartBlueTooth){
this.mMapDevice = new HashMap();
return;
}
this.mCurrentDeviceName = BlueToothMgr.Ins().getCurrentDeviceName();
}
// 用户申请权限
async reqPermissionsFromUser(): Promise<number[]> {
let context = getContext() as common.UIAbilityContext;
let atManager = abilityAccessCtrl.createAtManager();
let grantStatus = await atManager.requestPermissionsFromUser(context, ['ohos.permission.ACCESS_BLUETOOTH']);
return grantStatus.authResults;
}
// 用户申请蓝牙权限
async requestBlueToothPermission() {
let grantStatus = await this.reqPermissionsFromUser();
for (let i = 0; i < grantStatus.length; i++) {
if (grantStatus[i] === 0) {
// 用户授权，可以继续访问目标操作
this.userGrant = true;
promptAction.showToast({ message: "蓝牙授权成功！"});
}else{
promptAction.showToast({ message: "蓝牙授权失败！"});
}
}
}
setBlueToothScan = ()=>{
if(!this.isStartScan){
promptAction.showToast({ message: "开启扫描！"});
BlueToothMgr.Ins().startScanDevice((data: Array<string>)=>{
let deviceId: string = data[0];
if(this.mMapDevice.hasKey(deviceId)){
// 重复设备，丢弃不处理
}else{
// 添加到表中
let deviceInfo: DeviceInfo = new DeviceInfo();
deviceInfo.deviceId = deviceId;
deviceInfo.deviceName = BlueToothMgr.Ins().getDeviceName(deviceId);
deviceInfo.deviceClass = BlueToothMgr.Ins().getDeviceClass(deviceId);
this.mMapDevice.set(deviceId, deviceInfo);
this.mListDeviceInfo = this.mListDeviceInfo.concat(deviceInfo);
}
});
this.mMapDevice.clear();
this.mListDeviceInfo = [];
// 开启定时器
this.mNumInterval = setInterval(()=>{
let discovering = BlueToothMgr.Ins().isCurrentDiscovering();
if(!discovering){
this.closeScanDevice();
}
}, 1000);
this.isStartScan = true;
}else{
promptAction.showToast({ message: "关闭扫描！"});
BlueToothMgr.Ins().stopScanDevice();
this.closeScanDevice();
}
}
private closeScanDevice(){
clearInterval(this.mNumInterval);
this.isStartScan = false;
}
setBlueToothState = ()=>{
try {
if(!this.isStartBlueTooth){
// 开启蓝牙
BlueToothMgr.Ins().setBlueToothAccess(true, (state: access.BluetoothState) => {
console.log(this.TAG, "getState setBlueToothAccessTrue: " + state);
if(state == access.BluetoothState.STATE_ON){
this.isStartBlueTooth = true;
promptAction.showToast({ message: "开启蓝牙！"});
console.log(this.TAG, "getState isStartBlueTooth: " + this.isStartBlueTooth);
}
});
}else{
BlueToothMgr.Ins().setBlueToothAccess(false, (state: access.BluetoothState) => {
console.log(this.TAG, "getState setBlueToothAccessFalse: " + state);
if(state == access.BluetoothState.STATE_OFF){
this.isStartBlueTooth = false;
promptAction.showToast({ message: "关闭蓝牙！"});
console.log(this.TAG, "getState isStartBlueTooth: " + this.isStartBlueTooth);
}
});
}
} catch (err) {
console.error(this.TAG,'errCode: ' + (err as BusinessError).code + ', errMessage: ' + (err as BusinessError).message);
}
}
private isLog(){
console.log(this.TAG, "isLog isStartBlueTooth: " + this.isStartBlueTooth);
return true;
}
build() {
Column() {
if(this.userGrant){
if(this.isLog()){
Text("当前蓝牙设备信息:\n " + this.mCurrentDeviceName)
.fontSize(px2fp(80))
.margin({ top: px2vp(100) })
.fontWeight(FontWeight.Bold)
Text(this.isStartBlueTooth ? "蓝牙状态: 开启" : "蓝牙状态: 关闭")
.fontSize(px2fp(80))
.margin({ top: px2vp(100) })
.fontWeight(FontWeight.Bold)
.onClick(this.setBlueToothState)
Text(this.isStartScan ? "蓝牙扫描: 开启ing" : "蓝牙扫描: 关闭")
.margin({ top: px2vp(100) })
.fontSize(px2fp(80))
.fontWeight(FontWeight.Bold)
.onClick(this.setBlueToothScan)
this.ListView()
}
}
}
.justifyContent(FlexAlign.Center)
.height('100%')
.width('100%')
}
@Builder ListView(){
List() {
ForEach(this.mListDeviceInfo, (item: DeviceInfo, index: number) => {
ListItem() {
Column(){
Row() {
Text("设备ID: " + item.deviceId).fontSize(px2fp(42)).fontColor(Color.Black)
Blank()
Text("设备名: " + item.deviceName).fontSize(px2fp(42)).fontColor(Color.Black)
}
.width('100%')
Text(item.deviceClass).fontSize(px2fp(42)).fontColor(Color.Black)
}
.width('100%')
.height(px2vp(200))
.justifyContent(FlexAlign.Start)
.onClick(()=>{
// 点击选择处理配对
AlertDialog.show({
title:"选择配对",
message:"是否选择该设备进行蓝牙配对？",
autoCancel: true,
primaryButton: {
value:"确定",
action:()=>{
promptAction.showToast({ message: item.deviceName + "配对ing！"});
BlueToothMgr.Ins().pairDevice(item.deviceId);
}
},
secondaryButton: {
value:"取消",
action:()=>{
promptAction.showToast({ message: "取消！"});
}
},
cancel:()=>{
promptAction.showToast({ message: "取消！"});
}
})
})
}
}, (item: string, index: number) => JSON.stringify(item) + index)
}
.width('100%')
}
}

复制代码

import { access, ble } from '@kit.ConnectivityKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { connection } from '@kit.ConnectivityKit';
export class BlueToothMgr {
private TAG: string = "BlueToothTest";
private static mBlueToothMgr: BlueToothMgr | undefined = undefined;
private advHandle: number = 0xFF; // default invalid value
private mDeviceDiscoverArr: Array<string> = new Array<string>();
public static Ins(){
if(!BlueToothMgr.mBlueToothMgr){
BlueToothMgr.mBlueToothMgr = new BlueToothMgr();
BlueToothMgr.init();
}
return BlueToothMgr.mBlueToothMgr;
}
private static init(){
try {
connection.on('pinRequired', (data: connection.PinRequiredParam) =>{
// data为配对请求参数
console.info("BlueToothTest",'pinRequired pin required = '+ JSON.stringify(data));
});
} catch (err) {
console.error("BlueToothTest", 'pinRequired errCode: ' + (err as BusinessError).code + ', errMessage: ' + (err as BusinessError).message);
}
}
/**
* 当前设备蓝牙设备名称
*/
public getCurrentDeviceName(){
let localName: string = "";
try {
localName = connection.getLocalName();
console.info(this.TAG, 'getCurrentDeviceName localName: ' + localName);
} catch (err) {
console.error(this.TAG, 'getCurrentDeviceName errCode: ' + (err as BusinessError).code + ', errMessage: ' + (err as BusinessError).message);
}
return localName;
}
/**
* 当前设备蓝牙可发现状态
*/
public isCurrentDiscovering(){
let res: boolean = false;
try {
res = connection.isBluetoothDiscovering();
console.info(this.TAG, 'isCurrentDiscovering isBluetoothDiscovering: ' + res);
} catch (err) {
console.error(this.TAG, 'isCurrentDiscovering errCode: ' + (err as BusinessError).code + ', errMessage: ' + (err as BusinessError).message);
}
return res;
}
// STATE_OFF 0 表示蓝牙已关闭。
// STATE_TURNING_ON 1 表示蓝牙正在打开。
// STATE_ON 2 表示蓝牙已打开。
// STATE_TURNING_OFF 3 表示蓝牙正在关闭。
// STATE_BLE_TURNING_ON 4 表示蓝牙正在打开LE-only模式。
// STATE_BLE_ON 5 表示蓝牙正处于LE-only模式。
// STATE_BLE_TURNING_OFF 6 表示蓝牙正在关闭LE-only模式。
public getBlueToothState(): access.BluetoothState {
let state = access.getState();
return state;
}
/**
* 设置蓝牙访问(开关状态)
* @param isAccess true: 打开蓝牙
*/
setBlueToothAccess(isAccess: boolean, callbackBluetoothState: Callback<access.BluetoothState>){
try {
if(isAccess){
console.info(this.TAG, 'bluetooth enableBluetooth 1');
access.enableBluetooth();
console.info(this.TAG, 'bluetooth enableBluetooth 2');
access.on('stateChange', (data: access.BluetoothState) => {
let btStateMessage = this.switchState(data);
if (btStateMessage == 'STATE_ON') {
access.off('stateChange');
}
console.info(this.TAG, 'bluetooth statues: ' + btStateMessage);
callbackBluetoothState(data);
})
}else{
console.info(this.TAG, 'bluetooth disableBluetooth 1');
access.disableBluetooth();
console.info(this.TAG, 'bluetooth disableBluetooth 2');
access.on('stateChange', (data: access.BluetoothState) => {
let btStateMessage = this.switchState(data);
if (btStateMessage == 'STATE_OFF') {
access.off('stateChange');
}
console.info(this.TAG, "bluetooth statues: " + btStateMessage);
callbackBluetoothState(data);
})
}
} catch (err) {
console.error(this.TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' + (err as BusinessError).message);
}
}
private switchState(data: access.BluetoothState){
let btStateMessage = '';
switch (data) {
case 0:
btStateMessage += 'STATE_OFF';
break;
case 1:
btStateMessage += 'STATE_TURNING_ON';
break;
case 2:
btStateMessage += 'STATE_ON';
break;
case 3:
btStateMessage += 'STATE_TURNING_OFF';
break;
case 4:
btStateMessage += 'STATE_BLE_TURNING_ON';
break;
case 5:
btStateMessage += 'STATE_BLE_ON';
break;
case 6:
btStateMessage += 'STATE_BLE_TURNING_OFF';
break;
default:
btStateMessage += 'unknown status';
break;
}
return btStateMessage;
}
/**
* 主播蓝牙广播
*/
public registerBroadcast(){
try {
ble.on('advertisingStateChange', (data: ble.AdvertisingStateChangeInfo) => {
console.info(this.TAG, 'bluetooth advertising state = ' + JSON.stringify(data));
AppStorage.setOrCreate('advertiserState', data.state);
});
} catch (err) {
console.error(this.TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' + (err as BusinessError).message);
}
}
/**
* 开启蓝牙广播
*/
public async startBroadcast(valueBuffer: Uint8Array){
// 表示发送广播的相关参数。
let setting: ble.AdvertiseSetting = {
// 表示广播间隔，最小值设置160个slot表示100ms，最大值设置16384个slot，默认值设置为1600个slot表示1s。
interval: 160,
// 表示发送功率，最小值设置-127，最大值设置1，默认值设置-7，单位dbm。推荐值：高档(1)，中档(-7)，低档(-15)。
txPower: 0,
// 表示是否是可连接广播，默认值设置为true，表示可连接，false表示不可连接。
connectable: true
};
// BLE广播数据包的内容。
let manufactureDataUnit: ble.ManufactureData = {
// 表示制造商的ID，由蓝牙SIG分配。
manufactureId: 4567,
manufactureValue: valueBuffer.buffer
};
let serviceValueBuffer = new Uint8Array(4);
serviceValueBuffer[0] = 5;
serviceValueBuffer[1] = 6;
serviceValueBuffer[2] = 7;
serviceValueBuffer[3] = 8;
// 广播包中服务数据内容。
let serviceDataUnit: ble.ServiceData = {
serviceUuid: "00001888-0000-1000-8000-00805f9b34fb",
serviceValue: serviceValueBuffer.buffer
};
// 表示广播的数据包内容。
let advData: ble.AdvertiseData = {
serviceUuids: ["00001888-0000-1000-8000-00805f9b34fb"],
manufactureData: [manufactureDataUnit],
serviceData: [serviceDataUnit],
includeDeviceName: false // 表示是否携带设备名，可选参数。注意带上设备名时广播包长度不能超出31个字节。
};
// 表示回复扫描请求的响应内容。
let advResponse: ble.AdvertiseData = {
serviceUuids: ["00001888-0000-1000-8000-00805f9b34fb"],
manufactureData: [manufactureDataUnit],
serviceData: [serviceDataUnit]
};
// 首次启动广播设置的参数。
let advertisingParams: ble.AdvertisingParams = {
advertisingSettings: setting,
advertisingData: advData,
advertisingResponse: advResponse,
// 表示发送广播持续的时间。单位为10ms，有效范围为1(10ms)到65535(655350ms)，如果未指定此参数或者将其设置为0，则会连续发送广播。
duration: 0 // 可选参数，若大于0，则广播发送一段时间后，则会临时停止，可重新启动发送
}
// 首次启动广播，且获取所启动广播的标识ID
try {
this.registerBroadcast();
this.advHandle = await ble.startAdvertising(advertisingParams);
} catch (err) {
console.error(this.TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' + (err as BusinessError).message);
}
}
/**
* 开始蓝牙扫描
*/
public startScanDevice(callback: Callback<Array<string>>){
try {
connection.on('bluetoothDeviceFind', (data: Array<string>)=>{
// 随机MAC地址
console.info(this.TAG, 'bluetooth device bluetoothDeviceFind = '+ JSON.stringify(data));
callback(data);
});
connection.startBluetoothDiscovery();
} catch (err) {
console.error(this.TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' + (err as BusinessError).message);
}
}
/**
* 停止蓝牙扫描
*/
public stopScanDevice(){
try {
connection.off('bluetoothDeviceFind');
connection.stopBluetoothDiscovery();
} catch (err) {
console.error(this.TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' + (err as BusinessError).message);
}
}
public getDeviceName(deviceID: string){
let remoteDeviceName: string = "";
try {
remoteDeviceName = connection.getRemoteDeviceName(deviceID);
console.info(this.TAG, 'getDeviceName device = '+ JSON.stringify(remoteDeviceName));
} catch (err) {
console.error(this.TAG, 'getDeviceName errCode: ' + (err as BusinessError).code + ', errMessage: ' + (err as BusinessError).message);
}
return remoteDeviceName;
}
public getDeviceClass(deviceID: string){
let remoteDeviceClass: string = "";
try {
let classObj = connection.getRemoteDeviceClass(deviceID);
remoteDeviceClass = JSON.stringify(classObj);
} catch (err) {
console.error(this.TAG, 'getDeviceName errCode: ' + (err as BusinessError).code + ', errMessage: ' + (err as BusinessError).message);
}
return remoteDeviceClass;
}
// BondState
// BOND_STATE_INVALID 0 无效的配对。
// BOND_STATE_BONDING 1 正在配对。
// BOND_STATE_BONDED 2 已配对。
/**
* 发起配对蓝牙
*/
public pairDevice(deviceID: string){
try {
connection.on('bondStateChange', (data: connection.BondStateParam) =>{
console.info(this.TAG, 'pairDevice pair state = '+ JSON.stringify(data));
// 当蓝牙配对类型PinType为PIN_TYPE_ENTER_PIN_CODE或PIN_TYPE_PIN_16_DIGITS时调用此接口，请求用户输入PIN码。
});
connection.pairDevice(deviceID, (err: BusinessError) => {
console.info(this.TAG, 'pairDevice device name err:' + JSON.stringify(err));
});
} catch (err) {
console.error(this.TAG, 'pairDevice errCode: ' + (err as BusinessError).code + ', errMessage: ' + (err as BusinessError).message);
}
}
}

复制代码