DMPSystem

分布式管理系统， 包括日志收集，消息订阅，SOA,集群管理，性能数据监控 配置文件 Event.Bindings.config <eventProvider> <queues> <queue id="DMPHubEvent" class="DMPSystem.Core.EventBus.Utilities.QueueContext,DMPSystem.Core.EventBus"> <property name="appRuleFile" ref="rule"/> <property name="dataContextPool" value="event_sample"> <map name="RabbitMq"> <property value="guest:[email protected]::test"/> </map> <map name="MsMq"></map> <map name="PushEvent"> </map> </property> <property name="connectTimeout" value="120"/> <property name="CunsumerNum" value="5"/> <property name="UseRetryNum" value="5"/> </queue> </queues> </eventProvider>

push publisher:

EventContainer.GetInstances<IEventPublisher>("PushEvent").Publish(new ChanageStateEvent() { UserID = manager.UserID }); rabbitmq publisher: EventContainer.GetInstances<IEventPublisher>("DMPHubEvent.RabbitMq").Publish(new ChanageStateEvent() { UserID = manager.UserID });

UseRateLimit 每分钟消息消费数限定在多少之内 UseRetryNum 消息消费失败后重试次数，每次间隔1分钟 增加注册消费者模块注册的方法，这样就不需要依赖Autofac EventContainer.RegisterConsumeModule(params Type[] types)