Net Core-MediatR

public class MyRequestMsg : IRequest<int>
{
    public string RequestMsgType { get;set;} = string.Empty;
}

public class MyRequestHandler : IRequestHandler<MyRequestMsg, int>
{
    public Task<int> Handle(MyRequestMsg request, CancellationToken cancellationToken)
    {
        System.Console.WriteLine($"开始处理信息了，消息类型：{request.RequestMsgType}");
        return Task.FromResult(1);
    }
}

builder.Services.AddMediatR( option => {
    option.RegisterServicesFromAssembly(typeof(Program).Assembly);
});

var mediator = builder.Services.BuildServiceProvider().GetRequiredService<IMediator>();
int nResponse = mediator.Send(new MyRequestMsg(){RequestMsgType="Requesttype1"}).Result;
System.Console.WriteLine($"消息处理完成。返回响应{nResponse}");