Refactor to minimal hosting model

Migrated from the traditional `Startup.cs` and `Program.cs` structure to the .NET 6+ minimal hosting model:
- Consolidated service registration and middleware configuration into `Program.cs`.
- Removed `Startup.cs` files across all integrations (Amazon SQS, Kafka, Pulsar, RabbitMQ with MongoDB, RabbitMQ with SQL Server).
- Added `WebApplication` and `WebApplicationBuilder` for streamlined configuration.
- Updated namespaces and constants for better alignment with the new structure.
- Included Docker setup commands as comments for dependencies like Kafka, PostgreSQL, and SQL Server.
- Simplified project structure, improving readability and reducing boilerplate code.

Author: yang-xiaodong

samples/Sample.AmazonSQS.InMemory/Program.cs

@@ -1,20 +1,23 @@
-using Microsoft.AspNetCore.Hosting;
-using Microsoft.Extensions.Hosting;
+using Amazon;
+using Microsoft.AspNetCore.Builder;
+using Microsoft.Extensions.DependencyInjection;
 
-namespace Sample.AmazonSQS.InMemory
+var builder = WebApplication.CreateBuilder(args);
+
+// Configure services
+builder.Services.AddCap(x =>
 {
-    public class Program
-    {
-        public static void Main(string[] args)
-        {
-            CreateHostBuilder(args).Build().Run();
-        }
+    x.UseInMemoryStorage();
+    x.UseAmazonSQS(RegionEndpoint.CNNorthWest1);
+    x.UseDashboard();
+});
+
+builder.Services.AddControllers();
+
+var app = builder.Build();
+
+// Configure middleware pipeline
+app.UseRouting();
+app.MapControllers();
 
-        public static IHostBuilder CreateHostBuilder(string[] args) =>
-            Host.CreateDefaultBuilder(args)
-                .ConfigureWebHostDefaults(webBuilder =>
-                {
-                    webBuilder.UseStartup<Startup>();
-                });
-    }
-}
+app.Run();

samples/Sample.AmazonSQS.InMemory/Startup.cs

@@ -1,13 +1,12 @@
-using System.Threading.Tasks;
+using System.Data.Common;
 using System.Threading;
+using System.Threading.Tasks;
+using DotNetCore.CAP;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Infrastructure;
 using Microsoft.EntityFrameworkCore.Storage;
-using DotNetCore.CAP;
 using Microsoft.Extensions.DependencyInjection;
 using Npgsql.EntityFrameworkCore.PostgreSQL.Storage.Internal;
-using Npgsql.EntityFrameworkCore.PostgreSQL.Infrastructure.Internal;
-using System.Data.Common;
 
 namespace Sample.Kafka.PostgreSql
 {

samples/Sample.Kafka.PostgreSql/AppDbContext.cs

@@ -47,7 +47,7 @@ public async Task<IActionResult> WithoutTransaction()
         [Route("~/adonet/transaction")]
         public IActionResult AdonetWithTransaction()
         {
-            using (var connection = new NpgsqlConnection(Startup.DbConnectionString))
+            using (var connection = new NpgsqlConnection(AppConstants.DbConnectionString))
             {
                 using (var transaction = connection.BeginTransaction(producer, autoCommit: false))
                 {

samples/Sample.Kafka.PostgreSql/Controllers/ValuesController.cs

@@ -1,20 +1,58 @@
-using Microsoft.AspNetCore.Hosting;
-using Microsoft.Extensions.Hosting;
+using Microsoft.AspNetCore.Builder;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Storage;
+using Microsoft.Extensions.DependencyInjection;
+using Sample.Kafka.PostgreSql;
 
-namespace Sample.Kafka.PostgreSql
+var builder = WebApplication.CreateBuilder(args);
+
+// Configure services
+builder.Services.AddDbContext<AppDbContext>((sp, opt) =>
+{
+    opt.UseNpgsql(AppConstants.DbConnectionString)
+        .ReplaceService<IRelationalConnection, CapNpgsqlRelationalConnection>();
+});
+
+builder.Services.AddCap(x =>
+{
+    //x.UseEntityFramework<AppDbContext>();
+    //docker run --name postgres -p 5432:5432 -e POSTGRES_PASSWORD=mysecretpassword -d postgres
+    x.UsePostgreSql(AppConstants.DbConnectionString);
+
+    /* //Run Kafka Docker Container (Powershell)
+    docker run -d `
+        --name kafka `
+        -p 9092:9092 `
+        -e KAFKA_NODE_ID=1 `
+        -e KAFKA_PROCESS_ROLES=broker,controller `
+        -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092,CONTROLLER://:9093 `
+        -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:9092 `
+        -e KAFKA_CONTROLLER_LISTENER_NAMES=CONTROLLER `
+        -e KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT `
+        -e KAFKA_CONTROLLER_QUORUM_VOTERS=1@localhost:9093 `
+        -e KAFKA_LOG_DIRS=/var/lib/kafka/data `
+        -e KAFKA_AUTO_CREATE_TOPICS_ENABLE=true `
+        -e KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1 `
+        -e KAFKA_OFFSETS_TOPIC_MIN_ISR=1 `
+        -e KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR=1 `
+        -e KAFKA_TRANSACTION_STATE_LOG_MIN_ISR=1 `
+        apache/kafka:3.7.0
+    */
+    x.UseKafka("127.0.0.1:9092");
+    x.UseDashboard();
+});
+
+builder.Services.AddControllers();
+
+var app = builder.Build();
+
+// Configure middleware pipeline
+app.UseRouting();
+app.MapControllers();
+
+app.Run();
+
+public static class AppConstants
 {
-    public class Program
-    {
-        public static void Main(string[] args)
-        {
-            CreateHostBuilder(args).Build().Run();
-        }
-
-        public static IHostBuilder CreateHostBuilder(string[] args) =>
-            Host.CreateDefaultBuilder(args)
-                .ConfigureWebHostDefaults(webBuilder =>
-                {
-                    webBuilder.UseStartup<Startup>();
-                });
-    }
+    public const string DbConnectionString = "User ID=postgres;Password=mysecretpassword;Host=127.0.0.1;Port=5432;Database=postgres;";
 }

samples/Sample.Kafka.PostgreSql/Program.cs

@@ -1,20 +1,25 @@
-using Microsoft.AspNetCore.Hosting;
-using Microsoft.Extensions.Hosting;
+using Microsoft.AspNetCore.Builder;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
 
-namespace Sample.Pulsar.InMemory
+var builder = WebApplication.CreateBuilder(args);
+
+// Configure services
+string pulsarUri = builder.Configuration.GetValue("AppSettings:PulsarUri", "pulsar://localhost:6650");
+
+builder.Services.AddCap(x =>
 {
-    public class Program
-    {
-        public static void Main(string[] args)
-        {
-            CreateHostBuilder(args).Build().Run();
-        }
+    x.UseInMemoryStorage();
+    x.UsePulsar(pulsarUri);
+    x.UseDashboard();
+});
+
+builder.Services.AddControllers();
+
+var app = builder.Build();
+
+// Configure middleware pipeline
+app.UseRouting();
+app.MapControllers();
 
-        public static IHostBuilder CreateHostBuilder(string[] args) =>
-            Host.CreateDefaultBuilder(args)
-                .ConfigureWebHostDefaults(webBuilder =>
-                {
-                    webBuilder.UseStartup<Startup>();
-                });
-    }
-}
+app.Run();

samples/Sample.Kafka.PostgreSql/Startup.cs

@@ -1,17 +1,26 @@
-using Microsoft.AspNetCore;
-using Microsoft.AspNetCore.Hosting;
+using Microsoft.AspNetCore.Builder;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using MongoDB.Driver;
 
-namespace Sample.RabbitMQ.MongoDB
+var builder = WebApplication.CreateBuilder(args);
+
+// Configure services
+builder.Services.AddSingleton<IMongoClient>(new MongoClient(builder.Configuration.GetConnectionString("MongoDB")));
+
+builder.Services.AddCap(x =>
 {
-    public class Program
-    {
-        public static void Main(string[] args)
-        {
-            CreateWebHostBuilder(args).Build().Run();
-        }
+    x.UseMongoDB(builder.Configuration.GetConnectionString("MongoDB"));
+    x.UseRabbitMQ("");
+    x.UseDashboard();
+});
+
+builder.Services.AddControllers();
+
+var app = builder.Build();
+
+// Configure middleware pipeline
+app.UseRouting();
+app.MapControllers();
 
-        public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
-            WebHost.CreateDefaultBuilder(args)
-                .UseStartup<Startup>();
-    }
-}
+app.Run();