






















题记:上篇介绍了Dapr的环境配置,这次我们来动手尝试一下Dapr应用的开发
Dapr应用的Hello World其实和其他的Hello World一样简单:
dotnet new console -o dapr-hello-worlddapr run --app-id hello-dotnet-dapr -- dotnet runPS:对于dapr run更多的帮助信息,可以通过 dapr run --help 来查看
接下来,我们来做一个服务调用的Hello World。我还是基于.NET 5中的ASP.NET Core来作为开发框架:
dotnet new webapi -o dapr-service-invocation --no-https --no-openapidapr run --app-id dotnetapp --app-port 5000 --dapr-http-port 13501 -- dotnet runGET http://localhost:13501/v1.0/invoke/dotnetapp/method/WeatherForecast示例代码可以参见这里:https://github.com/heavenwing/dapr-dotnet-quickstarts/tree/main/ServiceInvocation
状态管理的Hello World稍微复杂一点。你可以把对Dapr状态管理接口的访问代码添加到第一个示例当中(控制台程序)也可以添加到第二个示例当中(Web应用程序)。我们来基于控制台程序访问状态管理接口:
1,新建或者打开现有的一个dotnet控制台程序,首先创建如下实体类:
publicclassOrder
{
publicint Id { get; set; } publicint Amount { get; set; }
}
2,在Program中添加如下常量或静态字段:
staticstring daprPort = Environment.GetEnvironmentVariable("DAPR_HTTP_PORT") ?? "3500";
conststring stateStoreName = "statestore";//default state store name
conststring stateKey = "order-17";
staticstring stateUrl = $"http://localhost:{daprPort}/v1.0/state/{stateStoreName}";
其中第1句,从环境变量中得到Dapr边车暴露的http端口;第2句设置状态存储空间名称,Dapr本地开发环境会提供一个默认的statestore给你;第4句定义了Dapr状态管理的访问地址
3,为了保存状态值,需要先定义状态内容:
var state = new List<object>
{
new
{
key = stateKey,
value = new Order
{
Id = 17,
Amount = 1
}
}
};
4,通过Post方法把序列化后的状态值提交到Dapr的接口上:
var request = new HttpRequestMessage(HttpMethod.Post, stateUrl);
request.Content = new StringContent(JsonSerializer.Serialize(state));
var response = await httpClient.SendAsync(request);
5,使用Get方法从Dapr中获取状态值,需要传入你需要获取的状态key:
request = new HttpRequestMessage(HttpMethod.Get, $"{stateUrl}/{stateKey}");
response = await httpClient.SendAsync(request);
Console.WriteLine($"Respone content: {await response.Content?.ReadAsStringAsync()}");
6,使用Delete方法从Dapr中输出状态值,需要传入你需要输出的状态key:
request = new HttpRequestMessage(HttpMethod.Delete, $"{stateUrl}/{stateKey}");
response = await httpClient.SendAsync(request);
7,最后使用如下命令来运行这个Dapr应用:dapr run --app-id dotnetapp --dapr-http-port 13502 -- dotnet run
我们可以在控制台中看到状态值被保存、获取和删除的提示信息。
完整的示例代码可以在这里查看:https://github.com/heavenwing/dapr-dotnet-quickstarts/tree/main/StateManagement
上面在应用代码当中直接使用rest api去访问Dapr的状态管理接口,肯定显得稍微复杂。其实我们可以直接通过Dapr提供的dotnet SDK来方便的开发Dapr应用。
dotnet SDK的源代码地址在:https://github.com/dapr/dotnet-sdk
在dotnet SDK中,我最近还合并进去了一个pr,提供如何通过gRPC来包含服务调用接口的示例。大家可以查看这里:https://github.com/dapr/dotnet-sdk/tree/master/samples/AspNetCore/GrpcServiceSample
当然也可以通过Nuget来引用:https://www.nuget.org/packages?q=Tags%3A"Dapr"
通过sdk,我们要访问状态管理就非常简单了,比如如下的示例代码实现一个简单的deposit操作:
var state = await _daprClient.GetStateEntryAsync<Account>(StoreName, transaction.Id);
state.Value ??= new Account() { Id = transaction.Id, };
state.Value.Balance += transaction.Amount;
await state.SaveAsync();
接下来的文章我将会开始逐一介绍Dapr中的各个构件块。如果对Dapr感兴趣,又希望快点跟着我深入了解的。可以参加本周末12月19日在苏州举行的2020中国.NET开发者峰会,我在这个会议上会分享一个关于Dapr的主题:《Dapr开启微服务应用开发新世界》,欢迎到现场或者线上和我交流讨论。
关于2020中国.NET开发者峰会的信息可以看这里:https://www.cnblogs.com/shanyou/p/14118444.html
另外,我这里送现场票5张,先到先得: dotNETZHYGXH dotNETZHYGCZ dotNETZHYGcU dotNETZHYGas dotNETZHYGVJ
PS:请通过以下链接报名:http://hdxu.cn/yzcnG操作步骤为:
此内容由惯性聚合(RSS阅读器)自动聚合整理,仅供阅读参考。 原文来自 — 版权归原作者所有。