Flutter 与开源鸿蒙（OpenHarmony）深度集成：从插件开发到分布式能力实战（续篇）

// ohos_embedder.cc
#include "flutter/shell/platform/embedder/embedder.h"
#include "surface_ohos.h"      // 自定义 Surface
#include "event_handler.h"    // 事件分发

static FlutterEngine g_engine = nullptr;

void OnFlutterPlatformMessage(const FlutterPlatformMessage* message,
                              void* user_data) {
  if (strcmp(message->channel, "com.example/softbus") == 0) {
    // 转发到 OpenHarmony NAPI 模块处理分布式通信
    HandleSoftBusMessage(message);
  }
}

bool InitializeFlutterEngine() {
  FlutterRendererConfig config = {};
  config.type = kOpenGL;
  config.open_gl.struct_size = sizeof(config.open_gl);
  config.open_gl.make_current = [](void*) { return true; };
  config.open_gl.clear_current = [](void*) {};
  config.open_gl.fbo_callback = [](void*) { return 0; };
  config.open_gl.present_with_info = [](void*, const FlutterPresentInfo* info) {
    // 调用 OHOS 图形子系统提交帧
    OHOS::Surface::Present(info->frame_interval);
  };

  FlutterProjectArgs args = {};
  args.assets_path = "/data/app/assets";
  args.icu_data_path = "/system/etc/icu/icudt73l.dat";
  args.platform_message_callback = OnFlutterPlatformMessage;

  FlutterEngineResult result = FlutterEngineRun(
      FLUTTER_ENGINE_VERSION, &config, &args, nullptr, &g_engine);

  return result == kSuccess;
}

import flutterEmbedder from './native/libflutter_embedder.so';

export default class EntryAbility extends UIAbility {
  onCreate(want: Want, launchParam: AbilityConstant.LaunchParam): void {
    console.log('Flutter App onCreate');
    flutterEmbedder.init(); // 初始化 Embedder
  }

  onDestroy(): void {
    flutterEmbedder.shutdown(); // 释放 Engine
  }

  onWindowStageCreate(windowStage: window.WindowStage): void {
    // 获取窗口句柄并传给 Embedder
    const winId = windowStage.getMainWindowSync().windowId;
    flutterEmbedder.setWindowId(winId);
  }
}

final channel = MethodChannel('dsoftbus');

Future<void> startDeviceDiscovery() async {
  await channel.invokeMethod('startDiscovery', {'serviceType': 'smart_light'});
}

Future<void> sendDataToDevice(String deviceId, String data) async {
  await channel.invokeMethod('sendData', {
    'deviceId': deviceId,
    'data': data,
  });
}

// dsoftbus_plugin.cpp
#include "softbus_client.h" // OpenHarmony 软总线 SDK

napi_value StartDiscovery(napi_env env, napi_callback_info info) {
  // 解析参数
  char serviceType[64];
  // ... 从 JS 参数提取

  // 调用 OpenHarmony DSoftBus API
  int ret = PublishLNN(serviceType, OnDeviceFoundCallback);
  if (ret != 0) {
    // 错误处理
  }
  return nullptr;
}

// EntryAbility.ts
import continuationManager from '@ohos.application.continuationManager';

continuationManager.on('continue', (want) => {
  // 保存当前 Flutter 状态（如页面路径、表单数据）
  const state = flutter.getState();
  want.parameters = { flutterState: JSON.stringify(state) };
  return true; // 允许迁移
});

// 目标设备的 EntryAbility
onCreate(want: Want) {
  if (want.parameters?.flutterState) {
    const state = JSON.parse(want.parameters.flutterState);
    flutter.restoreState(state); // 恢复 UI 状态
  }
}

// module.json5
{
  "abilities": [
    {
      "name": "LightControlService",
      "type": "service",
      "srcEntry": "./ets/LightControlService.ts",
      "visible": true,
      "skills": [
        { "entities": ["entity.system.home"], "actions": ["action.service.light"] }
      ]
    }
  ]
}

// LightControlService.ts
import flutterMiniApp from './flutter_mini/light_control';

export default class LightControlService extends ServiceExtensionAbility {
  onConnect(want: Want): void {
    // 启动轻量级 Flutter 引擎（仅渲染一个 Widget）
    flutterMiniApp.renderToSurface(this.surfaceHandle);
  }
}

// flutter_preferences.dart
class OHOSPreferences {
  static const _channel = MethodChannel('ohos/preferences');

  static Future<void> setString(String key, String value) async =>
      _channel.invokeMethod('setString', {'key': key, 'value': value});

  static Future<String?> getString(String key) async =>
      _channel.invokeMethod('getString', {'key': key});
}

// 监听主题变化
import themeManager from '@ohos.app.ability.themeManager';

themeManager.on('themeChange', (theme) => {
  flutter.sendTheme(theme.isDarkMode ? 'dark' : 'light');
});

void initPlatformState() {
  const EventChannel('ohos/theme').receiveBroadcastStream().listen((theme) {
    ThemeMode mode = theme == 'dark' ? ThemeMode.dark : ThemeMode.light;
    context.read<ThemeBloc>().add(ThemeChanged(mode));
  });
}

#!/bin/bash
# 1. 编译 Flutter AOT
flutter build ohos --release

# 2. 复制产物到 ohos/assets
cp -r build/ohos/release/* ohos/src/main/resources/rawfile/

# 3. 使用 DevEco CLI 打包 HAP
devecostudio --build --project . --mode release

# 4. 安装到远程设备（通过 hdc）
hdc install outputs/default/oh_flutter_demo-unsigned.hap

name: Build for OpenHarmony
on: [push]
jobs:
  build:
    runs-on: ubuntu-latest
    steps:
      - uses: actions/checkout@v4
      - name: Setup DevEco CLI
        run: |
          wget https://.../devecostudio-cli.tar.gz
          tar -xzf devecostudio-cli.tar.gz
          echo "$PWD/devecostudio-cli/bin" >> $GITHUB_PATH
      - name: Build & Test
        run: ./scripts/build_and_test.sh