代码拉取完成，页面将自动刷新
本项目使用模拟文件下载进度变化的功能来给你展示JS FA订阅JAVA PA的能力，订阅之后JS可以一直实时获取到JAVA返回的进度数据来更新JS界面的进度条。另外，文件模拟下载完成跳转到一个求积的页面，在这个页面输入两个数，点击求积按钮会给你展示JS FA调用JAVA PA的能力，此处并不像订阅一样可以一直获取到java返回的数据，采用的模式是调用一次返回一次数据。 通过本项目，是想让你了解如下知识点： 1） FeatureAbility.callAbility(OBJECT)：调用PA能力。 2） FeatureAbility.subscribeAbilityEvent(OBJECT, Function)：订阅PA能力。 3） FeatureAbility.unsubscribeAbilityEvent(OBJECT)：取消订阅PA能力。
1、java/ServiceAbility : java与js的通信代码；
2、java-RequestParam ：请求参数的实体类；
3、js-pages-index.hml : js模拟文件下载页；
4、js-pages-index.js : js订阅java pa代码；
5、js-calculate-calculate.hml : js求积页面；
6、js-calculate-calculate.js : 调用java pa代码；
7、config.json : js、java的配置文件，里面包括页面配置、service配置、窗体配置等等。
右击—new—new project 。
选择模板—next。
输入项目名称、选择项目类型（单选)、api版本，设备类型，点击finish即可。
/**
* 请求开启订阅模式
*/
subscribe: async function() {
this.isShow = true; // 显示进度条内容
var that = this;
var actionData = {};
actionData.firstNum = that.message;
var action = {};
action.bundleName = 'com.example.javajscommunication'; // Ability的包名称，需要与PA端匹配，区分大小写
action.abilityName = 'com.example.javajscommunication.ServiceAbility'; // Ability名称，需要与PA端匹配，区分大小写
action.messageCode = ACTION_MESSAGE_CODE_PLUS_SUB; // Ability操作码（操作码定义PA的业务功能，需要与PA端约定)
action.data = actionData; // 发送到Ability的数据,数据字段名称需要与PA端约定
action.abilityType = ABILITY_TYPE_EXTERNAL; // Ability类型，对应PA端不同的实现方式
action.syncOption = ACTION_SYNC; // PA侧请求消息处理同步/异步选项 0：同步方式，默认方式。 1：异步方式
await FeatureAbility.subscribeAbilityEvent(action, function (callbackData) {
var callbackJson = JSON.parse(callbackData); // json字符串反序列化
that.message = callbackJson.data.abilityEvent;
if (that.message == 100) { // message 为100时进行跳转计算页面
router.push({
uri: "pages/calculate/calculate"
})
that.unsubscribe(); // 取消订阅
that.isShow = false; // 隐藏进度条
}
})
}
case ACTION_MESSAGE_CODE_PLUS_SUB: {
go = true; // 开启可以下载状态
remoteObjectHandler = data.readRemoteObject(); // 获取请求参数对象
String zsonStr = data.readString(); // 获取参数字符串
try {
param = ZSONObject.stringToClass(zsonStr, RequestParam.class); // 字符串对象转成RequestParam实例
} catch (RuntimeException e) {
}
startNotify(param); // 给js端发送信息
Map<String, Object> zsonResult = new HashMap<String, Object>();// 返回结果，关键字段应与Js方协商
zsonResult.put("code", SUCCESS);
reply.writeString(ZSONObject.toZSONString(zsonResult)); // map 对象转成json字符串，并返回给js端
return true;
}
/**
* 开启线程，按照5*3 每15毫秒的频率返回数据给js端。这里java发送给js的数据，
* js端会通过订阅java pa的回调函数中而实时获取到
*/
public void startNotify(RequestParam param) {
number = param.getFirstNum(); // 获取当前进度值从请求中获取
new Thread(() -> { // 开启线程
while (go) {
try {
Thread.sleep(5 * 3); // 线程睡眠15毫秒后继续往下执行
MessageParcel data = MessageParcel.obtain(); // 创建索引为0的空MessageParcel对象
MessageParcel reply = MessageParcel.obtain();
zsonEvent.put("abilityEvent", number++);
if (number == 101) { // number超过100 go状态设为false 下载结束
go = false;
}
data.writeString(ZSONObject.toZSONString(zsonEvent)); // 数据存到MessageParcel载体
remoteObjectHandler.sendRequest(100, data, reply, option); // 发送
reply.reclaim(); // 回收
data.reclaim();
} catch (RemoteException | InterruptedException e) {
break;
}
}
}).start();
}
js端代码如下：
/**
* 请求取消订阅, java端停止返回数据
*/
unsubscribe: async function() {
var action = {};
action.bundleName = 'com.example.javajscommunication'; // Ability的包名称，需要与PA端匹配，区分大小写
action.abilityName = 'com.example.javajscommunication.ServiceAbility'; // Ability名称，需要与PA端匹配，区分大小写
action.messageCode = ACTION_MESSAGE_CODE_PLUS_UNSUB; // Ability操作码（操作码定义PA的业务功能，需要与PA端约定)
action.abilityType = ABILITY_TYPE_EXTERNAL; // Ability类型，对应PA端不同的实现方式
action.syncOption = ACTION_SYNC; // PA侧请求消息处理同步/异步选项 0：同步方式，默认方式。 1：异步方式
var result = await FeatureAbility.unsubscribeAbilityEvent(action); // 取消订阅
var ret = JSON.parse(result); // 反序列化，
if (ret.code == 0) {
prompt.showToast({
message: '取消下载成功'
})
} else {
prompt.showToast({
message: '取消下载失败'
})
}
}
java端service代码如下：
case ACTION_MESSAGE_CODE_PLUS_UNSUB: {
go = false; // 停止方法startNotify中的while循环,停止往js端发送消息
Map<String, Object> zsonResult = new HashMap<String, Object>();
zsonResult.put("code", SUCCESS);
reply.writeString(ZSONObject.toZSONString(zsonResult)); // 响应js端
return true;
}
/**
* 取传过去的第一个值
*/
numOne (e){
this.numOne = e.value
},
/**
* 获取传过去的第二个值
*/
numTwo (e){
this.numTwo = e.value
}
calculate: async function() {
var actionData = {}; // key值对应PA端的RequestParam类的成员字段
actionData.firstNum = this.numOne;
actionData.secondNum = this.numTwo;
var action = {};
action.bundleName = 'com.example.javajscommunication'; // Ability的包名称，需要与PA端匹配，区分大小写
action.abilityName = 'com.example.javajscommunication.ServiceAbility'; // Ability名称，需要与PA端匹配，区分大小写
action.messageCode = ACTION_MESSAGE_CODE_PLUS; // Ability操作码（操作码定义PA的业务功能，需要与PA端约定)
action.data = actionData; // 发送到Ability的数据,数据字段名称需要与PA端约定
action.abilityType = ABILITY_TYPE_EXTERNAL; // Ability类型，对应PA端不同的实现方式
action.syncOption = ACTION_SYNC; // PA侧请求消息处理同步/异步选项 0：同步方式，默认方式。 1：异步方式
var result = await FeatureAbility.callAbility(action);
var ret = JSON.parse(result);
if (ret.code == 0) {
this.message = 'java端传回的数据为:' + JSON.stringify(ret.abilityResult);
} else {
this.message = 'java端传回的数据报错' + JSON.stringify(ret.code);
}
},
case ACTION_MESSAGE_CODE_PLUS: {
String zsonStr = data.readString(); // 获取传入参数的字符串
RequestParam param = new RequestParam();
try {
param = ZSONObject.stringToClass(zsonStr, RequestParam.class); // 字符串对象转成RequestParam实例
} catch (RuntimeException e) {
}
// 返回结果仅支持可序列化的Object类型
Map<String, Object> zsonResult = new HashMap<>();
zsonResult.put("code", SUCCESS);
zsonResult.put("abilityResult", param.getFirstNum() + " * " + param.getSecondNum() + " = " + (param.getFirstNum() * param.getSecondNum()));
reply.writeString(ZSONObject.toZSONString(zsonResult)); // 数据返回给js端
return true;
}
back(){
router.back() // 返回到前一个页面
}
https://gitee.com/chinasoft6_ohos/java-js-communication
作者 ：晋国晨
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
1. 开源生态
2. 协作、人、软件
3. 评估模型