HarmonyOS开发实例：【事件的订阅和发布】
介绍
本示例主要展示了公共事件相关的功能，实现了一个检测用户部分行为的应用。具体而言实现了如下几点功能：
1.通过订阅系统公共事件，实现对用户操作行为（亮灭屏、锁屏和解锁屏幕、断联网）的监测；
2.通过在用户主动停止监测行为时发布自定义有序公共事件，实现对用户主动触发监听行为的持久化记录；
3.通过在用户设置对某一事件的监听状态时发布粘性事件，记录下本次应用运行期间允许监听的事件列表，同时在应用退出时将临时允许的修改为不允许；
4.打开自定义订阅事件页面需先安装[CardEvent]应用，通过订阅指定应用事件，实现用户对指定卡片发送事件的监听。
效果预览
订阅系统公共事件，主动停止监听行为及对某一事件的监听状态时发布粘性事件
使用说明：鸿蒙开发文档参考了[gitee.com/li-shizhen-skin/harmony-os/blob/master/README.md]点击或者复制转到即可。
1.安装编译生成的hap包，依赖包hap，桌面上显示应用图标如下，点击图标即可进入应用。
2.进入应用显示菜单页，可选择“进入”，“历史”，“设置”及“关于”几个选项。
3.点击“进入”后跳转至主页面，点击主页面“开始监控”按钮，将开始监听系统公共事件，并进行计时，此时按钮内容变更为“停止监听”；点击停止监听按钮，页面上将显示本次监听时长及监听期间收到的干扰信息汇总，并在页面右下角显示“查看详情”按钮，点击按钮将跳转至详情页，显示监听期间收到的干扰信息，应用当前仅监听了亮灭屏、锁屏和解锁屏幕、断联网等用户可操作的系统公共事件，后续可根据需求快速扩展。
4.返回至应用菜单页面，点击“历史”可查看用户操作监听的历史记录，当前支持每次运行期间最多存储10条历史记录，超过10条后将删除历史数据。
5.返回至应用菜单页面，点击“设置”可进行具体系统事件的监听配置，应用提供了“一直”、“仅本次”及“从不”三个选项，其中“仅本次”选项是指本次应用运行期间将监听特定系统公共事件，应用退出后该选项将自动调整为“从不”。
6.在设置页面，点击“自定义事件定向订阅”进入订阅页面，
- 点击”订阅“按钮进行订阅事件，同时订阅指定本应用事件和订阅非指定应用事件。
- 点击应用内卡片发送事件或点击应用外卡片发送事件。
- 点击应用内卡片发送事件后，指定应用事件和非指定应用事件均会接收到卡片所发送的事件 ；点击应用外卡片发送事件后，非指定应用事件会被接收，指定应用事件不会被接收。
- 点击”取消订阅“ 页面中会提示当前事件取消订阅。
7.返回至应用菜单页面，点击“关于”可查看应用版本信息及本示例的说明。
代码解读
CustomCommonEvent
HarmonyOS与OpenHarmony开发文档+mau123789是v直接拿取
entry/src/main/ets/
|---Application
| |---MyAbilityStage.ts
|---component
| |---Header.ets // 头部组件
|---entryformability
| |---EntryFormAbility.ts // 卡片提供方
|---feature
| |---HistoryFeature.ts
| |---LaunchFeature.ts
| |---MainFeature.ts
| |---SettingFeature.ts
|---LauncherAbility
| |---LauncherAbility.ts
|---MainAbility
| |---MainAbility.ts
|---model
| |---Consts.ts // 数据定义
| |---Logger.ts // 日志打印
| |---SurveillanceEventsManager.ts // 公共事件模块
| |---Utils.ts
|---pages
| |---About.ets // 关于页面
| |---Detail.ets // 详情页面
| |---History.ets // 历史页面
| |---jumpToCommonEvent.ets // 自定义订阅事件页面
| |---Launch.ets // 发起页面
| |---Main.ets // 进入页面
| |---Setting.ets // 设置页面
|---publishcard
| |---pages
| | |---PublishCard.ets // 卡片页面
CustomCommonEventRely
entry/src/main/ets/
|---entryformability
| |---EntryFormAbility.ts // 发布事件
|---pages
| |---Index.ets
|---widget
| |---pages
| | |---PublishCard.ets // 发布事件的卡片
具体实现
- 该示例entry部分分为五个模块：
- 进入模块
- 使用到应用文上下文，createSubscriber方法创建订阅者，getCurrentTime获取获取自Unix纪元以来经过的时间进行对用户操作行为的监测功能页面开发。
- 进入模块
- 源码链接：[Consts.ts]
/*
* Copyright (c) 2022-2023 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import commonEvent from '@ohos.commonEventManager';
export default class consts {
// definition for database
static readonly DATA_BASE_NAME: string = "nothing_pre";
static readonly DATA_BASE_KEY_TOTAL_TIMES: string = "totalTimes";
static readonly DATA_BASE_KEY_START_TIME: string = "startTime";
static readonly DATA_BASE_KEY_WIFI_POWER_STATE: string = commonEvent.Support.COMMON_EVENT_WIFI_POWER_STATE;
static readonly DATA_BASE_KEY_SCREEN_OFF: string = commonEvent.Support.COMMON_EVENT_SCREEN_OFF;
static readonly DATA_BASE_KEY_SCREEN_ON: string = commonEvent.Support.COMMON_EVENT_SCREEN_ON;
static readonly DATA_BASE_KEY_SCREEN_LOCKED: string = commonEvent.Support.COMMON_EVENT_SCREEN_LOCKED;
static readonly DATA_BASE_KEY_SCREEN_UNLOCKED: string = commonEvent.Support.COMMON_EVENT_SCREEN_UNLOCKED;
static readonly DATA_BASE_KEY_ONCE_EVENTS: string = "onceCall";
static readonly DATA_BASE_KEY_NEVER_EVENTS: string = "neverCall";
// definition for event enable state
static readonly ENABLE_STATE_ALWAYS : number = 0
static readonly ENABLE_STATE_ONCE : number = 1
static readonly ENABLE_STATE_NEVER : number = 2
// definition for record volume
static readonly MAX_RECORD_NUM: number = 10;
// definition for self defined common events
static readonly COMMON_EVENT_FINISH_MEDITATION: string = "finish_meditation"
static readonly COMMON_EVENT_SETTING_UPDATE: string = "setting_update"
}
[LaunchFeature.ts]
/*
* Copyright (c) 2024 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import common from '@ohos.app.ability.common';
import commonEvent from '@ohos.commonEventManager';
import dataPreferences from '@ohos.data.preferences';
import Want from '@ohos.app.ability.Want';
import router from '@ohos.router';
import consts from '../module/Consts';
import Logger from '../module/Logger';
export default class LaunchFeature {
private innerContext: common.UIAbilityContext = null;
private pref: dataPreferences.Preferences = null;
private subscriber = null;
private subscriberLow = null;
private currentRecordTimes: number = 0;
constructor(abilityContext: common.UIAbilityContext) {
this.innerContext = abilityContext;
}
async init(): Promise< void > {
await dataPreferences.getPreferences(this.innerContext, consts.DATA_BASE_NAME).then((pref) = > {
this.pref = pref;
});
await this.pref.get(consts.DATA_BASE_KEY_WIFI_POWER_STATE, 0).then((value: number) = > {
globalThis.settings.set(commonEvent.Support.COMMON_EVENT_WIFI_POWER_STATE, value);
});
await this.pref.get(consts.DATA_BASE_KEY_SCREEN_OFF, 0).then((value1: number) = > {
globalThis.settings.set(commonEvent.Support.COMMON_EVENT_SCREEN_OFF, value1);
});
await this.pref.get(consts.DATA_BASE_KEY_SCREEN_ON, 0).then((value2: number) = > {
globalThis.settings.set(commonEvent.Support.COMMON_EVENT_SCREEN_ON, value2);
});
await this.pref.get(consts.DATA_BASE_KEY_SCREEN_LOCKED, 0).then((value3: number) = > {
globalThis.settings.set(commonEvent.Support.COMMON_EVENT_SCREEN_LOCKED, value3);
});
await this.pref.get(consts.DATA_BASE_KEY_SCREEN_UNLOCKED, 0).then((value4: number) = > {
globalThis.settings.set(commonEvent.Support.COMMON_EVENT_SCREEN_UNLOCKED, value4);
});
}
private insertRecord = (event, value) = > {
value.push(event.parameters[consts.DATA_BASE_KEY_START_TIME]);
// refresh database
this.pref.put(consts.DATA_BASE_KEY_TOTAL_TIMES, value).then(() = > {
let detail: Array< string > = [];
detail.push(event.parameters["startTime"]);
detail.push(event.parameters["endTime"]);
detail.push(event.parameters["totalTime"]);
detail.push(event.parameters["totalEvents"]);
this.pref.put(event.parameters[consts.DATA_BASE_KEY_START_TIME], detail).then(() = > {
this.pref.flush()
})
});
}
private callbackFunc = (error, event) = > {
this.pref.has(consts.DATA_BASE_KEY_TOTAL_TIMES, (err, ret) = > {
if (ret) {
this.pref.get(consts.DATA_BASE_KEY_TOTAL_TIMES, []).then((value) = > {
this.insertRecord(event, value);
});
} else {
let value: Array< string > = [];
this.insertRecord(event, value);
}
if (this.currentRecordTimes >= consts.MAX_RECORD_NUM) {
this.subscriber.finishCommonEvent();
return;
}
this.subscriber.abortCommonEvent();
this.subscriber.finishCommonEvent();
this.currentRecordTimes++;
})
}
private callbackLowFunc = (error, event) = > {
this.currentRecordTimes = 1;
this.pref.get(consts.DATA_BASE_KEY_TOTAL_TIMES, []).then((value: Array< string >) = > {
for (let i = 0; i < consts.MAX_RECORD_NUM; i++) {
this.pref.delete(value[i]).then(() = > {
this.pref.flush();
this.subscriberLow.finishCommonEvent();
})
}
let records = value.slice(consts.MAX_RECORD_NUM, consts.MAX_RECORD_NUM + 1);
this.pref.put(consts.DATA_BASE_KEY_TOTAL_TIMES, records);
this.pref.flush();
})
}
jumpToStart = () = > {
// subscribe
if (this.subscriber == null) {
let highSubscriberInfo = {
events: [
consts.COMMON_EVENT_FINISH_MEDITATION // unordered self defined event
],
priority: 2 // 2 indicates high priority subscriber
};
commonEvent.createSubscriber(highSubscriberInfo, (err, subscriber) = > {
this.subscriber = subscriber
if (subscriber != null) {
commonEvent.subscribe(subscriber, this.callbackFunc)
}
});
}
// subscribe
if (this.subscriberLow == null) {
let lowSubscriberInfo = {
events: [
consts.COMMON_EVENT_FINISH_MEDITATION // unordered self defined event
],
priority: 1 // 1 indicates low priority subscriber
};
commonEvent.createSubscriber(lowSubscriberInfo, (updaerr, subscriber) = > {
this.subscriberLow = subscriber
if (subscriber != null) {
commonEvent.subscribe(subscriber, this.callbackLowFunc)
}
});
}
let want = {
bundleName: 'com.samples.customcommonevent',
abilityName: 'MainAbility',
};
this.innerContext.startAbility(want);
}
jumpToHistory = () = > {
Logger.info("ready to jump to history page");
router.pushUrl({
url: 'pages/History',
params: {}
});
}
jumpToSetting = () = > {
Logger.info("ready to jump to setting page");
router.pushUrl({
url: 'pages/Setting',
params: {}
});
}
jumpToAbout = () = > {
Logger.info("ready to jump to about page");
router.pushUrl({
url: 'pages/About',
params: {}
});
}
jumpToCommonEvent = (): void = > {
Logger.info('ready to jump to commonEvent page');
let context: common.UIAbilityContext | undefined = AppStorage.get('context');
let want: Want = {
bundleName: "com.samples.cardevent",
abilityName: "EntryAbility",
};
context && context.startAbility(want, (err) = > {
if (err.code) {
Logger.error('StartAbility', `Failed to startAbility. Code: ${err.code}, message: ${err.message}`);
}
});
};
}
[LauncherAbility.ts]
/*
* Copyright (c) 2022-2023 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import UIAbility from '@ohos.app.ability.UIAbility';
import commonEvent from '@ohos.commonEventManager';
import consts from '../module/Consts';
import dataPreferences from '@ohos.data.preferences';
import surveillanceEventsManager from '../module/SurveillanceEventsManager';
import Logger from '../module/Logger';
export default class LauncherAbility extends UIAbility {
onCreate(want) {
globalThis.abilityWant = want;
let settings: Map< string, number > = new Map();
surveillanceEventsManager.surveillanceEvents.forEach((element: string) = > {
settings.set(element, consts.ENABLE_STATE_ALWAYS);
});
globalThis.settings = settings;
AppStorage.setOrCreate('context', this.context);
Logger.info(`LauncherAbility onCreate, settings.size = ${globalThis.settings.size}`)
}
async onDestroy() {
Logger.info("LauncherAbility onDestroy")
globalThis.settings.forEach((value: number, key: string) = > {
if (value == consts.ENABLE_STATE_ONCE) {
globalThis.settings.set(key, consts.ENABLE_STATE_NEVER);
}
});
let thisPref = null;
await dataPreferences.getPreferences(this.context, consts.DATA_BASE_NAME).then((pref) = > {
thisPref = pref;
});
for (let element of surveillanceEventsManager.surveillanceEvents) {
await thisPref.put(element, globalThis.settings.get(element));
};
await thisPref.flush();
let options = {
isSticky: true,
parameters: surveillanceEventsManager.getSurveillanceEventStates()
};
commonEvent.publish(consts.COMMON_EVENT_SETTING_UPDATE, options, () = > {
Logger.info("success to publish once enable event");
});
}
onWindowStageCreate(windowStage) {
// Main window is created, set main page for this ability
windowStage.loadContent("pages/Launch", (err, data) = > {
if (err.code) {
Logger.error('Failed to load the content. Cause:' + JSON.stringify(err));
return;
}
Logger.info('Succeeded in loading the content. Data: ' + JSON.stringify(data));
});
}
onWindowStageDestroy() {
// Main window is destroyed, release UI related resources
Logger.info("LauncherAbility onWindowStageDestroy");
}
onForeground() {
// Ability has brought to foreground
Logger.info("LauncherAbility onForeground");
}
onBackground() {
// Ability has back to background
Logger.info("LauncherAbility onBackground");
}
}
[SurveillanceEventsManager.ts]
/*
* Copyright (c) 2022-2023 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import commonEvent from '@ohos.commonEventManager';
export class EventData {
"usual.event.wifi.POWER_STATE": number;
"usual.event.SCREEN_OFF": number;
"usual.event.SCREEN_ON": number;
"usual.event.SCREEN_LOCKED": number;
"usual.event.SCREEN_UNLOCKED": number;
}
export default class SurveillanceEventsManager {
constructor() {
}
static getSurveillanceEventStates(): EventData {
return {
"usual.event.wifi.POWER_STATE": globalThis.settings.get(commonEvent.Support.COMMON_EVENT_WIFI_POWER_STATE),
"usual.event.SCREEN_OFF": globalThis.settings.get(commonEvent.Support.COMMON_EVENT_SCREEN_OFF),
"usual.event.SCREEN_ON": globalThis.settings.get(commonEvent.Support.COMMON_EVENT_SCREEN_ON),
"usual.event.SCREEN_LOCKED": globalThis.settings.get(commonEvent.Support.COMMON_EVENT_SCREEN_LOCKED),
"usual.event.SCREEN_UNLOCKED": globalThis.settings.get(commonEvent.Support.COMMON_EVENT_SCREEN_UNLOCKED)
}
}
static surveillanceEvents: Array< string > = [
commonEvent.Support.COMMON_EVENT_WIFI_POWER_STATE,
commonEvent.Support.COMMON_EVENT_SCREEN_OFF,
commonEvent.Support.COMMON_EVENT_SCREEN_ON,
commonEvent.Support.COMMON_EVENT_SCREEN_LOCKED,
commonEvent.Support.COMMON_EVENT_SCREEN_UNLOCKED,
]
}
- 参考接口：[@ohos.app.ability.common]，[@ohos.commonEventManager]，[@ohos.data.preferences]，[@ohos.commonEvent]，[@ohos.router]，[@ohos.systemTime]
- 历史模块
- 使用到应用文上下文，getPreferences方法获取Preferences实例，组件Header进行历史页面开发。
- 历史模块
- 源码链接：[Header.ets]
/*
* Copyright (c) 2022 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import router from '@ohos.router'
@Component
export struct Header {
@State src: string = ''
build() {
Column() {
}
.backgroundImage($rawfile(this.src))
.backgroundImageSize(ImageSize.Cover)
.position({ x: '2%', y: '2%' })
.size({ width: 100, height: 50 })
.onClick(() = > {
router.back()
})
}
}
[Consts.ts]
/*
* Copyright (c) 2022-2023 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import commonEvent from '@ohos.commonEventManager';
export default class consts {
// definition for database
static readonly DATA_BASE_NAME: string = "nothing_pre";
static readonly DATA_BASE_KEY_TOTAL_TIMES: string = "totalTimes";
static readonly DATA_BASE_KEY_START_TIME: string = "startTime";
static readonly DATA_BASE_KEY_WIFI_POWER_STATE: string = commonEvent.Support.COMMON_EVENT_WIFI_POWER_STATE;
static readonly DATA_BASE_KEY_SCREEN_OFF: string = commonEvent.Support.COMMON_EVENT_SCREEN_OFF;
static readonly DATA_BASE_KEY_SCREEN_ON: string = commonEvent.Support.COMMON_EVENT_SCREEN_ON;
static readonly DATA_BASE_KEY_SCREEN_LOCKED: string = commonEvent.Support.COMMON_EVENT_SCREEN_LOCKED;
static readonly DATA_BASE_KEY_SCREEN_UNLOCKED: string = commonEvent.Support.COMMON_EVENT_SCREEN_UNLOCKED;
static readonly DATA_BASE_KEY_ONCE_EVENTS: string = "onceCall";
static readonly DATA_BASE_KEY_NEVER_EVENTS: string = "neverCall";
// definition for event enable state
static readonly ENABLE_STATE_ALWAYS : number = 0
static readonly ENABLE_STATE_ONCE : number = 1
static readonly ENABLE_STATE_NEVER : number = 2
// definition for record volume
static readonly MAX_RECORD_NUM: number = 10;
// definition for self defined common events
static readonly COMMON_EVENT_FINISH_MEDITATION: string = "finish_meditation"
static readonly COMMON_EVENT_SETTING_UPDATE: string = "setting_update"
}
[HistoryFeature.ts]
/*
* Copyright (c) 2022-2023 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import common from '@ohos.app.ability.common'
import consts from '../module/Consts'
import dataPreferences from '@ohos.data.preferences'
import Logger from '../module/Logger'
const TAG: string = '[Sample_CustomCommonEvent_HistoryFeature]'
export default class HistoryFeature {
constructor(abilityContext: common.UIAbilityContext) {
this.innerContext = abilityContext
}
async getData() {
await this.init()
return new Promise((resolve) = > {
resolve(this.dataSource)
})
}
private async init() {
let prefer = null
await dataPreferences.getPreferences(this.innerContext, consts.DATA_BASE_NAME).then((pref) = > {
prefer = pref
})
let records: Array< string >
await prefer.get(consts.DATA_BASE_KEY_TOTAL_TIMES, []).then((value: Array< string >) = > {
records = value
})
for (let item of records) {
await prefer.get(item, []).then((detail: Array< string >) = > {
if(JSON.stringify(detail) !== '[]'){
this.dataSource.push(detail)
}
}).catch((error)= >{
Logger.info(TAG, `Failed to get value code is ${error.code}`)
})
}
}
private dataSource: Array< Array< string >> = []
private innerContext: common.UIAbilityContext = null
}
- 参考接口：[@ohos.app.ability.common]，[@ohos.data.preferences]
- 设置模块
- 本模块分为三个事件，分别为记录联网事件，记录灭屏事件，记录亮屏事件，进行锁屏事件、进行解锁屏幕事件，每一个事件都可进行一直，仅本次和从不的单项选择，使用到应用文上下文吗，CommonEvent.publish发布公共事件，getPreferences方法获取Preferences实例进行功能页面开发。
- 源码链接：[Header.ets]，[Consts.ts]
- 设置模块
[SettingFeature.ts]
/*
* Copyright (c) 2022 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import commonEvent from '@ohos.commonEventManager';
import common from '@ohos.app.ability.common';
import consts from '../module/Consts';
import dataPreferences from '@ohos.data.preferences';
import Logger from '../module/Logger';
import surveillanceEventsManager from '../module/SurveillanceEventsManager';
export default class SettingFeature {
private innerContext: common.UIAbilityContext = null
private pref: dataPreferences.Preferences = null
constructor(abilityContext: common.UIAbilityContext) {
this.innerContext = abilityContext
}
async init() {
await dataPreferences.getPreferences(this.innerContext, consts.DATA_BASE_NAME).then((pref= >{
this.pref = pref
})).catch(err= >{
Logger.info(`getPreferences err ${JSON.stringify(err)}`)
})
}
changeState(group: string, state: number) {
globalThis.settings.set(group, state);
let options = {
isSticky: true,
parameters: surveillanceEventsManager.getSurveillanceEventStates()
}
commonEvent.publish(consts.COMMON_EVENT_SETTING_UPDATE, options, () = > {
Logger.info('success to publish setting update event')
})
this.pref.put(group, state).then(() = > {
this.pref.flush()
})
}
checkStateForAlways(group: string): boolean {
return globalThis.settings.get(group) == consts.ENABLE_STATE_ALWAYS
}
checkStateForOnce(group: string): boolean {
return globalThis.settings.get(group) == consts.ENABLE_STATE_ONCE
}
checkStateForNever(group: string): boolean {
return globalThis.settings.get(group) == consts.ENABLE_STATE_NEVER
}
changeStateToAlways(group: string) {
this.changeState(group, consts.ENABLE_STATE_ALWAYS)
}
changeStateToOnce(group: string) {
this.changeState(group, consts.ENABLE_STATE_ONCE)
}
changeStateToNever(group: string) {
this.changeState(group, consts.ENABLE_STATE_NEVER)
}
}
[SurveillanceEventsManager.ts]
/*
* Copyright (c) 2022-2023 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import commonEvent from '@ohos.commonEventManager';
export class EventData {
"usual.event.wifi.POWER_STATE": number;
"usual.event.SCREEN_OFF": number;
"usual.event.SCREEN_ON": number;
"usual.event.SCREEN_LOCKED": number;
"usual.event.SCREEN_UNLOCKED": number;
}
export default class SurveillanceEventsManager {
constructor() {
}
static getSurveillanceEventStates(): EventData {
return {
"usual.event.wifi.POWER_STATE": globalThis.settings.get(commonEvent.Support.COMMON_EVENT_WIFI_POWER_STATE),
"usual.event.SCREEN_OFF": globalThis.settings.get(commonEvent.Support.COMMON_EVENT_SCREEN_OFF),
"usual.event.SCREEN_ON": globalThis.settings.get(commonEvent.Support.COMMON_EVENT_SCREEN_ON),
"usual.event.SCREEN_LOCKED": globalThis.settings.get(commonEvent.Support.COMMON_EVENT_SCREEN_LOCKED),
"usual.event.SCREEN_UNLOCKED": globalThis.settings.get(commonEvent.Support.COMMON_EVENT_SCREEN_UNLOCKED)
}
}
static surveillanceEvents: Array< string > = [
commonEvent.Support.COMMON_EVENT_WIFI_POWER_STATE,
commonEvent.Support.COMMON_EVENT_SCREEN_OFF,
commonEvent.Support.COMMON_EVENT_SCREEN_ON,
commonEvent.Support.COMMON_EVENT_SCREEN_LOCKED,
commonEvent.Support.COMMON_EVENT_SCREEN_UNLOCKED,
]
}
- 参考接口：[@ohos.app.ability.common]，[@ohos.data.preferences]，[@ohos.commonEvent],[@ohos.router]，[@ohos.commonEvent]
关于模块
- 该模块开发主要介绍了本示例的功能作用以及说明了什么情况下不能使用。
- 源码链接：[Header.ets]，[Consts.ts]
设置中订阅事件模块
- 本模块主要支持指定应用订阅自定义事件。subScribeInfo新增可选属性publisherBundleName,创建订阅对象时可指定PublisherBundlerName，事件发布时，获取订阅者信息，增加校验bundleName是否等于publisherBundlerName，相等则加入事件回调方，达成只接收指定发布方发布的事件的效果。
- 源码链接：[EntryFormAbility.ts]，[PublishCard.ets]
- 参考接口：[@ohos.commonEventManager]，[@ohos.hilog]，[@ohos.app.form.formInfo]，[@ohos.app.form.formBindingData]，[@ohos.app.form.FormExtensionAbility]
审核编辑 黄宇
声明：本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人，不代表电子发烧友网立场。文章及其配图仅供工程师学习之用，如有内容侵权或者其他违规问题，请联系本站处理。
举报投诉
-
鸿蒙
+关注
关注
55文章
1641浏览量
42123 -
HarmonyOS
+关注
关注
79文章
1861浏览量
29267
发布评论请先 登录
相关推荐
RabbitMQ中的发布订阅模型
上一篇文章中，简单的介绍了一下RabbitMQ的work模型。这篇文章来学习一下RabbitMQ中的发布订阅模型。 发布订阅模型(Publish/Subscribe)：简单的说就是队列
鸿蒙原生应用/元服务开发-发布基础类型通知类型与接口
。基础类型通知呈现效果示意图如下所示。
图1基础类型通知呈现效果示意图
接口说明：通知发布接口如下表所示，不同发布类型通知由NotificationRequest的字段携带不同的信息。
本文主要参考HarmonyOS官方文档整理
发表于 01-03 14:46
MQTT协议介绍之一：发布/订阅
MQTT协议的内容。这里先介绍MQTT信息和协议背景。MQTT介绍MQTT是客户端服务器发布/订阅消息传输协议，它重量轻，开放，简单，设计好，易于实施，这些特性使其成为在许多情况下的理想选择，包括了受限
发表于 08-25 19:58
HarmonyOS应用开发-编译、调试、应用发布资料
Studio提供了基于各种编写代码及不同设备的调试功能，如果使用了多种代码编写应用，请参考选择调试代码类型进行配置后启动调试，调试过程中基于不同的代码进行断点管理。开发者完成HarmonyOS应用开发后
发表于 09-21 16:29
HarmonyOS初步探索系列文章汇总
DevEco Studio是基于IntelliJ IDEA社区的开源版本打造，面向华为终端全场景多设备的一站式集成开发环境（IDE），为开发者提供工程模板创建，开发，编译，调试和发布等
发表于 12-15 14:56
重磅！HarmonyOS 2.0正式发布：Firefly与华为计划推出RK3399 HarmonyOS 2.0开发套件
，10.1寸多触摸显示屏等整体硬件，一站式解决了开发者对硬件平台的选择与适配的问题。HarmonyOS2.0发布后，Firefly会继续深入HarmonyOS的生态。除了“
发表于 06-03 13:59
绝对干货！HarmonyOS开发者日资料全公开，鸿蒙开发者都在看
的在线教育内容和小游戏快速适配发布到HarmonyOS平台的迁移方案。5、HarmonyOS 开发平台和工具：该主题介绍了HarmonyOS
发表于 08-04 14:36
NodeMCU实现订阅和发布主题
NodeMCU实现订阅和发布主题。1、要点扫盲1.1 MQTT《MQTT协议--MQTT协议简介及原理》《MQTT协议--MQTT协议解析》1.2 OneNET《NodeMCU学习（十）--发送数据
发表于 11-01 08:37
新一期HarmonyOS认证正式发布，速来围观！
华为认证HarmonyOS应用开发高级工程师HCIP-HarmonyOS Application Developer V1.0（中文版）自2022年05月30日起，正式在中国区发布。
发表于 06-06 19:17
面向开发者的HarmonyOS 3.0 Beta发布
2021年10月，我们面向开发者发布了HarmonyOS 3.0 Developer Preview版，但开发的脚步永不停歇，现在我们又更新了API版本，配套
发表于 07-08 11:14
HarmonyOS 3.1版本发布，全面进入声明式开发
开发者的脚步永不停歇，2022年我们发布了HarmonyOS 3.0 Release版本，为了进一步满足开发者高效开发应用程序的诉求，在同年
发表于 11-15 11:58
HarmonyOS远端状态订阅开发实例
IPC/RPC提供对远端Stub对象状态的订阅机制， 在远端Stub对象消亡时，可触发消亡通知告诉本地Proxy对象。这种状态通知订阅需要调用特定接口完成，当不再需要订阅时也需要调用特定接口取消
发表于 10-12 14:55
面向HarmonyOS开发者的HarmonyOS 3.0 Beta介绍
2021年10月，我们面向开发者发布了HarmonyOS 3.0 Developer Preview版，但开发的脚步永不停歇，现在我们又更新了API版本，配套
工商网监
评论