Support to extend the middleware based on kestrel http

Author: fanliang11

src/Surging.Core/Surging.Core.KestrelHttpServer/KestrelHttpMessageListener.cs

@@ -132,7 +132,7 @@ private void AppResolve(IApplicationBuilder app)
             _moduleProvider.Initialize(new ApplicationInitializationContext(app, _moduleProvider.Modules,
                 _moduleProvider.VirtualPaths,
                 AppConfig.Configuration));
-            app.Run(async (context) =>
+            app.Use(async (context,next) =>
             {
                 var messageId = Guid.NewGuid().ToString("N");
                 var subject = new ReplaySubject<HttpResultMessage<object>>();
@@ -146,6 +146,7 @@ private void AppResolve(IApplicationBuilder app)
                         var actionFilters = app.ApplicationServices.GetServices<IActionFilter>();
                         await OnReceived(sender, messageId, context, actionFilters, subject);
                     }
+                    await next();
                 }
                 catch (Exception ex)
                 {
@@ -154,6 +155,7 @@ private void AppResolve(IApplicationBuilder app)
                     await OnException(context, sender, messageId, ex, filters);
                 }
             });
+            app.Run( context=> Task.CompletedTask);
         }
 
         private void WirteDiagnosticError(string messageId,Exception ex)

src/Surging.Core/Surging.Core.NLog/NLogger.cs

@@ -62,16 +62,16 @@ public void Log<TState>(Microsoft.Extensions.Logging.LogLevel logLevel, EventId
                 switch (logLevel)
                 {
                     case LogLevel.Critical:
-                        _log.Fatal(message);
+                        _log.Fatal(exception, message);
                         break;
                     case LogLevel.Debug:
-                        _log.Debug(message);
+                        _log.Debug(exception, message);
                         break;
                     case LogLevel.Trace:
-                        _log.Trace(message);
+                        _log.Trace(exception, message);
                         break;
                     case LogLevel.Error:
-                        _log.Error(message, exception,null);
+                        _log.Error(exception, message);
                         break;
                     case LogLevel.Information:
                         _log.Info(message);
@@ -81,7 +81,7 @@ public void Log<TState>(Microsoft.Extensions.Logging.LogLevel logLevel, EventId
                         break;
                     default:
                         _log.Warn($"遇到未知日志级别{logLevel}");
-                        _log.Info(message, exception,null);
+                        _log.Info(message, exception, null);
                         break;
                 }
             }

src/Surging.Modules/Surging.Modules.Common/Domain/UserService.cs

@@ -1,4 +1,5 @@
 
+using Microsoft.Extensions.Logging;
 using Surging.Core.Common;
 using Surging.Core.CPlatform;
 using Surging.Core.CPlatform.EventBus.Events;
@@ -30,9 +31,11 @@ public class UserService : ProxyServiceBase, IUserService
     {
         #region Implementation of IUserService
         private readonly UserRepository _repository;
-        public UserService(UserRepository repository)
+        private readonly ILogger<UserService> _logger;
+        public UserService(UserRepository repository,ILogger<UserService> logger)
         {
             this._repository = repository;
+            _logger = logger;
         }
 
         public async Task<string> GetUserName(int id)
@@ -86,6 +89,7 @@ public Task<bool> Update(int id, UserModel model)
 
         public Task<bool> GetDictionary()
         {
+            _logger.LogError("测试");
             return Task.FromResult<bool>(true);
         }