JSFA調(diào)用PA之三Ability調(diào)用方式

原創(chuàng)

作者：HagonChan 2022-02-17 21:28:08

系統(tǒng) OpenHarmony

我們借助官方文檔的案例來解讀一下 Ability 調(diào)用方式的具體實現(xiàn)方法。

??想了解更多內(nèi)容，請訪問：??

??51CTO和華為官方合作共建的鴻蒙技術(shù)社區(qū)??

??https://harmonyos.51cto.com??

引言

【FFH】JSFA調(diào)用PA(一)Ability概念及Ability與Internal Ability
【FFH】JSFA調(diào)用PA(二) Internal Ability調(diào)用方式

上兩篇文章我們已經(jīng)了解到了Ability的概念，還有JS FA調(diào)用Java PA兩種方式，Ability和Internal Ability的區(qū)別，還有第二篇文章對InternalAbility調(diào)用方式的講解。

接下來我們借助官方文檔的案例來解讀一下 Ability 調(diào)用方式的具體實現(xiàn)方法。

在此之前，我們先來看一下一些相關(guān)概念。

JS FA調(diào)用Java PA — Ability調(diào)用方式

接下來進入正題。

JS FA端

這部分我們就不細說，因為和InternalAbility的實現(xiàn)方法差不多，只是action.abilityType值不一樣，要具體了解就看看上一篇文章吧。

// abilityType: 0-Ability; 1-Internal Ability
const ABILITY_TYPE_EXTERNAL = 0;
const ABILITY_TYPE_INTERNAL = 1;
// syncOption(Optional, default sync): 0-Sync; 1-Async
const ACTION_SYNC = 0;
const ACTION_ASYNC = 1;
const ACTION_MESSAGE_CODE_PLUS = 1001;
export default {
  plus: async function() {
    var actionData = {};
    actionData.firstNum = 1024;
    actionData.secondNum = 2048;

    var action = {};
    action.bundleName = 'com.example.hiaceservice';
    action.abilityName = 'com.example.hiaceservice.ComputeServiceAbility';
    action.messageCode = ACTION_MESSAGE_CODE_PLUS;
    action.data = actionData;
    action.abilityType = ABILITY_TYPE_EXTERNAL;
    action.syncOption = ACTION_SYNC;

    var result = await FeatureAbility.callAbility(action);
    var ret = JSON.parse(result);
    if (ret.code == 0) {
      console.info('plus result is:' + JSON.stringify(ret.abilityResult));
    } else {
      console.error('plus error code:' + JSON.stringify(ret.code));
    }
  }
}

PA端(Ability方式)

這里我們還是以官方文檔的案例為參考，我們對官方案例進行一個步驟分解，以方便理解

??https://developer.harmonyos.com/cn/docs/documentation/doc-references/js-apis-fa-calls-pa-examples-0000000000618000??

1.導(dǎo)入相關(guān)ohos接口包

// ohos相關(guān)接口包
import ohos.aafwk.ability.Ability;
import ohos.aafwk.content.Intent;
import ohos.hiviewdfx.HiLog;
import ohos.hiviewdfx.HiLogLabel;
import ohos.rpc.IRemoteBroker;
import ohos.rpc.IRemoteObject;
import ohos.rpc.RemoteObject;
import ohos.rpc.MessageParcel;
import ohos.rpc.MessageOption;
import ohos.utils.zson.ZSONObject;

import java.util.HashMap;
import java.util.Map;

2.創(chuàng)建一個繼承Ability的類并且重寫onConnect方法

創(chuàng)建完這個類之后，先重寫onConnect(Intent: intent)方法，并且在onConnect返回一個remote對象，供FA向PA發(fā)送消息。

public class ComputeServiceAbility extends Ability {
  // 定義日志標(biāo)簽
  private static final HiLogLabel LABEL = new HiLogLabel(HiLog.LOG_APP, 0, "MY_TAG");

  // FA在請求PA服務(wù)時會調(diào)用Ability.connectAbility連接PA，連接成功后，需要在onConnect返回一個remote對象，供FA向PA發(fā)送消息
  @Override
  protected IRemoteObject onConnect(Intent intent) {
    super.onConnect(intent);
    return remote.asObject();
  }
}

3.繼承RemoteObject類重寫方法完成業(yè)務(wù)邏輯

private MyRemote remote = new MyRemote();  
class MyRemote extends RemoteObject implements IRemoteBroker {
    private static final int SUCCESS = 0;
    private static final int ERROR = 1;
    private static final int PLUS = 1001;   

    MyRemote() {
      super("MyService_MyRemote");
    }
 
    @Override
    public boolean onRemoteRequest(int code, MessageParcel data, MessageParcel reply, MessageOption option) {
      switch (code) {
        case PLUS: {
          String dataStr = data.readString();
          RequestParam param = new RequestParam();
          try {    
              param = ZSONObject.stringToClass(dataStr, RequestParam.class);
          } catch (RuntimeException e) {    
              HiLog.error(LABEL, "convert failed.");
          }
                    
          // 返回結(jié)果當(dāng)前僅支持String，對于復(fù)雜結(jié)構(gòu)可以序列化為ZSON字符串上報
          Map<String, Object> result = new HashMap<String, Object>();
          result.put("code", SUCCESS);
          result.put("abilityResult", param.getFirstNum() + param.getSecondNum());
          reply.writeString(ZSONObject.toZSONString(result));
          break;
        }
        default: {
          Map<String, Object> result = new HashMap<String, Object>();
          result.put("abilityError", ERROR);
          reply.writeString(ZSONObject.toZSONString(result));
          return false;
        }
      }
      return true;   
    }
    @Override
    public IRemoteObject asObject() {
      return this;
    }
  }