分布式管理系统，_包括日志收集，消息订阅，SOA,集群管理，性能数据监控_DMPSystem.zip

# DMPSystem 分布式管理系统， 包括日志收集，消息订阅，SOA,集群管理，性能数据监控 配置文件 Event.Bindings.config</br> &lt;eventProvider&gt; </br> &lt;queues&gt; </br> &lt;queue id=&quot;DMPHubEvent&quot; class=&quot;DMPSystem.Core.EventBus.Utilities.QueueContext,DMPSystem.Core.EventBus&quot;&gt; </br> &lt;property name=&quot;appRuleFile&quot; ref=&quot;rule&quot;/&gt; </br> &lt;property name=&quot;dataContextPool&quot; value=&quot;event_sample&quot;&gt; </br> &lt;map name=&quot;RabbitMq&quot;&gt; </br> &lt;property value=&quot;guest:guest@127.0.0.1::test&quot;/&gt; </br> &lt;/map&gt; </br> &lt;map name=&quot;MsMq&quot;&gt;&lt;/map&gt; </br> &lt;map name=&quot;PushEvent&quot;&gt; </br> &lt;/map&gt; </br> &lt;/property&gt; </br> &lt;property name=&quot;connectTimeout&quot; value=&quot;120&quot;/&gt; </br> &lt;property name=&quot;CunsumerNum&quot; value=&quot;5&quot;/&gt; </br> &lt;property name=&quot;UseRetryNum&quot; value=&quot;5&quot;/&gt; </br> &lt;/queue&gt; </br> &lt;/queues&gt; </br> &lt;/eventProvider&gt; </br> push publisher: EventContainer.GetInstances&lt;IEventPublisher&gt;(&quot;PushEvent&quot;).Publish(new ChanageStateEvent() { UserID = manager.UserID });</br> rabbitmq publisher:</br> EventContainer.GetInstances&lt;IEventPublisher&gt;(&quot;DMPHubEvent.RabbitMq&quot;).Publish(new ChanageStateEvent() { UserID = manager.UserID }); UseRateLimit 每分钟消息消费数限定在多少之内</br> UseRetryNum 消息消费失败后重试次数，每次间隔1分钟</br> 增加注册消费者模块注册的方法，这样就不需要依赖Autofac</br> EventContainer.RegisterConsumeModule(params Type[] types)