sheng-jie / eventbus Goto Github PK

View Code? Open in Web Editor NEW

158.0 13.0 69.0 63 KB

C# 事件总线实现

Home Page: http://www.jianshu.com/p/22fbe7a7c120

License: MIT License

C# 100.00%

csharp eventbus observer-pattern publisher-subscriber

eventbus's People

Contributors

Stargazers

Watchers

Forkers

lidamon neoayi njmrli wuhailong githubhaikuang breakmind kouweizhong zhengjun-jing shelmanlee zche llenroc equalshelby jaapyang dawsonzhangwei ztxyzu red201432 iericzheng xw-fighting wangshifeng gongtaohub lenkasetsong lyx2013 wang080134 imqdf zmk523 gongyunhao yidaibawang lygood001 wenfeifei maxxuxu dotnetexample ztaiit1025 bionstt jangocheng wuhz520 repo-archive yangxueminghao rocching rex-guo ysking beyong226 nuxseme wangning08115 yangmaomao86 zsjyrlw weinre longlong579 loyouyang y1024866464 liubiaoyong xs0910 swicasejia lanicon chenjian88886666 bubdm vmyspace adityasaraswat0035 861191244 stmen hjl779408529 yeming-zhang doublexinglee subendong lonelyyeezhichicken river-yu liming467 startgis

eventbus's Issues

集合Autofac后ActionEventHandler如何触发？

圣杰兄请教一个问题下，我结合了Autofac实现了事件总线的注册和Trigger的解耦，但是唯独Action的注册和调用没法通过Autofac做到，后面尝试使用反射实现也没办法，原因是ActionEventHandler的构造函数就是一个Action,希望圣杰兄帮忙指点下。这是我触发事件的那一段代码：

public void Trigger(TEventData eventData) where TEventData : IEventData
{
//从事件映射集合里获取匹配当前EventData(事件源数据)的Handler
List handlerTypes = _eventStore.GetHandlersForEvent(eventData.GetType()).ToList();
if (handlerTypes.Count <= 0) return;
//循环执行事件处理函数
foreach (var handlerType in handlerTypes)
{
var handlerInterface = handlerType.GetInterface("IEventHandler`1");
var eventHandler = ContainerManager.Current.Container.Resolve(handlerInterface);
if (eventHandler.GetType().FullName == handlerType.FullName)
{
var handler = eventHandler as IEventHandler;
handler?.HandleEvent(eventData);
}
else
{
//如果Ioc容器里没有则需要反射生成
//因为ActionEventHandler的构造函数需要有指定的入参:Action，这里没法反射！！
MethodInfo methodInfo = handlerType.GetMethod("HandleEvent").MakeGenericMethod();
if (methodInfo != null)
{
object obj = Activator.CreateInstance(handlerType);
methodInfo.Invoke(obj, new object[] { eventData });
}
}
}

线程安全字典集合

线程安全字典集合可以采用类似这样的 ConcurrentDictionary<string, ConcurrentBag<ServiceResult>> 处理方式，，这样就可不用设置线程同步锁对象了

有没有计划实现确认回复，线程等待、事务和RPC？

看了下，和微软eshop实现原理一样，现在遇到数据一致性，和同步等待的问题，有没有计划实现？

sheng-jie / eventbus Goto Github PK

eventbus's People

Contributors

Stargazers

Watchers

Forkers

eventbus's Issues

集合Autofac后ActionEventHandler如何触发？

线程安全字典集合

有没有计划实现确认回复，线程等待、事务和RPC？

Recommend Projects

React

Vue.js

Typescript

TensorFlow

Django

Laravel

D3

Recommend Topics

javascript

web

server

Machine learning

Visualization

Game

Recommend Org

Facebook

Microsoft

Google

Alibaba

D3

Tencent