AddPollyTest

Author: jerviscui

src/plugins/ConsolePollyTest/PollyTest.cs

@@ -1,4 +1,5 @@
 using Polly;
+using Polly.Retry;
 
 namespace ConsolePollyTest;
 
@@ -7,9 +8,63 @@ public static class PollyTest
 
     #region Constants & Statics
 
-    public static void MethodName()
+    public static Uri Host { get; set; } = new Uri("http://localhost:5222");
+
+    private static HttpClient GetClient()
+    {
+        var client = new HttpClient { BaseAddress = Host };
+        return client;
+    }
+
+    private static Uri GetUri(string path)
+    {
+        return new Uri(Host, path);
+    }
+
+    public static async Task NoStrategy_TestAsync()
+    {
+        var builder = new ResiliencePipelineBuilder();
+        var pipeline = builder.Build();
+
+        using var client = GetClient();
+
+        var result = await pipeline.ExecuteAsync(
+            async (token) =>
+            {
+                var r = await client.GetAsync(GetUri("/weatherforecast/"), token);
+                return r;
+            },
+            cancellationToken: default);
+
+        Console.WriteLine(result);
+    }
+
+    public static async Task Retry_ExecThree_TestAsync()
     {
-        var builder = new ResiliencePipelineBuilder().;
+        var builder = new ResiliencePipelineBuilder().AddRetry(
+            new RetryStrategyOptions
+            {
+                Delay = TimeSpan.FromSeconds(1),
+                MaxRetryAttempts = 2,
+                ShouldHandle = (args) =>
+                        {
+                            Console.WriteLine(args.AttemptNumber);
+                            return ValueTask.FromResult(args.AttemptNumber >= 0);
+                        }
+            });
+        var pipeline = builder.Build();
+
+        using var client = GetClient();
+
+        var result = await pipeline.ExecuteAsync(
+            async (token) =>
+            {
+                var r = await client.GetAsync(GetUri("/weatherforecast/"), token);
+                return r;
+            },
+            cancellationToken: default);
+
+        Console.WriteLine(result);
     }
 
     #endregion

src/plugins/ConsolePollyTest/Program.cs

@@ -5,8 +5,12 @@ internal static class Program
 
     #region Constants & Statics
 
-    private static void Main(string[] args)
+    private static async Task Main(string[] args)
     {
+        //await PollyTest.NoStrategy_TestAsync();
+        await PollyTest.Retry_ExecThree_TestAsync();
+
+        _ = Console.ReadKey();
     }
 
     #endregion

src/plugins/WebPollyTest/Program.cs

@@ -1,3 +1,5 @@
+using Microsoft.AspNetCore.HttpLogging;
+
 namespace WebPollyTest;
 
 internal static class Program
@@ -9,21 +11,29 @@ private static void Main(string[] args)
     {
         var builder = WebApplication.CreateBuilder(args);
 
-        // Add services to the container.
+        _ = builder.Logging.AddConsole();
 
         _ = builder.Services.AddControllers();
-        // Learn more about configuring OpenAPI at https://aka.ms/aspnet/openapi
         _ = builder.Services.AddOpenApi();
 
+        _ = builder.Services
+            .AddHttpLogging(
+                (options) =>
+                {
+                    options.LoggingFields = HttpLoggingFields.All;
+                    options.CombineLogs = true;
+                });
+
         var app = builder.Build();
 
-        // Configure the HTTP request pipeline.
+        _ = app.UseHttpLogging();
+
         if (app.Environment.IsDevelopment())
         {
             _ = app.MapOpenApi();
         }
 
-        _ = app.UseHttpsRedirection();
+        //_ = app.UseHttpsRedirection();
 
         _ = app.UseAuthorization();
 
@@ -34,4 +44,4 @@ private static void Main(string[] args)
 
     #endregion
 
-}
+}

src/plugins/WebPollyTest/appsettings.Development.json

@@ -1,8 +1,2 @@
 {
-  "Logging": {
-    "LogLevel": {
-      "Default": "Information",
-      "Microsoft.AspNetCore": "Warning"
-    }
-  }
 }

src/plugins/WebPollyTest/appsettings.json

@@ -2,7 +2,8 @@
   "Logging": {
     "LogLevel": {
       "Default": "Information",
-      "Microsoft.AspNetCore": "Warning"
+      "Microsoft.AspNetCore": "Warning",
+      "Microsoft.AspNetCore.HttpLogging.HttpLoggingMiddleware": "Information"
     }
   },
   "AllowedHosts": "*"