使用 Aspire 启动分布式微服务

视频免费1:09:00将近 2 年前

使用 Aspire 启动分布式微服务，包括配置 PostgreSQL 数据库的时间类型为 UTC 时间，删除不优雅的时间转换设置，并推荐使用 TimeProvider 抽象类获取当前时间，以便在测试时更方便地模拟时间。

正在加载视频…

使用 Aspire 启动分布式微服务

准备数据库

docker run --name postgres -e POSTGRES_PASSWORD=postgres -e TZ=Asia/Shanghai -d -p 5432:5432 postgres

shell

docker run --name pgadmin -e PGADMIN_DEFAULT_EMAIL=test@test.com -e PGADMIN_DEFAULT_PASSWORD=test -e TZ=Asia/Shanghai -d -p 5050:80 dpage/pgadmin4

shell

初始化 Dapr 运行时

dapr init -s --from-dir C:\dapr

shell

延长等待 RabbitMQ 启动时间

public static IResourceBuilder<IDaprSidecarResource> WithReference(this IResourceBuilder<IDaprSidecarResource> builder, IResourceBuilder<IResourceWithConnectionString> resourceBuilder, int waitInSeconds = 10)

csharp

修改 MediatR 依赖注入

之前使用 options.AddBehavior 方法注册行为，现在使用 options.AddOpenBehavior 方法注册行为。

 
builder.Services.AddMediatR(options =>
{
    options.RegisterServicesFromAssembly(Assembly.GetExecutingAssembly());
    options.AddOpenBehavior(typeof(LoggingBehavior<,>));
    options.AddOpenBehavior(typeof(ValidatorBehavior<,>));
    options.AddOpenBehavior(typeof(TransactionBehavior<,>));
});

csharp

使用分布式事件的微服务需要依赖注入上下文

builder.Services.AddHttpContextAccessor();

csharp

Azure Data Studio 删除数据库

-- 终止所有连接到目标数据库的会话
SELECT pg_terminate_backend(pg_stat_activity.pid)
FROM pg_stat_activity
WHERE pg_stat_activity.datname = 'my_database'
  AND pid <> pg_backend_pid();
 
-- 删除数据库
DROP DATABASE my_database;

sql

IdentityService 演示数据生成前自动创建数据库

await serviceProvider.GetRequiredService<IdentityServiceDbContext>().Database.EnsureCreatedAsync(cancellationToken);

csharp

统一使用 DateTimeOffset 类型而不是 DateTime 类型

使用 UTC 时间的优点是可以在不同的时区之间进行转换，而不会丢失时间信息，让程序更好的处理时间，有利于跨时区的应用程序国际化本地化。

var utcNow = DateTimeOffset.UtcNow;

csharp

当显示时间时，可以使用 ToLocalTime 方法转换为本地时间。

var localTime = utcNow.LocalDateTime;

csharp

PostgreSQL 数据库中的时间类型是 timestamp with time zone，它会将时间转换为 UTC 时间存储。

所有 Postgres 数据库中的时间都是 UTC 时间，但是在查询时会根据时区转换为本地时间，这个过程是透明的，自动的。

删除之前配置不优雅的时间转换设置。

AppContext.SetSwitch("Npgsql.EnableLegacyTimestampBehavior", true);
AppContext.SetSwitch("Npgsql.DisableDateTimeInfinityConversions", true);

csharp

优先使用 TimeProvider 获取当前时间

尽可能使用 TimeProvider 抽象类，原因是可以在测试时更方便的模拟时间。

var now = TimeProvider.System.Now;
var utcNow = TimeProvider.System.UtcNow;

csharp

相当于

var now = DateTimeOffset.Now;
var utcNow = DateTimeOffset.UtcNow;

csharp

public class MyTimeProvider: TimeProvider
{
    public override DateTimeOffset Now => new DateTimeOffset(2021, 1, 1, 0, 0, 0, TimeSpan.Zero);
    public override DateTimeOffset UtcNow => new DateTimeOffset(2021, 1, 1, 0, 0, 0, TimeSpan.Zero);
}

csharp

services.AddSingleton<TimeProvider, MyTimeProvider>();

csharp

public class MyService
{
    private readonly TimeProvider _timeProvider;
 
    public MyService(TimeProvider timeProvider)
    {
        _timeProvider = timeProvider;
    }
 
    public void DoSomething()
    {
        var now = _timeProvider.Now;
        var utcNow = _timeProvider.UtcNow;
    }
}

csharp

配置 OrderingService 身份验证

  const string issuerSigningKey = ServiceDefaults.Constants.IdentityConstantsIssuerSigningKey;
 
  builder.Services.AddAuthentication().AddJwtBearer(options =>
  {
      options.TokenValidationParameters.ValidateIssuer = false;
      options.TokenValidationParameters.ValidateAudience = false;
      options.TokenValidationParameters.IssuerSigningKey = new SymmetricSecurityKey(Encoding.Default.GetBytes(issuerSigningKey));
  });

csharp

配置 OrderingService 对象映射

    public class OrdersMapConfiguration : Profile
    {
        public OrdersMapConfiguration()
        {
            CreateMap<CreateOrderRequest, CreateOrderCommand>().ForMember(dest => dest.OrderItems, opt => opt.MapFrom(src => src.Items));
            CreateMap<BasketItem, CreateOrderCommand.CreateOrderCommandItem>().ForMember(dest => dest.Units, opt => opt.MapFrom(src => src.Quantity));
            CreateMap<CreateOrderCommand.CreateOrderCommandItem, OrderItem>();
            CreateMap<CreateOrderCommand, Address>();
        }
    }

csharp

配置 ProductService 实体 Product 字段长度

public class ProductEntityTypeConfiguration : IEntityTypeConfiguration<Product>
{
    public void Configure(EntityTypeBuilder<Product> builder)
    {
        builder.Property(x => x.Name).HasMaxLength(64);
    }
}

csharp

接着看

视频零度新版框架搭建系列视频教程订阅

构建可靠的事务性发件箱模式

事务性发件箱模式确保将事件保存在数据存储中，然后再最终推送到消息代理。如果业务对象和相应的事件保存在同一数据库事务中，则保证不会丢失任何数据。所有内容都将被提交，或在出错时所有内容回滚。为了最终发布事件，其他服务或工作进程会在发件箱表中查询未处理项，发布这些事件，并将其标记为已处理。此模式可确保创建或修改业务对象后不会丢失事件。

1:01:15超过 1 年前

视频零度新版框架搭建系列视频教程订阅

EF Core中数据库迁移与初始化的核心概念与实用技巧。内容包括生成与应用迁移脚本、EnsureCreatedAsync与MigrateAsync的使用及冲突解决、通过内部服务实现优雅的自动迁移、EF Core 9.0推荐的异步种子数据初始化方法，以及利用IHostedService或BackgroundService实现耗时操作的异步数据库初始化。通过本课程，开发者将掌握高效管理数据库生命周期的最佳实践，提升项目开发效率与质量。

57:00超过 1 年前

视频零度新版框架搭建系列视频教程订阅