XiHan Framework 处于预览阶段

查看获取方式
跳转到内容

插件 ​

本页讲插件的三种隔离级别、清单与权限、发现与加载、握手与生命周期,以及怎样用 .NET、Rust 或 Go 写插件,适用于要在应用里运行第三方或跨语言代码的宿主开发者和插件作者。各宿主的完整 API 与配置见 Plugins.InProcess、Plugins.OutOfProcess、Plugins.Wasm 与 Plugins.Protocol。

三种隔离级别 ​

插件是在运行期装载、与宿主隔离的代码,清单写 kind: plugin,isolation 决定由哪个宿主包加载。它和能力包的区别在于装配时机与信任:能力包在启动时进入能力图谱、与应用一起编译,插件按目录发现、由宿主授予权限,失败只影响自己。

isolation宿主包载体插件可贡献稳定性
in-processPlugins.InProcess可收集的 AssemblyLoadContext,插件有自己的服务容器插件自己的服务与启停逻辑Preview
wasmPlugins.Wasmwasmtime 进程内沙箱里的 WASI preview 1 reactor 模块操作、事件处理器、管道中间件Experimental
out-of-processPlugins.OutOfProcess子进程 + 本机 gRPC,协议 xihan.plugin.v1操作、事件处理器Preview

三者的信任边界不同,选型主要看这一点。

进程内插件与宿主同进程,XiHan.Framework.*、Microsoft.Extensions.*、System.* 程序集与宿主共享(类型身份一致),私有依赖按插件自己的 .deps.json 隔离解析。它能访问进程里的一切,宿主只在加载前核对权限,运行期无从约束,所以只用于受信任的 .NET 扩展。加载要用运行期反射,Native AOT 应用不能使用。进程内宿主只给插件独立的服务容器和宿主配置的只读视图,PluginContext.Pipeline 恒为 null,插件不能向宿主登记操作或中间件。

Wasm 插件在沙箱里运行:线性内存与栈有上限,按截止时间以 epoch 中断强制停下,没有网络,文件系统只有宿主映射的目录。它适合运行不可信代码,也是唯一能在管道阶段插入中间件的插件。ABI v1 只增不改,但当前大版本内不承诺不升版本(RFC-0018)。

进程外插件是独立进程,崩溃与依赖冲突都不会波及宿主,任意语言只要有 protobuf、gRPC 与 JSON 就能实现。宿主不做操作系统级沙箱,插件能做的事等同于运行它的系统账户,fs.*: 与 net.outbound: 权限只在加载时核对授予。

三种宿主都实现内核的 IPluginHost(LoadAsync / UnloadAsync / Plugins),失败以 Result 返回、不抛到宿主。

插件清单 ​

每个插件目录放一份 xihan.manifest.json(RFC-0002,字段全集见能力包与清单)。清单是装配的唯一事实源:宿主读它校验种类、隔离级别与权限;进程外与 Wasm 插件握手时还要把同一份清单原样发回,逐字段一致才算通过。下面是示例 samples/EchoPlugin 的清单:

json
{
  "$schema": "https://spec.xihanfun.com/manifest/v1.json",
  "id": "xihan.samples.echo",
  "package": "EchoPlugin",
  "version": "1.0.0",
  "primitives": "1",
  "stability": "experimental",
  "kind": "plugin",
  "isolation": "out-of-process",
  "requires": [ { "id": "kernel.plugins", "version": "1" } ],
  "contributes": {
    "operations": [ "echoes.create", "echoes.relay", "echoes.crash", "events.list" ],
    "config": { "section": "XiHan:Echo" },
    "health": [ "echo" ]
  },
  "permissions": [ "capability:kernel.pipeline" ],
  "activation": [ "onStartup" ],
  "entry": "EchoPlugin"
}
字段在插件里的含义
kind必须是 plugin;与宿主不匹配的种类或隔离级别以 PLUGINS_VALIDATION_001 拒绝
isolationin-process / wasm / out-of-process
entry进程内:入口类型全名,程序集按 package 取 <package>.dll;进程外:相对插件目录的可执行文件(Windows 上没有扩展名时补 .exe);Wasm:相对插件目录的 .wasm(参考实现也接受 .wat 文本)
contributes.operations插件服务的全部操作 ID,握手声明的操作必须都在其中
contributes.config.sectionConfigure 时宿主下发的配置节(领域节或其子节,如 XiHan:Echo 或 XiHan:Caching:Remote),按 IConfiguration 展开后序列化为 JSON 对象;没有声明为 {}
contributes.health插件自报的健康项名,未声明的健康项是握手不一致
contributes.pipeline只用于 Wasm:中间件名与阶段。进程外与进程内插件写了(非空)在发现或加载时以 PLUGINS_VALIDATION_001 拒绝,不静默忽略;Go SDK 读清单时同样拒绝
permissions所需权限,见下一节
activationonStartup(缺省)、onOperation:<模式>、onEvent:<模式>

权限:声明、授予与强制 ​

权限是 <种类>:<对象> 形式的字符串,种类只有四个:capability:、fs.read:、fs.write:、net.outbound:。插件在清单里声明需要什么,宿主在配置里按清单 ID 授予;声明了而未授予的权限一项也不能少,宿主在运行任何插件代码之前核对,缺一项即以 PLUGINS_DENIED_001 拒绝加载。

json
{
  "XiHan": {
    "Plugins": {
      "OutOfProcess": {
        "Directories": [ "plugins/echo" ],
        "Grants": { "xihan.samples.echo": [ "capability:kernel.pipeline" ] }
      },
      "Wasm": {
        "Directories": [ "plugins/echo-wasm" ],
        "Grants": { "xihan.samples.echowasm": [ "capability:kernel.pipeline" ] },
        "Mounts": { "xihan.samples.echowasm": { "/data": "/var/lib/app/echo-wasm" } }
      }
    }
  }
}

插件定义的权限码 ​

上面的权限是插件向宿主要的能力;插件自己的操作要求调用方持有的权限码是另一回事。清单 contributes.permissions 写插件定义的权限码(文法同授权:小写、点分、至少两段,不重复),进程外与 Wasm 宿主登记插件的代理操作时替它把这些码一并登记进 PermissionRegistry(ADR-0080),显示名取码本身,插件可以在握手的消息目录里给 permissions.<码>.name / .description 的译文:

json
"contributes": {
  "operations": [ "echoes.create", "echoes.export" ],
  "permissions": [ "echoes.export" ]
}
  • 只登记清单声明了的。操作的 permission 既不是宿主特性登记的码、也不在本插件清单里,仍按未登记拒绝(KERNEL_VALIDATION_005);要引用宿主或别的插件定义的码,只在操作里写,不在清单里声明。
  • 声明的码与已登记的重复是冲突(KERNEL_SECURITY_001):两个插件声明同一个码,后登记的那个整体失败;宿主特性定义的码插件又声明,不论谁先登记都失败。配置阶段的冲突是启动失败。
  • 权限码与代理操作一次登记、全进或全不进,任何一项不过都不留下这个插件的权限码。
  • 操作的 policy 同样要存在:配置阶段发现的插件在授权能力的启动核对里一并核对(不论失败策略都拒绝启动),之后登记的在登记时核对,不存在即 SECURITY_VALIDATION_004;permission:<本插件声明的码> 能通过。
  • 卸载时按归属撤回:插件的代理操作、它声明的码与 Wasm 插件贡献的中间件一次撤回,之后可以直接再加载(见运行期加载与卸载)。
  • 进程内插件有自己的容器,不向应用的登记表贡献操作,也不登记权限码。

加载之后各宿主对权限的强制方式。回调权限按「清单声明且已被授予」判定:清单是插件权限的唯一事实源,宿主授予了而清单没有声明的权限不生效,不能靠多授予让插件获得清单里没写的回调能力。

权限进程外Wasm
capability:kernel.pipeline回调 Host.Invoke 时判定,未声明或未授予为 gRPC PermissionDenied,尾部元数据 xihan-error-code: PLUGINS_DENIED_002导入 xihan.invoke 时判定,未声明或未授予返回 PLUGINS_DENIED_002 的失败状态,不陷阱
capability:messaging.queue回调 Host.Publish 时判定,同上导入 xihan.publish 时判定,同上
fs.read:<路径> / fs.write:<路径>只在加载时核对授予只有 Mounts:<清单 ID>:<客体路径> 映射了才算授予,映射的宿主目录以只读 / 可写预开放给模块
net.outbound:<目标>只在加载时核对授予永不授予,声明了即加载失败

进程内插件的权限只在加载时核对,插件可以在 Configure 里用 PluginContext.Permissions.IsGranted(...) 自查(samples/SamplePlugin 就这样做)。

回调以插件身份执行:主体 ID 是清单 ID、认证方案 Plugin(OutOfProcessPluginHost.PluginScheme)、没有声明;回调元数据里的 xihan.principal 被忽略,xihan.tenant 与其他已登记的 Baggage 照常采用。回调经宿主完整管道,Authorize 阶段照常按操作契约判定,所以插件主体还要在授权里被授予目标操作要求的权限码。

发现与加载 ​

进程外与 Wasm 插件按目录发现 ​

  1. 引用宿主包并启用特性:UseFeature<OutOfProcessPluginsFeature>() 或 UseFeature<WasmPluginsFeature>()。两者都依赖 kernel.hosting@1,分别提供 plugins.out-of-process@1 与 plugins.wasm@1。
  2. 在 XiHan:Plugins:OutOfProcess:Directories 或 XiHan:Plugins:Wasm:Directories 列出插件目录(一个目录一个插件,相对路径相对当前目录),在 Grants 里授予权限。
  3. 特性在配置阶段同步完成发现:读清单、核对权限,进程外插件启动进程、读握手行、调用 Handshake,Wasm 插件编译模块、校验导出与导入表、实例化并调用 xihan_handshake,然后核对握手声明与清单。
  4. 握手声明的操作登记为代理操作,清单 contributes.permissions 声明的权限码与它们一次登记,消息目录接进本地化器,订阅的主题登记事件处理器;Wasm 插件清单里的中间件按 清单 ID:中间件名 插进对应阶段。
  5. 启动阶段启动 onStartup 的插件(Configure → Start → 健康监视)。懒激活(只写了 onOperation: / onEvent:)的插件在握手后停下,首次调用或投递时再启动。
csharp
using XiHan.Framework.Hosting.AspNetCore;
using XiHan.Framework.Plugins.OutOfProcess;
using XiHan.Framework.Plugins.Wasm;
using XiHan.Framework.Profiles.Standard;
using XiHan.Framework.Protocols.Http;
using XiHan.Framework.Protocols.Http.Routing;

var builder = WebApplication.CreateBuilder(args);

builder.AddXiHan(xihan => xihan
    .UseStandardProfile()
    .UseFeature<HttpProtocolFeature>()
    .UseFeature<OutOfProcessPluginsFeature>()
    .UseFeature<WasmPluginsFeature>());

var app = builder.Build();
app.UseXiHan();
app.MapXiHanHealth();

// 插件声明的操作已登记为代理操作,与本地操作一样按 expose 发布路由
app.MapXiHanOperations();

app.Run();

发现阶段的失败分三种结果:

失败结果
清单不合法(含进程外插件的清单写了 contributes.pipeline)、权限未授予、入口文件不存在不启动插件代码,插件以 Failed 登记(错误分别为 PLUGINS_VALIDATION_001、PLUGINS_DENIED_001、PLUGINS_NOTFOUND_001):进入 IPluginHost.Plugins、可 Describe、健康条目 plugins.<清单 ID> 报 Failed,应用进入 Degraded,宿主启动时记错误日志;清单读不出来时没有清单 ID,只有健康条目 plugins.<目录名>。属配置错误,不重试,可 UnloadAsync 后改正再 LoadAsync
握手超时、握手行不合法、声明与清单不一致、模块不合法插件以 Failed 留在宿主里,健康条目 plugins.<清单 ID> 报 Failed,应用进入 Degraded。进程外插件在应用启动后按重启策略重试(1 秒起翻倍,计入 RestartLimit),启动阶段的 Configure / Start 失败同样重试;首次握手就失败的插件重试成功后,代理操作按运行期加载补登记(只对 IOperationInvoker 可见),订阅与消息目录要等宿主重启才生效。Wasm 插件的这类失败不重试
插件声明的权限码与已登记的重复、声明的操作与应用已有操作重名,或操作的 permission 既不是宿主已登记的、也不在本插件清单里,或操作的 policy 不存在配置错误,应用启动失败(KERNEL_SECURITY_001 / KERNEL_OPERATION_001 / KERNEL_VALIDATION_005;policy 不存在在授权能力的启动核对里报 SECURITY_VALIDATION_004);装配完成之后才登记的(重试成功、运行期 LoadAsync)插件整体登记失败、按发现时被拒处理,一个权限码与代理操作都不留下(见插件定义的权限码)

运行期加载与卸载 ​

宿主同时以 IPluginHost 登记在容器里,可以在运行期加载与卸载:

csharp
using XiHan.Framework.Kernel.Plugins;
using XiHan.Framework.Primitives;

// 运行期加载:授予由调用方给出,不读 Grants 配置
static async Task<bool> LoadEchoAsync(IPluginHost plugins, CancellationToken cancellationToken)
{
    var source = new PluginSource("plugins/echo", new PermissionGrant(["capability:kernel.pipeline"]));
    var loaded = await plugins.LoadAsync(source, cancellationToken);
    return loaded.TryGetValue(out var status) && status.State == LifecycleState.Ready;
}

运行期加载的代理操作只对 IOperationInvoker 可见:协议适配器的路由在启动时已经发布,不会为它新增 HTTP 路由或 MCP tool。卸载(UnloadAsync)先按归属(清单 ID)一次撤回插件登记的代理操作与它声明的权限码,再停止插件(ADR-0085):之后按 ID 调用这些操作返回 KERNEL_NOTFOUND_001(不进管道),撤回之前已经在执行的调用照常完成或以 PLUGINS_UNAVAILABLE_001 结束;同一插件(同一版本或新版本)可以直接再 LoadAsync,不用重启宿主。别的插件或宿主的操作引用了被撤回的权限码时,在码重新登记之前它们的授权按策略不存在拒绝(SECURITY_NOTFOUND_001)。Wasm 插件贡献的中间件也随卸载按归属撤出管道、随再加载回来(ADR-0088,见Wasm 插件贡献中间件),贡献中间件的插件同样可以在运行期加载。不随卸载撤回的:配置阶段接进容器的订阅与消息目录(卸载期间发给它的事件不投给任何插件,再加载后恢复;变了要重启宿主),协议适配器在启动时发布的路由与文档(按操作 ID 转交调用器,再加载后同一 ID 照常可用)。同一清单 ID 重复加载为 PLUGINS_CONFLICT_001,卸载未加载的插件为 PLUGINS_NOTFOUND_001。进程外插件在 LoadAsync 里握手、Configure 或 Start 失败时,错误返回给调用方,插件保持 Failed 并按重启策略在后台重试,不想再试就 UnloadAsync;清单、权限、入口不合格的直接返回、不登记。

进程内宿主 ​

Plugins.InProcess 没有特性入口,应用自己创建并持有 InProcessPluginHost:

csharp
using XiHan.Framework.Hosting.AspNetCore;
using XiHan.Framework.Kernel.Plugins;
using XiHan.Framework.Plugins.InProcess;
using XiHan.Framework.Profiles.Minimal;

var builder = WebApplication.CreateBuilder(args);
builder.AddXiHan(xihan => xihan.UseMinimalProfile());

var app = builder.Build();
app.UseXiHan();

// 插件目录:SamplePlugin.dll + xihan.manifest.json + 私有依赖
await using var plugins = new InProcessPluginHost(app.Configuration, app.Services.GetRequiredService<ILoggerFactory>());
var source = new PluginSource(Path.Combine(AppContext.BaseDirectory, "plugins", "sample"), new PermissionGrant(["capability:kernel.diagnostics"]));
var loaded = await plugins.LoadAsync(source, CancellationToken.None);
if (loaded.IsFailure)
{
    // 加载失败以结果返回,应用照常运行
    app.Logger.LogWarning("Plugin was not loaded: {Code}", loaded.Error!.Code);
}

await app.RunAsync();

宿主核对清单种类与隔离级别、权限、package 与 entry,在新的可收集加载上下文里加载 <package>.dll,实例化 entry 类型(必须实现 IPlugin,且自带清单的 ID 与文件一致),调用 Configure 后构建插件专属容器,再调用 StartAsync,成功即为 Ready。UnloadAsync 先调用 StopAsync,无论成败都释放容器并卸载加载上下文。构造函数标注了 RequiresDynamicCode 与 RequiresUnreferencedCode,项目开启裁剪或 AOT 分析时会报 IL2026 / IL3050。

写进程内插件:类库项目设 <EnableDynamicLoading>true</EnableDynamicLoading>,引用 XiHan.Framework.Kernel,实现 IPlugin,把 xihan.manifest.json 复制到输出目录。示例见 samples/SamplePlugin。

握手与生命周期 ​

进程外插件的启动顺序(spec/plugin/handshake.md):宿主只继承必要的环境变量(PATH、用户与临时目录、区域与时区、操作系统所需的系统变量、DOTNET_*、GO*),再追加下表的变量启动进程,工作目录是插件目录;插件启动 gRPC 服务端后向 stdout 写一行握手行 xihan-plugin/1 <network> <address>(network 为 unix、tcp 或 npipe,tcp 只能是回环地址),宿主连上后调用 Handshake。

环境变量含义
XIHAN_PLUGIN_PROTOCOL_VERSIONS宿主支持的协议版本,逗号分隔、升序,当前为 1
XIHAN_PLUGIN_PRIMITIVES宿主的原语层大版本
XIHAN_PLUGIN_SESSION本次启动的会话令牌,回调时放在元数据 xihan-plugin-session
XIHAN_PLUGIN_HOST_ADDRESS宿主回调端点 <network> <address>:Windows 上是命名管道,其他系统是 Unix 域套接字
XIHAN_PLUGIN_INSTANCE实例 ID
XIHAN_PLUGIN_LOCALE宿主默认区域

握手协商协议版本(取双方都支持的最高版本,没有交集时插件以 gRPC FailedPrecondition 拒绝)、核对原语层大版本、比对清单、交换操作声明(契约与 JSON Schema)、订阅与消息目录。stdin 在插件停止前保持打开,插件必须在 stdin 关闭时自行退出;stderr 是插件日志,宿主逐行转成来源 plugins.<清单 ID> 的日志,以 { 开头的 JSON 行按结构化日志处理。Wasm 插件没有进程与握手行,同一套消息按 proto3 JSON 经导出函数与线性内存传递(spec/plugin/wasm.md),环境变量只有上表里的协议版本、原语层、实例与区域四个。

生命周期状态与原语层的 LifecycleState 一致:

状态进入时机
Declared宿主读到清单
Resolved握手成功,声明与清单一致
ConfiguredConfigure 成功
ReadyStart 成功;之后按健康推送或轮询更新
Degraded插件自报 Degraded,或任一健康项为 Degraded / Unhealthy
Draining宿主已发 Stop,等待插件完成在途调用
Stopped正常停止
Failed握手、配置、启动失败,进程异常退出或实例陷阱,健康自报 Failed,停止超时被终止

时限与重启的缺省值(进程外与 Wasm 相同的部分):

环节缺省配置键
握手(读到握手行并完成 Handshake)10 秒,超时 PLUGINS_TIMEOUT_001HandshakeTimeoutSeconds(进程外)
Configure 与 Start 各自30 秒StartTimeoutSeconds(进程外);Wasm 的生命周期调用用 CallTimeoutSeconds
健康进程外先订阅 WatchHealth 推送,断开后每 10 秒一次 Health;Wasm 每 10 秒轮询 xihan_health;连续 3 次失败视为失效HealthIntervalSeconds、HealthFailures
崩溃后重启1 秒起翻倍、上限 60 秒的退避—
重启上限10 分钟窗口内 5 次,超过后保持 Failed,直到 UnloadAsync + LoadAsyncRestartLimit、RestartWindowSeconds
停止宽限进程外取 XiHan:Kernel:StopTimeoutSeconds(缺省 30 秒)StopGraceSeconds(进程外)

进程外插件停止时,宿主发 Stop(带宽限秒数与原因 shutdown / unload / restart),在宽限内等进程退出;超时先发终止信号(关闭插件的 stdin,Unix 上同时发 SIGTERM,Windows 没有 SIGTERM、关闭 stdin 即等价信号),5 秒内仍未退出才终止整个进程树,两种结局都记为 Failed(PLUGINS_TIMEOUT_001)。宿主停止时按与登记相反的顺序停止插件。重启后是新进程、新会话令牌、重新握手,声明必须与首次一致,否则 PLUGINS_VALIDATION_004。

代理操作经完整管道 ​

握手声明的每个操作在宿主的 OperationRegistry 里登记为代理操作,归属 ID 是插件清单 ID,契约(stability、expose、权限码或策略)与 Schema 取自声明。代理操作和本地操作契约没有区别:协议适配器按 expose 发布(HTTP 路由、gRPC 方法、MCP tool、命令行),调用经宿主十一个阶段的完整管道,Authorize 阶段按契约判定,Handle 阶段把 JSON 载荷与上下文发给插件。

上下文按 RFC-0003 平铺:traceparent / tracestate、截止时间(同时设为 gRPC 调用的截止时间)、只含已登记 xihan.* 键的 Baggage(租户、主体、关联 ID、幂等键、区域都在其中);Items 与服务不传播。插件返回的业务失败原样成为调用结果,宿主用握手时拿到的消息目录翻译消息键(国际化);传输层失败按下表映射:

插件侧宿主错误码
插件未就绪、正在停止、进程已退出或不可达;调用方没取消,进行中的调用被插件停机切断PLUGINS_UNAVAILABLE_001
截止时间到(插件那边报的是取消、调用方同时取消也一样:调用方的令牌触发时,宿主运行时把 gRPC 的 Cancelled 与插件写下的取消写成取消,不按时钟判断,宿主的 DeadlineMiddleware 按截止令牌一律改报超时,见韧性)KERNEL_TIMEOUT_001
截止时间到达之前调用方取消KERNEL_CANCELLED_001
插件未实现该操作(gRPC Unimplemented;Wasm 返回 KERNEL_NOTFOUND_001 状态)KERNEL_NOTFOUND_001
载荷或帧序不合法(gRPC InvalidArgument)KERNEL_VALIDATION_001
其他 gRPC 失败PLUGINS_UNEXPECTED_001

协议定义了流式帧 InvokeStream,.NET 宿主暂不发布流式操作;Wasm 插件声明流式操作在握手时就被拒绝。

事件投递 ​

握手里的每个订阅让宿主按它的 mode 向消息代理订阅该主题:空或 competing 是竞争消费(订阅了主题的宿主实例里只有一个把消息交给插件),broadcast 是广播(每个在线的宿主实例都交给自己的插件,尽力而为、不进死信,见订阅方式),宿主只投给以同一方式订阅了主题的插件;mode 不合法或同一(主题,类型)以两种方式各声明一次是 PLUGINS_VALIDATION_004。消息到达时派发器按 消息与事件 的规则开新作用域、经完整管道,在 Handle 阶段把信封(CloudEvents 1.0 属性平铺,attempt 从 1 起)发给插件。订阅写了消息类型时只投递类型相同的消息,其余在宿主侧按成功处理。投递至少一次,插件处理器必须幂等,可用 Baggage 里的 xihan.idempotency-key 或信封 id 去重。插件返回失败或不可用时由代理按自己的重试与死信策略处理,宿主不缓冲消息。宿主要装配一个消息代理(Standard 组合已带内存默认实现)。

回调:Host.Invoke 与 Host.Publish ​

插件可以反过来调用宿主:

回调进程外 RPCWasm 导入权限语义
调用操作Host.Invokexihan.invokecapability:kernel.pipeline(须在清单声明且已授予,下同)以新的调用经宿主完整管道执行操作,未登记的操作为 KERNEL_NOTFOUND_001
发布消息Host.Publishxihan.publishcapability:messaging.queue按主题分组批量经宿主消息发布器发布,逐项返回结果;宿主没有发布器时每项为 PLUGINS_UNAVAILABLE_001

进程外插件回调时必须带 xihan-plugin-session 元数据,令牌缺失或不匹配为 gRPC Unauthenticated + PLUGINS_DENIED_002;令牌只对本次进程有效,宿主端点只接受本机连接。Wasm 回调受当前调用(宿主进入模块的那次导出调用)的截止时间与取消约束:xihan.invoke 发起的新调用,截止时间取请求元数据与当前调用中较早者,请求不带截止时间也一样受限,xihan.publish 的发布同样随当前调用取消;到期宿主不再等待,导入返回 KERNEL_TIMEOUT_001(截止时间到了即超时,当前调用同时被取消也一样;截止时间到达之前被取消为 KERNEL_CANCELLED_001;不再等待与回调已返回两种情形同一判断)。嵌套深度上限 8,超过返回 PLUGINS_UNAVAILABLE_002;回调期间管道可能再次进入同一插件(它自己的中间件、操作或订阅),再入在同一线程上、导入函数返回前同步完成,受外层调用的截止时间约束,模块跨导入调用不得持有不可重入的锁。

Wasm 插件贡献中间件 ​

Wasm 插件清单 contributes.pipeline 的每一项在对应阶段插入一个中间件,名字为 清单 ID:中间件名、归属为清单 ID,阶段不能是 handle。每次调用宿主在进入下游前后各调一次 xihan_middleware:

阶段插件应答宿主行为
beforeCONTINUE合并应答里的 Baggage(未登记的键丢弃,xihan.principal 不可改写)后进入下游
beforeSHORT_CIRCUIT把应答里的失败结果写为调用结果,不进入下游;结果缺失或不是失败按 KERNEL_VALIDATION_001 处理
after任意只观察下游结果,动作与 Baggage 忽略

中间件只看得到元数据、操作 ID 与结果,看不到也改不了载荷,需要载荷的逻辑写成操作。每次钩子调用的时限是 MiddlewareTimeoutMilliseconds(缺省 100 毫秒)。中间件陷阱、超时或无响应时调用以 PLUGINS_UNAVAILABLE_001 失败,插件按崩溃处理并重建:安全相关的阶段不能失败即放行。每个中间件以 <清单 ID>:<middleware> 为名登记在所在阶段(基准位置是阶段末尾),清单的 before / after 按 RFC-0004 参与排序:每一项先按本插件 contributes.pipeline 里的中间件名解析,否则原样作为管道里的中间件名,即另一个插件的 <清单 ID>:<middleware> 或只登记一次的宿主中间件类型全名(如 after 一项写租户解析中间件的类型全名,插件中间件就排在它后面)。目标未登记、有歧义或跨阶段为 KERNEL_PIPELINE_003,成环为 KERNEL_PIPELINE_001:配置阶段发现的插件在宿主构建或打印管道时报出,运行期 LoadAsync 的插件在加载时报出、整个插件不登记。示例 samples/EchoWasmPlugin 的 echo-guard 在 observe 阶段把租户 blocked 短路为 ECHOWASM_DENIED_001。

中间件随插件的运行期加载与卸载进出管道(ADR-0088,内核的成组登记 PipelineBuilder.UseOwned 与按归属撤回 RemoveOwnedBy,见执行管道):

  • 运行期 LoadAsync:中间件与代理操作、声明的权限码一次登记,全进或全不进;次序约束在加载时立即核对,不过就整个插件不登记、管道不变。加载成功之后开始的调用经过它的中间件。
  • UnloadAsync:先把中间件撤出管道,再撤回操作与权限码、停止插件。卸载之后开始的调用不再经过它的中间件,经过它原来所在阶段的调用照常进入下游,不会因为插件不在了而失败;卸载之前已经进入管道的调用按进入时的管道走完,插件停止后它的钩子以 PLUGINS_UNAVAILABLE_001 失败即关闭。
  • 宿主或别的插件的中间件以次序约束引用了它的中间件(比如宿主中间件声明 After(类型全名, "xihan.samples.echowasm:echo-guard"))时,卸载被拒(KERNEL_PIPELINE_003)、什么都不撤,先撤回引用方。
  • 卸载之后可以直接再加载同一插件(同一版本或新版本),中间件按排序规则回到原来的位置,不用重启宿主。

Windows 上 Wasm 宿主的可执行项目要关闭 CET 兼容

wasmtime 处理陷阱时改写线程上下文,与 Windows 用户态影子栈(CET)冲突;.NET 9 起 apphost 默认开启 CET 兼容,影子栈强制时第一次陷阱就让整个进程 fail-fast(退出码 0xC0000409)。宿主、测试与一致性套件的可执行项目都要设 <CETCompat>false</CETCompat>。WasmPluginHost 创建时检测进程的影子栈策略,强制时以 PLUGINS_UNAVAILABLE_003 抛出 FrameworkException。Linux 与 macOS 不受影响。

失败降级,不让宿主崩溃 ​

插件故障的结果是降级而不是退出:每个插件是一个健康条目 plugins.<清单 ID>,条目 Failed 或 Degraded 只把应用从 Ready 压成 Degraded,/health/ready 仍按宿主自己的就绪规则应答(生命周期与健康)。

故障插件状态调用方看到
进程异常退出 / Wasm 陷阱或导出返回 0Failed(PLUGINS_UNEXPECTED_002),按退避重启或重建在途调用 PLUGINS_UNAVAILABLE_001
调用超过截止时间Wasm 实例被 epoch 中断,记为 Failed 并重建;进程外插件不受影响KERNEL_TIMEOUT_001
健康探测连续失败进程被终止,按崩溃处理重启前 PLUGINS_UNAVAILABLE_001
重启次数超过上限保持 FailedPLUGINS_UNAVAILABLE_001
沙箱资源不足(回调嵌套超限、客体内存分配失败)不变PLUGINS_UNAVAILABLE_002

用 Go SDK 写插件 ​

framework-sdk-go 是规范的 Go 实现,plugin 包提供进程外插件运行时 plugin.Serve:读环境变量、监听、写握手行、实现 xihan.plugin.v1 服务端、生命周期与健康推送、事件投递、宿主回调客户端和 stderr 结构化日志。SDK 当前为 v0.1,不提供流式操作,不覆盖 Wasm 载体。

  1. 写清单 xihan.manifest.json:kind: plugin、isolation: out-of-process、contributes.operations 列出全部操作、entry 是可执行文件名。不写 contributes.pipeline:只有 Wasm 插件能贡献中间件,SDK 的 manifest.Read(plugin.Serve 启动时调用)读到非空即返回错误、插件不启动,与宿主在发现时以 PLUGINS_VALIDATION_001 拒绝是同一条规则。

  2. 写入口,用 operation.Add 登记操作,交给 plugin.Serve:

    go
    package main
    
    import (
        "context"
        _ "embed"
        "os"
    
        "github.com/xihanfun/framework-sdk-go/invocation"
        "github.com/xihanfun/framework-sdk-go/operation"
        "github.com/xihanfun/framework-sdk-go/plugin"
        "github.com/xihanfun/framework-sdk-go/primitives"
    )
    
    //go:embed xihan.manifest.json
    var manifest []byte
    
    type CreateRequest struct{ Text string `json:"text"` }
    type CreateResponse struct{ Text, Tenant string }
    
    func main() {
        registry := operation.NewRegistry()
        _ = operation.Add(registry, operation.Contract{ID: "echoes.create", Stability: primitives.Experimental, Expose: []string{operation.ExposeHTTP}},
            operation.HandlerFunc[CreateRequest, CreateResponse](func(ctx *invocation.Context, request CreateRequest) primitives.Result[CreateResponse] {
                return primitives.Ok(CreateResponse{Text: request.Text, Tenant: ctx.Tenant()})
            }), nil, "")
    
        if err := plugin.Serve(context.Background(), plugin.Options{Manifest: manifest, Operations: registry}); err != nil {
            os.Exit(1)
        }
    }
  3. 订阅、生命周期回调与健康项经 plugin.Options 的 Subscriptions、Hooks、Catalogs 接入;Hooks.Configure 里用 configuration.Decode(&settings) 读配置节;操作里用 plugin.HostOf(ctx) 回调宿主;业务失败返回 primitives.Fail,文案用消息键加 plugin.LoadCatalog 加载的 Localization/<区域>.json。完整写法见 SDK 的 examples/echo。

  4. 构建并把清单放进产物目录:

    bash
    go build -o bin/echo-go .
    cp xihan.manifest.json bin/
  5. 用规范仓库的黑盒运行器验证协议一致性(测试与一致性套件):

    bash
    go install github.com/xihanfun/framework-spec/conformance/cmd/xihan-conformance@latest
    xihan-conformance plugin --dir bin --exclude echoes.crash --sample 'echoes.create={"text":"hi"}'
  6. 在宿主的 XiHan:Plugins:OutOfProcess:Directories 里指向 bin,按清单在 Grants 里授予权限。

samples/EchoGoPlugin 是在 .NET 宿主里端到端运行的 Go 插件,Plugins.OutOfProcess.Tests 用本机的 go 构建它并跑一致性套件与宿主测试。.NET 写进程外插件不引用任何 XiHan 包,只需 protobuf 与 gRPC 从 plugin.proto 生成桩,见 samples/EchoPlugin;Rust 写 Wasm 插件见 samples/EchoWasmPlugin(wasm32-wasip1、cdylib,只依赖 serde_json 与 base64)。

远程 Provider ​

子系统能力也可以由进程外插件提供(RFC-0019):宿主侧的 Caching.Remote 适配器声明 caching.distributed@1,插件只实现规范规定的操作集 cache-entries.*,示例是 Go 写的 samples/CacheGoPlugin。

相关 ​

Released under The MIT License