mirror of
https://github.com/GeWuYou/GFramework.git
synced 2026-05-07 00:39:00 +08:00
6e1eaf8f5c
- 新增 request reflection 与 generated invoker provider 的 steady-state 对照基准 - 引入 handwritten generated registry/provider 以走通真实 registrar 与 dispatcher 预热链路 - 更新 benchmark README 与 cqrs-rewrite RP-088 跟踪记录
99 lines
3.8 KiB
C#
99 lines
3.8 KiB
C#
// Copyright (c) 2025-2026 GeWuYou
|
||
// SPDX-License-Identifier: Apache-2.0
|
||
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Reflection;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
using GFramework.Core.Abstractions.Logging;
|
||
using GFramework.Cqrs.Abstractions.Cqrs;
|
||
using Microsoft.Extensions.DependencyInjection;
|
||
|
||
namespace GFramework.Cqrs.Benchmarks.Messaging;
|
||
|
||
/// <summary>
|
||
/// 为 benchmark 手写一个“生成后等价物” registry，用于驱动真实的 generated invoker provider 运行时接线路径。
|
||
/// </summary>
|
||
public sealed class GeneratedRequestInvokerBenchmarkRegistry :
|
||
GFramework.Cqrs.ICqrsHandlerRegistry,
|
||
GFramework.Cqrs.ICqrsRequestInvokerProvider,
|
||
GFramework.Cqrs.IEnumeratesCqrsRequestInvokerDescriptors
|
||
{
|
||
private static readonly GFramework.Cqrs.CqrsRequestInvokerDescriptor Descriptor =
|
||
new(
|
||
typeof(IRequestHandler<
|
||
RequestInvokerBenchmarks.GeneratedBenchmarkRequest,
|
||
RequestInvokerBenchmarks.GeneratedBenchmarkResponse>),
|
||
typeof(GeneratedRequestInvokerBenchmarkRegistry).GetMethod(
|
||
nameof(InvokeGeneratedRequestHandler),
|
||
BindingFlags.Public | BindingFlags.Static)
|
||
?? throw new InvalidOperationException("Missing generated request invoker benchmark method."));
|
||
|
||
private static readonly IReadOnlyList<GFramework.Cqrs.CqrsRequestInvokerDescriptorEntry> Descriptors =
|
||
[
|
||
new GFramework.Cqrs.CqrsRequestInvokerDescriptorEntry(
|
||
typeof(RequestInvokerBenchmarks.GeneratedBenchmarkRequest),
|
||
typeof(RequestInvokerBenchmarks.GeneratedBenchmarkResponse),
|
||
Descriptor)
|
||
];
|
||
|
||
/// <summary>
|
||
/// 将 generated benchmark request handler 注册到目标服务集合。
|
||
/// </summary>
|
||
public void Register(IServiceCollection services, ILogger logger)
|
||
{
|
||
ArgumentNullException.ThrowIfNull(services);
|
||
ArgumentNullException.ThrowIfNull(logger);
|
||
|
||
services.AddTransient(
|
||
typeof(IRequestHandler<
|
||
RequestInvokerBenchmarks.GeneratedBenchmarkRequest,
|
||
RequestInvokerBenchmarks.GeneratedBenchmarkResponse>),
|
||
typeof(RequestInvokerBenchmarks.GeneratedBenchmarkRequestHandler));
|
||
logger.Debug("Registered generated request invoker benchmark handler.");
|
||
}
|
||
|
||
/// <summary>
|
||
/// 返回当前 provider 暴露的全部 generated request invoker 描述符。
|
||
/// </summary>
|
||
public IReadOnlyList<GFramework.Cqrs.CqrsRequestInvokerDescriptorEntry> GetDescriptors()
|
||
{
|
||
return Descriptors;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 为目标请求/响应类型对返回 generated request invoker 描述符。
|
||
/// </summary>
|
||
public bool TryGetDescriptor(
|
||
Type requestType,
|
||
Type responseType,
|
||
out GFramework.Cqrs.CqrsRequestInvokerDescriptor? descriptor)
|
||
{
|
||
if (requestType == typeof(RequestInvokerBenchmarks.GeneratedBenchmarkRequest) &&
|
||
responseType == typeof(RequestInvokerBenchmarks.GeneratedBenchmarkResponse))
|
||
{
|
||
descriptor = Descriptor;
|
||
return true;
|
||
}
|
||
|
||
descriptor = null;
|
||
return false;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 模拟 generated invoker provider 产出的开放静态调用入口。
|
||
/// </summary>
|
||
public static ValueTask<RequestInvokerBenchmarks.GeneratedBenchmarkResponse> InvokeGeneratedRequestHandler(
|
||
object handler,
|
||
object request,
|
||
CancellationToken cancellationToken)
|
||
{
|
||
var typedHandler = (IRequestHandler<
|
||
RequestInvokerBenchmarks.GeneratedBenchmarkRequest,
|
||
RequestInvokerBenchmarks.GeneratedBenchmarkResponse>)handler;
|
||
var typedRequest = (RequestInvokerBenchmarks.GeneratedBenchmarkRequest)request;
|
||
return typedHandler.Handle(typedRequest, cancellationToken);
|
||
}
|
||
}
|