MediatR发送对象而不键入

本文关键字：对象 MediatR | 更新日期: 2023-09-27 17:51:21

如果我发送一个HTTP Get请求:

/api/Company/1

我有一个OwinMiddleware，我使用context来确定IAsyncRequest<T>的path和json内容。

要知道使用哪个异步请求，我有IAsyncRequest<T>的Type的路径映射

var mappings = new Dictionary<string, Type> { ["api/Company/{id}"] = typeof(GetCompanyRequest) }
Type request;
var result = mappings.TryGetValue(context.Requst.Path.Value, out request);

我使用JObject来创建GetCompanyRequest的实例

var get = new JObject { ["id"] = "1" /* obtained from the url */ }
var instantiatedRequest = JObject.ToObject(request);

我使用JObject的原因是，对于PUT和POST请求，我直接将JSON体反序列化为请求。

拼图的最后一块现在是通过中介管道发送这个object instantiatedRequest。显然Task<T> SendAsync<T>(IAsyncRequest<T> request)是行不通的。

有趣的是，我不需要知道T，因为我将总是将其序列化为string以发送回用户。

那么，签名Task<object> SendAsync(object request)是否可以工作到当前的中介框架中以适应这一点呢?(不是要求做，只是可能吗?)

查看源代码

我在mediator.cs

中发现了这个
    private TWrapper GetHandler<TWrapper, TResponse>(object request, Type handlerType, Type wrapperType)
    {
        var requestType = request.GetType();
        var genericHandlerType = _genericHandlerCache.GetOrAdd(requestType, handlerType, (type, root) => root.MakeGenericType(type, typeof(TResponse)));
        var genericWrapperType = _wrapperHandlerCache.GetOrAdd(requestType, wrapperType, (type, root) => root.MakeGenericType(type, typeof(TResponse)));
        var handler = GetHandler(request, genericHandlerType);
        return (TWrapper) Activator.CreateInstance(genericWrapperType, handler);
    }
    private object GetHandler(object request, Type handlerType)
    {
        try
        {
            return _singleInstanceFactory(handlerType);
        }
        catch (Exception e)
        {
            throw BuildException(request, e);
        }
    }

第二个GetHandler有我需要的参数，第一个是SendAsync调用的，我不认为插入一些东西有问题。

做这件事有什么顾虑吗?

MediatR发送对象而不键入

这就是我如何实现从RabbitMqRequestHandler调用MediatR。基本上，我想使用队列消息触发任何命令类型。这个概念的验证帮助我创造了另一个功能。

重要:这适用于(MediatR 7.0.0)当我升级到版本9时，我的功能停止工作了。

private async Task HandleMessage(SmartConfigQueueMessage message)
{
    try
    {
        var type = AppDomain.CurrentDomain
            .GetAssemblies()
            .SelectMany(x => x.GetTypes())
            .FirstOrDefault(t => t.Name == message.OperationName);
        var resultType = type.GetInterfaces()
            .Where(r => r.FullName.Contains("SmartConfig"))? //MY ASSEMBLY MAIN NAMESPACE
            .FirstOrDefault().GenericTypeArguments
            .FirstOrDefault();
        dynamic command = message.Variables.ToObject(type);
        var method = _mediator.GetType().GetMethod("Send");
        var generic = method.MakeGenericMethod(resultType);
        var response = generic.InvokeAsync(_mediator, new object[] {command, new CancellationToken()});
    }
    catch (Exception ex)
    {
        _logger.LogInformation($"Consumer handler error: {ex.Message}");
    }
    // We just print this message   
    _logger.LogInformation($"Consumer message received: {message.OperationName}");
}

MediatR异步处理所有查询和命令。所以，我们需要这个扩展名:

public static class GenericMethodExtensions
{
    public static async Task<object> InvokeAsync(this MethodInfo @this, object obj, params object[] parameters)
    {
        var task = (Task)@this.Invoke(obj, parameters);
        await task.ConfigureAwait(false);
        var resultProperty = task.GetType().GetProperty("Result");
        return resultProperty?.GetValue(task);
    }
}

所以有一种方法无需修改源代码即可实现:

var irequestInterface = typeof(GetCompanyRequest).GetInterfaces().FirstOrDefault(x => x.Name.StartsWith("IRequest"));
if (irequestInterface == null)
{
    throw new Exception("IRequest is null");
}
var tresponse = irequestInterface.GenericTypeArguments.FirstOrDefault();
if (tresponse == null)
{
    throw new Exception("Reponse is null");
}
var method = typeof(IMediator).GetMethod("Send");
var generic = method.MakeGenericMethod(tresponse);
generic.Invoke(mediator, new []{ (object)Activator.CreateInstance<GetCompanyRequest>() });

最后一位来自Jon Skeets的回答

第一个位是因为我们不关心TResponse，所以我不想指定它。我们的GetCompanyRequest有足够的信息来执行SendAsync<TResponse>。

通常我会厌倦使用反射，但我知道Mediator的实现使用了很多反射-所以你知道吗-我们将把所有这些问题捆绑在一起。

相关文章：