根据你编辑的问题,我会给你一个基本的想法。
假设有消息类型:
// Message types
class Message { }
class MessageA : Message { }
class MessageB : Message { }
和基本消息处理器:
interface IMessageProcessor
{
void ProcessMessage(Message message);
}
abstract class MessageProcessor<TMessage> : IMessageProcessor
where TMessage : Message
{
protected abstract void ProcessMessage(TMessage message);
public void ProcessMessage(Message message)
{
ProcessMessage((TMessage)message);
}
}
您需要将特定的消息类型绑定到其自定义处理器。这可以使用一些元数据来完成,也就是说,您需要自定义属性:
// Mapping attribute
[AttributeUsage(AttributeTargets.Class, AllowMultiple = false)]
class MessageProcessorAttribute : Attribute
{
public MessageProcessorAttribute(Type messageType)
{
MessageType = messageType;
}
public Type MessageType { get; }
}
现在您可以声明消息处理器了:
[MessageProcessor(typeof(MessageA))]
class MessageAProcessor : MessageProcessor<MessageA>
{
protected override void ProcessMessage(MessageA message)
{
Console.WriteLine("Processing A message...");
}
}
[MessageProcessor(typeof(MessageB))]
class MessageBProcessor : MessageProcessor<MessageB>
{
protected override void ProcessMessage(MessageB message)
{
Console.WriteLine("Processing B message...");
}
}
这是示例队列,它将使用上面的代码:
// Message queue
class MessageQueue
{
private readonly Queue<Message> messages;
public MessageQueue()
{
messages = new Queue<Message>();
}
public void PostMessage(Message message)
{
messages.Enqueue(message);
}
public void ProcessMessages()
{
while (messages.Any())
{
var message = messages.Dequeue();
var messageProcessor = GetMessageProcessorOrDefault(message);
messageProcessor?.ProcessMessage(message);
}
}
private IMessageProcessor GetMessageProcessorOrDefault(Message message)
{
var messageType = message.GetType();
var messageProcessorTypes = GetMessageProcessorTypes();
var messageProcessorType = messageProcessorTypes
.FirstOrDefault(mpt => mpt.GetCustomAttribute<MessageProcessorAttribute>()?.MessageType == messageType);
return messageProcessorType != null ? (IMessageProcessor)Activator.CreateInstance(messageProcessorType) : null;
}
private IEnumerable<Type> GetMessageProcessorTypes()
{
// TODO: scan assemblies to retrieve IMessageProcessor implementations
return new[]
{
typeof(MessageAProcessor),
typeof(MessageBProcessor)
};
}
}
您可以将此方法与 DI 容器相结合,并构建基于插件的应用程序 - 消息类型和处理器的数量,因为它们的位置(相同的程序集或多个程序集)并不重要。
更新。我添加了一些泛型以避免在每个后代中进行类型转换。