优化 可靠消息

src/Pole.ReliableMessage.Storage.Abstraction/IMemberShipTable.cs → src/Pole.ReliableMessage.Storage.Abstraction/IMemberShipTableManager.cs

@@ -6,7 +6,7 @@ using System.Threading.Tasks;
 
 
 namespace Pole.ReliableMessage.Storage.Abstraction
 namespace Pole.ReliableMessage.Storage.Abstraction
 {
 {
-    public interface IMemberShipTable
+    public interface IMemberShipTableManager
     {
     {
         Task<bool> IsPendingMessageCheckerServiceInstance(string ipAddress);
         Task<bool> IsPendingMessageCheckerServiceInstance(string ipAddress);
         Task<bool> UpdateIAmAlive(string ipAddress, DateTime dateTime);
         Task<bool> UpdateIAmAlive(string ipAddress, DateTime dateTime);

src/Pole.ReliableMessage.Storage.Mongodb/MongodbMemberShipTable.cs → src/Pole.ReliableMessage.Storage.Mongodb/MongodbMemberShipTableManager.cs

@@ -12,12 +12,12 @@ using Pole.ReliableMessage.Storage.Abstraction;
 
 
 namespace Pole.ReliableMessage.Storage.Mongodb
 namespace Pole.ReliableMessage.Storage.Mongodb
 {
 {
-    class MongodbMemberShipTable : IMemberShipTable
+    class MongodbMemberShipTableManager : IMemberShipTableManager
     {
     {
         private readonly MongoClient _mongoClient;
         private readonly MongoClient _mongoClient;
         private readonly MongodbOption _mongodbOption;
         private readonly MongodbOption _mongodbOption;
         private readonly ILogger _logger;
         private readonly ILogger _logger;
-        public MongodbMemberShipTable(IConfiguration configuration, MongoClient mongoClient, IOptions<MongodbOption> mongodbOption, ILogger<MongodbMemberShipTable> logger)
+        public MongodbMemberShipTableManager(IConfiguration configuration, MongoClient mongoClient, IOptions<MongodbOption> mongodbOption, ILogger<MongodbMemberShipTableManager> logger)
         {
         {
             _mongoClient = mongoClient;
             _mongoClient = mongoClient;
             _mongodbOption = mongodbOption.Value;
             _mongodbOption = mongodbOption.Value;

src/Pole.ReliableMessage.Storage.Mongodb/ReliableMessageOptionExtension.cs

@@ -35,7 +35,7 @@ namespace Microsoft.Extensions.DependencyInjection
         {
         {
             services.Configure(_mongodbOption);
             services.Configure(_mongodbOption);
             services.AddSingleton<IMessageStorage, MongodbMessageStorage>();
             services.AddSingleton<IMessageStorage, MongodbMessageStorage>();
-            services.AddSingleton<IMemberShipTable, MongodbMemberShipTable>();
+            services.AddSingleton<IMemberShipTableManager, MongodbMemberShipTableManager>();
 
 
             var mongodbOption = services.BuildServiceProvider().GetRequiredService<IOptions<MongodbOption>>().Value;
             var mongodbOption = services.BuildServiceProvider().GetRequiredService<IOptions<MongodbOption>>().Value;
 
 

src/Pole.ReliableMessage/Processor/MessageCleanProcessor.cs

@@ -15,9 +15,9 @@ namespace Pole.ReliableMessage.Processor
         private readonly ReliableMessageOption _options;
         private readonly ReliableMessageOption _options;
         private readonly ILogger<MessageCleanProcessor> _logger;
         private readonly ILogger<MessageCleanProcessor> _logger;
         private readonly IMessageStorage _messageStorage;
         private readonly IMessageStorage _messageStorage;
-        private readonly IMemberShipTable _memberShipTable;
+        private readonly IMemberShipTableManager _memberShipTable;
         private readonly IServiceIPv4AddressProvider _serviceIPv4AddressProvider;
         private readonly IServiceIPv4AddressProvider _serviceIPv4AddressProvider;
-        public MessageCleanProcessor(IOptions<ReliableMessageOption> options, ILogger<MessageCleanProcessor> logger, IMessageStorage messageStorage, IMemberShipTable memberShipTable, IServiceIPv4AddressProvider serviceIPv4AddressProvider)
+        public MessageCleanProcessor(IOptions<ReliableMessageOption> options, ILogger<MessageCleanProcessor> logger, IMessageStorage messageStorage, IMemberShipTableManager memberShipTable, IServiceIPv4AddressProvider serviceIPv4AddressProvider)
         {
         {
             _options = options.Value ?? throw new Exception($"{nameof(ReliableMessageOption)} Must be injected");
             _options = options.Value ?? throw new Exception($"{nameof(ReliableMessageOption)} Must be injected");
             _logger = logger;
             _logger = logger;

src/Pole.ReliableMessage/Processor/PendingMessageCheckProcessor.cs

@@ -19,11 +19,11 @@ namespace Pole.ReliableMessage.Processor
         private readonly ReliableMessageOption _options;
         private readonly ReliableMessageOption _options;
         //private readonly IMessageBuffer _messageBuffer;
         //private readonly IMessageBuffer _messageBuffer;
         private readonly ITimeHelper _timeHelper;
         private readonly ITimeHelper _timeHelper;
-        private readonly IMemberShipTable _memberShipTable;
+        private readonly IMemberShipTableManager _memberShipTable;
         private readonly ILogger<PendingMessageCheckProcessor> _logger;
         private readonly ILogger<PendingMessageCheckProcessor> _logger;
         private readonly IServiceIPv4AddressProvider _serviceIPv4AddressProvider;
         private readonly IServiceIPv4AddressProvider _serviceIPv4AddressProvider;
         private readonly IMessageCheckRetryer _messageCheckRetryer;
         private readonly IMessageCheckRetryer _messageCheckRetryer;
-        public PendingMessageCheckProcessor(IMessageStorage storage, IOptions<ReliableMessageOption> options, ITimeHelper timeHelper, IMemberShipTable memberShipTable, ILogger<PendingMessageCheckProcessor> logger, IServiceIPv4AddressProvider serviceIPv4AddressProvider, IMessageCheckRetryer messageCheckRetryer)
+        public PendingMessageCheckProcessor(IMessageStorage storage, IOptions<ReliableMessageOption> options, ITimeHelper timeHelper, IMemberShipTableManager memberShipTable, ILogger<PendingMessageCheckProcessor> logger, IServiceIPv4AddressProvider serviceIPv4AddressProvider, IMessageCheckRetryer messageCheckRetryer)
         {
         {
             _storage = storage;
             _storage = storage;
             _options = options.Value ?? throw new Exception($"{nameof(ReliableMessageOption)} Must be injected");
             _options = options.Value ?? throw new Exception($"{nameof(ReliableMessageOption)} Must be injected");

src/Pole.ReliableMessage/Processor/PendingMessageServiceInstanceCheckProcessor.cs

@@ -14,10 +14,10 @@ namespace Pole.ReliableMessage.Processor
     {
     {
         private readonly ReliableMessageOption _options;
         private readonly ReliableMessageOption _options;
         private readonly ITimeHelper _timeHelper;
         private readonly ITimeHelper _timeHelper;
-        private readonly IMemberShipTable _memberShipTable;
+        private readonly IMemberShipTableManager _memberShipTable;
         private readonly ILogger<PendingMessageServiceInstanceCheckProcessor> _logger;
         private readonly ILogger<PendingMessageServiceInstanceCheckProcessor> _logger;
         private readonly IServiceIPv4AddressProvider _serviceIPv4AddressProvider;
         private readonly IServiceIPv4AddressProvider _serviceIPv4AddressProvider;
-        public PendingMessageServiceInstanceCheckProcessor(IOptions<ReliableMessageOption> options, ITimeHelper timeHelper, IMemberShipTable memberShipTable, ILogger<PendingMessageServiceInstanceCheckProcessor> logger, IServiceIPv4AddressProvider serviceIPv4AddressProvider)
+        public PendingMessageServiceInstanceCheckProcessor(IOptions<ReliableMessageOption> options, ITimeHelper timeHelper, IMemberShipTableManager memberShipTable, ILogger<PendingMessageServiceInstanceCheckProcessor> logger, IServiceIPv4AddressProvider serviceIPv4AddressProvider)
         {
         {
             _options = options.Value ?? throw new Exception($"{nameof(ReliableMessageOption)} Must be injected");
             _options = options.Value ?? throw new Exception($"{nameof(ReliableMessageOption)} Must be injected");
             _timeHelper = timeHelper;
             _timeHelper = timeHelper;