快速入门：配置

开始使用 Dapr 的配置构建块

让我们来看看 Dapr 的配置构建块。配置项目通常具有动态性质，并且与消费它的应用程序的需求紧密耦合。配置项是包含配置数据的键/值对，例如

App ids
Partition keys
数据库名称等

在本快速入门中，你将运行一个 order-processor 微服务，该微服务利用配置 API。该服务：

从配置存储中获取配置项。
订阅配置更新。

在继续快速入门之前，请选择您首选的特定语言 Dapr SDK。

Python
JavaScript
.NET
Java
Go

先决条件

对于此示例，您将需要：

第1步：设置环境

克隆在Quickstarts存储库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

克隆后，打开一个新的终端并运行以下命令来设置配置项的值 orderId1 和 orderId2。

docker exec dapr_redis redis-cli MSET orderId1 "101" orderId2 "102"

第2步：运行 `order-processor` 服务

从快速入门克隆目录的根目录导航到 order-processor 目录。

cd configuration/python/sdk/order-processor

安装依赖项：

pip3 install -r requirements.txt

与 Dapr sidecar 一起运行 order-processor 服务。

dapr run --app-id order-processor --resources-path ../../../components/ --app-port 6001 -- python3 app.py

注意：由于Python3.exe在Windows中未定义，您可能需要使用python app.py而不是python3 app.py。

预期输出：

== APP == Configuration for orderId1 : value: "101"
== APP ==
== APP == Configuration for orderId2 : value: "102"
== APP ==
== APP == App unsubscribed from config changes

（可选）步骤 3：更新配置项值

应用程序取消订阅后，请尝试更新配置项的值。使用以下命令更改 orderId1 和 orderId2 的值：

docker exec dapr_redis redis-cli MSET orderId1 "103" orderId2 "104"

再次运行 order-processor 服务：

dapr run --app-id order-processor --resources-path ../../../components/ --app-port 6001 -- python3 app.py

注意：由于Python3.exe在Windows中未定义，您可能需要使用python app.py而不是python3 app.py。

该应用程序将返回更新后的配置值：

== APP == Configuration for orderId1 : value: "103"
== APP ==
== APP == Configuration for orderId2 : value: "104"
== APP ==

`order-processor` 服务

order-processor 服务包括以下代码：

从配置存储中获取配置项
订阅配置更新（您之前在命令行工具中进行的更新）
在20秒不活动后，取消订阅配置更新并退出应用程序。

获取配置项目:

# Get config items from the config store
for config_item in CONFIGURATION_ITEMS:
    config = client.get_configuration(store_name=DAPR_CONFIGURATION_STORE, keys=[config_item], config_metadata={})
    print(f"Configuration for {config_item} : {config.items[config_item]}", flush=True)

订阅配置更新:

# Subscribe for configuration changes
configuration = await client.subscribe_configuration(DAPR_CONFIGURATION_STORE, CONFIGURATION_ITEMS)

取消订阅配置更新并退出应用程序：

# Unsubscribe from configuration updates
unsubscribed = True
for config_item in CONFIGURATION_ITEMS:
    unsub_item = client.unsubscribe_configuration(DAPR_CONFIGURATION_STORE, config_item)
    #...
if unsubscribed == True:
    print("App unsubscribed from config changes", flush=True)

先决条件

对于此示例，您将需要：

第1步：设置环境

克隆在Quickstarts存储库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

克隆后，打开一个新的终端并运行以下命令来设置配置项的值 orderId1 和 orderId2。

docker exec dapr_redis redis-cli MSET orderId1 "101" orderId2 "102"

第2步：运行 `order-processor` 服务

从快速入门克隆目录的根目录导航到 order-processor 目录。

cd configuration/javascript/sdk/order-processor

安装依赖项：

npm install

与 Dapr sidecar 一起运行 order-processor 服务。

dapr run --app-id order-processor --resources-path ../../../components/ --app-protocol grpc --dapr-grpc-port 3500 -- node index.js

预期输出：

== APP == Configuration for orderId1: {"key":"orderId1","value":"101","version":"","metadata":{}}
== APP == Configuration for orderId2: {"key":"orderId2","value":"102","version":"","metadata":{}}
== APP == App unsubscribed to config changes

（可选）步骤 3：更新配置项值

应用程序取消订阅后，请尝试更新配置项的值。使用以下命令更改 orderId1 和 orderId2 的值：

docker exec dapr_redis redis-cli MSET orderId1 "103" orderId2 "104"

再次运行 order-processor 服务：

dapr run --app-id order-processor --resources-path ../../../components/ --app-protocol grpc --dapr-grpc-port 3500 -- node index.js

该应用程序将返回更新后的配置值：

== APP == Configuration for orderId1: {"key":"orderId1","value":"103","version":"","metadata":{}}
== APP == Configuration for orderId2: {"key":"orderId2","value":"104","version":"","metadata":{}}

`order-processor` 服务

order-processor 服务包括以下代码：

从配置存储中获取配置项
订阅配置更新（您之前在命令行工具中进行的更新）
在20秒不活动后，取消订阅配置更新并退出应用程序。

获取配置项目:

// Get config items from the config store
//...
  const config = await client.configuration.get(DAPR_CONFIGURATION_STORE, CONFIGURATION_ITEMS);
  Object.keys(config.items).forEach((key) => {
    console.log("Configuration for " + key + ":", JSON.stringify(config.items[key]));
  });

订阅配置更新:

// Subscribe to config updates
try {
  const stream = await client.configuration.subscribeWithKeys(
    DAPR_CONFIGURATION_STORE,
    CONFIGURATION_ITEMS,
    (config) => {
      console.log("Configuration update", JSON.stringify(config.items));
    }
  );

取消订阅配置更新并退出应用程序：

// Unsubscribe to config updates and exit app after 20 seconds
setTimeout(() => {
  stream.stop();
  console.log("App unsubscribed to config changes");
  process.exit(0);
},

先决条件

对于此示例，您将需要：

第1步：设置环境

克隆在Quickstarts存储库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

克隆后，打开一个新的终端并运行以下命令来设置配置项的值 orderId1 和 orderId2。

docker exec dapr_redis redis-cli MSET orderId1 "101" orderId2 "102"

第2步：运行 `order-processor` 服务

从快速入门克隆目录的根目录导航到 order-processor 目录。

cd configuration/csharp/sdk/order-processor

还原 NuGet 包：

dotnet restore
dotnet build

与 Dapr sidecar 一起运行 order-processor 服务。

dapr run --app-id order-processor-http --resources-path ../../../components/ --app-port 7001 -- dotnet run --project .

预期输出：

== APP == Configuration for orderId1: {"Value":"101","Version":"","Metadata":{}}
== APP == Configuration for orderId2: {"Value":"102","Version":"","Metadata":{}}
== APP == App unsubscribed from config changes

（可选）步骤 3：更新配置项值

应用程序取消订阅后，请尝试更新配置项的值。使用以下命令更改 orderId1 和 orderId2 的值：

docker exec dapr_redis redis-cli MSET orderId1 "103" orderId2 "104"

再次运行 order-processor 服务：

dapr run --app-id order-processor-http --resources-path ../../../components/ --app-port 7001 -- dotnet run --project .

该应用程序将返回更新后的配置值：

== APP == Configuration for orderId1: {"Value":"103","Version":"","Metadata":{}}
== APP == Configuration for orderId2: {"Value":"104","Version":"","Metadata":{}}

`order-processor` 服务

order-processor 服务包括以下代码：

从配置存储中获取配置项
订阅配置更新（您之前在命令行工具中进行的更新）
在20秒不活动后，取消订阅配置更新并退出应用程序。

获取配置项目:

// Get config from configuration store
GetConfigurationResponse config = await client.GetConfiguration(DAPR_CONFIGURATION_STORE, CONFIGURATION_ITEMS);
foreach (var item in config.Items)
{
  var cfg = System.Text.Json.JsonSerializer.Serialize(item.Value);
  Console.WriteLine("Configuration for " + item.Key + ": " + cfg);
}

订阅配置更新:

// Subscribe to config updates
SubscribeConfigurationResponse subscribe = await client.SubscribeConfiguration(DAPR_CONFIGURATION_STORE, CONFIGURATION_ITEMS);

取消订阅配置更新并退出应用程序：

// Unsubscribe to config updates and exit the app
try
{
  client.UnsubscribeConfiguration(DAPR_CONFIGURATION_STORE, subscriptionId);
  Console.WriteLine("App unsubscribed from config changes");
  Environment.Exit(0);
}

先决条件

对于此示例，您将需要：

Dapr CLI 和初始化环境.
Java JDK 11（或更高版本）：
- Oracle JDK，或者
- OpenJDK
Apache Maven，3.x版本。
Docker Desktop

第1步：设置环境

克隆在Quickstarts存储库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

克隆后，打开一个新的终端并运行以下命令来设置配置项的值 orderId1 和 orderId2。

docker exec dapr_redis redis-cli MSET orderId1 "101" orderId2 "102"

第2步：运行 `order-processor` 服务

从快速入门克隆目录的根目录导航到 order-processor 目录。

cd configuration/java/sdk/order-processor

安装依赖项：

mvn clean install

与 Dapr sidecar 一起运行 order-processor 服务。

dapr run --app-id order-processor --resources-path ../../../components -- java -jar target/OrderProcessingService-0.0.1-SNAPSHOT.jar

预期输出：

== APP == Configuration for orderId1: {'value':'101'}
== APP == Configuration for orderId2: {'value':'102'}
== APP == App unsubscribed to config changes

（可选）步骤 3：更新配置项值

应用程序取消订阅后，请尝试更新配置项的值。使用以下命令更改 orderId1 和 orderId2 的值：

docker exec dapr_redis redis-cli MSET orderId1 "103" orderId2 "104"

再次运行 order-processor 服务：

dapr run --app-id order-processor --resources-path ../../../components -- java -jar target/OrderProcessingService-0.0.1-SNAPSHOT.jar

该应用程序将返回更新后的配置值：

== APP == Configuration for orderId1: {'value':'103'}
== APP == Configuration for orderId2: {'value':'104'}

`order-processor` 服务

order-processor 服务包括以下代码：

从配置存储中获取配置项
订阅配置更新（您之前在命令行工具中进行的更新）
在20秒不活动后，取消订阅配置更新并退出应用程序。

获取配置项目:

// Get config items from the config store
try (DaprPreviewClient client = (new DaprClientBuilder()).buildPreviewClient()) {
    for (String configurationItem : CONFIGURATION_ITEMS) {
        ConfigurationItem item = client.getConfiguration(DAPR_CONFIGURATON_STORE, configurationItem).block();
        System.out.println("Configuration for " + configurationItem + ": {'value':'" + item.getValue() + "'}");
    }

订阅配置更新:

// Subscribe for config changes
Flux<SubscribeConfigurationResponse> subscription = client.subscribeConfiguration(DAPR_CONFIGURATON_STORE,
        CONFIGURATION_ITEMS.toArray(String[]::new));

取消订阅配置更新并退出应用程序：

// Unsubscribe from config changes
UnsubscribeConfigurationResponse unsubscribe = client
        .unsubscribeConfiguration(subscriptionId, DAPR_CONFIGURATON_STORE).block();
if (unsubscribe.getIsUnsubscribed()) {
    System.out.println("App unsubscribed to config changes");
}

先决条件

对于此示例，您将需要：

第1步：设置环境

克隆在Quickstarts存储库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

克隆后，打开一个新的终端并运行以下命令来设置配置项的值 orderId1 和 orderId2。

docker exec dapr_redis redis-cli MSET orderId1 "101" orderId2 "102"

第2步：运行 `order-processor` 服务

从快速入门克隆目录的根目录导航到 order-processor 目录。

cd configuration/go/sdk/order-processor

与 Dapr sidecar 一起运行 order-processor 服务。

dapr run --app-id order-processor --app-port 6001 --resources-path ../../../components -- go run .

预期输出：

== APP == Configuration for orderId1: {"Value":"101","Version":"","Metadata":null}
== APP == Configuration for orderId2: {"Value":"102","Version":"","Metadata":null}
== APP == dapr configuration subscribe finished.
== APP == App unsubscribed to config changes

（可选）步骤 3：更新配置项值

应用程序取消订阅后，请尝试更新配置项的值。使用以下命令更改 orderId1 和 orderId2 的值：

docker exec dapr_redis redis-cli MSET orderId1 "103" orderId2 "104"

再次运行 order-processor 服务：

dapr run --app-id order-processor --app-port 6001 --resources-path ../../../components -- go run .

该应用程序将返回更新后的配置值：

== APP == Configuration for orderId1: {"Value":"103","Version":"","Metadata":null}
== APP == Configuration for orderId2: {"Value":"104","Version":"","Metadata":null}

`order-processor` 服务

order-processor 服务包括以下代码：

从配置存储中获取配置项
订阅配置更新（您之前在命令行工具中进行的更新）
在20秒不活动后，取消订阅配置更新并退出应用程序。

获取配置项目:

// Get config items from config store
for _, item := range CONFIGURATION_ITEMS {
    config, err := client.GetConfigurationItem(ctx, DAPR_CONFIGURATION_STORE, item)
    //...
    c, _ := json.Marshal(config)
    fmt.Println("Configuration for " + item + ": " + string(c))
}

订阅配置更新:

// Subscribe for config changes
err = client.SubscribeConfigurationItems(ctx, DAPR_CONFIGURATION_STORE, CONFIGURATION_ITEMS, func(id string, config map[string]*dapr.ConfigurationItem) {
    // First invocation when app subscribes to config changes only returns subscription id
    if len(config) == 0 {
        fmt.Println("App subscribed to config changes with subscription id: " + id)
        subscriptionId = id
        return
    }
})

取消订阅配置更新并退出应用程序：

// Unsubscribe to config updates and exit app after 20 seconds
select {
case <-ctx.Done():
    err = client.UnsubscribeConfigurationItems(context.Background(), DAPR_CONFIGURATION_STORE, subscriptionId)
    //...
    {
        fmt.Println("App unsubscribed to config changes")
    }

例子

观看此视频demoing the Configuration API quickstart:

告诉我们您的想法

我们一直在努力改进我们的快速入门示例，并重视您的反馈。您觉得此快速入门有帮助吗？您有改进的建议吗？

加入我们的discord频道参与讨论。

下一步

使用 HTTP 而不是 SDK 的 Dapr 配置。
了解更多关于配置构建块

探索 Dapr 教程 >>

Configuration

快速入门：配置

先决条件

第1步：设置环境

第2步：运行 order-processor 服务

（可选）步骤 3：更新配置项值

order-processor 服务

先决条件

第1步：设置环境

第2步：运行 order-processor 服务

（可选）步骤 3：更新配置项值

order-processor 服务

先决条件

第1步：设置环境

第2步：运行 order-processor 服务

（可选）步骤 3：更新配置项值

order-processor 服务

先决条件

第1步：设置环境

第2步：运行 order-processor 服务

（可选）步骤 3：更新配置项值

order-processor 服务

先决条件

第1步：设置环境

第2步：运行 order-processor 服务

（可选）步骤 3：更新配置项值

order-processor 服务

例子

告诉我们您的想法

下一步

第2步：运行 `order-processor` 服务

`order-processor` 服务

第2步：运行 `order-processor` 服务

`order-processor` 服务

第2步：运行 `order-processor` 服务

`order-processor` 服务

第2步：运行 `order-processor` 服务

`order-processor` 服务

第2步：运行 `order-processor` 服务

`order-processor` 服务