介紹

在HarmonyOS中，參考官方指導(dǎo)，其實(shí)你會(huì)發(fā)現(xiàn)在‘指南’和‘API參考’兩個(gè)文檔中，對(duì)消息傳遞使用的技術(shù)不是一對(duì)一的關(guān)系，那么今天這篇文章帶你全面了解HarmonyOS 中的消息傳遞

概況

參照官方指導(dǎo)，我總結(jié)了兩部分：1. 官方“指南”，即下圖中的“Stage模型” 2. 總結(jié)的內(nèi)容，即“消息事件”

開(kāi)始

EventHub

這個(gè)其實(shí)是可以幫大家解決幾個(gè)最常見(jiàn)的消息傳遞場(chǎng)景：1. UIAbility和其它 2.頁(yè)面和其它 3. 組件和其它
指導(dǎo)文檔：[《鴻蒙NEXT星河版開(kāi)發(fā)學(xué)習(xí)文檔》]

1. 訂閱

或者+mau123789是v獲得相關(guān)文檔

this.context.eventHub.on('onConfigurationUpdate', (data) = > {
    //訂閱

});
復(fù)制

2. 發(fā)送

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

3. 解除訂閱

this.context.eventHub.off('onConfigurationUpdate')
復(fù)制

CommonEvent

參照官方指南，其總稱(chēng)簡(jiǎn)寫(xiě)為CES(全稱(chēng)：Common Event Service），可以監(jiān)聽(tīng)系統(tǒng)鎖屏，時(shí)間變化，等等

1. 訂閱

usual.event.TIME_TICK ： 系統(tǒng)公共事件

harvey.event.CUSTOM_1 ： 自定義事件

let subscribeInfo = {
  events: ["usual.event.TIME_TICK", 'harvey.event.CUSTOM_1']
}

// 1. 創(chuàng)建訂閱者
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. 訂閱事件回調(diào)
  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. 發(fā)送

對(duì)于系統(tǒng)級(jí)別的公共事件， 三方應(yīng)用無(wú)權(quán)發(fā)送公共事件（即，即使你發(fā)送了，也是不會(huì)被收到的）

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

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

3. 解除訂閱

解除時(shí)用的是訂閱者ID

commonEventManager.unsubscribe(this.subscriberID);

Emitter

1. 訂閱

必須要有eventId, 這個(gè)代表消息的唯一標(biāo)識(shí)

let innerEvent = {
  eventId: 1847
};

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

2. 發(fā)送

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. 發(fā)送

a）從worker線(xiàn)程中發(fā)送

import worker, { ThreadWorkerGlobalScope, MessageEvents, ErrorEvent } from '@ohos.worker';

var workerPort : ThreadWorkerGlobalScope = worker.workerPort;

workerPort.postMessage(
  {
    ......
  }
)

b) 從主線(xiàn)程中發(fā)送

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

3. 解除訂閱

//第一種
wk1.off('message')
//第二種
wk1.removeEventListener('message')
//第三種：強(qiáng)制關(guān)閉線(xiàn)程
wk1..terminate()

TaskTool 和 Notification

• [TaskTools]
• [Notification]

總結(jié)

HarmonyOS是一個(gè)新系統(tǒng)，還是要實(shí)踐才可能在真實(shí)的業(yè)務(wù)開(kāi)發(fā)中靈活運(yùn)用

審核編輯 黃宇