介绍

在HarmonyOS中，参考官方指导，其实你会发现在‘指南’和‘API参考’两个文档中，对消息传递使用的技术不是一对一的关系，那么今天这篇文章带你全面了解HarmonyOS 中的消息传递

概况

参照官方指导，我总结了两部分：1. 官方“指南”，即下图中的“Stage模型” 2. 总结的内容，即“消息事件”

开始

EventHub

这个其实是可以帮大家解决几个最常见的消息传递场景：1. UIAbility和其它 2.页面和其它 3. 组件和其它
指导文档：《鸿蒙NEXT星河版开发学习文档》

1. 订阅

或者+mau123789是v获得相关文档

this.context.eventHub.on('onConfigurationUpdate', (data) => {//订阅});
复制

2. 发送

let eventhub = this.context.eventHub;
eventhub.emit('onConfigurationUpdate', config);
复制

3. 解除订阅

this.context.eventHub.off('onConfigurationUpdate')
复制

CommonEvent

参照官方指南，其总称简写为CES(全称：Common Event Service），可以监听系统锁屏，时间变化，等等

1. 订阅

usual.event.TIME_TICK ： 系统公共事件

harvey.event.CUSTOM_1 ： 自定义事件

let subscribeInfo = {events: ["usual.event.TIME_TICK", 'harvey.event.CUSTOM_1']
}// 1. 创建订阅者
commonEventManager.createSubscriber(subscribeInfo, (err, subscriber) => {if (err) {console.error(`Failed to create subscriber. Code is ${err.code}, message is ${err.message}`);return;}console.info('Succeeded in creating subscriber.' + JSON.stringify(subscriber));this.subscriberID = subscriber// 2. 订阅事件回调commonEventManager.subscribe(subscriber, (err, commonEventData) => {if (err) {console.error(`Failed to subscribe common event. Code is ${err.code}, message is ${err.message}`);return;} else {systemDateTime.getCurrentTime(false, (error, data) => {this.mySubscriberInfo = data + '<=>' + JSON.stringify(commonEventData, null, '\t')})}})
})

2. 发送

对于系统级别的公共事件， 三方应用无权发送公共事件（即，即使你发送了，也是不会被收到的）

但是你可以自定义自己的公共事件

commonEventManager.publish('harvey.event.CUSTOM_1', option, (error) => {console.log(JSON.stringify(error))
})

3. 解除订阅

解除时用的是订阅者ID

commonEventManager.unsubscribe(this.subscriberID);

Emitter

1. 订阅

必须要有eventId, 这个代表消息的唯一标识

let innerEvent = {eventId: 1847
};emitter.on(innerEvent, (eventData) => {this.emitterData = process.tid + ' ' + JSON.stringify(eventData)
});

2. 发送

let eventData = {data: {'count': this.emitterCount++,'from': 'emitter',"content": "c","id": 1,}};
let innerEvent = {eventId: 1847,priority: emitter.EventPriority.HIGH
};
emitter.emit(innerEvent, eventData);

3. 解除订阅

emitter.off(1847)

Worker

1. 订阅

import worker from '@ohos.worker';let wk1 = new worker.ThreadWorker("/entry/ets/workers/Worker.ts")wk1.onmessage = (msg) => {}

2. 发送

a）从worker线程中发送

import worker, { ThreadWorkerGlobalScope, MessageEvents, ErrorEvent } from '@ohos.worker';var workerPort : ThreadWorkerGlobalScope = worker.workerPort;workerPort.postMessage({......}
)

b) 从主线程中发送

wk1.dispatchEvent({type: 'message', timeStamp: 0})

3. 解除订阅

//第一种
wk1.off('message')
//第二种
wk1.removeEventListener('message')
//第三种：强制关闭线程
wk1..terminate()

TaskTool 和 Notification

• [TaskTools]
• [Notification]

总结

HarmonyOS是一个新系统，还是要实践才可能在真实的业务开发中灵活运用