Dapr を使用してマイクロサービスをゼロから簡素化する例

curl -sSL https://get.daocloud.io/docker | sh

[root@localhost ~]# docker -v
Docker バージョン 20.10.11、ビルド dea9396

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

dapr -v

CLI バージョン: 1.5.0
ランタイムバージョン: 1.5.0

vi /etc/hosts
140.82.114.4 github.com  
199.232.69.194 github.global.ssl.fastly.net
140.82.114.9 コードロード.github.com

yum インストール -y nscd
サービス nscd 再起動

git クローン -v https://gitee.com/Two-Twoone/dapr-installer.git
cd dapr-installer/
./install.sh

[root@localhost dapr-installer]# docker ps --format "テーブル {{.ID}}\t{{.Names}}\t{{.Ports}}"
コンテナID名ポート
a0565f609846 dapr_placement 0.0.0.0:50005->50005/tcp、:::50005->50005/tcp
c392f5cf7a18 dapr_redis 0.0.0.0:6379->6379/tcp、:::6379->6379/tcp
2ee68c450b29 dapr_zipkin 9410/tcp、0.0.0.0:9411->9411/tcp、:::9411->9411/tcp

rpm -Uvh https://packages.microsoft.com/config/rhel/7/packages-microsoft-prod.rpm
 yumアップデート
 yum で dotnet-sdk-6.0 をインストールします

dotnet パッケージ Dapr.AspNetCore を追加します

ビルダー.Services.AddControllers().AddDapr();

[ルート("api/[コントローラー]")]
    [APIコントローラー]
    パブリッククラス ProductController: ControllerBase
    {
        プライベート ILogger<ProductController> _logger;

        パブリック ProductController(ILogger<ProductController> ロガー)
        {
            _logger = ロガー;
        }
        プライベート静的読み取り専用List<string> products = 新しいList<string> { "aa", "bb", "cc", "dd", "ee", "ff", "gg", "hh", "ii", "jj", "kk", "ll", "mm", "nn" };
        [HttpGet]
        パブリックアクション結果取得()
        {
            _logger.LogInformation($"製品を取得するメソッドが呼び出されました");
            文字列[] temps = 新しい文字列[5];
            (int i = 0; i < 5; i++) の場合
            {
                ランダム random = new Random(Guid.NewGuid().GetHashCode());
                temps[i] = products[random.Next(0, products.Count - 1)];
            }
            Ok( temps ) を返します。
        }
    }

# 製品プロジェクトを開始します dapr run --app-id ProductDemo --app-port 5010 --dapr-http-port 7015 -- dotnet /root/www/product/Dapr.Product.Sample.dll --urls http://*:5010

[ルート("api/[コントローラー]")]
    [APIコントローラー]
    パブリッククラス CartController: ControllerBase
    {
        プライベート読み取り専用 DaprClient _daprClient;
        プライベート読み取り専用 ILogger<CartController> _logger;
        パブリック CartController(DaprClient daprClient、ILogger<CartController> ロガー)
        {
            _daprClient = daprClient;
            _logger = ロガー;
        }

        [HttpGet]
        [ルート("GetProducts")]
        パブリック非同期タスク<IActionResult> GetProducts()
        {
            _logger.LogInformation($"カートの商品を取得");
            var products = await _daprClient.InvokeMethodAsync<List<string>>(HttpMethod.Get, "ProductDemo", "/api/Product/GetAll");
            Ok(製品)を返します。
        }
    }

# Cart プロジェクトを開始します dapr run --app-id CartDemo --app-port 5020 --dapr-http-port 7025 -- dotnet /root/www/cart/Dapr.Cart.Sample.dll --urls http://*:5020

[root@localhost ~]# curl -X 'GET' 'http://192.168.2.110:5020/api/Cart/GetProducts'
["aa","bb","cc","dd","ee","ff","gg","hh","ii","jj","kk","ll","mm","nn"]

 アプリ。
        app.UseEndpoints(エンドポイント =>
        {
            エンドポイント.MapSubscribeHandler();
        });

 [トピック("pubsub", "newUser")]
        パブリック ActionResult サブユーザー情報 (ユーザー情報 us)
        {
            _logger.LogInformation($"サブスクリプションメッセージを受信しました。ID:{us.id}、名前:{us.name}、年齢:{us.age}、性別:{us.sex}");
            Ok("処理が完了しました")を返します。
        }

[HttpPost]
        パブリック非同期Task<IActionResult> PubUserInfo(UserInfo us)
        {
            _daprClient.PublishEventAsync("pubsub", "newUser", us); を待機します。
            Ok() を返します。
        }

[HttpPost]
       [ルート("SaveUserList")]
        パブリック非同期タスク<IActionResult> SaveUserList()
        {
            var temps = 新しいリスト<UserInfo>
            {
                新しいUserInfo("Xiaohong",1,true,Guid.NewGuid().ToString()),
                新しい UserInfo("小黄",1,true,Guid.NewGuid().ToString()),
                新しい UserInfo("小蓝",1,true,Guid.NewGuid().ToString())
            };
          	_daprClient.SaveStateAsync("statestore", "UserList", temps) を待機します。
            Ok(1)を返します。
        }
        [HttpGet]
        [ルート("GetUserList")]
        パブリック非同期タスク<IActionResult> GetUserList()
        {
            var list = _daprClient.GetStateAsync<List<UserInfo>>("statestore", "UserList"); を待機します。
            Ok(リスト)を返します。
        }
      	[HttpGet]
        [ルート("DeleteUserList")]
        パブリック非同期タスク<IActionResult> DeleteUserList()
        {
            _daprClient.DeleteStateAsync("statestore", "UserList") を待機します。
            Ok(1)を返します。
        }

        パブリックレコード UserInfo(string name, int age, bool sex, string id);