云原生 | .NET 5 with Dapr 初体验

添加受信源sudo rpm -Uvh https://packages.microsoft.com/config/centos/7/packages-microsoft-prod.rpm安装.NET 5 SDKsudo yum install dotnet-sdk-5.0

wget -q https://raw.githubusercontent.com/dapr/cli/master/install/install.sh -O - | /bin/bash

tar -zvxf dapr_linux_amd64.tar.gz

CLI version: 1.1.0 Runtime version: 1.1.0

dapr init

public void ConfigureServices(IServiceCollection services){    services.AddControllers()        .AddDapr();    ......}

[ApiController][Route("[controller]")]public class CartController : ControllerBase{    private readonly ILogger<CartController> _logger;    private readonly DaprClient _daprClient;
    public CartController(ILogger<CartController> logger, DaprClient daprClient)    {        _logger = logger;        _daprClient = daprClient;    }
    [HttpGet]    public async Task<IEnumerable<SKU>> Get()    {        _logger.LogInformation("[Begin] Query product data from Product Service");
        var products = await _daprClient.InvokeMethodAsync<IEnumerable<SKU>>            (HttpMethod.Get, "ProductService", "Product");
        _logger.LogInformation($"[End] Query product data from Product Service, data : {products.ToArray().ToString()}");
        return products;    }}

[ApiController][Route("[controller]")]public class ProductController : ControllerBase{    private static readonly string[] FakeProducts = new[]    {        "SKU1", "SKU2", "SKU3", "SKU4", "SKU5", "SKU6", "SKU7", "SKU8", "SKU9", "SKU10"    };
    ......
    [HttpGet]    public IEnumerable<SKU> Get()    {        _logger.LogInformation("[Begin] Query product data.");
        var rng = new Random();        var result = Enumerable.Range(1, 5).Select(index => new SKU        {            Date = DateTime.Now.AddDays(index),            Index = rng.Next(1, 100),            Summary = FakeProducts[rng.Next(FakeProducts.Length)]        })        .ToArray();
        _logger.LogInformation("[End] Query product data.");
        return result;    }}

dapr run --app-id CartService --app-port 5000 --dapr-http-port 5005 -- dotnet EDT.EMall.Cart.API.dll --urls "http://*:5000" dapr run --app-id ProductService --app-port 5010 --dapr-http-port 5015 -- dotnet EDT.EMall.Product.API.dll --urls "http://*:5010"

[ApiController][Route("[controller]")]public class OrderController : ControllerBase{    private const string DaprPubSubName = "pubsub";
    private readonly ILogger<OrderController> _logger;    private readonly DaprClient _daprClient;
    public OrderController(ILogger<OrderController> logger, DaprClient daprClient)    {        _logger = logger;        _daprClient = daprClient;    }
    [HttpPost]    public async Task<Models.Order> Post(OrderDto orderDto)    {        _logger.LogInformation("[Begin] Create Order.");
        var order = new Models.Order()        {            // some mapping            Id = orderDto.Id,            ProductId = orderDto.ProductId,            Count = orderDto.Count        };        // some other logic for order
        var orderStockDto = new OrderStockDto()        {            ProductId = orderDto.ProductId,            Count = orderDto.Count        };        await _daprClient.PublishEventAsync(DaprPubSubName, "neworder", orderStockDto);
        _logger.LogInformation($"[End] Create Order Finished. Id : {orderStockDto.ProductId}, Count : {orderStockDto.Count}");
        return order;    }}

public void Configure(IApplicationBuilder app, IWebHostEnvironment env){    ......    app.UseCloudEvents(); // 标准化的消息传递格式    app.UseEndpoints(endpoints =>    {        endpoints.MapSubscribeHandler(); // 订阅消费处理        ......    });}

private const string DaprPubSubName = "pubsub";
[HttpPost][Topic(DaprPubSubName, "neworder")]public Models.Product SubProductStock(OrderStockDto orderStockDto){    _logger.LogInformation($"[Begin] Sub Product Stock, Stock Need : {orderStockDto.Count}.");
    var product = _productService.GetProductById(orderStockDto.ProductId);    if (orderStockDto.Count < 0 || orderStockDto.Count > product.Stock)    {        throw new InvalidOperationException("Invalid Product Count!");    }    product.Stock = product.Stock - orderStockDto.Count;    _productService.SaveProduct(product);
    _logger.LogInformation($"[End] Sub Product Stock Finished, Stock Now : {product.Stock}.");
    return product;}

[root@dapr-lab-server ~]# cat ~/.dapr/components/pubsub.yamlapiVersion: dapr.io/v1alpha1kind: Componentmetadata:  name: pubsubspec:  type: pubsub.redis  metadata:  - name: redisHost    value: localhost:6379  - name: redisPassword    value: ""

apiVersion: dapr.io/v1alpha1kind: Componentmetadata:  name: pubsub-rqspec:  type: pubsub.rabbitmq  version: v1  metadata:  - name: host    value: "amqp://localhost:5672"  - name: durable    value: true

dapr run --app-id OrderService --app-port 5020 --dapr-http-port 5025 -- dotnet EDT.EMall.Order.API.dll --urls "http://*:5020"dapr run --app-id ProductService --app-port 5010 --dapr-http-port 5015 -- dotnet EDT.EMall.Product.API.dll --urls "http://*:5010"