当前位置：首页 > news >正文

鸿蒙NEXT跨设备通信：掌握URPC，实现远程程序调用

news 2025/10/8 6:29:40

在万物互联的时代，如何让设备之间像调用本地方法一样简单地进行远程调用？鸿蒙NEXT的URPC技术正是答案。

在智能设备日益普及的今天，多设备协同工作已经成为一种常见需求。想象一下，你可以用手机控制家里的智能电视播放视频，或在平板电脑上查看和编辑电脑上的文档。

这些场景都离不开跨设备的进程间通信（IPC）和远程过程调用（RPC）技术。

什么是URPC？

URPC（Unified Remote Procedure Call）是鸿蒙NEXT系统中跨设备通信的核心技术，它基于分布式软总线构建，让开发者能够像调用本地方法一样调用远程设备的方法。

URPC与IPC的区别：

IPC：使用Binder驱动，用于设备内的跨进程通信
URPC：使用软总线驱动，用于跨设备跨进程通信

URPC的核心概念与工作原理

在URPC通信模型中，主要包含三个核心角色：

客户端（Proxy）：服务请求方，负责发送远程调用请求。
服务端（Stub）：服务提供方，接收并处理客户端的请求。
系统能力管理者（SAMgr）：管理系统能力（System Ability），协调Proxy和Stub之间的通信。

通信流程类似于构建一座无形的桥梁，将不同的智能设备连接在一起，实现信息的自由流通：

Stub端向SAMgr注册系统能力
Proxy端从SAMgr获取Stub端的代理对象
Proxy通过代理对象向Stub发送请求
Stub处理请求并返回结果给Proxy

环境准备与配置

开发环境要求

DevEco Studio版本：NEXT Developer Beta1及以上
HarmonyOS SDK版本：NEXT Developer Beta1 SDK及以上
支持设备：华为手机（标准系统）

权限配置

在entry/src/main/config.json中申请必要的分布式权限：

json

{"reqPermissions": [{"name": "ohos.permission.DISTRIBUTED_DEVICE_STATE_CHANGE","reason": "用于监听分布式组网内设备状态变化"},{"name": "ohos.permission.GET_DISTRIBUTED_DEVICE_INFO","reason": "用于获取分布式组网内设备列表和信息"},{"name": "ohos.permission.DISTRIBUTED_DATASYNC","reason": "用于不同设备间的数据交换"}]
}

依赖配置

在模块的CMakeLists.txt或hvigorfile.ts中添加URPC依赖：

text

# IPC场景
external_deps = ["ipc:ipc_single"]# RPC场景  
external_deps = ["ipc:ipc_core"]# 公共基础库
external_deps = ["c_utils:utils"]

实现URPC通信的详细步骤

1. 定义通信接口

首先需要创建一个接口类，继承IRemoteBroker，定义描述符、业务函数和消息码。

cpp

#include "iremote_broker.h"// 定义消息码
const int TRANS_ID_PING_ABILITY = 1;
const std::string DESCRIPTOR = "test.ITestAbility";class ITestAbility : public IRemoteBroker {
public:// DECLARE_INTERFACE_DESCRIPTOR是必需的DECLARE_INTERFACE_DESCRIPTOR(to_utf16(DESCRIPTOR));// 定义业务函数virtual int TestPingAbility(const std::u16string &dummy) = 0;
};

2. 实现服务端（Stub）

Stub端作为接收请求的一端，需要继承IRemoteStub并重写OnRemoteRequest方法。

cpp

#include "iability_test.h"
#include "iremote_stub.h"class TestAbilityStub : public IRemoteStub<ITestAbility> {
public:virtual int OnRemoteRequest(uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) override;int TestPingAbility(const std::u16string &dummy) override;
};int TestAbilityStub::OnRemoteRequest(uint32_t code,MessageParcel &data, MessageParcel &reply, MessageOption &option)
{switch (code) {case TRANS_ID_PING_ABILITY: {std::u16string dummy = data.ReadString16();int result = TestPingAbility(dummy);reply.WriteInt32(result);return 0;}default:return IPCObjectStub::OnRemoteRequest(code, data, reply, option);}
}// 实现具体的业务逻辑
class TestAbility : public TestAbilityStub {
public:int TestPingAbility(const std::u16string &dummy) override {// 这里实现具体的业务逻辑return 0;}
};

3. 实现客户端（Proxy）

Proxy端是服务请求方，需要继承IRemoteProxy，实现接口类中的方法。

cpp

#include "iability_test.h"
#include "iremote_proxy.h"
#include "iremote_object.h"class TestAbilityProxy : public IRemoteProxy<ITestAbility> {
public:explicit TestAbilityProxy(const sptr<IRemoteObject> &impl);int TestPingAbility(const std::u16string &dummy) override;private:static inline BrokerDelegator<TestAbilityProxy> delegator_;
};TestAbilityProxy::TestAbilityProxy(const sptr<IRemoteObject> &impl): IRemoteProxy<ITestAbility>(impl)
{
}int TestAbilityProxy::TestPingAbility(const std::u16string &dummy)
{MessageOption option;MessageParcel dataParcel, replyParcel;dataParcel.WriteString16(dummy);int error = Remote()->SendRequest(TRANS_ID_PING_ABILITY, dataParcel, replyParcel, option);int result = (error == ERR_NONE) ? replyParcel.ReadInt32() : -1;return result;
}

4. 设备发现与连接

跨设备通信前，需要获取目标设备的NetworkId，这就像是给每个设备分配了一个唯一的身份证号码。

java

import ohos.distributedhardware.devicemanager.DeviceManager;
import ohos.distributedhardware.devicemanager.DeviceManagerCallback;
import ohos.distributedhardware.devicemanager.RemoteDevice;public class CrossDeviceCommunication {private DeviceManager deviceManager;// 获取本地设备信息public void getLocalDeviceInfo() {try {LocalDevice localDevice = deviceManager.getLocalDevice();String deviceName = localDevice.getDeviceName();String networkId = localDevice.getNetworkId();// 使用networkId进行跨设备通信} catch (DeviceManagerException e) {// 异常处理}}// 设备发现回调private DeviceManagerCallback deviceManagerCallback = new DeviceManagerCallback() {@Overridepublic void onDeviceFound(RemoteDevice remoteDevice) {// 发现新设备时处理String deviceName = remoteDevice.getDeviceName();String networkId = remoteDevice.getNetworkId();}};
}