进程是计算机中运行的程序的实例。它是操作系统对正在执行的程序的一种抽象概念。每个进程都有自己的独立内存空间、运行状态和执行上下文。进程可以包含一个或多个线程，每个线程可以独立执行一部分任务。操作系统通过分配和管理进程资源来实现多任务和并发执行。进程之间可以通过进程间通信机制进行数据交换和协作。
在HarmonyOS中，应用的进程模型是基于多线程的。每个应用会运行在一个独立的进程中，并且应用中的所有UIAbility（即应用的界面部分）会运行在同一个进程中。这意味着应用中的不同界面之间可以通过共享内存和消息传递等方式进行通信。
另外，HarmonyOS中的WebView拥有独立的渲染进程。这是为了提高浏览器的安全性和稳定性。通过将WebView的渲染过程与应用的进程隔离开来，避免了恶意网页对应用进行攻击或造成应用崩溃的情况。
HarmonyOS的进程模型是基于多线程的，应用的界面部分运行在同一个进程中，而WebView拥有独立的渲染进程。这样可以提高应用的安全性和稳定性。
HarmonyOS的公共事件服务（Common Event Service，CES）是一种机制，可以为应用程序提供订阅、发布和退订公共事件的能力。这个服务使得不同应用程序之间可以进行事件的交互和通信。
通过CES，应用程序可以定义自己的事件，并将这些事件发布到系统的事件总线上。其他应用程序可以通过订阅感兴趣的事件来接收相关的通知。当有事件发生时，发布者会将事件信息发送到事件总线，然后事件总线会将这些信息传递给所有订阅者。
CES提供了一种可靠的事件通信机制，可以在不同的应用程序之间进行事件的交互。这样，应用程序可以更方便地实现功能的集成和扩展。
在CES中，事件是以消息的形式进行传递的，可以包含任意类型的数据。应用程序可以根据需要定义不同类型的事件，并指定事件的触发条件和处理方式。
公共事件从系统角度可分为：系统公共事件和自定义公共事件
公共事件按发送方式可分为：无序公共事件、有序公共事件和粘性公共事件
订阅是指在发布者-订阅者模式中，订阅者向发布者注册，以接收发布者发送的消息或事件。订阅者可以选择订阅他们感兴趣的特定主题或类型的消息。
在发布订阅模式中，订阅者需要执行以下步骤来进行订阅：
订阅者可以随时选择取消订阅，以停止接收发布者的消息。取消订阅通常通过调用发布者的取消订阅方法，并传递订阅者对象或函数作为参数来完成。
通过发布订阅模式，订阅者可以实现松耦合的消息传递，提高系统的可扩展性和灵活性。
动态订阅是在应用运行时，动态地调用公共事件订阅的API来实现对公共事件的订阅。这种方式适用于需要根据业务逻辑动态决定是否订阅某个公共事件的情况。例如，一个电子商务应用可能在用户下单时订阅订单创建事件，但在取消订单时取消订阅。
静态订阅是通过配置文件声明和实现继承自StaticSubscriberExtensionAbility的类来实现对公共事件的订阅。这种方式适用于需要一直订阅某个公共事件而不需要动态调整订阅的情况。例如，一个日志服务可能一直订阅用户登录事件，以记录用户的登录日志。
无论是动态订阅还是静态订阅，订阅方都可以实现自己的业务逻辑来处理接收到的公共事件。例如，订阅方可以在接收到订单创建事件时，将订单信息保存到数据库中。通过订阅公共事件，应用可以实现不同模块之间的解耦和灵活的消息传递。
注意需要申请权限
import commonEventManager from '@ohos.commonEventManager';
import Base from '@ohos.base';
// 用于保存创建成功的订阅者对象，后续使用其完成订阅及退订的动作
let subscriber: commonEventManager.CommonEventSubscriber | null = null;
// 订阅者信息
let subscribeInfo: commonEventManager.CommonEventSubscribeInfo = {
events: ["usual.event.SCREEN_OFF"], // 订阅灭屏公共事件
}
// 创建订阅者回调
commonEventManager.createSubscriber(subscribeInfo, (err: Base.BusinessError, data: commonEventManager.CommonEventSubscriber) => {
if (err) {
console.error(`Failed to create subscriber. Code is ${err.code}, message is ${err.message}`);
return;
}
console.info('Succeeded in creating subscriber.');
subscriber = data;
// 订阅公共事件回调
})
// 订阅公共事件回调
if (subscriber !== null) {
commonEventManager.subscribe(subscriber, (err: Base.BusinessError, data: commonEventManager.CommonEventData) => {
if (err) {
console.error(`Failed to subscribe common event. Code is ${err.code}, message is ${err.message}`);
return;
}
})
} else {
console.error(`Need create subscriber`);
}
1、声明一个静态订阅者，首先需要在工程中新建一个ExtensionAbility, 该ExtensionAbility从StaticSubscriberExtensionAbility派生，其代码实现如下：
import StaticSubscriberExtensionAbility from '@ohos.application.StaticSubscriberExtensionAbility'
export default class StaticSubscriber extends StaticSubscriberExtensionAbility {
onReceiveEvent(event) {
console.log('onReceiveEvent, event:' + event.event);
}
}
2、配置文件
{
"module": {
......
"extensionAbilities": [
{
"name": "StaticSubscriber",
"srcEntrance": "./ets/StaticSubscriber/StaticSubscriber.ts",
"description": "$string:StaticSubscriber_desc",
"icon": "$media:icon",
"label": "$string:StaticSubscriber_label",
"type": "staticSubscriber",
"visible": true,
"metadata": [
{
"name": "ohos.extension.staticSubscriber",
"resource": "$profile:subscribe"
}
]
}
]
......
}
}
metadata指向的二级配置文件的通常形式如下：
{
"commonEvents": [
{
"name": "xxx",
"permission": "xxx",
"events":[
"xxx"
]
}
]
}
修改设备系统配置文件 /etc/static_subscriber_config.json，将静态订阅应用者的包名添加至该json文件中即可
{
"xxx",
"ohos.extension.staticSubscriber",
"xxx"
}
import commonEvent from '@ohos.commonEventManager';
// subscriber为订阅事件时创建的订阅者对象
if (subscriber !== null) {
commonEvent.unsubscribe(subscriber, (err) => {
if (err) {
console.error(`[CommonEvent] UnsubscribeCallBack err=${JSON.stringify(err)}`)
} else {
console.info(`[CommonEvent] Unsubscribe`)
subscriber = null
}
})
}
在发布订阅模型中，发布是指将消息发送到主题中。发布者通常不需要关心谁订阅了它们的消息，也不需要知道是否有订阅者。发布者只需要将消息发送到主题，然后该主题负责将消息传递给所有订阅者。
发布订阅模型可以用于实现异步通信，其中发布者和订阅者可以在互不干扰的情况下进行工作。发布者可以继续发布消息，而订阅者可以在需要时接收消息。
import commonEvent from '@ohos.commonEventManager';
// 发布公共事件
commonEvent.publish("usual.event.SCREEN_OFF", (err) => {
if (err) {
console.error(`[CommonEvent] PublishCallBack err=${JSON.stringify(err)}`);
} else {
console.info(`[CommonEvent] Publish success`);
}
})
import commonEvent from '@ohos.commonEventManager';
// 公共事件相关信息
let options = {
code: 1, // 公共事件的初始代码
data: "initial data", // 公共事件的初始数据
}
// 发布公共事件
commonEvent.publish("usual.event.SCREEN_OFF", options, (err) => {
if (err) {
console.error('[CommonEvent] PublishCallBack err=' + JSON.stringify(err));
} else {
console.info('[CommonEvent] Publish success')
}
})
