Um ônibus evento simples para .NET [fechado]
Pergunta
Eu quero fazer um ônibus evento muito simples que permitirá que qualquer cliente para se inscrever em um determinado tipo de evento e quando qualquer editor empurra um evento no ônibus usando o método EventBus.PushEvent()
apenas os clientes que subscreveram a esse tipo de evento específico terá o evento.
Eu estou usando C # e .NET 2.0.
Solução 4
Eu encontrei genérico Message Bus . É uma classe simples.
Outras dicas
minúsculo Messenger é uma boa escolha, eu tenho usado em um projeto ao vivo para 2,5 anos. Alguns exemplos de código a partir do Wiki (link abaixo):
Publishing
messageHub.Publish(new MyMessage());
Subscribing
messageHub.Subscribe<MyMessage>((m) => { MessageBox.Show("Message Received!"); });
messageHub.Subscribe<MyMessageAgain>((m) => { MessageBox.Show("Message Received!"); }, (m) => m.Content == "Testing");
O código está no GitHub: https://github.com/grumpydev/TinyMessenger
O Wiki é aqui: https://github.com/grumpydev/TinyMessenger/wiki
Ele tem um pacote Nuget também
Install-Package TinyMessenger
Outra, inspirado por EventBus para o Android, mas muito mais simples:
public class EventBus
{
public static EventBus Instance { get { return instance ?? (instance = new EventBus()); } }
public void Register(object listener)
{
if (!listeners.Any(l => l.Listener == listener))
listeners.Add(new EventListenerWrapper(listener));
}
public void Unregister(object listener)
{
listeners.RemoveAll(l => l.Listener == listener);
}
public void PostEvent(object e)
{
listeners.Where(l => l.EventType == e.GetType()).ToList().ForEach(l => l.PostEvent(e));
}
private static EventBus instance;
private EventBus() { }
private List<EventListenerWrapper> listeners = new List<EventListenerWrapper>();
private class EventListenerWrapper
{
public object Listener { get; private set; }
public Type EventType { get; private set; }
private MethodBase method;
public EventListenerWrapper(object listener)
{
Listener = listener;
Type type = listener.GetType();
method = type.GetMethod("OnEvent");
if (method == null)
throw new ArgumentException("Class " + type.Name + " does not containt method OnEvent");
ParameterInfo[] parameters = method.GetParameters();
if (parameters.Length != 1)
throw new ArgumentException("Method OnEvent of class " + type.Name + " have invalid number of parameters (should be one)");
EventType = parameters[0].ParameterType;
}
public void PostEvent(object e)
{
method.Invoke(Listener, new[] { e });
}
}
}
Caso de uso:
public class OnProgressChangedEvent
{
public int Progress { get; private set; }
public OnProgressChangedEvent(int progress)
{
Progress = progress;
}
}
public class SomeForm : Form
{
// ...
protected override void OnLoad(EventArgs e)
{
base.OnLoad(e);
EventBus.Instance.Register(this);
}
public void OnEvent(OnProgressChangedEvent e)
{
progressBar.Value = e.Progress;
}
protected override void OnClosed(EventArgs e)
{
base.OnClosed(e);
EventBus.Instance.Unregister(this);
}
}
public class SomeWorkerSomewhere
{
void OnDoWork()
{
// ...
EventBus.Instance.PostEvent(new OnProgressChangedEvent(progress));
// ...
}
}
Você também pode verificar as extensões Unidade: http://msdn.microsoft.com/en-us/library/cc440958. aspx
[Publishes("TimerTick")]
public event EventHandler Expired;
private void OnTick(Object sender, EventArgs e)
{
timer.Stop();
OnExpired(this);
}
[SubscribesTo("TimerTick")]
public void OnTimerExpired(Object sender, EventArgs e)
{
EventHandler handlers = ChangeLight;
if(handlers != null)
{
handlers(this, EventArgs.Empty);
}
currentLight = ( currentLight + 1 ) % 3;
timer.Duration = lightTimes[currentLight];
timer.Start();
}
Existem outros melhores?
O Composite Application Block inclui um corretor de evento que pode ser de utilidade para você.
Outra boa implementação pode ser encontrada em:
http://code.google .com / p / fratura / fonte / browse / trunk / Squared / Util / EventBus.cs
Os casos de uso é acessível em: /trunk/Squared/Util/UtilTests/Tests/EventTests.cs
Esta implementação não precisa de biblioteca externa.
Uma melhoria pode ser a de ser capaz de se inscrever com um tipo e não uma string.
Você deve verificar episódio 3 em Hibernating Rhinos , série casts tela de Ayende - "Implementação o corretor evento".
Ele mostra como você pode implementar um corretor evento muito simples usando Windsor a fio as coisas. O código fonte está incluído também.
A solução evento corretor proposto é muito simples, mas que não iria demorar muitas horas para aumentar a solução para permitir argumentos a serem passados ??junto com os eventos.
Eu criei este:
https://github.com/RemiBou/RemiDDD/tree/ master / RemiDDD.Framework / Cqrs
Há uma dependência com ninject. Você tem um MessageProcessor. Se você quiser obsere um evento, implementar "IObserver" se você quiser lidar com um comando de implementar "ICommandHandleer"