0

我有一个实现的类

class MessageBus
{
    void Subscribe<T>(Func<T,Task> onMessage) {...}
}

在我的代码中，我想动态订阅几种不同的消息类型。例如，我有消息类型：

class Message {}
class MessageA : Message {}
class MessageB : Message {}

我写了类似这样的代码：

class MySubscriber
{
    void Initialize()
    {
         var mb = new MessageBus();
         var mbt = mb.GetType();
         var subscribeGeneric = mbt.GetMethods().First(x => x.Name == "Subscribe" && x.GetParameters().Length == 1);

         var subscribeConcrete = subscribeGeneric.MakeGenericMethod(typeof(Message1));
         subscribeConcrete.Invoke(mb, new object[]{ new Func<Message1,Task>(Handle) });
         // On this line I get exception TargetException("Type does not meet target type"). Message my be a bit different, on my system I see it in Russian.
    }
    Task Handle(Message msg) {}    
}

当然，在这个例子中，通过反射调用是没有意义的，但在实际程序中，我动态地得到 typeof(Message1)，并且得到这些类型的数组。我究竟做错了什么？如果正常写入，它可以工作（即 Handle(Message) 成功转换为 Handle(Message1) 并被调用。

更新：所以上面的代码是正确的并且应该可以工作。在我的程序中，我只是有一个错字，并且在错误的对象上调用了该方法。

4

2 回答 2

1

在评论的帮助下解决了。我创建了一个单独的最小复制器并且它工作。然后检查原始代码，发现一个错字。所以基本的想法从一开始就是正确的。

于 2012-12-07T15:11:52.983 回答
0

您可能正在寻找这样的东西：

public class Dispatcher<TTarget,TArgBase>
{
    private Dictionary<Type, Action<TTarget, TArgBase>> _handlers;

    public Dispatcher(string methodName)
    {
        _handlers = typeof(TTarget).GetMethods(BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic)
            .Where(m => m.Name == methodName)
            .Where(m => m.ReturnType == typeof(void))
            .Where(m => !m.ContainsGenericParameters)
            .Where(m =>
            {
                var pars = m.GetParameters();
                return pars.Length == 1 && typeof(TArgBase).IsAssignableFrom(pars[0].ParameterType);
            })
            .ToDictionary(m => m.GetParameters()[0].ParameterType, m => BuildWrapper(m));
    }

    private static Action<TTarget, TArgBase> BuildWrapper(MethodInfo m)
    {
        var target = Expression.Parameter(typeof(TTarget), "target");
        var dest = Expression.Parameter(typeof(TArgBase), "destination");
        var castEvent = Expression.TypeAs(dest, m.GetParameters()[0].ParameterType);
        var call = Expression.Call(target, m, castEvent);
        return Expression.Lambda<Action<TTarget, TArgBase>>(call, target, dest).Compile();
    }

    public bool Call(TTarget target, TArgBase evt)
    {
        Action<TTarget, TArgBase> handler;
        _handlers.TryGetValue(evt.GetType(), out handler);
        if(handler == null)
            return false;
        handler(target, evt);
        return true;
    }
}
于 2012-12-07T14:00:28.687 回答