Flutter网页框架集成插件web_framework_flutter_api的使用

如果您希望在Android上运行示例，则需要物理设备或arm64-v8a模拟器。服务器需要几个文件才能运行：

• assets/executors/web.json 包含路由信息
• assets/executors/hello_executor.dll（Windows）或 assets/executors/libhello_executor.so（Android）
• assets/configs/config.json 包含服务器设置

快速开始

main.dart

import 'dart:io';
import 'dart:async';

import 'package:flutter/gestures.dart';
import 'package:flutter/material.dart';

import 'package:web_framework_flutter_api/config.dart';
import 'package:web_framework_flutter_api/web_framework.dart';
import 'package:web_framework_flutter_api/web_framework_exception.dart';
import 'package:web_framework_flutter_api/web_framework_utilities.dart';

import 'package:url_launcher/url_launcher.dart';

Future<void> main() async {
  if (Platform.isAndroid) {
    await unpackAndroidAssets(); // 在Android设备上解压资产文件
  }

  runApp(const App());
}

class App extends StatefulWidget {
  const App({super.key});

  @override
  State<App> createState() => _AppState();
}

class _AppState extends State<App> {
  String _message = "服务器未运行";
  String _address = "";
  WebFramework? _server;
  bool _isRunning = false;
  TapGestureRecognizer? _recognizer;

  void _initAddress(Config config) {
    String ip = config.getConfigurationString("ip"); // 从配置文件获取IP地址
    int port = config.getConfigurationInteger("port"); // 从配置文件获取端口号
    bool useHTTPS = config.getConfigurationBoolean("useHTTPS"); // 从配置文件获取HTTPS设置

    if (ip == "0.0.0.0") {
      ip = "127.0.0.1";
    }

    _address = "${useHTTPS ? "https" : "http"}://$ip:$port";
  }

  Future<void> start() async {
    Config? config;

    try {
      config = await Config.fromPath("configs/config.json"); // 创建配置对象

      config.overrideBasePath("${config.handler.assetsPath}/executors"); // 覆盖加载执行器的基础路径

      _server = await WebFramework.fromConfig(config); // 创建服务器

      await _server!.start(); // 在隔离中启动服务器

      setState(() {
        _isRunning = true;

        _initAddress(config!);

        config.dispose(); // 处置配置对象

        _message = "服务器正在运行于";
      });
    } on WebFrameworkException catch (e) {
      _message = e.toString();

      e.dispose();
      config?.dispose();
    } on Exception catch (e) {
      _message = e.toString();

      config?.dispose(); // 处置配置对象
    }

    // 如果小部件在异步平台消息飞行时被从树中移除，我们希望丢弃回复而不是调用
    // setState来更新我们的非存在的外观。
    if (!mounted) return;

    setState(() {});
  }

  Future<void> stop() async {
    try {
      if (_server == null) {
        return;
      }

      await _server!.stop(wait: true);

      setState(() {
        _isRunning = false;

        _address = "";

        _message = "服务器未运行";
      });
    } on WebFrameworkException catch (e) {
      _message = e.toString();
    } on Exception catch (e) {
      _message = e.toString();
    }
  }

  @override
  Widget build(BuildContext context) {
    _recognizer?.dispose();

    if (_address.isNotEmpty) {
      _recognizer = TapGestureRecognizer()..onTap = () => launchUrl(Uri.parse(_address));
    } else {
      _recognizer = TapGestureRecognizer();
    }

    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: const Text("插件示例应用"),
        ),
        body: Column(children: [
          Center(
            child: RichText(
                text: TextSpan(children: [
                  TextSpan(text: _message, style: const TextStyle(color: Colors.black)),
                  TextSpan(
                    text: _address,
                    style: const TextStyle(color: Colors.blue),
                    recognizer: _recognizer,
                  )
                ])),
          ),
          if (_isRunning)
            Center(
                child: TextButton(
                    onPressed: stop,
                    style: const ButtonStyle(backgroundColor: WidgetStatePropertyAll(Colors.blue), foregroundColor: WidgetStatePropertyAll(Colors.white)),
                    child: const Text("停止服务器")))
          else
            Center(
                child: TextButton(
                    onPressed: start,
                    style: const ButtonStyle(backgroundColor: WidgetStatePropertyAll(Colors.blue), foregroundColor: WidgetStatePropertyAll(Colors.white)),
                    child: const Text("启动服务器")))
        ]),
      ),
    );
  }

  @override
  void dispose() {
    super.dispose();

    _server?.dispose(); // 处置服务器
    _recognizer?.dispose();
  }
}

设置

assets/executors/web.json

{
  "HelloExecutor": {
    "route": "",
    "loadType": "initialization"
  }
}

配置

assets/configs/config.json

{
  "WebServer": {
    "ip": "0.0.0.0",
    "port": 8080,
    "timeout": 0
  },
  "WebFramework": {
    "settingsPaths": [
      "web.json"
    ],
    "loadSources": [
      "hello_executor"
    ],
    "assetsPath": "assets",
    "templatesPath": "templates",
    "cachingSize": 536870912,
    "webServerType": "multiThreaded",
    "HTTPS": {
      "useHTTPS": false,
      "pathToCertificate": "certificates/cert.pem",
      "pathToKey": "certificates/key.pem"
    },
    "defaultAssetsPath": "WebFrameworkAssets"
  },
  "Logging": {
    "usingLogging": false,
    "dateFormat": "DMY",
    "logFileSize": 134217728
  },
  "ThreadPoolServer": {
    "threadCount": 0
  }
}

运行示例

构建并运行示例在Android Studio中。

您将看到来自服务器的响应：

{
  "message": "Hello, World!"
}

执行器

执行器是负责为其路由（URL）提供响应的C++类。

HelloExecutor.h

#pragma once

#include "Executors/BaseStatelessExecutor.h"

namespace executors
{
	class HelloExecutor : public framework::BaseStatelessExecutor
	{
	public:
		HelloExecutor() = default;

		void doGet(framework::HTTPRequest& request, framework::HTTPResponse& response) override;

		~HelloExecutor() = default;
	};
}

HelloExecutor.cpp

#include "HelloExecutor.h"

#include "JSONBuilder.h"

namespace executors
{
	void HelloExecutor::doGet(framework::HTTPRequest& request, framework::HTTPResponse& response)
	{
		response.addBody(json::JSONBuilder(CP_UTF8).appendString("message", "Hello, World!"));
	}

	DECLARE_EXECUTOR(HelloExecutor);
}