重构 eventbus 的 代码结构

Pole.sln

@@ -43,7 +43,11 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "SagasTest.Api", "samples\ap
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Pole.Sagas.Server", "src\Pole.Sagas.Server\Pole.Sagas.Server.csproj", "{34ECE24E-0D78-4764-BC54-0CEE61BDB96A}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Pole.Sagas.Client", "src\Pole.Sagas.Client\Pole.Sagas.Client.csproj", "{EED4FEA7-4E20-41B2-9741-55FCA709373E}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Pole.Sagas.Client", "src\Pole.Sagas.Client\Pole.Sagas.Client.csproj", "{EED4FEA7-4E20-41B2-9741-55FCA709373E}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "SagasServer", "samples\apis\SagasServer\SagasServer.csproj", "{9717D0D7-9288-4B2F-9830-A06E13B1C8C4}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Pole.EventBus", "src\Pole.EventBus\Pole.EventBus.csproj", "{A92E194A-518F-4A93-B346-0FEA50CCD614}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -115,6 +119,14 @@ Global
 		{EED4FEA7-4E20-41B2-9741-55FCA709373E}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{EED4FEA7-4E20-41B2-9741-55FCA709373E}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{EED4FEA7-4E20-41B2-9741-55FCA709373E}.Release|Any CPU.Build.0 = Release|Any CPU
+		{9717D0D7-9288-4B2F-9830-A06E13B1C8C4}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{9717D0D7-9288-4B2F-9830-A06E13B1C8C4}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{9717D0D7-9288-4B2F-9830-A06E13B1C8C4}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{9717D0D7-9288-4B2F-9830-A06E13B1C8C4}.Release|Any CPU.Build.0 = Release|Any CPU
+		{A92E194A-518F-4A93-B346-0FEA50CCD614}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{A92E194A-518F-4A93-B346-0FEA50CCD614}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{A92E194A-518F-4A93-B346-0FEA50CCD614}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{A92E194A-518F-4A93-B346-0FEA50CCD614}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -138,6 +150,8 @@ Global
 		{6138197E-6202-4E1B-9458-3CBEE60A36F9} = {475116FC-DEEC-4255-94E4-AE7B8C85038D}
 		{34ECE24E-0D78-4764-BC54-0CEE61BDB96A} = {9932C965-8B38-4F70-9E43-86DC56860E2B}
 		{EED4FEA7-4E20-41B2-9741-55FCA709373E} = {9932C965-8B38-4F70-9E43-86DC56860E2B}
+		{9717D0D7-9288-4B2F-9830-A06E13B1C8C4} = {475116FC-DEEC-4255-94E4-AE7B8C85038D}
+		{A92E194A-518F-4A93-B346-0FEA50CCD614} = {9932C965-8B38-4F70-9E43-86DC56860E2B}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {DB0775A3-F293-4043-ADB7-72BAC081E87E}

samples/apis/Backet.Api/Backet.Api.csproj

@@ -49,6 +49,7 @@
   <ItemGroup>
     <ProjectReference Include="..\..\..\src\Pole.Core\Pole.Core.csproj" />
     <ProjectReference Include="..\..\..\src\Pole.EventBus.Rabbitmq\Pole.EventBus.Rabbitmq.csproj" />
+    <ProjectReference Include="..\..\..\src\Pole.EventBus\Pole.EventBus.csproj" />
     <ProjectReference Include="..\..\..\src\Pole.EventStorage.PostgreSql\Pole.EventStorage.PostgreSql.csproj" />
     <ProjectReference Include="..\..\..\src\Pole.Grpc\Pole.Grpc.csproj" />
     <ProjectReference Include="..\..\..\src\Pole.Orleans.Provider.EntityframeworkCore\Pole.Orleans.Provider.EntityframeworkCore.csproj" />

samples/apis/Backet.Api/Controllers/BacketController.cs

@@ -17,13 +17,10 @@ using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
 using Npgsql;
 using Orleans;
-using Pole.Core.EventBus;
-using Pole.Core.EventBus.Event;
-using Pole.Core.EventBus.EventHandler;
-using Pole.Core.EventBus.EventStorage;
 using Pole.Core.Serialization;
 using Pole.Core.UnitOfWork;
 using Pole.Core.Utils.Abstraction;
+using Pole.EventBus;
 
 namespace Backet.Api.Controllers
 {

samples/apis/Backet.Api/Domain/Events/BacketCreatedEvent.cs

-using Pole.Core.EventBus.Event;
+using Pole.Core.Domain;
 using System;
 using System.Collections.Generic;
 using System.Linq;
@@ -7,7 +7,7 @@ using System.Threading.Tasks;
 
 namespace Backet.Api.Domain.Event
 {
-    [EventInfo(EventName = "Backet")]
+    [Pole.EventBus.Event.EventInfo(EventName = "Backet")]
     public class BacketCreatedEvent : IEvent
     {
         public string BacketId { get; set; }

samples/apis/Backet.Api/EventHandlers/Abstraction/IToNoticeBacketCreatedEventHandler.cs

 using Backet.Api.Domain.Event;
-using Pole.Core.EventBus.EventHandler;
+using Pole.EventBus.EventHandler;
 using System;
 using System.Collections.Generic;
 using System.Linq;

samples/apis/Backet.Api/EventHandlers/ToNoticeBacketCreatedEventHandler.cs

 using Backet.Api.Domain.Event;
 using Backet.Api.EventHandlers.Abstraction;
-using Pole.Core.EventBus.EventHandler;
+using Pole.EventBus.EventHandler;
 using System;
 using System.Collections.Generic;
 using System.Linq;

samples/apis/Backet.Api/Grains/AddBacketGrain.cs

@@ -8,8 +8,8 @@ using System.Threading.Tasks;
 using Microsoft.Extensions.DependencyInjection;
 using Backet.Api.Domain.Event;
 using Pole.Core.UnitOfWork;
-using Pole.Core.EventBus.Transaction;
-using Pole.Core.EventBus;
+using Pole.EventBus.UnitOfWork;
+using Pole.EventBus;
 
 namespace Backet.Api.Grains
 {

samples/apis/SagasServer/Program.cs

+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+
+namespace SagasServer
+{
+    public class Program
+    {
+        public static void Main(string[] args)
+        {
+            CreateWebHostBuilder(args).Build().Run();
+        }
+
+        public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
+            WebHost.CreateDefaultBuilder(args)
+                .UseStartup<Startup>();
+    }
+}

samples/apis/SagasServer/Properties/launchSettings.json

+{
+  "iisSettings": {
+    "windowsAuthentication": false, 
+    "anonymousAuthentication": true, 
+    "iisExpress": {
+      "applicationUrl": "http://localhost:53309",
+      "sslPort": 44342
+    }
+  },
+  "profiles": {
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "SagasServer": {
+      "commandName": "Project",
+      "launchBrowser": true,
+      "applicationUrl": "https://localhost:5001;http://localhost:5000",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}
\ No newline at end of file

samples/apis/SagasServer/SagasServer.csproj

+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>netcoreapp3.1</TargetFramework>
+    <AspNetCoreHostingModel>InProcess</AspNetCoreHostingModel>
+  </PropertyGroup>
+
+  <ItemGroup>
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\..\..\src\Pole.Sagas.Server\Pole.Sagas.Server.csproj" />
+  </ItemGroup>
+
+</Project>

samples/apis/SagasServer/Startup.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+
+namespace SagasServer
+{
+    public class Startup
+    {
+        // This method gets called by the runtime. Use this method to add services to the container.
+        // For more information on how to configure your application, visit https://go.microsoft.com/fwlink/?LinkID=398940
+        public void ConfigureServices(IServiceCollection services)
+        {
+            services.AddPoleSagasServer();
+        }
+
+        // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
+        public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
+        {
+            if (env.IsDevelopment())
+            {
+                app.UseDeveloperExceptionPage();
+            }
+
+            app.Run(async (context) =>
+            {
+                await context.Response.WriteAsync("Hello World!");
+            });
+        }
+    }
+}

samples/apis/SagasServer/appsettings.Development.json

+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Debug",
+      "System": "Information",
+      "Microsoft": "Information"
+    }
+  }
+}

samples/apis/SagasServer/appsettings.json

+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Warning"
+    }
+  },
+  "AllowedHosts": "*"
+}

samples/apis/SagasTest.Api/Startup.cs

@@ -33,13 +33,13 @@ namespace SagasTest.Api
             services.AddControllers();
             services.AddPole(config =>
             {
-                config.AddRabbitMQ(option =>
-                {
-                    option.Hosts = new string[1] { Configuration["RabbitmqConfig:HostAddress"] };
-                    option.Password = Configuration["RabbitmqConfig:HostPassword"];
-                    option.UserName = Configuration["RabbitmqConfig:HostUserName"];
-                });
-                config.AddEntityFrameworkEventStorage<BacketDbContext>();
+                //config.AddRabbitMQ(option =>
+                //{
+                //    option.Hosts = new string[1] { Configuration["RabbitmqConfig:HostAddress"] };
+                //    option.Password = Configuration["RabbitmqConfig:HostPassword"];
+                //    option.UserName = Configuration["RabbitmqConfig:HostUserName"];
+                //});
+                //config.AddEntityFrameworkEventStorage<BacketDbContext>();
                 config.AddSagas(option=> {
                     option.ServiceName = "SagasTest";
                 });

src/Pole.Core/Domain/Entity.cs

-using Pole.Core.EventBus.Event;
-using System;
+using System;
 using System.Collections.Generic;
 using System.Text;
 

src/Pole.Core/EventBus/Event/IEvent.cs → src/Pole.Core/Domain/IEvent.cs

@@ -2,7 +2,7 @@
 using System.Collections.Generic;
 using System.Text;
 
-namespace Pole.Core.EventBus.Event
+namespace Pole.Core.Domain
 {
     public interface IEvent
     {

src/Pole.Core/Extensions/PoleServiceCollectionExtensions.cs

 using Microsoft.Extensions.DependencyInjection;
 using Pole.Core;
 using Pole.Core.Channels;
-using Pole.Core.EventBus;
 using Pole.Core.Processor;
-using Pole.Core.Processor.Server;
 using Pole.Core.Query;
 using Pole.Core.Serialization;
-using Pole.Core.UnitOfWork;
 using Pole.Core.Utils;
 using Pole.Core.Utils.Abstraction;
 using System;
@@ -24,14 +21,9 @@ namespace Microsoft.Extensions.DependencyInjection
             {
                 services.Configure<PoleOptions>(option => { });
             }
-            services.AddSingleton<IEventTypeFinder, EventTypeFinder>();
-            services.AddSingleton<IEventBuffer, EventBuffer>();
             services.AddTransient(typeof(IMpscChannel<>), typeof(MpscChannel<>));
-            services.AddScoped<IBus, Bus>();
-            services.AddScoped<IUnitOfWork, Pole.Core.UnitOfWork.UnitOfWork>();
             services.AddSingleton<ISerializer, DefaultJsonSerializer>();
             services.AddSingleton<IGeneratorIdSolver, InstanceIPV4_16IdGeneratorIdSolver>();
-            services.AddSingleton<IObserverUnitContainer, ObserverUnitContainer>();
             services.AddSingleton<IQueryRegister, QueryRegister>();
             using (var serviceProvider = services.BuildServiceProvider())
             {
@@ -41,11 +33,6 @@ namespace Microsoft.Extensions.DependencyInjection
                 var queryRegister = serviceProvider.GetService<IQueryRegister>();
                 queryRegister.Register(services, ServiceLifetime.Scoped);
             }
-
-            services.AddSingleton<IProcessor, PendingMessageRetryProcessor>();
-            services.AddSingleton<IProcessor, ExpiredEventsCollectorProcessor>();
-            services.AddHostedService<BackgroundServiceBasedProcessorServer>();
-
             config(startupOption);
             return services;
         }

src/Pole.Core/Grains/PoleGrain.cs

 using Orleans;
 using Pole.Core.Domain;
-using Pole.Core.EventBus.Event;
 using System;
 using System.Collections.Generic;
 using System.Text;

src/Pole.EventBus.Rabbitmq/Consumer/RabbitConsumer.cs

 using System;
 using System.Collections.Generic;
 using System.Threading.Tasks;
-using Pole.Core.EventBus;
 
 namespace Pole.EventBus.RabbitMQ
 {

src/Pole.EventBus.Rabbitmq/Core/EventBusContainer.cs

@@ -2,17 +2,17 @@
 using Microsoft.Extensions.Logging;
 using Orleans;
 using RabbitMQ.Client;
-using Pole.Core.EventBus;
 using Pole.Core.Exceptions;
 using Pole.Core.Utils;
 using System;
 using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Threading.Tasks;
-using Pole.Core.EventBus.Event;
-using Pole.Core.EventBus.EventHandler;
 using Microsoft.Extensions.Options;
 using System.Linq;
+using Pole.EventBus.Event;
+using Pole.Core.Domain;
+using Pole.EventBus.EventHandler;
 
 namespace Pole.EventBus.RabbitMQ
 {

src/Pole.EventBus.Rabbitmq/Core/IRabbitEventBusContainer.cs

 using System.Threading.Tasks;
-using Pole.Core.EventBus;
 
 namespace Pole.EventBus.RabbitMQ
 {

src/Pole.EventBus.Rabbitmq/Core/RabbitEventBus.cs

-using Pole.Core.EventBus;
-using Pole.Core.EventBus.EventHandler;
-using Pole.Core.Exceptions;
+using Pole.Core.Exceptions;
 using Pole.Core.Utils;
 using System;
 using System.Collections.Generic;

src/Pole.EventBus.Rabbitmq/Pole.EventBus.Rabbitmq.csproj

@@ -15,6 +15,7 @@
 
   <ItemGroup>
     <ProjectReference Include="..\Pole.Core\Pole.Core.csproj" />
+    <ProjectReference Include="..\Pole.EventBus\Pole.EventBus.csproj" />
   </ItemGroup>
 
 </Project>

src/Pole.EventBus.Rabbitmq/PoleRabbitmqStartupConfigExtensions.cs

@@ -5,7 +5,7 @@ using System.Threading.Tasks;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Options;
 using Pole.Core;
-using Pole.Core.EventBus;
+using Pole.EventBus;
 using Pole.EventBus.RabbitMQ;
 
 namespace Microsoft.Extensions.DependencyInjection

src/Pole.EventBus.Rabbitmq/Producer/RabbitProducer.cs

 using Microsoft.Extensions.Options;
 using Pole.Core;
-using Pole.Core.EventBus;
 using System;
 using System.Collections.Generic;
 using System.Linq;

src/Pole.Core/EventBus/Bus.cs → src/Pole.EventBus/Bus.cs

 
-using Pole.Core.EventBus.Event;
-using Pole.Core.EventBus.EventStorage;
-using Pole.Core.EventBus.Transaction;
+using Pole.EventBus.Event;
+using Pole.EventBus.EventStorage;
+using Pole.EventBus.Transaction;
 using Pole.Core.Serialization;
 using Pole.Core.Utils.Abstraction;
 using System;
@@ -11,7 +11,7 @@ using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace Pole.Core.EventBus
+namespace Pole.EventBus
 {
     class Bus : IBus
     {

src/Pole.Core/EventBus/Consumer.cs → src/Pole.EventBus/Consumer.cs

@@ -3,7 +3,7 @@ using System.Collections.Generic;
 using System.Linq;
 using System.Threading.Tasks;
 
-namespace Pole.Core.EventBus
+namespace Pole.EventBus
 {
     public abstract class Consumer : IConsumer
     {

src/Pole.Core/EventBus/Event/EventBytesTransport.cs → src/Pole.EventBus/Event/EventBytesTransport.cs

@@ -4,7 +4,7 @@ using System;
 using System.Collections.Generic;
 using System.Text;
 
-namespace Pole.Core.EventBus.Event
+namespace Pole.EventBus.Event
 {
     public readonly struct EventBytesTransport
     {

src/Pole.Core/EventBus/Event/EventInfoAttribute.cs → src/Pole.EventBus/Event/EventInfoAttribute.cs

@@ -2,7 +2,7 @@
 using System.Collections.Generic;
 using System.Text;
 
-namespace Pole.Core.EventBus.Event
+namespace Pole.EventBus.Event
 {
     [AttributeUsage(AttributeTargets.Class)]
     public class EventInfoAttribute: Attribute

src/Pole.Core/EventBus/EventBuffer.cs → src/Pole.EventBus/EventBuffer.cs

 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
-using Pole.Core.EventBus.Event;
-using Pole.Core.EventBus.EventStorage;
+using Pole.Core;
+using Pole.EventBus.Event;
+using Pole.EventBus.EventStorage;
 using System;
 using System.Collections.Generic;
 using System.Linq;
@@ -10,7 +11,7 @@ using System.Threading;
 using System.Threading.Tasks;
 using System.Threading.Tasks.Dataflow;
 
-namespace Pole.Core.EventBus
+namespace Pole.EventBus
 {
     class EventBuffer : IEventBuffer
     {

src/Pole.Core/EventBus/EventHandler/IPoleEventHandler.cs → src/Pole.EventBus/EventHandler/IPoleEventHandler.cs

 using Orleans;
-using Pole.Core.EventBus.Event;
+using Pole.EventBus.Event;
 using System;
 using System.Collections.Generic;
 using System.Text;
 using System.Threading.Tasks;
 
-namespace Pole.Core.EventBus.EventHandler
+namespace Pole.EventBus.EventHandler
 {
     public interface IPoleEventHandler<TEvent> : IPoleEventHandler
     {

src/Pole.Core/EventBus/EventHandler/PoleEventHandler.cs → src/Pole.EventBus/EventHandler/PoleEventHandler.cs

 using Microsoft.Extensions.Logging;
 using Orleans.Concurrency;
-using Pole.Core.EventBus.Event;
+using Pole.EventBus.Event;
 using Pole.Core.Serialization;
 using System;
 using System.Collections.Generic;
@@ -14,7 +14,7 @@ using Pole.Core.Exceptions;
 using Orleans;
 using Pole.Core.Utils.Abstraction;
 
-namespace Pole.Core.EventBus.EventHandler
+namespace Pole.EventBus.EventHandler
 {
     /// <summary>
     /// 

src/Pole.Core/EventBus/EventStorage/EventEntity.cs → src/Pole.EventBus/EventStorage/EventEntity.cs

@@ -2,7 +2,7 @@
 using System.Collections.Generic;
 using System.Text;
 
-namespace Pole.Core.EventBus.EventStorage
+namespace Pole.EventBus.EventStorage
 {
     public class EventEntity
     {

src/Pole.Core/EventBus/EventStorage/EventStatus.cs → src/Pole.EventBus/EventStorage/EventStatus.cs

@@ -2,7 +2,7 @@
 using System.Collections.Generic;
 using System.Text;
 
-namespace Pole.Core.EventBus.EventStorage
+namespace Pole.EventBus.EventStorage
 {
     public enum EventStatus
     {

src/Pole.Core/EventBus/EventStorage/IEventStorage.cs → src/Pole.EventBus/EventStorage/IEventStorage.cs

@@ -4,7 +4,7 @@ using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace Pole.Core.EventBus.EventStorage
+namespace Pole.EventBus.EventStorage
 {
     public interface IEventStorage
     {

src/Pole.Core/EventBus/EventStorage/IEventStorageInitializer.cs → src/Pole.EventBus/EventStorage/IEventStorageInitializer.cs

@@ -4,7 +4,7 @@ using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace Pole.Core.EventBus.EventStorage
+namespace Pole.EventBus.EventStorage
 {
     public interface IEventStorageInitializer
     {

src/Pole.Core/Serialization/EventTypeFinder.cs → src/Pole.EventBus/EventTypeFinder.cs

 using Microsoft.Extensions.Logging;
-using Pole.Core.EventBus.Event;
+using Pole.Core.Domain;
 using Pole.Core.Exceptions;
 using Pole.Core.Utils;
 using Pole.Core.Utils.Abstraction;
+using Pole.EventBus.Event;
 using System;
 using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 
-namespace Pole.Core.Serialization
+namespace Pole.EventBus
 {
     public class EventTypeFinder : IEventTypeFinder
     {

src/Pole.Core/EventBus/IBus.cs → src/Pole.EventBus/IBus.cs

-using Pole.Core.EventBus.EventStorage;
-using Pole.Core.EventBus.Transaction;
+using Pole.EventBus.EventStorage;
+using Pole.EventBus.Transaction;
 using System;
 using System.Collections.Concurrent;
 using System.Collections.Generic;
@@ -7,7 +7,7 @@ using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace Pole.Core.EventBus
+namespace Pole.EventBus
 {
     public interface IBus
     {

src/Pole.Core/EventBus/IConsumer.cs → src/Pole.EventBus/IConsumer.cs

 using System.Collections.Generic;
 using System.Threading.Tasks;
 
-namespace Pole.Core.EventBus
+namespace Pole.EventBus
 {
     public interface IConsumer
     {

src/Pole.Core/EventBus/IConsumerContainer.cs → src/Pole.EventBus/IConsumerContainer.cs

 using System.Collections.Generic;
 
-namespace Pole.Core.EventBus
+namespace Pole.EventBus
 {
     public interface IConsumerContainer
     {

src/Pole.Core/EventBus/IEventBuffer.cs → src/Pole.EventBus/IEventBuffer.cs

-using Pole.Core.EventBus.EventStorage;
+using Pole.EventBus.EventStorage;
 using System;
 using System.Collections.Generic;
 using System.Text;
 using System.Threading.Tasks;
 
-namespace Pole.Core.EventBus
+namespace Pole.EventBus
 {
     public interface IEventBuffer
     {

src/Pole.Core/Utils/Abstraction/IEventTypeFinder.cs → src/Pole.EventBus/IEventTypeFinder.cs

@@ -2,7 +2,7 @@
 using System.Collections.Generic;
 using System.Text;
 
-namespace Pole.Core.Utils.Abstraction
+namespace Pole.EventBus
 {
     public interface IEventTypeFinder
     {

src/Pole.Core/EventBus/IGrainID.cs → src/Pole.EventBus/IGrainID.cs

 using System;
 
-namespace Pole.Core.EventBus
+namespace Pole.EventBus
 {
     public interface IGrainID
     {

src/Pole.Core/EventBus/IObserverUnit.cs → src/Pole.EventBus/IObserverUnit.cs

@@ -2,7 +2,7 @@
 using System.Collections.Generic;
 using System.Threading.Tasks;
 
-namespace Pole.Core.EventBus
+namespace Pole.EventBus
 {
     public interface IObserverUnit<PrimaryKey> : IGrainID
     {

src/Pole.Core/EventBus/IObserverUnitContainer.cs → src/Pole.EventBus/IObserverUnitContainer.cs

 using System;
 using System.Collections.Generic;
 
-namespace Pole.Core.EventBus
+namespace Pole.EventBus
 {
     public interface IObserverUnitContainer
     {

src/Pole.Core/EventBus/IProducer.cs → src/Pole.EventBus/IProducer.cs

 using System.Collections.Generic;
 using System.Threading.Tasks;
 
-namespace Pole.Core.EventBus
+namespace Pole.EventBus
 {
     public interface IProducer
     {

src/Pole.Core/EventBus/IProducerInfoContainer.cs → src/Pole.EventBus/IProducerInfoContainer.cs

 using System;
 using System.Threading.Tasks;
 
-namespace Pole.Core.EventBus
+namespace Pole.EventBus
 {
     public interface IProducerInfoContainer
     {

src/Pole.Core/EventBus/ObserverUnit.cs → src/Pole.EventBus/ObserverUnit.cs

@@ -7,14 +7,14 @@ using System.Text;
 using System.Threading.Tasks;
 using Microsoft.Extensions.DependencyInjection;
 using System.Linq;
-using Pole.Core.EventBus.Event;
+using Pole.EventBus.Event;
 using Orleans.Concurrency;
 using System.Collections.Concurrent;
 using System.Linq.Expressions;
-using Pole.Core.EventBus.EventHandler;
+using Pole.EventBus.EventHandler;
 using Pole.Core.Utils.Abstraction;
 
-namespace Pole.Core.EventBus
+namespace Pole.EventBus
 {
     public class ObserverUnit<PrimaryKey> : IObserverUnit<PrimaryKey>
     {

src/Pole.Core/EventBus/ObserverUnitContainer.cs → src/Pole.EventBus/ObserverUnitContainer.cs

@@ -5,12 +5,12 @@ using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Text;
 using Microsoft.Extensions.DependencyInjection;
-using Pole.Core.EventBus.EventHandler;
+using Pole.EventBus.EventHandler;
 using System.Linq;
 using Pole.Core.Exceptions;
-using Pole.Core.EventBus.Event;
+using Pole.EventBus.Event;
 
-namespace Pole.Core.EventBus
+namespace Pole.EventBus
 {
     public class ObserverUnitContainer : IObserverUnitContainer
     {

src/Pole.EventBus/Pole.EventBus.csproj

+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>netstandard2.1</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\Pole.Core\Pole.Core.csproj" />
+  </ItemGroup>
+
+</Project>

src/Pole.EventBus/PoleEventBusStartupConfigExtensions.cs

+using Microsoft.Extensions.DependencyInjection;
+using Pole.Core;
+using Pole.Core.Processor;
+using Pole.EventBus.Processor;
+using Pole.EventBus.Processor.Server;
+using Pole.EventBus.UnitOfWork;
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace Pole.EventBus
+{
+    public static class PoleEventBusStartupConfigExtensions
+    {
+        public static void AddEventBus(
+           this StartupConfig startupOption)
+        {
+            startupOption.Services.AddSingleton<IEventBuffer, EventBuffer>();
+            startupOption.Services.AddScoped<IBus, Bus>();
+            startupOption.Services.AddSingleton<IObserverUnitContainer, ObserverUnitContainer>();
+            startupOption.Services.AddSingleton<IProcessor, PendingMessageRetryProcessor>();
+            startupOption.Services.AddSingleton<IProcessor, ExpiredEventsCollectorProcessor>();
+            startupOption.Services.AddHostedService<BackgroundServiceBasedProcessorServer>();
+            startupOption.Services.AddScoped<IUnitOfWork, Pole.EventBus.UnitOfWork.UnitOfWork>();
+            startupOption.Services.AddSingleton<IEventTypeFinder, EventTypeFinder>();
+
+            Startup.Register(async serviceProvider =>
+            {
+
+            });
+        }
+    }
+}

src/Pole.Core/Processor/ExpiredEventsCollectorProcessor.cs → src/Pole.EventBus/Processor/ExpiredEventsCollectorProcessor.cs

 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
-using Pole.Core.EventBus.EventStorage;
+using Pole.Core;
+using Pole.Core.Processor;
+using Pole.EventBus.EventStorage;
 using System;
 using System.Collections.Generic;
 using System.Text;
 using System.Threading.Tasks;
 
-namespace Pole.Core.Processor
+namespace Pole.EventBus.Processor
 {
     class ExpiredEventsCollectorProcessor : IProcessor
     {

src/Pole.Core/Processor/PendingMessageRetryProcessor.cs → src/Pole.EventBus/Processor/PendingMessageRetryProcessor.cs

 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
-using Pole.Core.EventBus;
-using Pole.Core.EventBus.Event;
-using Pole.Core.EventBus.EventStorage;
+using Pole.EventBus;
+using Pole.EventBus.Event;
+using Pole.EventBus.EventStorage;
 using Pole.Core.Serialization;
 using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
+using Pole.Core.Processor;
+using Pole.Core;
 
-namespace Pole.Core.Processor
+namespace Pole.EventBus.Processor
 {
     class PendingMessageRetryProcessor : ProcessorBase
     {

src/Pole.Core/Processor/Server/BackgroundServiceBasedProcessorServer.cs → src/Pole.EventBus/Processor/Server/BackgroundServiceBasedProcessorServer.cs

 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
-using Pole.Core.EventBus.EventStorage;
+using Pole.Core.Processor;
+using Pole.EventBus.EventStorage;
 using System;
 using System.Collections.Generic;
 using System.Linq;
@@ -9,7 +10,7 @@ using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace Pole.Core.Processor.Server
+namespace Pole.EventBus.Processor.Server
 {
     public class BackgroundServiceBasedProcessorServer : BackgroundService, IProcessorServer
     {

src/Pole.Core/EventBus/Transaction/IDbTransactionAdapter.cs → src/Pole.EventBus/Transaction/IDbTransactionAdapter.cs

-using Pole.Core.EventBus.EventStorage;
+using Pole.EventBus.EventStorage;
 using System;
 using System.Collections.Concurrent;
 using System.Collections.Generic;
@@ -6,7 +6,7 @@ using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace Pole.Core.EventBus.Transaction
+namespace Pole.EventBus.Transaction
 {
     public interface IDbTransactionAdapter : IDisposable
     {

src/Pole.Core/UnitOfWork/IUnitOfWork.cs → src/Pole.EventBus/UnitOfWork/IUnitOfWork.cs

-using Pole.Core.EventBus;
-using Pole.Core.EventBus.Transaction;
-using System;
+using System;
 using System.Collections.Generic;
 using System.Data;
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.Extensions.DependencyInjection;
+using Pole.EventBus.Transaction;
 
-namespace Pole.Core.UnitOfWork
+namespace Pole.EventBus.UnitOfWork
 {
     public interface IUnitOfWork : IDisposable
     {

src/Pole.Core/UnitOfWork/UnitOfWork.cs → src/Pole.EventBus/UnitOfWork/UnitOfWork.cs

-using Pole.Core.EventBus;
-using Pole.Core.EventBus.Transaction;
-using System;
+using System;
 using System.Collections.Generic;
 using System.Data;
 using System.Linq;
@@ -9,13 +7,13 @@ using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.Extensions.DependencyInjection;
 using Pole.Core.Serialization;
-using Pole.Core.EventBus.Event;
-using Pole.Core.EventBus.EventStorage;
 using Microsoft.Extensions.Options;
 using Pole.Core.Utils.Abstraction;
 using Pole.Core.Exceptions;
+using Pole.EventBus.Event;
+using Pole.EventBus.Transaction;
 
-namespace Pole.Core.UnitOfWork
+namespace Pole.EventBus.UnitOfWork
 {
     class UnitOfWork : IUnitOfWork
     {

src/Pole.EventStorage.PostgreSql/IUnitOfWorkExtensions.cs

 using Microsoft.EntityFrameworkCore.Storage;
 using Microsoft.Extensions.DependencyInjection;
-using Pole.Core.EventBus;
-using Pole.Core.EventBus.Transaction;
 using Pole.Core.UnitOfWork;
+using Pole.EventBus;
+using Pole.EventBus.Transaction;
+using Pole.EventBus.UnitOfWork;
 using System;
 using System.Collections.Generic;
 using System.Data;

src/Pole.EventStorage.PostgreSql/Pole.EventStorage.PostgreSql.csproj

@@ -11,6 +11,7 @@
 
   <ItemGroup>
     <ProjectReference Include="..\Pole.Core\Pole.Core.csproj" />
+    <ProjectReference Include="..\Pole.EventBus\Pole.EventBus.csproj" />
   </ItemGroup>
 
 </Project>

src/Pole.EventStorage.PostgreSql/PoleNpgsqlBulkUploader.cs

 using Npgsql;
 using NpgsqlTypes;
-using Pole.Core.EventBus.EventStorage;
 using System;
 using System.Collections.Concurrent;
 using System.Collections.Generic;
@@ -8,6 +7,7 @@ using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
 using Dapper;
+using Pole.EventBus.EventStorage;
 
 namespace Pole.EventStorage.PostgreSql
 {

src/Pole.EventStorage.PostgreSql/PolePostgreSqlStartupConfigExtensions.cs

 using Microsoft.EntityFrameworkCore;
 using Pole.Core;
-using Pole.Core.EventBus.EventStorage;
-using Pole.Core.EventBus.Transaction;
+using Pole.EventBus.EventStorage;
+using Pole.EventBus.Transaction;
 using Pole.EventStorage.PostgreSql;
 using System;
 using System.Collections.Generic;

src/Pole.EventStorage.PostgreSql/PostgreSqlDbTransactionAdapter.cs

 using Microsoft.EntityFrameworkCore.Storage;
-using Pole.Core.EventBus;
-using Pole.Core.EventBus.Event;
-using Pole.Core.EventBus.EventStorage;
-using Pole.Core.EventBus.Transaction;
 using Pole.Core.Serialization;
+using Pole.EventBus.Transaction;
 using System;
 using System.Collections.Concurrent;
 using System.Collections.Generic;

src/Pole.EventStorage.PostgreSql/PostgreSqlEventStorage.cs

@@ -3,7 +3,7 @@ using Microsoft.EntityFrameworkCore.Storage;
 using Microsoft.Extensions.Options;
 using Npgsql;
 using Pole.Core;
-using Pole.Core.EventBus.EventStorage;
+using Pole.EventBus.EventStorage;
 using System;
 using System.Collections.Generic;
 using System.Data;

src/Pole.EventStorage.PostgreSql/PostgreSqlEventStorageInitializer.cs

@@ -2,7 +2,7 @@
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
 using Npgsql;
-using Pole.Core.EventBus.EventStorage;
+using Pole.EventBus.EventStorage;
 using System;
 using System.Collections.Generic;
 using System.Text;

src/Pole.Orleans.Provider.EntityframeworkCore/GrainStorage.cs

@@ -8,10 +8,9 @@ using Orleans;
 using Orleans.Runtime;
 using Orleans.Storage;
 using Pole.Core.Domain;
-using Pole.Core.EventBus;
-using Pole.Core.EventBus.Event;
-using Pole.Core.EventBus.Transaction;
-using Pole.Core.UnitOfWork;
+using Pole.EventBus;
+using Pole.EventBus.Transaction;
+using Pole.EventBus.UnitOfWork;
 using System;
 using System.Collections.Generic;
 using System.Linq;

src/Pole.Orleans.Provider.EntityframeworkCore/Pole.Orleans.Provider.EntityframeworkCore.csproj

@@ -10,6 +10,7 @@
 
   <ItemGroup>
     <ProjectReference Include="..\Pole.Core\Pole.Core.csproj" />
+    <ProjectReference Include="..\Pole.EventBus\Pole.EventBus.csproj" />
   </ItemGroup>
 
 </Project>

src/Pole.Sagas.Server/PoleSagasServerOption.cs

@@ -6,10 +6,25 @@ namespace Pole.Sagas.Server
 {
     public class PoleSagasServerOption
     {
+        /// <summary>
+        /// 从数据库获取未结束的 sagas 的 时间间隔 单位秒
+        /// </summary>
         public int NotEndedSagasFetchIntervalSeconds { get; set; } = 30;
+        /// <summary>
+        /// 每个Grpc 获取Sagas 的请求 ,服务端流式返回,每一次返回的间隔时间 单位秒
+        /// </summary>
         public int GetSagasGrpcStreamingResponseDelaySeconds { get; set; } = 20;
+        /// <summary>
+        /// 过期数据 批量删除触发的时间间隔,单位秒
+        /// </summary>
         public int ExpiredDataBulkDeleteIntervalSeconds { get; set; } = 10*60;
+        /// <summary>
+        /// 过期数据 批量是每一次删除的数量
+        /// </summary>
         public int ExpiredDataDeleteBatchCount { get; set; } = 1000;
+        /// <summary>
+        /// 批量删除时 实际过期的数量比预定数量要大时,会分多次删除,此值为其中每次分批删除的时间间隔
+        /// </summary>
         public int ExpiredDataPreBulkDeleteDelaySeconds { get; set; } = 3;
     }
 }

src/Pole.Sagas.Server/PoleSagasServerServiceCollectionExtensions.cs

 using Microsoft.Extensions.DependencyInjection;
 using Pole.Core.Processor;
+using Pole.Sagas.Server;
 using Pole.Sagas.Server.Processor;
 using System;
 using System.Collections.Generic;
 using System.Text;
 
-namespace Pole.Sagas.Server
+namespace Microsoft.Extensions.DependencyInjection
 {
     public static class PoleSagasServerServiceCollectionExtensions
     {
-        public static IServiceCollection AddPoleSagasServer(IServiceCollection services)
-        {
+        public static IServiceCollection AddPoleSagasServer(this IServiceCollection services, Action<PoleSagasServerOption> config = null)
+        {       
+            Action<PoleSagasServerOption> defaultConfig = option => { };
+            var finalConfig = config ?? defaultConfig;
             services.AddGrpc();
+            services.Configure(config);
 
             services.AddSingleton<IProcessor, NotEndedSagasFetchProcessor>();
             services.AddSingleton<IProcessor, ExpiredSagasCollectorProcessor>();

src/Pole.Sagas.Storage.PostgreSql/PoleSagasStoragePostgreSqlOption.cs

@@ -9,8 +9,6 @@ namespace Pole.Sagas.Storage.PostgreSql
         public string SagaTableName { get; set; } = "Sagas";
         public string SchemaName { get; set; } = "pole-sagas";
         public string ActivityTableName { get; set; } = "Activities";
-        public string OvertimeCompensationGuaranteeTableName { get; set; } = "OCG-Activities";
-        public int SagasRecoveryIntervalSecond { get; set; }
         public string ConnectionString { get; set; }
     }
 }

src/Pole.Sagas.Storage.PostgreSql/PostgreSqlSagaStorageInitializer.cs

@@ -2,7 +2,6 @@
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
 using Npgsql;
-using Pole.Core.EventBus.EventStorage;
 using Pole.Sagas.Core;
 using Pole.Sagas.Core.Abstraction;
 using System;

test/Pole.Samples.Backet.Api/Program.cs

 using BenchmarkDotNet.Reports;
 using BenchmarkDotNet.Running;
 using Npgsql;
-using Pole.Core.EventBus.EventStorage;
 using Pole.Samples.Backet.Api.Benchmarks;
 using System;
 using System.Collections.Generic;